Spring 7種事務傳播行爲

一、PROPAGATION_REQUIRED：若是當前沒有事務，就建立一個新事務，若是當前存在事務，就加入該事務，該設置是最經常使用的設置。java

二、PROPAGATION_SUPPORTS：支持當前事務，若是當前存在事務，就加入該事務，若是當前不存在事務，就以非事務執行。‘mysql

三、PROPAGATION_MANDATORY：支持當前事務，若是當前存在事務，就加入該事務，若是當前不存在事務，就拋出異常。spring

四、PROPAGATION_REQUIRES_NEW：建立新事務，不管當前存不存在事務，都建立新事務。sql

五、PROPAGATION_NOT_SUPPORTED：以非事務方式執行操做，若是當前存在事務，就把當前事務掛起。數據庫

六、PROPAGATION_NEVER：以非事務方式執行，若是當前存在事務，則拋出異常。apache

七、PROPAGATION_NESTED：若是當前存在事務，則在嵌套事務內執行。若是當前沒有事務，則執行與PROPAGATION_REQUIRED相似的操做。測試

羅列了7種spring的事務傳播行爲，咱們具體來看看它的實現。在這裏，咱們使用spring annotation註解實現事務。url

實現事務的類BusinessServiceImplspa

package com.aop; import org.springframework.aop.support.AopUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Isolation; import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; import com.entity.Student; @Service("businessSerivce") public class BusinessServiceImpl implements IBaseService { @Autowired IStudentDao studentDao; @Autowired IBaseServiceB baseServiceb; @Transactional(propagation = Propagation.REQUIRED, isolation = Isolation.DEFAULT, rollbackFor = Exception.class) public String doA() throws Exception { Student st = new Student(); st.setId(1); st.setSex("girl"); st.setUsername("zx"); studentDao.insertStudent(st); System.out.println(baseServiceb); System.out.println("是不是代理調用，AopUtils.isAopProxy(baseServiceb) : " + AopUtils.isAopProxy(baseServiceb)); System.out .println("是不是cglib類代理調用，AopUtils.isCglibProxy(baseServiceb) : " + AopUtils.isCglibProxy(baseServiceb)); System.out.println("是不是jdk動態接口代理調用，AopUtils.isJdkDynamicProxy(baseServiceb) : "
                + AopUtils.isJdkDynamicProxy(baseServiceb)); //使用代理調用方法doB()
 baseServiceb.doB(); int i = 1 / 0;// 拋出異常，doB()的事務事務回滾
        return "success"; } // @Transactional(propagation = Propagation.REQUIRES_NEW, isolation = // Isolation.DEFAULT, rollbackFor = Exception.class) // public String doB() throws Exception { // Student st = new Student(); // st.setId(2); // st.setSex("girl"); // st.setUsername("zx2"); // studentDao.insertStudent(st); //
    // return "success"; // }
 }

實現事務的類BusinessServiceImpl3d

package com.aop; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Isolation; import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; import com.entity.Student; @Service("businessSerivceB") public class BusinessServiceImplB implements IBaseServiceB { @Autowired IStudentDao studentDao; @Transactional(propagation = Propagation.REQUIRES_NEW,isolation=Isolation.DEFAULT,rollbackFor=Exception.class) public String doB() throws Exception { Student st = new Student(); st.setId(2); st.setSex("girl"); st.setUsername("zx2"); studentDao.insertStudent(st); return "success"; } }

測試類：

package com.aop; import org.springframework.beans.factory.BeanFactory; import org.springframework.context.support.ClassPathXmlApplicationContext; import com.thread.service.IBaseFacadeService; //@RunWith(SpringJUnit4ClassRunner.class) //@ContextConfiguration(locations = { "classpath:/spring-ibatis.xml", "classpath:/spring-jdbctemplate.xml" })
public class TestStudentDao { public static void main(String[] args) { try { BeanFactory factory = new ClassPathXmlApplicationContext("spring-jdbctemplate.xml"); IBaseService service = (IBaseService) factory.getBean("businessSerivce"); service.doA(); } catch (Exception e) { // TODO Auto-generated catch block
 e.printStackTrace(); } } }

測試結果：

om.aop.BusinessServiceImplB@14b75fd9
是不是代理調用，AopUtils.isAopProxy(baseServiceb) : true
是不是cglib類代理調用，AopUtils.isCglibProxy(baseServiceb) : true
是不是jdk動態接口代理調用，AopUtils.isJdkDynamicProxy(baseServiceb) : false
java.lang.ArithmeticException: / by zero

從測試結果能夠看到，咱們在數據庫中成功插入了doB()方法中要插入的數據，而doA()中插入的數據被回滾了，這是由於咱們在doB()方法中加入ROPAGATION_REQUIRES_NEW傳播行爲，doB()建立了屬於本身的事務，掛起了doA()中的事務，因此事務B提交了，而事務A由於執行異常插入的數據被回滾了。

若是咱們將BusinessServiceImplB作下修改，改成第一種傳播行爲ROPAGATION_REQUIRED

package com.aop; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Isolation; import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; import com.entity.Student; @Service("businessSerivceB") public class BusinessServiceImplB implements IBaseServiceB { @Autowired IStudentDao studentDao; @Transactional(propagation = Propagation.REQUIRED,isolation=Isolation.DEFAULT,rollbackFor=Exception.class) public String doB() throws Exception { Student st = new Student(); st.setId(2); st.setSex("girl"); st.setUsername("zx2"); studentDao.insertStudent(st); return "success"; } }

測試結果：

com.aop.BusinessServiceImplB@97c87a4
是不是代理調用，AopUtils.isAopProxy(baseServiceb) : true
是不是cglib類代理調用，AopUtils.isCglibProxy(baseServiceb) : true
是不是jdk動態接口代理調用，AopUtils.isJdkDynamicProxy(baseServiceb) : false
java.lang.ArithmeticException: / by zero

從結果能夠看到，咱們沒有成功插入數據，這是爲何呢？由於咱們使用的是第一種傳播行爲PROPAGATION_REQUIRED ，doB()方法被加入到doA()的事務中，doA()執行時拋出了異常，由於doB()和doA()同屬於一個事務，則執行操做被一塊兒回滾了。其實在doB()中咱們不加入註解，也等同PROPAGATION_REQUIRED的效果。

接下來咱們再來看看第五種傳播行爲PROPAGATION_NOT_SUPPORTED，咱們一樣修改B類，以下

package com.aop; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Isolation; import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; import com.entity.Student; @Service("businessSerivceB") public class BusinessServiceImplB implements IBaseServiceB { @Autowired IStudentDao studentDao; @Transactional(propagation = Propagation.NOT_SUPPORTED,isolation=Isolation.DEFAULT,rollbackFor=Exception.class) public String doB() throws Exception { Student st = new Student(); st.setId(2); st.setSex("girl"); st.setUsername("zx2"); studentDao.insertStudent(st); return "success"; } }

測試結果：

能夠看到doB()方法成功插入了數據。doA()方法中插入的數據被回滾了。這是由於傳播行爲PROPAGATION_NOT_SUPPORTED是doB()以非事務執行的，而且提交了。因此當doA()的事務被回滾時，doB()的操做沒有被回滾。

其餘的傳播行爲就不一一列舉了，機制是差很少的。

注意：在上面的實例中，我沒有把doB()方法放在類BusinessServiceImpl，而是放在BusinessServiceImplB中，這是由於spring經過掃描全部含有註解的@Trasation的方法，使用aop造成事務加強advise。可是加入加強時是經過代理對象調用方法的形式加入的，若是將doB()方法放在doA()方法直接調用時，在調用doB()方法的時候是經過當前對象來調用doB()方法的，而不是經過代理來調用的doB()方法，這個時候doB()方法上加的事務註解就失效了不得做用。在Spring事務傳播行爲在內部方法不起做用講到。

spring配置文件：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:jdbc="http://www.springframework.org/schema/jdbc" xmlns:context="http://www.springframework.org/schema/context" xmlns:aop="http://www.springframework.org/schema/aop" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc-3.0.xsd" default-lazy-init="false">
 
    <context:component-scan base-package="com.aop"/>
    <aop:aspectj-autoproxy proxy-target-class="true"/>
    <!-- 數據 -->
    <bean id="dataSource" class="org.apache.commons.dbcp2.BasicDataSource">
        <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql://localhost:3306/lpWeb"/>
        <property name="username" value="root"/>
        <property name="password" value="root123"/>
    </bean>
    
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
         <property name = "dataSource" ref="dataSource"/>  
    </bean>
  
     <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"/>
    </bean> 
    
    <tx:annotation-driven transaction-manager="transactionManager" />  
</beans>