springboot@Transactional事务多数据源的问题

骑猪看日落 2022-11-26 08:58 189阅读 0赞

### springboot事务不生效的几种解决方案 ###

*  原文：[https://blog.csdn.net/weixin\_44138309/article/details/100561860?utm\_medium=distribute.pc\_relevant.none-task-blog-BlogCommendFromMachineLearnPai2-3.channel\_param&depth\_1-utm\_source=distribute.pc\_relevant.none-task-blog-BlogCommendFromMachineLearnPai2-3.channel\_param][https_blog.csdn.net_weixin_44138309_article_details_100561860_utm_medium_distribute.pc_relevant.none-task-blog-BlogCommendFromMachineLearnPai2-3.channel_param_depth_1-utm_source_distribute.pc_relevant.none-task-blog-BlogCommendFromMachineLearnPai2-3.channel_param]

**最近在业务中遇到了很奇怪的场景,在加上** **@Transactional注解后,插入2条数据,如果第二条出异常了,第一条不会回滚,排查了很久,上网也找资料看了很久,问题得以解决,总结了事务不生效的几点可能的原因:**

*  mysql的MyISAM引擎不支持回滚,如果需要自动回滚事务,需要将mysql的引擎设置成InnoDB;
 *  在业务中抛出异常时,本应该被事务管理器捕获的异常,被手动catch处理了,或者事务结果未满足具体业务需求的,如果需要手动catch异常做业务处理,需要在catch里手动回滚事务TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(),或者在catch中主动抛出异常throw new RuntimeException();.
 *  默认的spring事务只会捕获RuntimeException,如果是非运行时异常也需要进行事务回滚的话,可以在@Transactional注解中加上rollbackfor = Exception.class属性;
 *  项目中没有配置事务管理器(大坑!我遇到的就是这个),需要在配置类或者配置文件中配置,以本人的配置类为例,因为项目是多数据源的,所以要区别配置不同数据源的事务管理器.

*  数据源一:
 *  @Bean(name = "detDataSource")  
    public DataSource getDataSource() \{  
    return createDataSource();  
    \}  
    @Bean(name = "detTransactionManager")  
    public PlatformTransactionManager txManager(@Qualifier("detDataSource") DataSource dataSource) \{  
    return new DataSourceTransactionManager(dataSource);  
    \}  
    
 *  数据源二:
 *  @Primary  
    @Bean(name = "shardDataSource")  
    public DataSource getDataSource() \{  
    return buildDataSource();  
    \}  
    @Bean(name = "shardTransactionManager")  
    public PlatformTransactionManager txManager(@Qualifier("shardDataSource") DataSource dataSource) \{  
    return new DataSourceTransactionManager(dataSource);  
    \}  
    
 *  *可以看到,两个事务管理器配置了不同的beanName,接下来只需要* *在需要事务控制的位置加上该事务管理器的name就可以完美解决啦!*
 *  *@Override  
    @Transactional(value = "detTransactionManager",rollbackFor = Exception.class)  
    public int updateOrInsert(BaseRequest<BankTemplateDto> param) \{*   
    
 *  原文：[https://blog.csdn.net/weixin\_44138309/article/details/100561860?utm\_medium=distribute.pc\_relevant.none-task-blog-BlogCommendFromMachineLearnPai2-3.channel\_param&depth\_1-utm\_source=distribute.pc\_relevant.none-task-blog-BlogCommendFromMachineLearnPai2-3.channel\_param][https_blog.csdn.net_weixin_44138309_article_details_100561860_utm_medium_distribute.pc_relevant.none-task-blog-BlogCommendFromMachineLearnPai2-3.channel_param_depth_1-utm_source_distribute.pc_relevant.none-task-blog-BlogCommendFromMachineLearnPai2-3.channel_param]

[https_blog.csdn.net_weixin_44138309_article_details_100561860_utm_medium_distribute.pc_relevant.none-task-blog-BlogCommendFromMachineLearnPai2-3.channel_param_depth_1-utm_source_distribute.pc_relevant.none-task-blog-BlogCommendFromMachineLearnPai2-3.channel_param]: https://blog.csdn.net/weixin_44138309/article/details/100561860?utm_medium=distribute.pc_relevant.none-task-blog-BlogCommendFromMachineLearnPai2-3.channel_param&depth_1-utm_source=distribute.pc_relevant.none-task-blog-BlogCommendFromMachineLearnPai2-3.channel_param