日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務時間：8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
Springboot編程式事務使用方式詳解

環(huán)境：springboot2.3.9.RELEASE

懷柔網(wǎng)站建設公司成都創(chuàng)新互聯(lián)公司,懷柔網(wǎng)站設計制作，有大型網(wǎng)站制作公司豐富經(jīng)驗。已為懷柔上1000家提供企業(yè)網(wǎng)站建設服務。企業(yè)網(wǎng)站搭建\外貿(mào)營銷網(wǎng)站建設要多少錢，請找那個售后服務好的懷柔做網(wǎng)站的公司定做！

Spring提供兩種編程式事務管理方法：

  1. 使用TransactionTemplate 或 TransactionalOperator
  2. 直接創(chuàng)建TransactionManager的實現(xiàn)

Spring官方推薦使用TransactionTemplate方式

準備

 
 
 
    
  
  
  
  1. // 實體類 
    2. 
  
  
  
  2. @Entity 
    3. 
  
  
  
  3. @Table(name = "BC_USERS") 
    4. 
  
  
  
  4. @Data 
    5. 
  
  
  
  5. public class Users{ 
    6. 
  
  
  
  6.     private String username ; 
    7. 
  
  
  
  7.     private String password ; 
    8. 
  
  
  
  8.     private Integer status = 0 ; 
    9. 
  
  
  
  9. } 
    10. 
  
  
  
  10. // DAO 
    11. 
  
  
  
  11. public interface UsersRepository extends JpaRepository { 
    12. 
  
  
  
  12.  
    13. 
  
  
  
  13.   @Modifying 
    14. 
  
  
  
  14.   @Query("update Users u set u.status=?1,u.password='123123' where u.id=?2") 
    15. 
  
  
  
  15.   int updateUsers(Integer status, String id) ; 
    16. 
  
  
  
  16.      
    17. 
  
  
  
  17. } 
    18. 
  
  
  
  18. @Mapper 
    19. 
  
  
  
  19. public interface UsersMapper { 
    20. 
  
  
  
  20.  
    21. 
  
  
  
  21.   int insertUser(Users user) ; 
    22. 
  
  
  
  22.      
    23. 
  
  
  
  23. } 
    24. 
  
  
  
  24. // Mapper.xml 
    25. 
  
  
  
  25.  
    26. 
  
  
  
  26.   insert into bc_users (id, username, password) values (#{id}, #{username}, #{password}) 
    27. 
  
  
  
  27.  
    28.

1 TransactionTemplate

1.1 有返回值的

 
 
 
    
  
  
  
  1. @Service 
    2. 
  
  
  
  2. public class UserService { 
    3. 
  
  
  
  3.      
    4. 
  
  
  
  4.   @Resource 
    5. 
  
  
  
  5.   private TransactionTemplate transactionTemplate ; 
    6. 
  
  
  
  6.   @Resource 
    7. 
  
  
  
  7.   private UsersRepository usersRepository ; 
    8. 
  
  
  
  8.      
    9. 
  
  
  
  9.   public Integer saveUsers(Users users) { 
    10. 
  
  
  
  10.     this.transactionTemplate.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW); 
    11. 
  
  
  
  11.     Integer result = transactionTemplate.execute(new TransactionCallback() { 
    12. 
  
  
  
  12.       @Override 
    13. 
  
  
  
  13.       public Integer doInTransaction(TransactionStatus status) { 
    14. 
  
  
  
  14.         return usersMapper.insertUser(users) ; 
    15. 
  
  
  
  15.       } 
    16. 
  
  
  
  16.     }) ; 
    17. 
  
  
  
  17.     return result ; 
    18. 
  
  
  
  18.     } 
    19. 
  
  
  
  19.      
    20. 
  
  
  
  20. } 
    21.

1.2 無返回值的

當沒有返回值時可以使用

TransactionCallbackWithoutResult

 
 
 
    
  
  
  
  1. public void saveUsers(Users users) { 
    2. 
  
  
  
  2.   transactionTemplate.execute(new TransactionCallbackWithoutResult() { 
    3. 
  
  
  
  3.     @Override 
    4. 
  
  
  
  4.     protected void doInTransactionWithoutResult(TransactionStatus status) { 
    5. 
  
  
  
  5.       usersMapper.insertUser(users) ; 
    6. 
  
  
  
  6.     } 
    7. 
  
  
  
  7.   }) ; 
    8. 
  
  
  
  8. } 
    9.

1.3 事務回滾

事務的回滾通過

TransactionStatus.setRollbackOnly方法

 
 
 
    
  
  
  
  1. public Users saveUser(Users users) { 
    2. 
  
  
  
  2.   return transactionTemplate.execute(new TransactionCallback() { 
    3. 
  
  
  
  3.     @Override 
    4. 
  
  
  
  4.     public Users doInTransaction(TransactionStatus status) { 
    5. 
  
  
  
  5.       try { 
    6. 
  
  
  
  6.         return usersMapper.insertUser(users) ; 
    7. 
  
  
  
  7.       } catch (Exception e) { 
    8. 
  
  
  
  8.         status.setRollbackOnly() ; 
    9. 
  
  
  
  9.       } 
    10. 
  
  
  
  10.       return null ; 
    11. 
  
  
  
  11.     } 
    12. 
  
  
  
  12.   }) ; 
    13. 
  
  
  
  13. } 
    14.

1.4 配置事務屬性

在實例化TransactionTemplate對象的時候我們可以對事務進行相關(guān)的屬性配置，通過如下方式。

 
 
 
    
  
  
  
  1. private TransactionTemplate transactionTemplate ; 
    2. 
  
  
  
  2.      
    3. 
  
  
  
  3. public UserService(PlatformTransactionManager transactionManager) { 
    4. 
  
  
  
  4.   this.transactionTemplate = new TransactionTemplate(transactionManager) ; 
    5. 
  
  
  
  5.   this.transactionTemplate.setPropagationBehavior(TransactionDefinition.PROPAGATION_NOT_SUPPORTED); 
    6. 
  
  
  
  6.   this.transactionTemplate.setTimeout(30); //seconds 
    7. 
  
  
  
  7. } 
    8.

測試代碼

 
 
 
    
  
  
  
  1. public Integer updateUsers(Integer statusValue, String id) { 
    2. 
  
  
  
  2.   return transactionTemplate.execute(new TransactionCallback() { 
    3. 
  
  
  
  3.     @Override 
    4. 
  
  
  
  4.     public Integer doInTransaction(TransactionStatus status) { 
    5. 
  
  
  
  5.       return usersRepository.updateUsers(statusValue, id) ; 
    6. 
  
  
  
  6.     } 
    7. 
  
  
  
  7.   }) ; 
    8. 
  
  
  
  8. } 
    9. 
  
  
  
  9. @Modifying 
    10. 
  
  
  
  10. @Query("update Users u set u.status=?1 where u.id=?2") 
    11. 
  
  
  
  11. int updateUsers(Integer status, String id) ; 
    12.

由于這里事務傳播屬性設置的NOT_SUPPORTED.所以程序會報錯誤

 
 
 
    
  
  
  
  1. org.springframework.dao.InvalidDataAccessApiUsageException: Executing an update/delete query; nested exception is javax.persistence.TransactionRequiredException: Executing an update/delete query 
    2. 
  
  
  
  2.     at org.springframework.orm.jpa.EntityManagerFactoryUtils.convertJpaAccessExceptionIfPossible(EntityManagerFactoryUtils.java:403) 
    3. 
  
  
  
  3.     at org.springframework.orm.jpa.vendor.HibernateJpaDialect.translateExceptionIfPossible(HibernateJpaDialect.java:257) 
    4. 
  
  
  
  4.     at org.springframework.orm.jpa.AbstractEntityManagerFactoryBean.translateExceptionIfPossible(AbstractEntityManagerFactoryBean.java:531) 
    5.

2 TransactionalOperator

TransactionalOperator適用于反應式編程，這里不做介紹。

3 TransactionManager

使用TransactionManager管理事務也有兩種

PlatformTransactionManager，

ReactiveTransactionManager

ReactiveTransactionManager適用于反應式編程，這里不做介紹。

3.1 PlatformTransactionManager

在程序中可以使用

PlatformTransactionManager來控制事務的提交與回滾

示例：

 
 
 
    
  
  
  
  1. private PlatformTransactionManager transactionManager ; 
    2. 
  
  
  
  2. private DefaultTransactionDefinition definition ; 
    3. 
  
  
  
  3. private TransactionStatus status ; 
    4. 
  
  
  
  4. @Resource 
    5. 
  
  
  
  5. private UsersRepository usersRepository ; 
    6. 
  
  
  
  6.  
    7. 
  
  
  
  7. public UserService3(PlatformTransactionManager transactionManager) { 
    8. 
  
  
  
  8.   this.transactionManager = transactionManager ; 
    9. 
  
  
  
  9.   definition = new DefaultTransactionDefinition() ; 
    10. 
  
  
  
  10.   definition.setName("pgName") ; 
    11. 
  
  
  
  11.   definition.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED) ; 
    12. 
  
  
  
  12. } 
    13. 
  
  
  
  13.      
    14. 
  
  
  
  14. public Integer saveUsers(Users users) { 
    15. 
  
  
  
  15.   TransactionStatus status = this.transactionManager.getTransaction(definition) ; 
    16. 
  
  
  
  16.   Integer result = null ; 
    17. 
  
  
  
  17.   try { 
    18. 
  
  
  
  18.     result = usersMapper.insertUser(users) ; 
    19. 
  
  
  
  19.   } catch (Exception e) { 
    20. 
  
  
  
  20.     transactionManager.rollback(status) ; 
    21. 
  
  
  
  21.     throw e ; 
    22. 
  
  
  
  22.   } 
    23. 
  
  
  
  23.   transactionManager.commit(status) ; 
    24. 
  
  
  
  24.   publisher.publishEvent(new UsersEvent(users)); 
    25. 
  
  
  
  25.   return result ;        
    26. 
  
  
  
  26. } 
    27.

4 事務事件監(jiān)聽

通過@

TransactionalEventListener注解監(jiān)聽事務的不同階段的事件信息

 
 
 
    
  
  
  
  1. public @interface TransactionalEventListener { 
    2. 
  
  
  
  2.   TransactionPhase phase() default TransactionPhase.AFTER_COMMIT; 
    3. 
  
  
  
  3.   boolean fallbackExecution() default false; 
    4. 
  
  
  
  4.   @AliasFor(annotation = EventListener.class, attribute = "classes") 
    5. 
  
  
  
  5.   Class[] value() default {}; 
    6. 
  
  
  
  6.   @AliasFor(annotation = EventListener.class, attribute = "classes") 
    7. 
  
  
  
  7.   Class[] classes() default {}; 
    8. 
  
  
  
  8.   String condition() default ""; 
    9. 
  
  
  
  9. } 
    10.

fallbackExecution: 默認值false;如果設置為true，當前即便沒有事務也會觸發(fā)事件。

TransactionPhase：默認值是事務提交以后;有如下幾個取值：

 
 
 
    
  
  
  
  1. public enum TransactionPhase { 
    2. 
  
  
  
  2.   BEFORE_COMMIT, // 事務提交前觸發(fā) 
    3. 
  
  
  
  3.   AFTER_COMMIT, // 事務提交后觸發(fā) 
    4. 
  
  
  
  4.   AFTER_ROLLBACK, // 事務回滾觸發(fā) 
    5. 
  
  
  
  5.   AFTER_COMPLETION // 事務完成后 觸發(fā) 
    6. 
  
  
  
  6. } 
    7.

注意：@

TransactionalEventListener注解只對聲明式事務起作用，對編程式事務無效。僅適用于由PlatformTransactionManager管理的線程綁定事務

示例：

 
 
 
    
  
  
  
  1. // 事件監(jiān)聽 
    2. 
  
  
  
  2. @Component 
    3. 
  
  
  
  3. public class TxListenerComponent { 
    4. 
  
  
  
  4.   @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT) 
    5. 
  
  
  
  5.   public void handleUsersAfterCommit(UsersEvent usersEvent) { 
    6. 
  
  
  
  6.     Users user = (Users) usersEvent.getSource() ; 
    7. 
  
  
  
  7.     System.out.println("AfterCommit收到事件通知：" + user.getPassword()) ; 
    8. 
  
  
  
  8.   } 
    9. 
  
  
  
  9.   @TransactionalEventListener(phase = TransactionPhase.AFTER_COMPLETION) 
    10. 
  
  
  
  10.   public void handleUsersAfterCompletion(UsersEvent usersEvent) { 
    11. 
  
  
  
  11.     Users user = (Users) usersEvent.getSource() ; 
    12. 
  
  
  
  12.     System.out.println("AfterCompletion收到事件通知：" + user.getPassword()) ; 
    13. 
  
  
  
  13.   } 
    14. 
  
  
  
  14.  
    15. 
  
  
  
  15.   @TransactionalEventListener(phase = TransactionPhase.AFTER_ROLLBACK) 
    16. 
  
  
  
  16.   public void handleUsersAfterRollback(UsersEvent usersEvent) { 
    17. 
  
  
  
  17.     Users user = (Users) usersEvent.getSource() ; 
    18. 
  
  
  
  18.     System.out.println("AfterRollback收到事件通知：" + user.getPassword()) ; 
    19. 
  
  
  
  19.   } 
    20. 
  
  
  
  20.  
    21. 
  
  
  
  21.   @TransactionalEventListener(phase = TransactionPhase.BEFORE_COMMIT) 
    22. 
  
  
  
  22.   public void handleUsersBeforeCommit(UsersEvent usersEvent) { 
    23. 
  
  
  
  23.     Users user = (Users) usersEvent.getSource() ; 
    24. 
  
  
  
  24.     System.out.println("BeforeCommit收到事件通知：" + user.getPassword()) ; 
    25. 
  
  
  
  25.   } 
    26. 
  
  
  
  26. } 
    27. 
  
  
  
  27. // 發(fā)布事件 
    28. 
  
  
  
  28. @Resource 
    29. 
  
  
  
  29. private ApplicationEventPublisher publisher ; 
    30. 
  
  
  
  30. @Resource 
    31. 
  
  
  
  31. private UsersMapper usersMapper ; 
    32. 
  
  
  
  32.  
    33. 
  
  
  
  33. public Integer saveUsers(Users users) { 
    34. 
  
  
  
  34.   Integer result = transactionTemplate.execute(new TransactionCallback() { 
    35. 
  
  
  
  35.     @Override 
    36. 
  
  
  
  36.     public Integer doInTransaction(TransactionStatus status) { 
    37. 
  
  
  
  37.       return usersMapper.insertUser(users) ; 
    38. 
  
  
  
  38.     } 
    39. 
  
  
  
  39.   }) ; 
    40. 
  
  
  
  40.   publisher.publishEvent(new UsersEvent(users)); 
    41. 
  
  
  
  41.   return result ; 
    42. 
  
  
  
  42. } 
    43.

運行結(jié)果：

 
 
 
    
  
  
  
  1. 2021-06-17 14:02:56.830 DEBUG 10000 --- [nio-8081-exec-1] com.pack.mapper.UsersMapper.insertUser   : ==>  Preparing: insert into bc_users (id, username, password) values (?, ?, ?) 
    2. 
  
  
  
  2. 2021-06-17 14:02:56.840 DEBUG 10000 --- [nio-8081-exec-1] com.pack.mapper.UsersMapper.insertUser   : ==> Parameters: mmmmm(String), mmmmm(String), mmmmm(String) 
    3. 
  
  
  
  3. 2021-06-17 14:02:56.842 DEBUG 10000 --- [nio-8081-exec-1] com.pack.mapper.UsersMapper.insertUser   : <==    Updates: 1 
    4. 
  
  
  
  4. BeforeCommit收到事件通知：mmmmm 
    5. 
  
  
  
  5. AfterCommit收到事件通知：mmmmm 
    6. 
  
  
  
  6. AfterCompletion收到事件通知：mmmmm 
    7.

總結(jié)：編程式的事務適合少量的事務操作;比如在一個服務的調(diào)用中有大量的計算操作，最后將計算結(jié)果進行事務的操作這種情況就適合應用事務編程式的進行事務控制。如果一個操作有很多的事務的操作那聲明式的事務方式就更加的合適。


網(wǎng)站欄目：Springboot編程式事務使用方式詳解
轉(zhuǎn)載源于：http://www.5511xx.com/article/cohoiii.html