<output id="qn6qe"></output>

    1. <output id="qn6qe"><tt id="qn6qe"></tt></output>
    2. <strike id="qn6qe"></strike>

      亚洲 日本 欧洲 欧美 视频,日韩中文字幕有码av,一本一道av中文字幕无码,国产线播放免费人成视频播放,人妻少妇偷人无码视频,日夜啪啪一区二区三区,国产尤物精品自在拍视频首页,久热这里只有精品12

      Spring 事務(wù)的配置和使用詳解(轉(zhuǎn)載)

      最近項(xiàng)目中用到了spring的注解類(lèi)的事務(wù)管理,所以特地學(xué)習(xí)和記錄一下spring的配置和使用。項(xiàng)目中使用的是springMVC + mybatis + mysql。spring的版本是4.3.0.RELEASE

      1. spring 注解事務(wù)的配置

      Spring配置文件中關(guān)于事務(wù)配置總是由三個(gè)組成部分,分別是DataSource、TransactionManager和代理機(jī)制這三部分,無(wú)論哪種配置方式,一般變化的只是代理機(jī)制這部分。 
      這里寫(xiě)圖片描述 
      (1)spring+mybatis 事務(wù)配置 
      xml配置文件的命名空間的引用:如下斜體所示:

      <?xml version="1.0" encoding="UTF-8"?>
      <beans xmlns="http://www.springframework.org/schema/beans"
          xmlns:context="http://www.springframework.org/schema/context"
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"
          *xmlns:tx="http://www.springframework.org/schema/tx"* xmlns:p="http://www.springframework.org/schema/p"
          xmlns:util="http://www.springframework.org/schema/util" xmlns:jdbc="http://www.springframework.org/schema/jdbc"
          xmlns:cache="http://www.springframework.org/schema/cache"
          xsi:schemaLocation="http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
              http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
              *http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd*
              http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc.xsd
              http://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache.xsd
              http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd
              http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util.xsd">
      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10
      • 11
      • 12
      • 13
      • 14
      <!-- 注冊(cè)事務(wù)管理類(lèi) -->
          <bean id="transactionManager"
              class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
              <property name="dataSource" ref="dataSource" />
          </bean>
      
          <!-- 開(kāi)啟事務(wù)行為 -->
          <tx:annotation-driven transaction-manager="transactionManager" />
      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8

      (2)Spring+hibernate

      <!-- 事務(wù)管理器配置,單數(shù)據(jù)源事務(wù) -->  
      <bean id="transactionManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager">  
          <property name="sessionFactory" ref="sessionFactory" />  
      </bean>  
      
      <!-- 使用annotation定義事務(wù) -->  
      <tx:annotation-driven  transaction-manager="transactionManager"   proxy-target-class="true" />  
      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7

      注:根據(jù)使用不同的orm框架,事務(wù)管理器就不同。使用mybatis使用:

      org.springframework.jdbc.datasource.DataSourceTransactionManager
      • 1

      而使用hibernate,則事務(wù)管理器類(lèi)為:

      org.springframework.orm.hibernate3.HibernateTransactionManager
      • 1

      事務(wù)的傳播性、隔離性級(jí)別一般設(shè)置在service層。

      2.spring事務(wù)的傳播性、隔離性。

      @Transactional 
      (1)這里說(shuō)明一下,有的把這個(gè)注解放在類(lèi)名稱(chēng)上面了,這樣你配置的這個(gè)@Transactional 對(duì)這個(gè)類(lèi)中的所有public方法都起作用. 
      (2)@Transactional 方法方法名上,只對(duì)這個(gè)方法有作用,同樣必須是public的方法

      我們?cè)谑褂肧pring聲明式事務(wù)時(shí),有一個(gè)非常重要的概念就是事務(wù)的屬性。事務(wù)屬性通常由事務(wù)的傳播行為、事務(wù)的隔離級(jí)別、事務(wù)的超時(shí)值和事務(wù)的只讀標(biāo)識(shí)組成。我們?cè)谶M(jìn)行事務(wù)劃分時(shí),需要進(jìn)行事務(wù)定義,也就是配置事務(wù)的屬性。

      Spring在TransactionDefinition接口中定義這些屬性,以供PlatfromTransactionManager使用, PlatfromTransactionManager是spring事務(wù)管理的核心接口。

      TransactionDefinition  
      public interface TransactionDefinition {  
          int getPropagationBehavior();  
          int getIsolationLevel();  
          int getTimeout();  
          boolean isReadOnly();  
      }  
      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7

      getTimeout()方法,它返回事務(wù)必須在多少秒內(nèi)完成。 
      isReadOnly(),事務(wù)是否只讀,事務(wù)管理器能夠根據(jù)這個(gè)返回值進(jìn)行優(yōu)化,確保事務(wù)是只讀的。 
      getIsolationLevel()方法返回事務(wù)的隔離級(jí)別,事務(wù)管理器根據(jù)它來(lái)控制另外一個(gè)事務(wù)可以看到本事務(wù)內(nèi)的哪些數(shù)據(jù)。

      一。事務(wù)的隔離級(jí)別

      在TransactionDefinition接口中定義了五個(gè)不同的事務(wù)隔離級(jí)別 : 
      (a) ISOLATION_DEFAULT:(PlatfromTransactionManager的)默認(rèn)的隔離級(jí)別。使用數(shù)據(jù)庫(kù)默認(rèn)的事務(wù)隔離級(jí)別.另外四個(gè)與JDBC的隔離級(jí)別相對(duì)應(yīng) 。 
      (b)ISOLATION_READ_UNCOMMITTED:這是事務(wù)最低的隔離級(jí)別,它充許別外一個(gè)事務(wù)可以看到這個(gè)事務(wù)未提交的數(shù)據(jù)。這種隔離級(jí)別會(huì)產(chǎn)生臟讀,不可重復(fù)讀和幻像讀。 
      例如: 
      Mary的原工資為1000,財(cái)務(wù)人員將Mary的工資改為了8000,但未提交事務(wù)

      Connection con1 = getConnection();  
      con.setAutoCommit(false);  
      update employee set salary = 8000 where empId ="Mary"; 
      • 1
      • 2
      • 3

      與此同時(shí),Mary正在讀取自己的工資 。

      Connection con2 = getConnection();  
      select  salary from employee where empId ="Mary";  
      con2.commit();
      • 1
      • 2
      • 3

      Mary發(fā)現(xiàn)自己的工資變?yōu)榱?000,歡天喜地! 
      而財(cái)務(wù)發(fā)現(xiàn)操作有誤,而回滾了事務(wù),Mary的工資又變?yōu)榱?000 。

      //con1  
        con1.rollback(); 
      • 1
      • 2

      像這樣,Mary記取的工資數(shù)8000是一個(gè)臟數(shù)據(jù)。

      (c)ISOLATION_READ_COMMITTED: 保證一個(gè)事務(wù)修改的數(shù)據(jù)提交后才能被另外一個(gè)事務(wù)讀取。另外一個(gè)事務(wù)不能讀取該事務(wù)未提交的數(shù)據(jù)。這種事務(wù)隔離級(jí)別可以避免臟讀出現(xiàn),但是可能會(huì)出現(xiàn)不可重復(fù)讀和幻像讀。

      (d)ISOLATION_REPEATABLE_READ : 這種事務(wù)隔離級(jí)別可以防止臟讀,不可重復(fù)讀。但是可能出現(xiàn)幻像讀。它除了保證一個(gè)事務(wù)不能讀取另一個(gè)事務(wù)未提交的數(shù)據(jù)外,還保證了避免下面的情況產(chǎn)生(不可重復(fù)讀)。

      例如: 
      在事務(wù)1中,Mary 讀取了自己的工資為1000,操作并沒(méi)有完成 :

      con1 = getConnection();  
      select salary from employee empId ="Mary";  
      • 1
      • 2

      在事務(wù)2中,這時(shí)財(cái)務(wù)人員修改了Mary的工資為2000,并提交了事務(wù).

      con2 = getConnection();  
      update employee set salary = 2000;  
      con2.commit();  
      • 1
      • 2
      • 3

      在事務(wù)1中,Mary 再次讀取自己的工資時(shí),工資變?yōu)榱?000

      //con1  
      select salary from employee empId ="Mary";  
      • 1
      • 2

      在一個(gè)事務(wù)中前后兩次讀取的結(jié)果并不致,導(dǎo)致了不可重復(fù)讀。 
      使用ISOLATION_REPEATABLE_READ可以避免這種情況發(fā)生。

      (e)ISOLATION_SERIALIZABLE 這是花費(fèi)最高代價(jià)但是最可靠的事務(wù)隔離級(jí)別。事務(wù)被處理為順序執(zhí)行。除了防止臟讀,不可重復(fù)讀外,還避免了幻像讀。

      目前工資為1000的員工有10人。 
      事務(wù)1,讀取所有工資為1000的員工。

      con1 = getConnection();  
      Select * from employee where salary =1000; 
      • 1
      • 2

      共讀取10條記錄

      這時(shí)另一個(gè)事務(wù)向employee表插入了一條員工記錄,工資也為1000

      con2 = getConnection();  
      Insert into employee(empId,salary) values("Lili",1000);  
      con2.commit();  
      • 1
      • 2
      • 3

      事務(wù)1再次讀取所有工資為1000的員工

      select * from employee where salary =1000;  
      • 1

      共讀取到了11條記錄,這就產(chǎn)生了幻像讀。 
      ISOLATION_SERIALIZABLE能避免這樣的情況發(fā)生。但是這樣也耗費(fèi)了最大的資源。

      getPropagationBehavior()返回事務(wù)的傳播行為,由是否有一個(gè)活動(dòng)的事務(wù)來(lái)決定一個(gè)事務(wù)調(diào)用。

      二。事務(wù)的傳播性

      在TransactionDefinition接口中定義了七個(gè)事務(wù)傳播行為。

      假如我寫(xiě)了兩個(gè)service類(lèi)。名字分別為ServiceA和ServiceB。如下:

      @Service("ServiceA")
      public class ServiceA {
      
          @Resource(name="ServiceB")
          private ServiceB serviceB;
      
          @Transactional(propagation=Propagation.REQUIRED)
          public methodA(){
             //doSomething
             serviceB.methodB(); 
             //doSomething
          }
      }
      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10
      • 11
      • 12
      • 13
      @Service("ServiceB")
      public class ServiceB {
      
          @Transactional(propagation=Propagation.REQUIRED)
          public methodB(){
             //doSomething
          }
      }
      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8

      使用spring聲明式事務(wù),spring使用AOP來(lái)支持聲明式事務(wù),會(huì)根據(jù)事務(wù)屬性,自動(dòng)在方法調(diào)用之前決定是否開(kāi)啟一個(gè)事務(wù),并在方法執(zhí)行之后決定事務(wù)提交或回滾事務(wù)。

      (a)PROPAGATION_REQUIRED:如果存在一個(gè)事務(wù),則支持當(dāng)前事務(wù)。如果沒(méi)有事務(wù)則開(kāi)啟一個(gè)新的事務(wù)。 
      如果單獨(dú)調(diào)用serviceB.methodB方法:

      main {
         serviceB.methodB();
      }
      • 1
      • 2
      • 3

      相當(dāng)于:

      Main{  
        Connection con=null;  
        try{  
            con = getConnection();  
            con.setAutoCommit(false);  
            //方法調(diào)用  
            methodB();  
            //提交事務(wù)  
            con.commit();  
       }Catch(RuntimeException ex){  
          //回滾事務(wù)  
          con.rollback();    
       }finally{  
          //釋放資源  
          closeCon();  
       }  
      }  
      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10
      • 11
      • 12
      • 13
      • 14
      • 15
      • 16
      • 17

      Spring保證在methodB方法中所有的調(diào)用都獲得到一個(gè)相同的連接。在調(diào)用methodB時(shí),沒(méi)有一個(gè)存在的事務(wù),所以獲得一個(gè)新的連接,開(kāi)啟了一個(gè)新的事務(wù)。

      如果單獨(dú)調(diào)用MethodA時(shí),在MethodA內(nèi)又會(huì)調(diào)用MethodB. 
      執(zhí)行效果相當(dāng)于:

      main{  
         Connection con = null;  
         try{  
            con = getConnection();  
            methodA();  
            con.commit();  
         }cathc(RuntimeException ex){  
            con.rollback();  
         }finally{  
            closeCon();  
         }   
      }  
      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10
      • 11
      • 12

      調(diào)用MethodA時(shí),環(huán)境中沒(méi)有事務(wù),所以開(kāi)啟一個(gè)新的事務(wù). 
      當(dāng)在MethodA中調(diào)用MethodB時(shí),環(huán)境中已經(jīng)有了一個(gè)事務(wù),所以methodB就加入當(dāng)前事務(wù)。

      (b)PROPAGATION_SUPPORTS :如果存在一個(gè)事務(wù),支持當(dāng)前事務(wù)。如果沒(méi)有事務(wù),則非事務(wù)的執(zhí)行。但是對(duì)于事務(wù)同步的事務(wù)管理器,PROPAGATION_SUPPORTS與不使用事務(wù)有少許不同。

      //事務(wù)屬性 PROPAGATION_REQUIRED   
      methodA(){  
        serviceB.methodB();  
      }  
      
      //事務(wù)屬性 PROPAGATION_SUPPORTS   
      methodB(){  
        ……  
      }  
      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9

      單純的調(diào)用methodB時(shí),methodB方法是非事務(wù)的執(zhí)行的。 
      當(dāng)調(diào)用methdA時(shí),methodB則加入了methodA的事務(wù)中,事務(wù)地執(zhí)行。

      (c)PROPAGATION_MANDATORY :如果已經(jīng)存在一個(gè)事務(wù),支持當(dāng)前事務(wù)。如果沒(méi)有一個(gè)活動(dòng)的事務(wù),則拋出異常。

      //事務(wù)屬性 PROPAGATION_REQUIRED   
      methodA(){  
        serviceB.methodB();  
      }  
      
      //事務(wù)屬性 PROPAGATION_MANDATORY   
      methodB(){  
        ……  
      }  
      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9

      當(dāng)單獨(dú)調(diào)用methodB時(shí),因?yàn)楫?dāng)前沒(méi)有一個(gè)活動(dòng)的事務(wù),則會(huì)拋出異常 
      throw new IllegalTransactionStateException(“Transaction propagation ‘mandatory’ but no existing transaction found”);

      當(dāng)調(diào)用methodA時(shí),methodB則加入到methodA的事務(wù)中,事務(wù)地執(zhí)行。

      (d)PROPAGATION_REQUIRES_NEW :總是開(kāi)啟一個(gè)新的事務(wù)。如果一個(gè)事務(wù)已經(jīng)存在,則將這個(gè)存在的事務(wù)掛起。

      //事務(wù)屬性 PROPAGATION_REQUIRED   
      methodA(){  
         doSomeThingA();  
         serviceB.methodB();  
         doSomeThingB();  
      }  
      
      //事務(wù)屬性 PROPAGATION_REQUIRES_NEW   
      methodB(){  
        ……  
      }  
      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10
      • 11

      當(dāng)單獨(dú)調(diào)用methodB時(shí),相當(dāng)于把methodb聲明為REQUIRED。開(kāi)啟一個(gè)新的事務(wù),事務(wù)地執(zhí)行。

      當(dāng)調(diào)用methodA時(shí):

      main(){  
        methodA();  
      }  
      • 1
      • 2
      • 3

      情況就大不一樣了,相當(dāng)于下面的效果。

      main(){  
       TransactionManager tm = null;  
       try{  
        //獲得一個(gè)JTA事務(wù)管理器  
         tm = getTransactionManager();  
         tm.begin();//開(kāi)啟一個(gè)新的事務(wù)  
         Transaction ts1 = tm.getTransaction();  
         doSomeThing();  
         tm.suspend();//掛起當(dāng)前事務(wù)  
         try{  
           tm.begin();//重新開(kāi)啟第二個(gè)事務(wù)  
           Transaction ts2 = tm.getTransaction();  
           methodB();  
           ts2.commit();//提交第二個(gè)事務(wù)  
      
         }Catch(RunTimeException ex){  
           ts2.rollback();//回滾第二個(gè)事務(wù)  
         }finally{  
          //釋放資源  
         }  
         //methodB執(zhí)行完后,復(fù)恢第一個(gè)事務(wù)  
         tm.resume(ts1);  
         doSomeThingB();  
         ts1.commit();//提交第一個(gè)事務(wù)  
       }catch(RunTimeException ex){  
        ts1.rollback();//回滾第一個(gè)事務(wù)  
       }finally{  
        //釋放資源  
       }  
      }  
      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10
      • 11
      • 12
      • 13
      • 14
      • 15
      • 16
      • 17
      • 18
      • 19
      • 20
      • 21
      • 22
      • 23
      • 24
      • 25
      • 26
      • 27
      • 28
      • 29
      • 30

      在這里,我把ts1稱(chēng)為外層事務(wù),ts2稱(chēng)為內(nèi)層事務(wù)。從上面的代碼可以看出,ts2與ts1是兩個(gè)獨(dú)立的事務(wù),互不相干。Ts2是否成功并不依賴(lài)于ts1。如果methodA方法在調(diào)用methodB方法后的doSomeThingB方法失敗了,而methodB方法所做的結(jié)果依然被提交。而除了methodB之外的其它代碼導(dǎo)致的結(jié)果卻被回滾了。 
      使用PROPAGATION_REQUIRES_NEW,需要使用JtaTransactionManager作為事務(wù)管理器。

      (e)PROPAGATION_NOT_SUPPORTED: 總是非事務(wù)地執(zhí)行,并掛起任何存在的事務(wù)。

      //事務(wù)屬性 PROPAGATION_REQUIRED   
      methodA(){  
        doSomeThingA();  
        serviceB.methodB();  
        doSomeThingB();  
      }  
      
      //事務(wù)屬性 PROPAGATION_NOT_SUPPORTED   
      methodB(){  
        ……  
      }  
      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10
      • 11

      當(dāng)單獨(dú)調(diào)用methodB時(shí),不啟用任何事務(wù)機(jī)制,非事務(wù)地執(zhí)行。

      當(dāng)調(diào)用methodA時(shí),相當(dāng)于下面的效果

      main(){  
       TransactionManager tm = null;  
       try{  
        //獲得一個(gè)JTA事務(wù)管理器  
         tm = getTransactionManager();  
         tm.begin();//開(kāi)啟一個(gè)新的事務(wù)  
         Transaction ts1 = tm.getTransaction();  
         doSomeThing();  
         tm.suspend();//掛起當(dāng)前事務(wù)  
         methodB();  
         //methodB執(zhí)行完后,復(fù)恢第一個(gè)事務(wù)  
         tm.resume(ts1);  
         doSomeThingB();  
         ts1.commit();//提交第一個(gè)事務(wù)  
       }catch(RunTimeException ex){  
         ts1.rollback();//回滾第一個(gè)事務(wù)  
       }finally{  
        //釋放資源  
       }  
      }  
      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10
      • 11
      • 12
      • 13
      • 14
      • 15
      • 16
      • 17
      • 18
      • 19
      • 20

      使用PROPAGATION_NOT_SUPPORTED,也需要使用JtaTransactionManager作為事務(wù)管理器。

      (f)PROPAGATION_NEVER :總是非事務(wù)地執(zhí)行,如果存在一個(gè)活動(dòng)事務(wù),則拋出異常:

      //事務(wù)屬性 PROPAGATION_REQUIRED   
      methodA(){  
        doSomeThingA();  
        seviceB.methodB();  
        doSomeThingB();  
      }  
      
      //事務(wù)屬性 PROPAGATION_NEVER   
      methodB(){  
        ……  
      }  
      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10
      • 11

      單獨(dú)調(diào)用methodB,則非事務(wù)的執(zhí)行。 
      調(diào)用methodA則會(huì)拋出異常 
      throw new IllegalTransactionStateException( 
      “Transaction propagation ‘never’ but existing transaction found”);

      (g)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類(lèi)。有一些JTA的事務(wù)管理器實(shí)現(xiàn)可能也提供了同樣的功能。

      使用PROPAGATION_NESTED,還需要把PlatformTransactionManager的nestedTransactionAllowed屬性設(shè)為true; 
      而nestedTransactionAllowed屬性值默認(rèn)為false; 
      例如如下:

      <bean id="system.platformTransactionManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager">  
              <property name="sessionFactory" ref="system.sessionFactory"/>  
              <property name="nestedTransactionAllowed" value="true"/>  
          </bean>
      • 1
      • 2
      • 3
      • 4
      //事務(wù)屬性 PROPAGATION_REQUIRED   
      methodA(){  
        doSomeThingA();  
        serviceB.methodB();  
        doSomeThingB();  
      }  
      
      //事務(wù)屬性 PROPAGATION_NESTED  
      methodB(){  
        ……  
      }  
      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10
      • 11

      如果單獨(dú)調(diào)用methodB方法,則按REQUIRED屬性執(zhí)行。

      如果調(diào)用methodA方法,相當(dāng)于下面的效果

      main(){  
      Connection con = null;  
      Savepoint savepoint = null;  
      try{  
        con = getConnection();  
        con.setAutoCommit(false);  
        doSomeThingA(); 
        //創(chuàng)造一個(gè)事務(wù)的保存點(diǎn) 
        savepoint = con2.setSavepoint();  
        try  
            methodB();  
        }catch(RuntimeException ex){  
           con.rollback(savepoint);  
        }  
        finally{  
          //釋放資源  
        }  
      
        doSomeThingB();  
        con.commit();  
      }  
      catch(RuntimeException ex){  
        con.rollback();  
      }  
      finally{  
        //釋放資源  
      }  
      }  
      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10
      • 11
      • 12
      • 13
      • 14
      • 15
      • 16
      • 17
      • 18
      • 19
      • 20
      • 21
      • 22
      • 23
      • 24
      • 25
      • 26
      • 27
      • 28

      當(dāng)methodB方法調(diào)用之前,調(diào)用setSavepoint方法,保存當(dāng)前的狀態(tài)到savepoint。如果methodB方法調(diào)用失敗,則恢復(fù)到之前保存的狀態(tài)。但是需要注意的是,這時(shí)的事務(wù)并沒(méi)有進(jìn)行提交,如果后續(xù)的代碼(doSomeThingB()方法)調(diào)用失敗,則回滾包括methodB方法的所有操作。

      嵌套事務(wù)一個(gè)非常重要的概念就是內(nèi)層事務(wù)依賴(lài)于外層事務(wù)。外層事務(wù)失敗時(shí),會(huì)回滾內(nèi)層事務(wù)所做的動(dòng)作。而內(nèi)層事務(wù)操作失敗并不會(huì)引起外層事務(wù)的回滾。

      PROPAGATION_NESTED 與PROPAGATION_REQUIRES_NEW的區(qū)別:它們非常類(lèi)似,都像一個(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_REQUIRED應(yīng)該是我們首先的事務(wù)傳播行為。它能夠滿足我們大多數(shù)的事務(wù)需求。

      3。事務(wù)的超時(shí)性、回滾和只讀

      超時(shí): 
      @Transactional(timeout=30) //默認(rèn)是30秒

      異常回滾: 
      指定單一異常類(lèi):@Transactional(rollbackFor=RuntimeException.class)

      指定多個(gè)異常類(lèi):@Transactional(rollbackFor={RuntimeException.class, Exception.class}) 
      該屬性用于設(shè)置需要進(jìn)行回滾的異常類(lèi)數(shù)組,當(dāng)方法中拋出指定異常數(shù)組中的異常時(shí),則進(jìn)行事務(wù)回滾。

      正常的情況下也可以回滾:

      TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();

      只讀: 
      @Transactional(readOnly=true) 
      該屬性用于設(shè)置當(dāng)前事務(wù)是否為只讀事務(wù),設(shè)置為true表示只讀,false則表示可讀寫(xiě),默認(rèn)值為false。

      4。單獨(dú)創(chuàng)建事務(wù)點(diǎn)手動(dòng)提交

      1、配置文件 applicationContext.xml:

      <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
              <property name="dataSource" ref="dataSource" />
          </bean>
      • 1
      • 2
      • 3

      2、在需要加事務(wù)的方法上加上(有ApplicationContext 的情況下):

      //這種情況是有ApplicationContext的情況下,即ctx
      DataSourceTransactionManager transactionManager = (DataSourceTransactionManager) ctx
                      .getBean("transactionManager");
          DefaultTransactionDefinition def = new DefaultTransactionDefinition();
          def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW); // 事物隔離級(jí)別,開(kāi)啟新事務(wù),這樣會(huì)比較安全些。
          TransactionStatus status = transactionManager.getTransaction(def); // 獲得事務(wù)狀態(tài)
          try {
              //邏輯代碼,可以寫(xiě)上你的邏輯處理代碼
              transactionManager.commit(status);
          } catch (Exception e) {
              transactionManager.rollback(status);
          }
      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10
      • 11
      • 12

      上面是有ApplicationContext 的情況下。

      3、ApplicationContext 不存在的情況下:

      //可以通過(guò)注解實(shí)現(xiàn)
       @Autowired
          private DataSourceTransactionManager txManager;
         DefaultTransactionDefinition def = new DefaultTransactionDefinition();
         def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);// 事物隔離級(jí)別,開(kāi)啟新事務(wù)
         TransactionStatus status = txManager.getTransaction(def); // 獲得事務(wù)狀態(tài)
      try{
      //邏輯代碼,可以寫(xiě)上你的邏輯處理代碼
      txManager.commit(status);
      }catch(Exception
       e){
      txManager.rollback(status);
      }

       

      轉(zhuǎn)載文章:

      https://blog.csdn.net/whbing1471/article/details/54097574

      posted @ 2019-05-16 11:14  培杰  閱讀(844)  評(píng)論(0)    收藏  舉報(bào)
      主站蜘蛛池模板: 亚洲码亚洲码天堂码三区| 亚洲少妇一区二区三区老| 人妻影音先锋啪啪AV资源| 日韩人妻无码一区二区三区综合部 | 亚洲一二三区精品美妇| 日韩中文字幕免费在线观看| 欧美韩中文精品有码视频在线| 国产目拍亚洲精品二区| 成人乱码一区二区三区四区 | 日韩乱码人妻无码系列中文字幕| 亚洲欧美中文日韩v在线97| 亚洲国产精品毛片在线看| 国产亚洲视频免费播放| av无码精品一区二区乱子| 老色鬼在线精品视频在线观看| 无码天堂亚洲国产AV| 无码av免费毛片一区二区| 亚洲偷自拍另类一区二区| 国产精品日日摸夜夜添夜夜添无码 | 亚洲 日本 欧洲 欧美 视频| 草草浮力影院| 成人中文在线| 国产欧美日韩视频怡春院| 午夜成人无码免费看网站| 国产午夜福利一区二区三区| 老司机精品成人无码av| 久久一日本道色综合久久| 亚洲国产一区二区精品专| 欧美一区内射最近更新| 日韩av一中美av一中文字慕| 极品尤物被啪到呻吟喷水| 无码精品国产va在线观看dvd| 国产成人综合在线观看不卡| 国产亚洲亚洲国产一二区| 国产三级a三级三级| 女同精品女同系列在线观看| 久久亚洲2019中文字幕| 日韩精品有码中文字幕| 中文字幕亚洲男人的天堂| 欧美性猛交xxxx免费看| 久久精产国品一二三产品 |