1 初步理解
原子性（Atomicity）：事務(wù)是一個(gè)原子操作，由一系列動(dòng)作組成。事務(wù)的原子性確保動(dòng)作要么全部完成，要么完全不起作用。
Public interface PlatformTransactionManager()…{
2.1.1 JDBC事務(wù)
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource" />
</bean>
實(shí)際上，DataSourceTransactionManager是通過(guò)調(diào)用java.sql.Connection來(lái)管理事務(wù)，而后者是通過(guò)DataSource獲取到的。通過(guò)調(diào)用連接的commit()方法來(lái)提交事務(wù)，同樣，事務(wù)失敗則通過(guò)調(diào)用rollback()方法進(jìn)行回滾。
2.1.2 Hibernate事務(wù)
<bean id="transactionManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager">
<property name="sessionFactory" ref="sessionFactory" />
</bean>
sessionFactory屬性需要裝配一個(gè)Hibernate的session工廠，HibernateTransactionManager的實(shí)現(xiàn)細(xì)節(jié)是它將事務(wù)管理的職責(zé)委托給org.hibernate.Transaction對(duì)象，而后者是從Hibernate Session中獲取到的。當(dāng)事務(wù)成功完成時(shí)，HibernateTransactionManager將會(huì)調(diào)用Transaction對(duì)象的commit()方法，反之，將會(huì)調(diào)用rollback()方法。
2.1.3 Java持久化API事務(wù)（JPA）
<bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager">
<property name="sessionFactory" ref="sessionFactory" />
</bean>
JpaTransactionManager只需要裝配一個(gè)JPA實(shí)體管理工廠（javax.persistence.EntityManagerFactory接口的任意實(shí)現(xiàn)）。JpaTransactionManager將與由工廠所產(chǎn)生的JPA EntityManager合作來(lái)構(gòu)建事務(wù)。
2.1.4 Java原生API事務(wù)
<bean id="transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager">
<property name="transactionManagerName" value="java:/TransactionManager" />
</bean>
JtaTransactionManager將事務(wù)管理的責(zé)任委托給javax.transaction.UserTransaction和javax.transaction.TransactionManager對(duì)象，其中事務(wù)成功完成通過(guò)UserTransaction.commit()方法提交，事務(wù)失敗通過(guò)UserTransaction.rollback()方法回滾。
2.2 基本事務(wù)屬性的定義
public interface TransactionDefinition {
2.2.1 傳播行為
傳播行為 含義
注：以下具體講解傳播行為的內(nèi)容參考自Spring事務(wù)機(jī)制詳解
//事務(wù)屬性 PROPAGATION_REQUIRED
單獨(dú)調(diào)用methodB方法：
main{
Main{
//方法調(diào)用
methodB();
//提交事務(wù)
con.commit();
} Catch(RuntimeException ex) {
//回滾事務(wù)
con.rollback();
} finally {
//釋放資源
closeCon();
}
}
執(zhí)行效果相當(dāng)于：
main{
（2）PROPAGATION_SUPPORTS 如果存在一個(gè)事務(wù)，支持當(dāng)前事務(wù)。如果沒(méi)有事務(wù)，則非事務(wù)的執(zhí)行。但是對(duì)于事務(wù)同步的事務(wù)管理器，PROPAGATION_SUPPORTS與不使用事務(wù)有少許不同。
//事務(wù)屬性 PROPAGATION_REQUIRED
//事務(wù)屬性 PROPAGATION_SUPPORTS
（3）PROPAGATION_MANDATORY 如果已經(jīng)存在一個(gè)事務(wù)，支持當(dāng)前事務(wù)。如果沒(méi)有一個(gè)活動(dòng)的事務(wù)，則拋出異常。
//事務(wù)屬性 PROPAGATION_REQUIRED
//事務(wù)屬性 PROPAGATION_MANDATORY
（4）PROPAGATION_REQUIRES_NEW 總是開(kāi)啟一個(gè)新的事務(wù)。如果一個(gè)事務(wù)已經(jīng)存在，則將這個(gè)存在的事務(wù)掛起。
//事務(wù)屬性 PROPAGATION_REQUIRED
//事務(wù)屬性 PROPAGATION_REQUIRES_NEW
main(){
main(){
（5）PROPAGATION_NOT_SUPPORTED 總是非事務(wù)地執(zhí)行，并掛起任何存在的事務(wù)。使用PROPAGATION_NOT_SUPPORTED,也需要使用JtaTransactionManager作為事務(wù)管理器。（代碼示例同上，可同理推出）
（6）PROPAGATION_NEVER 總是非事務(wù)地執(zhí)行，如果存在一個(gè)活動(dòng)事務(wù)，則拋出異常。
（7）PROPAGATION_NESTED如果一個(gè)活動(dòng)的事務(wù)存在，則運(yùn)行在一個(gè)嵌套的事務(wù)中. 如果沒(méi)有活動(dòng)事務(wù), 則按TransactionDefinition.PROPAGATION_REQUIRED 屬性執(zhí)行。這是一個(gè)嵌套事務(wù),使用JDBC 3.0驅(qū)動(dòng)時(shí),僅僅支持DataSourceTransactionManager作為事務(wù)管理器。需要JDBC 驅(qū)動(dòng)的java.sql.Savepoint類。有一些JTA的事務(wù)管理器實(shí)現(xiàn)可能也提供了同樣的功能。使用PROPAGATION_NESTED，還需要把PlatformTransactionManager的nestedTransactionAllowed屬性設(shè)為true;而 nestedTransactionAllowed屬性值默認(rèn)為false。
//事務(wù)屬性 PROPAGATION_REQUIRED
//事務(wù)屬性 PROPAGATION_NESTED
main(){
嵌套事務(wù)一個(gè)非常重要的概念就是內(nèi)層事務(wù)依賴于外層事務(wù)。外層事務(wù)失敗時(shí)，會(huì)回滾內(nèi)層事務(wù)所做的動(dòng)作。而內(nèi)層事務(wù)操作失敗并不會(huì)引起外層事務(wù)的回滾。
PROPAGATION_NESTED 與PROPAGATION_REQUIRES_NEW的區(qū)別:它們非常類似,都像一個(gè)嵌套事務(wù)，如果不存在一個(gè)活動(dòng)的事務(wù)，都會(huì)開(kāi)啟一個(gè)新的事務(wù)。使用 PROPAGATION_REQUIRES_NEW時(shí)，內(nèi)層事務(wù)與外層事務(wù)就像兩個(gè)獨(dú)立的事務(wù)一樣，一旦內(nèi)層事務(wù)進(jìn)行了提交后，外層事務(wù)不能對(duì)其進(jìn)行回滾。兩個(gè)事務(wù)互不影響。兩個(gè)事務(wù)不是一個(gè)真正的嵌套事務(wù)。同時(shí)它需要JTA事務(wù)管理器的支持。
使用PROPAGATION_NESTED時(shí)，外層事務(wù)的回滾可以引起內(nèi)層事務(wù)的回滾。而內(nèi)層事務(wù)的異常并不會(huì)導(dǎo)致外層事務(wù)的回滾，它是一個(gè)真正的嵌套事務(wù)。DataSourceTransactionManager使用savepoint支持PROPAGATION_NESTED時(shí)，需要JDBC 3.0以上驅(qū)動(dòng)及1.4以上的JDK版本支持。其它的JTA TrasactionManager實(shí)現(xiàn)可能有不同的支持方式。
PROPAGATION_REQUIRES_NEW 啟動(dòng)一個(gè)新的, 不依賴于環(huán)境的 “內(nèi)部” 事務(wù). 這個(gè)事務(wù)將被完全 commited 或 rolled back 而不依賴于外部事務(wù), 它擁有自己的隔離范圍, 自己的鎖, 等等. 當(dāng)內(nèi)部事務(wù)開(kāi)始執(zhí)行時(shí), 外部事務(wù)將被掛起, 內(nèi)務(wù)事務(wù)結(jié)束時(shí), 外部事務(wù)將繼續(xù)執(zhí)行。
另一方面, PROPAGATION_NESTED 開(kāi)始一個(gè) “嵌套的” 事務(wù), 它是已經(jīng)存在事務(wù)的一個(gè)真正的子事務(wù). 潛套事務(wù)開(kāi)始執(zhí)行時(shí), 它將取得一個(gè) savepoint. 如果這個(gè)嵌套事務(wù)失敗, 我們將回滾到此 savepoint. 潛套事務(wù)是外部事務(wù)的一部分, 只有外部事務(wù)結(jié)束后它才會(huì)被提交。
由此可見(jiàn), PROPAGATION_REQUIRES_NEW 和 PROPAGATION_NESTED 的最大區(qū)別在于, PROPAGATION_REQUIRES_NEW 完全是一個(gè)新的事務(wù), 而 PROPAGATION_NESTED 則是外部事務(wù)的子事務(wù), 如果外部事務(wù) commit, 嵌套事務(wù)也會(huì)被 commit, 這個(gè)規(guī)則同樣適用于 roll back.
PROPAGATION_REQUIRED應(yīng)該是我們首先的事務(wù)傳播行為。它能夠滿足我們大多數(shù)的事務(wù)需求。
2.2.2 隔離級(jí)別
臟讀（Dirty reads）——臟讀發(fā)生在一個(gè)事務(wù)讀取了另一個(gè)事務(wù)改寫(xiě)但尚未提交的數(shù)據(jù)時(shí)。如果改寫(xiě)在稍后被回滾了，那么第一個(gè)事務(wù)獲取的數(shù)據(jù)就是無(wú)效的。
不可重復(fù)讀的重點(diǎn)是修改:
con1 = getConnection();
select salary from employee empId ="Mary";
在事務(wù)2中，這時(shí)財(cái)務(wù)人員修改了Mary的工資為2000,并提交了事務(wù).
con2 = getConnection();
update employee set salary = 2000;
con2.commit();
在事務(wù)1中，Mary 再次讀取自己的工資時(shí)，工資變?yōu)榱?000
//con1
select salary from employee empId ="Mary";
在一個(gè)事務(wù)中前后兩次讀取的結(jié)果并不一致，導(dǎo)致了不可重復(fù)讀。
幻讀的重點(diǎn)在于新增或者刪除：
con1 = getConnection();
Select * from employee where salary =1000;
共讀取10條記錄
這時(shí)另一個(gè)事務(wù)向employee表插入了一條員工記錄，工資也為1000
con2 = getConnection();
Insert into employee(empId,salary) values("Lili",1000);
con2.commit();
事務(wù)1再次讀取所有工資為1000的員工
//con1
select * from employee where salary =1000;
共讀取到了11條記錄，這就產(chǎn)生了幻像讀。
從總的結(jié)果來(lái)看, 似乎不可重復(fù)讀和幻讀都表現(xiàn)為兩次讀取的結(jié)果不一致。但如果你從控制的角度來(lái)看, 兩者的區(qū)別就比較大。
（2）隔離級(jí)別
隔離級(jí)別 含義
2.2.4 事務(wù)超時(shí)
2.2.5 回滾規(guī)則
2.3 事務(wù)狀態(tài)
public interface TransactionStatus{
3 編程式事務(wù)
3.2 如何實(shí)現(xiàn)編程式事務(wù)？
3.2.1 使用TransactionTemplate
TransactionTemplate tt = new TransactionTemplate(); // 新建一個(gè)TransactionTemplate
Object result = tt.execute(
new TransactionCallback(){
public Object doTransaction(TransactionStatus status){
updateOperation();
return resultOfUpdateOperation();
}
}); // 執(zhí)行execute方法進(jìn)行事務(wù)管理
使用TransactionCallback()可以返回一個(gè)值。如果使用TransactionCallbackWithoutResult則沒(méi)有返回值。
3.2.2 使用PlatformTransactionManager
DataSourceTransactionManager dataSourceTransactionManager = new DataSourceTransactionManager(); //定義一個(gè)某個(gè)框架平臺(tái)的TransactionManager，如JDBC、Hibernate
dataSourceTransactionManager.setDataSource(this.getJdbcTemplate().getDataSource()); // 設(shè)置數(shù)據(jù)源
DefaultTransactionDefinition transDef = new DefaultTransactionDefinition(); // 定義事務(wù)屬性
transDef.setPropagationBehavior(DefaultTransactionDefinition.PROPAGATION_REQUIRED); // 設(shè)置傳播行為屬性
TransactionStatus status = dataSourceTransactionManager.getTransaction(transDef); // 獲得事務(wù)狀態(tài)
try {
// 數(shù)據(jù)庫(kù)操作
dataSourceTransactionManager.commit(status);// 提交
} catch (Exception e) {
dataSourceTransactionManager.rollback(status);// 回滾
}
4 聲明式事務(wù)
根據(jù)代理機(jī)制的不同，總結(jié)了五種Spring事務(wù)的配置方式，配置文件如下：
（1）每個(gè)Bean都有一個(gè)代理
<?xml version="1.0" encoding="UTF-8"?>
<bean id="sessionFactory"
class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
<property name="configLocation" value="classpath:hibernate.cfg.xml" />
<property name="configurationClass" value="org.hibernate.cfg.AnnotationConfiguration" />
</bean>
<!-- 定義事務(wù)管理器（聲明式的事務(wù)） -->
<bean id="transactionManager"
class="org.springframework.orm.hibernate3.HibernateTransactionManager">
<property name="sessionFactory" ref="sessionFactory" />
</bean>
<!-- 配置DAO -->
<bean id="userDaoTarget" class="com.bluesky.spring.dao.UserDaoImpl">
<property name="sessionFactory" ref="sessionFactory" />
</bean>
<bean id="userDao"
class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">
<!-- 配置事務(wù)管理器 -->
<property name="transactionManager" ref="transactionManager" />
<property name="target" ref="userDaoTarget" />
<property name="proxyInterfaces" value="com.bluesky.spring.dao.GeneratorDao" />
<!-- 配置事務(wù)屬性 -->
<property name="transactionAttributes">
<props>
<prop key="*">PROPAGATION_REQUIRED</prop>
</props>
</property>
</bean>
<bean id="sessionFactory"
class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
<property name="configLocation" value="classpath:hibernate.cfg.xml" />
<property name="configurationClass" value="org.hibernate.cfg.AnnotationConfiguration" />
</bean>
<!-- 定義事務(wù)管理器（聲明式的事務(wù)） -->
<bean id="transactionManager"
class="org.springframework.orm.hibernate3.HibernateTransactionManager">
<property name="sessionFactory" ref="sessionFactory" />
</bean>
<bean id="transactionBase"
class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean"
lazy-init="true" abstract="true">
<!-- 配置事務(wù)管理器 -->
<property name="transactionManager" ref="transactionManager" />
<!-- 配置事務(wù)屬性 -->
<property name="transactionAttributes">
<props>
<prop key="*">PROPAGATION_REQUIRED</prop>
</props>
</property>
</bean>
<!-- 配置DAO -->
<bean id="userDaoTarget" class="com.bluesky.spring.dao.UserDaoImpl">
<property name="sessionFactory" ref="sessionFactory" />
</bean>
<bean id="userDao" parent="transactionBase" >
<property name="target" ref="userDaoTarget" />
</bean>
<bean id="sessionFactory"
class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
<property name="configLocation" value="classpath:hibernate.cfg.xml" />
<property name="configurationClass" value="org.hibernate.cfg.AnnotationConfiguration" />
</bean>
<!-- 定義事務(wù)管理器（聲明式的事務(wù)） -->
<bean id="transactionManager"
class="org.springframework.orm.hibernate3.HibernateTransactionManager">
<property name="sessionFactory" ref="sessionFactory" />
</bean>
<bean id="transactionInterceptor"
class="org.springframework.transaction.interceptor.TransactionInterceptor">
<property name="transactionManager" ref="transactionManager" />
<!-- 配置事務(wù)屬性 -->
<property name="transactionAttributes">
<props>
<prop key="*">PROPAGATION_REQUIRED</prop>
</props>
</property>
</bean>
<bean class="org.springframework.aop.framework.autoproxy.BeanNameAutoProxyCreator">
<property name="beanNames">
<list>
<value>*Dao</value>
</list>
</property>
<property name="interceptorNames">
<list>
<value>transactionInterceptor</value>
</list>
</property>
</bean>
<!-- 配置DAO -->
<bean id="userDao" class="com.bluesky.spring.dao.UserDaoImpl">
<property name="sessionFactory" ref="sessionFactory" />
</bean>
<context:annotation-config />
<context:component-scan base-package="com.bluesky" />
<bean id="sessionFactory"
class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
<property name="configLocation" value="classpath:hibernate.cfg.xml" />
<property name="configurationClass" value="org.hibernate.cfg.AnnotationConfiguration" />
</bean>
<!-- 定義事務(wù)管理器（聲明式的事務(wù)） -->
<bean id="transactionManager"
class="org.springframework.orm.hibernate3.HibernateTransactionManager">
<property name="sessionFactory" ref="sessionFactory" />
</bean>
<tx:advice id="txAdvice" transaction-manager="transactionManager">
<tx:attributes>
<tx:method name="*" propagation="REQUIRED" />
</tx:attributes>
</tx:advice>
<aop:config>
<aop:pointcut id="interceptorPointCuts"
expression="execution(* com.bluesky.spring.dao.*.*(..))" />
<aop:advisor advice-ref="txAdvice"
pointcut-ref="interceptorPointCuts" />
</aop:config>
<context:annotation-config />
<context:component-scan base-package="com.bluesky" />
<tx:annotation-driven transaction-manager="transactionManager"/>
<bean id="sessionFactory"
class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
<property name="configLocation" value="classpath:hibernate.cfg.xml" />
<property name="configurationClass" value="org.hibernate.cfg.AnnotationConfiguration" />
</bean>
<!-- 定義事務(wù)管理器（聲明式的事務(wù)） -->
<bean id="transactionManager"
class="org.springframework.orm.hibernate3.HibernateTransactionManager">
<property name="sessionFactory" ref="sessionFactory" />
</bean>
package com.bluesky.spring.dao;
import java.util.List;
import org.hibernate.SessionFactory;
import com.bluesky.spring.domain.User;
@Transactional
public List<User> listUsers() {
return this.getSession().createQuery("from User").list();
}
}
首先是數(shù)據(jù)庫(kù)表
然后是XML配置
<import resource="applicationContext-db.xml" />
<context:component-scan
base-package="com.springinaction.transaction">
</context:component-scan>
<tx:annotation-driven transaction-manager="txManager"/>
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource" />
</bean>
package com.springinaction.transaction;
public interface BookShopDao {
package com.springinaction.transaction;
import org.springframework.beans.factory.annotation.Autowired;
@Repository(“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) {
//檢查書(shū)的庫(kù)存是否足夠，若不夠，則拋出異常
String sql2 = "SELECT stock FROM book_stock WHERE isbn = ?";
int stock = JdbcTemplate.queryForObject(sql2, Integer.class, isbn);
if (stock == 0) {
throw new BookStockException("庫(kù)存不足！");
}
String sql = "UPDATE book_stock SET stock = stock - 1 WHERE isbn = ?";
JdbcTemplate.update(sql, isbn);
}
@Override
public void updateUserAccount(String username, int price) {
//檢查余額是否不足，若不足，則拋出異常
String sql2 = "SELECT balance FROM account WHERE username = ?";
int balance = JdbcTemplate.queryForObject(sql2, Integer.class, username);
if (balance < price) {
throw new UserAccountException("余額不足！");
}
String sql = "UPDATE account SET balance = balance - ? WHERE username = ?";
JdbcTemplate.update(sql, price, username);
}
}
package com.springinaction.transaction;
package com.springinaction.transaction;
import org.springframework.beans.factory.annotation.Autowired;
@Service(“bookShopService”)
@Autowired
private BookShopDao bookShopDao;
/**
* 1.添加事務(wù)注解
* 使用propagation 指定事務(wù)的傳播行為，即當(dāng)前的事務(wù)方法被另外一個(gè)事務(wù)方法調(diào)用時(shí)如何使用事務(wù)。
* 默認(rèn)取值為REQUIRED，即使用調(diào)用方法的事務(wù)
* REQUIRES_NEW：使用自己的事務(wù)，調(diào)用的事務(wù)方法的事務(wù)被掛起。
*
* 2.使用isolation 指定事務(wù)的隔離級(jí)別，最常用的取值為READ_COMMITTED
* 3.默認(rèn)情況下 Spring 的聲明式事務(wù)對(duì)所有的運(yùn)行時(shí)異常進(jìn)行回滾，也可以通過(guò)對(duì)應(yīng)的屬性進(jìn)行設(shè)置。通常情況下，默認(rèn)值即可。
* 4.使用readOnly 指定事務(wù)是否為只讀。 表示這個(gè)事務(wù)只讀取數(shù)據(jù)但不更新數(shù)據(jù)，這樣可以幫助數(shù)據(jù)庫(kù)引擎優(yōu)化事務(wù)。若真的是一個(gè)只讀取數(shù)據(jù)庫(kù)值得方法，應(yīng)設(shè)置readOnly=true
* 5.使用timeOut 指定強(qiáng)制回滾之前事務(wù)可以占用的時(shí)間。
*/
@Transactional(propagation=Propagation.REQUIRES_NEW,
isolation=Isolation.READ_COMMITTED,
noRollbackFor={UserAccountException.class},
readOnly=true, timeout=3)
@Override
public void purchase(String username, String isbn) {
//1.獲取書(shū)的單價(jià)
int price = bookShopDao.findBookPriceByIsbn(isbn);
//2.更新書(shū)的庫(kù)存
bookShopDao.updateBookStock(isbn);
//3.更新用戶余額
bookShopDao.updateUserAccount(username, price);
}
}
package com.springinaction.transaction;
package com.springinaction.transaction;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
@Service(“cashier”)
@Transactional
@Override
public void checkout(String username, List<String> isbns) {
for(String isbn : isbns) {
bookShopService.purchase(username, isbn);
}
}
}
package com.springinaction.transaction;
private static final long serialVersionUID = 1L;
public BookStockException() {
super();
// TODO Auto-generated constructor stub
}
public BookStockException(String arg0, Throwable arg1, boolean arg2,
boolean arg3) {
super(arg0, arg1, arg2, arg3);
// TODO Auto-generated constructor stub
}
public BookStockException(String arg0, Throwable arg1) {
super(arg0, arg1);
// TODO Auto-generated constructor stub
}
public BookStockException(String arg0) {
super(arg0);
// TODO Auto-generated constructor stub
}
public BookStockException(Throwable arg0) {
super(arg0);
// TODO Auto-generated constructor stub
}
}
package com.springinaction.transaction;
private static final long serialVersionUID = 1L;
public UserAccountException() {
super();
// TODO Auto-generated constructor stub
}
public UserAccountException(String arg0, Throwable arg1, boolean arg2,
boolean arg3) {
super(arg0, arg1, arg2, arg3);
// TODO Auto-generated constructor stub
}
public UserAccountException(String arg0, Throwable arg1) {
super(arg0, arg1);
// TODO Auto-generated constructor stub
}
public UserAccountException(String arg0) {
super(arg0);
// TODO Auto-generated constructor stub
}
public UserAccountException(Throwable arg0) {
super(arg0);
// TODO Auto-generated constructor stub
}
}
package com.springinaction.transaction;
import java.util.Arrays;
import org.junit.Test;
public class SpringTransitionTest {
private ApplicationContext ctx = null;
private BookShopDao bookShopDao = null;
private BookShopService bookShopService = null;
private Cashier cashier = null;
{
ctx = new ClassPathXmlApplicationContext("config/transaction.xml");
bookShopDao = ctx.getBean(BookShopDao.class);
bookShopService = ctx.getBean(BookShopService.class);
cashier = ctx.getBean(Cashier.class);
}
@Test
public void testBookShopDaoFindPriceByIsbn() {
System.out.println(bookShopDao.findBookPriceByIsbn("1001"));
}
@Test
public void testBookShopDaoUpdateBookStock(){
bookShopDao.updateBookStock("1001");
}
@Test
public void testBookShopDaoUpdateUserAccount(){
bookShopDao.updateUserAccount("AA", 100);
}
@Test
public void testBookShopService(){
bookShopService.purchase("AA", "1001");
}
@Test
public void testTransactionPropagation(){
cashier.checkout("AA", Arrays.asList("1001", "1002"));
}
}
來(lái)源：http://www./content-4-160701.html
