<rt id="bn8ez"></rt>
<label id="bn8ez"></label>
  • 

    • <span id="bn8ez"></span>
    

    <label id="bn8ez"><meter id="bn8ez"></meter></label>
    

    
    

    




    







												


        

    
	

    
	
    
		
    
			
				
    hk2000c技術專欄
    
				
    技術源于哲學，哲學來源于生活

關心生活，關注健康，關心他人

    
			    		
		
    
	
    

    

    
	
    
		
    
			
 
BlogJava ::
首頁 ::
新隨筆 ::
聯系 ::
聚合
 ::
管理 ::


			
			
				

    
	
    
		
    
			
			
			
				 
				111 
				隨筆 ::
				1 文章
				::
				28 評論
				::
				0 Trackbacks
			
		
    
	
    

    

			    		
		
    
	
    

    


    


    
	
					

    
	
	
	
    
		
    Spring聲明式事務讓我們從復雜的事務處理中得到解脫。使得我們再也無需要去處理獲得連接、關閉連接、事務提交和回滾等這些操作。再也無需要我們在與事務相關的方法中處理大量的try…catch…finally代碼。 
    
我們在使用Spring聲明式事務時，有一個非常重要的概念就是事務屬性。事務屬性通常由事務的傳播行為，事務的隔離級別，事務的超時值和事務只讀標志組成。我們在進行事務劃分時，需要進行事務定義，也就是配置事務的屬性。 
    
Spring在TransactionDefinition接口中定義這些屬性,以供PlatfromTransactionManager使用, PlatfromTransactionManager是spring事務管理的核心接口。 
    

    代碼
    

    

    

    

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

    

    

    


     
    

    getTimeout()方法，它返回事務必須在多少秒內完成。 
    
isReadOnly(),事務是否只讀，事務管理器能夠根據這個返回值進行優化，確保事務是只讀的。 
    
getIsolationLevel()方法返回事務的隔離級別，事務管理器根據它來控制另外一個事務可以看到本事務內的哪些數據。
    

    在TransactionDefinition接口中定義了五個不同的事務隔離級別 
    
ISOLATION_DEFAULT 這是一個PlatfromTransactionManager默認的隔離級別，使用數據庫默認的事務隔離級別.另外四個與JDBC的隔離級別相對應 
    
ISOLATION_READ_UNCOMMITTED 這是事務最低的隔離級別，它充許別外一個事務可以看到這個事務未提交的數據。這種隔離級別會產生臟讀，不可重復讀和幻像讀。 
    
例如: 
    
Mary的原工資為1000,財務人員將Mary的工資改為了8000，但未提交事務 
    

    代碼
    

    

    

    

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

    

    

    

    
與此同時，Mary正在讀取自己的工資 
    

    代碼
    

    

    

    

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

    

    

    


     
    

    Mary發現自己的工資變為了8000，歡天喜地！ 
    
而財務發現操作有誤，而回滾了事務,Mary的工資又變為了1000 
    

    代碼
    

    

    

    

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

    

    

    

    
像這樣,Mary記取的工資數8000是一個臟數據。

     
    

    ISOLATION_READ_COMMITTED 保證一個事務修改的數據提交后才能被另外一個事務讀取。另外一個事務不能讀取該事務未提交的數據。這種事務隔離級別可以避免臟讀出現，但是可能會出現不可重復讀和幻像讀。
    

    ISOLATION_REPEATABLE_READ 這種事務隔離級別可以防止臟讀，不可重復讀。但是可能出現幻像讀。它除了保證一個事務不能讀取另一個事務未提交的數據外，還保證了避免下面的情況產生(不可重復讀)。
    

    在事務1中，Mary 讀取了自己的工資為1000,操作并沒有完成 
    

    代碼
    

    

    

    

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

    

    

    


     
    

    在事務2中，這時財務人員修改了Mary的工資為2000,并提交了事務. 
    

    代碼
    

    

    

    

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

    

    

    


     
    

    在事務1中，Mary 再次讀取自己的工資時，工資變為了2000 
    

    代碼
    

    

    

    

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

    

    

    


     
    

    在一個事務中前后兩次讀取的結果并不致，導致了不可重復讀。 
    
使用ISOLATION_REPEATABLE_READ可以避免這種情況發生。
    

    ISOLATION_SERIALIZABLE 這是花費最高代價但是最可靠的事務隔離級別。事務被處理為順序執行。除了防止臟讀，不可重復讀外，還避免了幻像讀。
    

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

    代碼
    

    

    

    

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

    

    

    
共讀取10條記錄

     
    

    這時另一個事務向employee表插入了一條員工記錄，工資也為1000 
    

    代碼
    

    

    

    

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

    

    

    


     
    

    事務1再次讀取所有工資為1000的員工 
    

    代碼
    

    

    

    

      
    
    1. //con1   
      2. 
    
    2. select * from employee where salary =1000;  
      3. 

    

    

    


     
    

    共讀取到了11條記錄，這就產生了幻像讀。 
    
ISOLATION_SERIALIZABLE能避免這樣的情況發生。但是這樣也耗費了最大的資源。
    

    getPropagationBehavior()返回事務的傳播行為，由是否有一個活動的事務來決定一個事務調用。
    

    在TransactionDefinition接口中定義了七個事務傳播行為。
    

    PROPAGATION_REQUIRED 如果存在一個事務，則支持當前事務。如果沒有事務則開啟一個新的事務。
    

    

    代碼
    

    

    

    

      
    
    1. //事務屬性 PROPAGATION_REQUIRED   
      2. 
    
    2. methodA{   
      3. 
    
    3. ……   
      4. 
    
    4. methodB();   
      5. 
    
    5. ……   
      6. 
    
    6. }   
      7. 
    
    7.   
      8. 
    
    8. //事務屬性 PROPAGATION_REQUIRED   
      9. 
    
    9. methodB{   
      10. 
    
    10.    ……   
      11. 
    
    11. }  
      12. 

    

    

    

    
使用spring聲明式事務，spring使用AOP來支持聲明式事務，會根據事務屬性，自動在方法調用之前決定是否開啟一個事務，并在方法執行之后決定事務提交或回滾事務。

     
    

    單獨調用methodB方法 
    

    代碼
    

    

    

      
    
    1. main{   
      2. 
    
    2.   metodB();   
      3. 
    
    3. }  
      4. 

    

    

    

    
相當于 
    

    代碼
    

    

    

    

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

    

    

    

    
Spring保證在methodB方法中所有的調用都獲得到一個相同的連接。在調用methodB時，沒有一個存在的事務，所以獲得一個新的連接，開啟了一個新的事務。

     
    

    單獨調用MethodA時，在MethodA內又會調用MethodB.
    

    執行效果相當于 
    

    代碼
    

    

    

    

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

    

    

    

    
調用MethodA時，環境中沒有事務，所以開啟一個新的事務. 
    
當在MethodA中調用MethodB時，環境中已經有了一個事務，所以methodB就加入當前事務。

     
    

    PROPAGATION_SUPPORTS 如果存在一個事務，支持當前事務。如果沒有事務，則非事務的執行。但是對于事務同步的事務管理器，PROPAGATION_SUPPORTS與不使用事務有少許不同。
    

    

    代碼
    

    

    

    

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

    

    

    

    
單純的調用methodB時，methodB方法是非事務的執行的。 
    
當調用methdA時,methodB則加入了methodA的事務中,事務地執行。

     
    

    PROPAGATION_MANDATORY 如果已經存在一個事務，支持當前事務。如果沒有一個活動的事務，則拋出異常。
    

    

    代碼
    

    

    

    

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

    

    

    

    
當單獨調用methodB時，因為當前沒有一個活動的事務，則會拋出異常 
    
throw new IllegalTransactionStateException("Transaction propagation 'mandatory' but no existing transaction found");

     
    

    當調用methodA時，methodB則加入到methodA的事務中，事務地執行。
    

    PROPAGATION_REQUIRES_NEW 總是開啟一個新的事務。如果一個事務已經存在，則將這個存在的事務掛起。
    

    

    代碼
    

    

    

    

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

    

    

    

    
當單獨調用methodB時，相當于把methodb聲明為REQUIRED。開啟一個新的事務，事務地執行。

     
    

    當調用methodA時 
    

    代碼
    

    

    

      
    
    1. main(){   
      2. 
    
    2.   methodA();   
      3. 
    
    3. }  
      4. 

    

    

    
情況有些大不一樣.相當于下面的效果。 
    

    代碼
    

    

    

    

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

    

    

    

    
在這里，我把ts1稱為外層事務，ts2稱為內層事務。從上面的代碼可以看出，ts2與ts1是兩個獨立的事務，互不相干。Ts2是否成功并不依賴于ts1。如果methodA方法在調用methodB方法后的doSomeThingB方法失敗了，而methodB方法所做的結果依然被提交。而除了methodB之外的其它代碼導致的結果卻被回滾了。 
    
使用PROPAGATION_REQUIRES_NEW,需要使用JtaTransactionManager作為事務管理器。

     
    

    PROPAGATION_NOT_SUPPORTED 總是非事務地執行，并掛起任何存在的事務。
    

    

    代碼
    

    

    

    

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

    

    

    

    
當單獨調用methodB時，不啟用任何事務機制，非事務地執行。 
    
當調用methodA時，相當于下面的效果

     
    

    

    代碼
    

    

    

    

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

    

    

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

     
    

    PROPAGATION_NEVER 總是非事務地執行，如果存在一個活動事務，則拋出異常
    

    

    代碼
    

    

    

    

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

    

    

    
單獨調用methodB，則非事務的執行。 
    
調用methodA則會拋出異常 
    
throw new IllegalTransactionStateException( 
    
"Transaction propagation 'never' but existing transaction found");

     
    

    PROPAGATION_NESTED如果一個活動的事務存在，則運行在一個嵌套的事務中. 如果沒有活動事務, 則按TransactionDefinition.PROPAGATION_REQUIRED 屬性執行
    

    這是一個嵌套事務,使用JDBC 3.0驅動時,僅僅支持DataSourceTransactionManager作為事務管理器。需要JDBC 驅動的java.sql.Savepoint類。有一些JTA的事務管理器實現可能也提供了同樣的功能。
    

    使用PROPAGATION_NESTED，還需要把PlatformTransactionManager的nestedTransactionAllowed屬性設為true; 
    
而nestedTransactionAllowed屬性值默認為false; 
    

    代碼
    

    

    

    

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

    

    

    

    
如果單獨調用methodB方法，則按REQUIRED屬性執行。

     
    

    如果調用methodA方法，相當于下面的效果 
    

    代碼
    

    

    

    

      
    
    1. main(){   
      2. 
    
    2. Connection con = null;   
      3. 
    
    3. Savepoint savepoint = null;   
      4. 
    
    4. try{   
      5. 
    
    5.   con = getConnection();   
      6. 
    
    6.   con.setAutoCommit(false);   
      7. 
    
    7.   doSomeThingA();   
      8. 
    
    8.   savepoint = con2.setSavepoint();   
      9. 
    
    9.   try  
      10. 
    
    10.       methodB();   
      11. 
    
    11.   }catch(RuntimeException ex){   
      12. 
    
    12.      con.rollback(savepoint);   
      13. 
    
    13.   }   
      14. 
    
    14.   finally{   
      15. 
    
    15.     //釋放資源   
      16. 
    
    16.   }   
      17. 
    
    17.   
      18. 
    
    18.   doSomeThingB();   
      19. 
    
    19.   con.commit();   
      20. 
    
    20. }   
      21. 
    
    21. catch(RuntimeException ex){   
      22. 
    
    22.   con.rollback();   
      23. 
    
    23. }   
      24. 
    
    24. finally{   
      25. 
    
    25.   //釋放資源   
      26. 
    
    26. }   
      27. 
    
    27. }  
      28. 

    

    

    
當methodB方法調用之前，調用setSavepoint方法，保存當前的狀態到savepoint。如果methodB方法調用失敗，則恢復到之前保存的狀態。但是需要注意的是，這時的事務并沒有進行提交，如果后續的代碼(doSomeThingB()方法)調用失敗，則回滾包括methodB方法的所有操作。

     
    

    嵌套事務一個非常重要的概念就是內層事務依賴于外層事務。外層事務失敗時，會回滾內層事務所做的動作。而內層事務操作失敗并不會引起外層事務的回滾。
    

    PROPAGATION_NESTED 與PROPAGATION_REQUIRES_NEW的區別:它們非常類似,都像一個嵌套事務，如果不存在一個活動的事務，都會開啟一個新的事務。使用PROPAGATION_REQUIRES_NEW時，內層事務與外層事務就像兩個獨立的事務一樣，一旦內層事務進行了提交后，外層事務不能對其進行回滾。兩個事務互不影響。兩個事務不是一個真正的嵌套事務。同時它需要JTA事務管理器的支持。 
    
使用PROPAGATION_NESTED時，外層事務的回滾可以引起內層事務的回滾。而內層事務的異常并不會導致外層事務的回滾，它是一個真正的嵌套事務。DataSourceTransactionManager使用savepoint支持PROPAGATION_NESTED時，需要JDBC 3.0以上驅動及1.4以上的JDK版本支持。其它的JTA TrasactionManager實現可能有不同的支持方式。
    

    PROPAGATION_REQUIRED應該是我們首先的事務傳播行為。它能夠滿足我們大多數的事務需求。
    

	
    
	
	
    
		posted on 2007-11-01 16:13 hk2000c 閱讀(292) 評論(0)  編輯  收藏  所屬分類: CMS項目開發 
	
    

    







    
	    
    




    








    

				

    




    







    
        
	



主站蜘蛛池模板：
日韩免费观看一级毛片看看|
黄网站免费在线观看|
0588影视手机免费看片|
久久精品国产亚洲麻豆|
99久久免费国产精精品|
亚洲?V无码乱码国产精品|
精品国产亚洲一区二区三区在线观看|
中字幕视频在线永久在线观看免费|
亚洲毛片在线观看|
91制片厂制作传媒免费版樱花|
亚洲av午夜成人片精品网站|
热99RE久久精品这里都是精品免费
|
中字幕视频在线永久在线观看免费|
亚洲综合区图片小说区|
亚洲一区二区三区免费在线观看|
亚洲黄色在线观看视频|
美女被cao免费看在线看网站|
亚洲13又紧又嫩又水多|
在线中文高清资源免费观看|
日本亚洲欧美色视频在线播放|
手机看片久久国产免费|
四虎成人精品国产永久免费无码|
国产成人亚洲综合无码|
99在线免费观看视频|
亚洲AV永久纯肉无码精品动漫|
99免费在线观看视频|
亚洲另类精品xxxx人妖|
无码中文字幕av免费放|
国产精品亚洲а∨天堂2021|
亚洲国产成人精品无码久久久久久综合|
jizz在线免费观看|
亚洲一区二区三区日本久久九|
久久www免费人成看片|
亚洲精品无码久久久久久|
亚洲精品99久久久久中文字幕|
特级做A爰片毛片免费看无码
|
中国一级特黄高清免费的大片中国一级黄色片
|
亚洲综合区小说区激情区|
免费人成毛片动漫在线播放|
www.亚洲日本|
久久久久亚洲AV综合波多野结衣
|