Springboot编程式事务使用方式详解

环境：springboot2.3.9.RELEASE

怀柔网站建设公司成都创新互联公司,怀柔网站设计制作，有大型网站制作公司丰富经验。已为怀柔上1000家提供企业网站建设服务。企业网站搭建\外贸营销网站建设要多少钱，请找那个售后服务好的怀柔做网站的公司定做！

Spring提供两种编程式事务管理方法：

  1. 使用TransactionTemplate 或 TransactionalOperator
  2. 直接创建TransactionManager的实现

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对象的时候我们可以对事务进行相关的属性配置，通过如下方式。

 
 
 
    
  
  
  
  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 事务事件监听

通过@

TransactionalEventListener注解监听事务的不同阶段的事件信息

 
 
 
    
  
  
  
  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，当前即便没有事务也会触发事件。

TransactionPhase：默认值是事务提交以后;有如下几个取值：

 
 
 
    
  
  
  
  1. public enum TransactionPhase { 
    2. 
  
  
  
  2.   BEFORE_COMMIT, // 事务提交前触发 
    3. 
  
  
  
  3.   AFTER_COMMIT, // 事务提交后触发 
    4. 
  
  
  
  4.   AFTER_ROLLBACK, // 事务回滚触发 
    5. 
  
  
  
  5.   AFTER_COMPLETION // 事务完成后 触发 
    6. 
  
  
  
  6. } 
    7.

注意：@

TransactionalEventListener注解只对声明式事务起作用，对编程式事务无效。仅适用于由PlatformTransactionManager管理的线程绑定事务

示例：

 
 
 
    
  
  
  
  1. // 事件监听 
    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. // 发布事件 
    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.

运行结果：

 
 
 
    
  
  
  
  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.

总结：编程式的事务适合少量的事务操作;比如在一个服务的调用中有大量的计算操作，最后将计算结果进行事务的操作这种情况就适合应用事务编程式的进行事务控制。如果一个操作有很多的事务的操作那声明式的事务方式就更加的合适。

文章标题：Springboot编程式事务使用方式详解
网站地址：http://www.csdahua.cn/qtweb/news12/507512.html

网站建设、网络推广公司-快上网，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 快上网

成都快上网为您推荐相关内容

定制网站知识

同城分类信息

大邑珉田数据中心　　 　广安搬家公司　　 　达州做网站　　 　网络营销推广　　 　成都租用服务器　　 　宜宾做网站　　 　主机租用　　 　腾讯云虚拟主机　　 　成都手机网站建设　　 　成都集团网站建设　　 　成都企业网站建设　　 　成都品牌网站建设　　 　微信公众号开发　　 　app开发　　 　服务器租用　　 　成都服务器托管　　 　买链接　　 　成都网站建设　　 　温江网站建设　　 　广东网站设计