spring4-5-事務管理

1.簡單介紹

　　事務管理是企業級應用程序開發中必不可少的技術,  用來確保數據的完整性和一致性. 事務就是一系列的動作, 它們被當做一個單獨的工作單元. 這些動作要么全部完成, 要么全部不起作用

　　事務的四個關鍵屬性(ACID):

• 原子性(atomicity): 事務是一個原子操作, 由一系列動作組成. 事務的原子性確保動作要么全部完成要么完全不起作用.
• 一致性(consistency): 一旦所有事務動作完成, 事務就被提交. 數據和資源就處於一種滿足業務規則的一致性狀態中.
• 隔離性(isolation): 可能有許多事務會同時處理相同的數據, 因此每個事物都應該與其他事務隔離開來, 防止數據損壞.
• 持久性(durability): 一旦事務完成, 無論發生什么系統錯誤, 它的結果都不應該受到影響. 通常情況下, 事務的結果被寫到持久化存儲器中.

 2.事務管理

　　作為企業級應用程序框架, Spring 在不同的事務管理 API 之上定義了一個抽象層. 而應用程序開發人員不必了解底層的事務管理 API, 就可以使用 Spring 的事務管理機制.Spring 既支持編程式事務管理, 也支持聲明式的事務管理.編程式事務管理: 將事務管理代碼嵌入到業務方法中來控制事務的提交和回滾. 在編程式管理事務時, 必須在每個事務操作中包含額外的事務管理代碼. 聲明式事務管理: 大多數情況下比編程式事務管理更好用. 它將事務管理代碼從業務方法中分離出來, 以聲明的方式來實現事務管理. 事務管理作為一種橫切關注點, 可以通過 AOP 方法模塊化. Spring 通過 Spring AOP 框架支持聲明式事務管理.
　　Spring 從不同的事務管理 API 中抽象了一整套的事務機制. 開發人員不必了解底層的事務 API, 就可以利用這些事務機制. 有了這些事務機制, 事務管理代碼就能獨立於特定的事務技術了.Spring 的核心事務管理抽象是 interface PlatformTransactionManager   它為事務管理封裝了一組獨立於技術的方法. 無論使用 Spring 的哪種事務管理策略(編程式或聲明式), 事務管理器都是必須的.

3.Spring 中的事務管理器的不同實

org.springframework.jdbc.datasource  Class DataSourceTransactionManager:在應用程序中只需要處理一個數據源, 而且通過 JDBC 存取

org.springframework.jdbc.jta Class  JtaTransactionManager:在 JavaEE 應用服務器上用 JTA(Java Transaction API) 進行事務管理

org.springframework.orm.hibernate3 Class HibernateTransactionManager:用 Hibernate 框架存取數據庫

　　事務管理器以普通的 Bean 形式聲明在 Spring IOC 容器中

4.需求:

　　

這里將事務添加到bookShopServiceImpl中.

 

5.基於注解方式:

5.1 創建測試代碼

BookShopDao:

package com.l1.spring.jdbc.tx;

public interface BookShopDao {
    //根據書號獲取書的單價
    public int findBookPriceByIsbn(String isbn);
    //更新書的庫存,庫存減一
    public void updateBookStock(String isbn);
    
    // 更新用戶賬戶余額: balance - price
    public void updateAccount(String username,int price);
}

 

實現類:

package com.l1.spring.jdbc.tx;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;

@Repository("bookShopDao")
public class BookShopDaoImpl implements BookShopDao {
    
    @Autowired
    private JdbcTemplate jdbcTemplate;
    @Override
    public int findBookPriceByIsbn(String isbn) {
        String sql = "select price from book where isbn = ?";
        return jdbcTemplate.queryForObject(sql, Integer.class, isbn);
    }

    @Override
    public void updateBookStock(String isbn) {
        //驗證庫存是否足夠
        String sql1 = "select stock from book_stock where isbn = ? ";
        int stock = jdbcTemplate.queryForObject(sql1, Integer.class, isbn);
        if(stock == 0){
            throw new BookStockException("庫存不足!");
        }
        
        String sql = "update book_stock  set stock = (stock-1) where isbn = ? ";
        jdbcTemplate.update(sql, isbn);
    }

    @Override
    public void updateAccount(String username, int price) {
        //驗證賬戶余額是否夠用
        String sql1  = "select balance from account where username = ?";
        int balance = jdbcTemplate.queryForObject(sql1, Integer.class, username);
        if(balance<price){
            throw new AccountException("賬戶余額不夠!");
        }
        
        String sql = "update account set balance = balance-? where username = ?";
        jdbcTemplate.update(sql, price,username);
    }

}

 

BookShopService:

package com.l1.spring.jdbc.tx;

public interface BookShopService {
    public void purchase(String username,String isbn);
}

 

實現類:

package com.l1.spring.jdbc.tx;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service("bookShopService")
public class BookShopServiceImpl implements BookShopService {

    @Autowired
    @Qualifier("bookShopDao")
    private BookShopDao bookShopDao;
    //添加事務注解
    @Transactional
    @Override
    public void purchase(String username, String isbn) {
        //1.獲取書的單價
        int price = bookShopDao.findBookPriceByIsbn(isbn);
        //2.更新書的庫存
        bookShopDao.updateBookStock(isbn);
        //3.更新賬戶余額
        bookShopDao.updateAccount(username, price);
    }

}

 

5.2 xml中配置事務管理器:

    <!-- 首先配置事務管理器 -基於注解的方式 -->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"></property>
    </bean>

 

5.3 xml中引入事務命名空間 tx,啟動事務注解:

    <!-- 引入tx 命名空間,啟用事務注解  -->
    <tx:annotation-driven transaction-manager="transactionManager"/>

 

 

5.4  在需要管理的方法前添加事務注解:

package com.l1.spring.jdbc.tx;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service("bookShopService")
public class BookShopServiceImpl implements BookShopService {

    @Autowired
    @Qualifier("bookShopDao")
    private BookShopDao bookShopDao;
    //添加事務注解
    @Transactional
    @Override
    public void purchase(String username, String isbn) {
        //1.獲取書的單價
        int price = bookShopDao.findBookPriceByIsbn(isbn);
        //2.更新書的庫存
        bookShopDao.updateBookStock(isbn);
        //3.更新賬戶余額
        bookShopDao.updateAccount(username, price);
    }

}

 

6.基於xml配置的:

　　6.1基本配置:

    <!-- 配置自動掃描組件 -->
    <context:component-scan base-package="com.l1.spring.jdbc.tx"></context:component-scan>
    <!-- 1.導入資源文件 -->
    <context:property-placeholder location="classpath:db.properties"/>
    <!-- 2.配置C3P0數據源 -->
    <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="user" value="${jdbc.user}"></property>
        <property name="password" value="${jdbc.password}"></property>
        <property name="driverClass" value="${jdbc.driverClass}"></property>
        <property name="jdbcUrl" value="${jdbc.jdbcUrl}"></property>
        <property name="initialPoolSize" value="${jdbc.initialPoolSize}"></property>
        <property name="maxPoolSize" value="${jdbc.maxPoolSize}"></property>
    </bean>

    <!-- 3.配置 jdbc template -->
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dataSource"></property>
    </bean>

 

　　6.2 配置bean:

    <!-- 1. 配置Bean -->
    <bean id="bookShopDao" class="com.l1.spring.jdbc.tx.xml.BookShopDaoImpl">
        <property name="jdbcTemplate" ref="jdbcTemplate"></property>
    </bean>
    <bean id="bookShopService" class="com.l1.spring.jdbc.tx.xml.BookShopServiceImpl">
        <property name="bookShopDao" ref="bookShopDao"></property>
    </bean>
    <bean id="cashier" class="com.l1.spring.jdbc.tx.xml.CashierImpl">
        <property name="bookShopService"  ref="bookShopService"></property>
    </bean>

 

 　　6.3 配置事務管理器:

    <!-- 2.配置事務管理器 -->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"></property>
    </bean>

 

　　6.4 配置事務通知,屬性:

    <!-- 3.配置事務屬性 -->
    <tx:advice id="txAdvice" transaction-manager="transactionManager">
        <tx:attributes>
            <tx:method name="*"/>
        </tx:attributes>
    </tx:advice>

 

 　指定事務屬性:

    <!-- 3.配置事務屬性 -->
    <tx:advice id="txAdvice" transaction-manager="transactionManager">
        <tx:attributes>
            <!-- 根據方法名指定事務屬性 -->
            <tx:method name="purchase" propagation="REQUIRES_NEW"/>
            <tx:method name="get*" read-only="true"/>
            <tx:method name="find*" read-only="true"/>
            <tx:method name="*"/>
        </tx:attributes>
    </tx:advice>

 

　　6.5 配置事務切入點,將切入點和事務通知關聯起來:

    <!-- 4.配置事務切入點,以及關聯切入點和事務屬性 -->
    <aop:config>
        <aop:pointcut expression="execution(public * com.l1.spring.jdbc.tx.xml.BookShopService.*(..))"
             id="txPoinCut"/>
             
        <aop:advisor advice-ref="txAdvice" pointcut-ref="txPoinCut"/>
    </aop:config>