在Spring中實(shí)現(xiàn)事務(wù)管理的方法有哪些

這篇文章主要介紹了在Spring中實(shí)現(xiàn)事務(wù)管理的方法有哪些，此處給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考價(jià)值，需要的朋友可以參考下：

一、事務(wù)的作用

  將若干的數(shù)據(jù)庫操作作為一個(gè)整體控制,一起成功或一起失敗。

  原子性：指事務(wù)是一個(gè)不可分割的工作單位，事務(wù)中的操作要么都發(fā)生，要么都不發(fā)生。

  一致性：指事務(wù)前后數(shù)據(jù)的完整性必須保持一致。

  隔離性：指多個(gè)用戶并發(fā)訪問數(shù)據(jù)庫時(shí)，一個(gè)用戶的事務(wù)不能被其他用戶的事務(wù)所干擾，多個(gè)并發(fā)事務(wù)之間數(shù)據(jù)要相互隔離。

  持久性：指一個(gè)事務(wù)一旦被提交，它對數(shù)據(jù)庫中數(shù)據(jù)的改變就是永久性的，即時(shí)數(shù)據(jù)庫發(fā)生故障也不應(yīng)該對其有任何影響。

二、Spring事務(wù)管理高層抽象主要包括3個(gè)接口

  --Platform TransactionManager 事務(wù)管理器（提交、回滾事務(wù)）

     Spring為不同的持久化框架提供了不同的Platform TransactionManager接口實(shí)現(xiàn)。如：

        使用Spring JDBC或iBatis進(jìn)行持久化數(shù)據(jù)時(shí)使用DataSourceTransactionManager

        使用Hibernate3.0版本進(jìn)行持久化數(shù)據(jù)時(shí)使用HibernateTransactionManager

  --TransactionDefinition 事務(wù)定義信息（隔離、傳播、超時(shí)、只讀）

        臟讀：一個(gè)事務(wù)讀取了另一個(gè)事務(wù)改寫但還未提交的數(shù)據(jù)，如果這些數(shù)據(jù)被回滾，則讀到的數(shù)據(jù)是無效的。

        不可重復(fù)讀：在同一事務(wù)中，多次讀取同一數(shù)據(jù)返回的結(jié)果有所不同。

        幻讀：一個(gè)事務(wù)讀取了幾行記錄后，另一個(gè)事務(wù)插入一些記錄，幻讀就發(fā)生了。再后來的查詢中，第一個(gè)事務(wù)就會發(fā)現(xiàn)有些原來沒有的記錄。

        事務(wù)隔離級別：（五種）

•     DEFAULT--使用后端數(shù)據(jù)庫默認(rèn)的隔離級別（Spring中的選擇項(xiàng)）

•     READ_UNCOMMITED--允許你讀取還未提交的改變了的數(shù)據(jù)。可能導(dǎo)致臟、幻、不可重復(fù)讀

•     READ_COMMITTED--允許在并發(fā)事務(wù)已經(jīng)提交后讀取?？煞乐古K讀，但幻讀和不可重復(fù)讀仍可發(fā)生

•     REPEATABLE_READ--對相同字段的多次讀取是一致的，除非數(shù)據(jù)被事務(wù)本身改變?？煞乐古K、不可重復(fù)讀，但幻讀仍可能發(fā)生

•     SERIALIZABLE--完全服從ACID的隔離級別，確保不發(fā)生臟、幻、不可重復(fù)讀。這在所有的隔離級別中是最慢的，它是典型的通過完全鎖定在事務(wù)中涉及的數(shù)據(jù)表來完成的
  

    其中，MySQL默認(rèn)采用REPEATABLE_READ隔離級別；Oracle默認(rèn)采用READ_COMMITTED隔離級別

        事務(wù)傳播行為：（七種）

•     REQUIRED--支持當(dāng)前事務(wù)，如果當(dāng)前沒有事務(wù)，就新建一個(gè)事務(wù)。這是最常見的選擇。

•     SUPPORTS--支持當(dāng)前事務(wù)，如果當(dāng)前沒有事務(wù)，就以非事務(wù)方式執(zhí)行。

•     MANDATORY--支持當(dāng)前事務(wù)，如果當(dāng)前沒有事務(wù)，就拋出異常。

•     REQUIRES_NEW--新建事務(wù)，如果當(dāng)前存在事務(wù)，把當(dāng)前事務(wù)掛起。

•     NOT_SUPPORTED--以非事務(wù)方式執(zhí)行操作，如果當(dāng)前存在事務(wù)，就把當(dāng)前事務(wù)掛起。

•     NEVER--以非事務(wù)方式執(zhí)行，如果當(dāng)前存在事務(wù)，則拋出異常。

•     NESTED--如果當(dāng)前存在事務(wù)，則在嵌套事務(wù)內(nèi)執(zhí)行。如果當(dāng)前沒有事務(wù)，則進(jìn)行與REQUIRED類似的操作。擁有多個(gè)可以回滾的保存點(diǎn)，內(nèi)部回滾不會對外部事務(wù)產(chǎn)生影響。只對DataSourceTransactionManager有效

  --TransactionStatus 事務(wù)具體運(yùn)行狀態(tài)

三、Spring提供了以下方法控制事務(wù)

  a.編程式事務(wù)管理(基于Java編程控制，很少使用)--見demo1包

       利用TransactionTemplate將多個(gè)DAO操作封裝起來

  *b.聲明式事務(wù)管理(基于Spring的AOP配置控制)

       -基于TransactionProxyFactoryBean的方式.(很少使用)--見demo2包

            需要為每個(gè)進(jìn)行事務(wù)管理的類,配置一個(gè)TransactionProxyFactoryBean進(jìn)行增強(qiáng).

       -基于XML配置(經(jīng)常使用)--見demo3包

            一旦配置好之后,類上不需要添加任何東西。

            如果Action作為目標(biāo)對象切入事務(wù)，需要在<aop:config>元素里添加proxy-target-class="true"屬性。原因是通知Spring框架采用CGLIB技術(shù)生成具有事務(wù)管理功能的Action類。

       -基于注解(配置簡單，經(jīng)常使用)--見demo4包

            在applicationContext.xml中開啟事務(wù)注解配置。(applicationContext.xml中只需定義Bean并追加以下元素)

<bean id="txManager" class="...">
 <property name="sessionFactory">
 </property>
<tx:annotation-driven transaction-manager="txManager"/>

            在目標(biāo)組件類中使用@Transactional，該標(biāo)記可定義在類前或方法前。

四、示例（銀行轉(zhuǎn)賬）

        --編程式

/** 
 * @Description:轉(zhuǎn)賬案例的DAO層接口 
 * 
 */ 
public interface AccountDao { 
 /** 
 * @param out 
 * :轉(zhuǎn)出賬號 
 * @param money 
 * :轉(zhuǎn)賬金額 
 */ 
 public void outMoney(String out, Double money); 
 
 /** 
 * 
 * @param in 
 * :轉(zhuǎn)入賬號 
 * @param money 
 * :轉(zhuǎn)賬金額 
 */ 
 public void inMoney(String in, Double money); 
}

/** 
 * @Description:轉(zhuǎn)賬案例的DAO層實(shí)現(xiàn)類 
 */ 
public class AccountDaoImpl extends JdbcDaoSupport implements AccountDao { 
 /** 
 * @param out 
 * :轉(zhuǎn)出賬號 
 * @param money 
 * :轉(zhuǎn)賬金額 
 */ 
 @Override 
 public void outMoney(String out, Double money) { 
 String sql = "update account set money = money-? where name = ?"; 
 this.getJdbcTemplate().update(sql, money, out); 
 } 
 /** 
 * @param in 
 * :轉(zhuǎn)入賬號 
 * @param money 
 * :轉(zhuǎn)賬金額 
 */ 
 @Override 
 public void inMoney(String in, Double money) { 
 String sql = "update account set money = money+? where name = ?"; 
 this.getJdbcTemplate().update(sql, money, in); 
 } 
}

/** 
 * @Description:轉(zhuǎn)賬案例的業(yè)務(wù)接口 
 * 
 */ 
public interface AccountService { 
 /** 
 * @param out :轉(zhuǎn)出賬號 
 * @param in :轉(zhuǎn)入賬號 
 * @param money :轉(zhuǎn)賬金額 
 */ 
 public void transfer(String out,String in,Double money); 
}

/** 
 * @Description:轉(zhuǎn)賬案例的業(yè)務(wù)層實(shí)現(xiàn)類 
 */ 
public class AccountServiceImpl implements AccountService { 
 // 注入轉(zhuǎn)賬的DAO 
 private AccountDao accountDao; 
 
 // 注入事務(wù)管理的模板 
 private TransactionTemplate transactionTemplate; 
 
 /** 
 * @param out 
 * :轉(zhuǎn)出賬號 
 * @param in 
 * :轉(zhuǎn)入賬號 
 * @param money 
 * :轉(zhuǎn)賬金額 
 */ 
 @Override 
 public void transfer(final String out, final String in, final Double money) { 
 
 // 未經(jīng)事務(wù)控制的業(yè)務(wù)處理操作，如果過程中出異常，則導(dǎo)致前面的操作能完成，后面的不能，即轉(zhuǎn)賬成功但未收到轉(zhuǎn)賬款 
 // accountDao.outMoney(out, money); 
 // int i = 1/0; 
 // accountDao.inMoney(in, money); 
 
 transactionTemplate.execute(new TransactionCallbackWithoutResult() { 
 
 @Override 
 protected void doInTransactionWithoutResult( 
  TransactionStatus transactionStatus) { 
 accountDao.outMoney(out, money); 
 // int i = 1 / 0;//事務(wù)控制，即出現(xiàn)異常，該段內(nèi)代碼都執(zhí)行失效 
 accountDao.inMoney(in, money); 
 } 
 }); 
 } 
 
 public void setAccountDao(AccountDao accountDao) { 
 this.accountDao = accountDao; 
 } 
 
 public void setTransactionTemplate(TransactionTemplate transactionTemplate) { 
 this.transactionTemplate = transactionTemplate; 
 } 
}

applicationContext1.xml

<!-- 引入外部的屬性文件 --> 
 <context:property-placeholder location="classpath:jdbc.properties"/> 
 
 <!-- 配置c3p0連接池 --> 
 <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"> 
 <property name="driverClass" value="${jdbc.driverClass}" /> 
 <property name="jdbcUrl" value="${jdbc.url}" /> 
 <property name="user" value="${jdbc.username}" /> 
 <property name="password" value="${jdbc.password}" /> 
 </bean> 
 
 <!-- 配置業(yè)務(wù)層類 --> 
 <bean id="accountService" class="com.zs.spring.demo1.AccountServiceImpl"> 
 <property name="accountDao" ref="accountDao" /> 
 <!-- 注入事務(wù)管理的模板 --> 
 <property name="transactionTemplate" ref="transactionTemplate" /> 
 </bean> 
 
 <!-- 配置DAO類(簡化，會自動配置JdbcTemplate) --> 
 <bean id="accountDao" class="com.zs.spring.demo1.AccountDaoImpl"> 
 <property name="dataSource" ref="dataSource" /> 
 </bean> 
 
 <!-- 配置DAO類(未簡化) --> 
 <!-- <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"> 
 <property name="dataSource" ref="dataSource" /> 
 </bean> 
 <bean id="accountDao" class="com.zs.spring.demo1.AccountDaoImpl"> 
 <property name="jdbcTemplate" ref="jdbcTemplate" /> 
 </bean> --> 
 
 <!-- ==================================1.編程式的事務(wù)管理=============================================== --> 
 <!-- 配置事務(wù)管理器 --> 
 <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> 
 <property name="dataSource" ref="dataSource" /> 
 </bean> 
 
 <!-- 配置事務(wù)管理的模板:Spring為了簡化事務(wù)管理的代碼而提供的類 --> 
 <bean id="transactionTemplate" class="org.springframework.transaction.support.TransactionTemplate"> 
 <property name="transactionManager" ref="transactionManager"/> 
 </bean>

測試：

@RunWith(SpringJUnit4ClassRunner.class) 
@ContextConfiguration("classpath:applicationContext1.xml") 
public class TransactionTest { 
 @Resource(name = "accountService") 
 private AccountService accountService; 
 
 @Test 
 public void demo1() { 
 accountService.transfer("aaa", "bbb", 200d); 
 } 
}

    --基于TransactionProxyFactoryBean的方式

public class AccountServiceImpl implements AccountService { 
 // 注入轉(zhuǎn)賬的DAO 
 private AccountDao accountDao; 
 
 /** 
 * @param out 
 *  :轉(zhuǎn)出賬號 
 * @param in 
 *  :轉(zhuǎn)入賬號 
 * @param money 
 *  :轉(zhuǎn)賬金額 
 */ 
 @Override 
 public void transfer(String out, String in, Double money) { 
 accountDao.outMoney(out, money); 
 // int i = 1/0; 
 accountDao.inMoney(in, money); 
 } 
 
 public void setAccountDao(AccountDao accountDao) { 
 this.accountDao = accountDao; 
 } 
}

applicationContext2.xml

<!-- 引入外部的屬性文件 --> 
 <context:property-placeholder location="classpath:jdbc.properties"/> 
 
 <!-- 配置c3p0連接池 --> 
 <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"> 
 <property name="driverClass" value="${jdbc.driverClass}" /> 
 <property name="jdbcUrl" value="${jdbc.url}" /> 
 <property name="user" value="${jdbc.username}" /> 
 <property name="password" value="${jdbc.password}" /> 
 </bean> 
 
 <!-- 配置業(yè)務(wù)層類 --> 
 <bean id="accountService" class="com.zs.spring.demo2.AccountServiceImpl"> 
 <property name="accountDao" ref="accountDao" /> 
 </bean> 
 
 <!-- 配置DAO類(簡化，會自動配置JdbcTemplate) --> 
 <bean id="accountDao" class="com.zs.spring.demo2.AccountDaoImpl"> 
 <property name="dataSource" ref="dataSource" /> 
 </bean> 
 
 <!-- ==================================2.使用XML配置聲明式的事務(wù)管理(原始方式)=============================================== --> 
 
 <!-- 配置事務(wù)管理器 --> 
 <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> 
 <property name="dataSource" ref="dataSource" /> 
 </bean> 
 
 <!-- 配置業(yè)務(wù)層的代理 --> 
 <bean id="accountServiceProxy" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean"> 
 <!-- 配置目標(biāo)對象 --> 
 <property name="target" ref="accountService" /> 
 <!-- 注入事務(wù)管理器 --> 
 <property name="transactionManager" ref="transactionManager"></property> 
 <!-- 注入事務(wù)的屬性 --> 
 <property name="transactionAttributes"> 
  <props> 
  <!-- 
   prop的格式: 
   * PROPAGATION :事務(wù)的傳播行為 
   * ISOTATION :事務(wù)的隔離級別 
   * readOnly :只讀 
   * -EXCEPTION :發(fā)生哪些異?；貪L事務(wù) 
   * +EXCEPTION :發(fā)生哪些異常不回滾事務(wù) 
   --> 
  <prop key="transfer">PROPAGATION_REQUIRED</prop> 
  <!-- <prop key="transfer">PROPAGATION_REQUIRED,readOnly</prop> --> 
  <!-- <prop key="transfer">PROPAGATION_REQUIRED,+java.lang.ArithmeticException</prop> --> 
  </props> 
 </property> 
 </bean>

測試：

@RunWith(SpringJUnit4ClassRunner.class) 
@ContextConfiguration("classpath:applicationContext2.xml") 
public class TransactionTest { 
 /** 
 * 一定要注入代理類:因?yàn)榇眍愡M(jìn)行增強(qiáng)的操作 
 */ 
 // @Resource(name="accountService") 
 @Resource(name = "accountServiceProxy") 
 private AccountService accountService; 
 
 @Test 
 public void demo1() { 
 accountService.transfer("aaa", "bbb", 200d); 
 } 
}

    --基于XML配置

public class AccountServiceImpl implements AccountService { 
 // 注入轉(zhuǎn)賬的DAO 
 private AccountDao accountDao; 
 
 /** 
 * @param out 
 *  :轉(zhuǎn)出賬號 
 * @param in 
 *  :轉(zhuǎn)入賬號 
 * @param money 
 *  :轉(zhuǎn)賬金額 
 */ 
 @Override 
 public void transfer(String out, String in, Double money) { 
 accountDao.outMoney(out, money); 
 // int i = 1/0; 
 accountDao.inMoney(in, money); 
 
 } 
 
 public void setAccountDao(AccountDao accountDao) { 
 this.accountDao = accountDao; 
 } 
}

applicationContext3.xml

<!-- 引入外部的屬性文件 --> 
 <context:property-placeholder location="classpath:jdbc.properties"/> 
 
 <!-- 配置c3p0連接池 --> 
 <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"> 
 <property name="driverClass" value="${jdbc.driverClass}" /> 
 <property name="jdbcUrl" value="${jdbc.url}" /> 
 <property name="user" value="${jdbc.username}" /> 
 <property name="password" value="${jdbc.password}" /> 
 </bean> 
 
 <!-- 配置業(yè)務(wù)層類 --> 
 <bean id="accountService" class="com.zs.spring.demo3.AccountServiceImpl"> 
 <property name="accountDao" ref="accountDao" /> 
 </bean> 
 
 <!-- 配置DAO類(簡化，會自動配置JdbcTemplate) --> 
 <bean id="accountDao" class="com.zs.spring.demo3.AccountDaoImpl"> 
 <property name="dataSource" ref="dataSource" /> 
 </bean> 
 
 <!-- ==================================3.使用XML配置聲明式的事務(wù)管理,基于tx/aop=============================================== --> 
 
 <!-- 配置事務(wù)管理器 --> 
 <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> 
 <property name="dataSource" ref="dataSource" /> 
 </bean> 
 
 <!-- 配置事務(wù)的通知 --> 
 <tx:advice id="txAdvice" transaction-manager="transactionManager"> 
 <tx:attributes> 
  <!-- 
  propagation :事務(wù)傳播行為 
  isolation :事務(wù)的隔離級別 
  read-only :只讀 
  rollback-for:發(fā)生哪些異常回滾 
  no-rollback-for :發(fā)生哪些異常不回滾 
  timeout :過期信息 
  --> 
  <tx:method name="transfer" propagation="REQUIRED"/> 
 </tx:attributes> 
 </tx:advice> 
 
 <!-- 配置切面 --> 
 <aop:config> 
 <!-- 配置切入點(diǎn) --> 
 <aop:pointcut expression="execution(* com.zs.spring.demo3.AccountService+.*(..))" id="pointcut1"/> 
 <!-- 配置切面 --> 
 <aop:advisor advice-ref="txAdvice" pointcut-ref="pointcut1"/> 
 </aop:config>

測試：

/** 
 * @Description:Spring的聲明式事務(wù)管理的方式二：基于AspectJ的XML方式的配置 
 */ 
@RunWith(SpringJUnit4ClassRunner.class) 
@ContextConfiguration("classpath:applicationContext3.xml") 
public class TransactionTest { 
 /** 
 * 一定要注入代理類:因?yàn)榇眍愡M(jìn)行增強(qiáng)的操作 
 */ 
 @Resource(name = "accountService") 
 private AccountService accountService; 
 
 @Test 
 public void demo1() { 
 accountService.transfer("aaa", "bbb", 200d); 
 } 
}

    --基于注解

/** 
 * @Transactional中的的屬性 propagation :事務(wù)的傳播行為 isolation :事務(wù)的隔離級別 readOnly :只讀 
 *   rollbackFor :發(fā)生哪些異?；貪L noRollbackFor :發(fā)生哪些異常不回滾 
 *   rollbackForClassName 根據(jù)異常類名回滾 
 */ 
@Transactional(propagation = Propagation.REQUIRED, isolation = Isolation.DEFAULT, readOnly = false) 
public class AccountServiceImpl implements AccountService { 
 // 注入轉(zhuǎn)賬的DAO 
 private AccountDao accountDao; 
 
 /** 
 * @param out 
 *  :轉(zhuǎn)出賬號 
 * @param in 
 *  :轉(zhuǎn)入賬號 
 * @param money 
 *  :轉(zhuǎn)賬金額 
 */ 
 @Override 
 public void transfer(String out, String in, Double money) { 
 accountDao.outMoney(out, money); 
 // int i = 1/0; 
 accountDao.inMoney(in, money); 
 } 
 
 public void setAccountDao(AccountDao accountDao) { 
 this.accountDao = accountDao; 
 } 
}

applicationContext4.xml

<!-- 引入外部的屬性文件 --> 
 <context:property-placeholder location="classpath:jdbc.properties"/> 
 
 <!-- 配置c3p0連接池 --> 
 <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"> 
 <property name="driverClass" value="${jdbc.driverClass}" /> 
 <property name="jdbcUrl" value="${jdbc.url}" /> 
 <property name="user" value="${jdbc.username}" /> 
 <property name="password" value="${jdbc.password}" /> 
 </bean> 
 
 <!-- 配置業(yè)務(wù)層類 --> 
 <bean id="accountService" class="com.zs.spring.demo4.AccountServiceImpl"> 
 <property name="accountDao" ref="accountDao" /> 
 </bean> 
 
 <!-- 配置DAO類(簡化，會自動配置JdbcTemplate) --> 
 <bean id="accountDao" class="com.zs.spring.demo4.AccountDaoImpl"> 
 <property name="dataSource" ref="dataSource" /> 
 </bean> 
 
 <!-- ==================================4.使用注解配置聲明式事務(wù)============================================ --> 
 
 <!-- 配置事務(wù)管理器 --> 
 <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> 
 <property name="dataSource" ref="dataSource" /> 
 </bean> 
 
 <!-- 開啟注解事務(wù) --> 
 <tx:annotation-driven transaction-manager="transactionManager"/>

測試：

@RunWith(SpringJUnit4ClassRunner.class) 
@ContextConfiguration("classpath:applicationContext4.xml") 
public class TransactionTest { 
 /** 
 * 一定要注入代理類:因?yàn)榇眍愡M(jìn)行增強(qiáng)的操作 
 */ 
 @Resource(name = "accountService") 
 private AccountService accountService; 
 
 @Test 
 public void demo1() { 
 accountService.transfer("aaa", "bbb", 200d); 
 } 
}

到此這篇關(guān)于在Spring中實(shí)現(xiàn)事務(wù)管理的方法有哪些的文章就介紹到這了，更多相關(guān)的內(nèi)容請搜索億速云以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持億速云！