如何解决spring声明式事务@Transactional不回滚的多种情况问题

发布时间：2021-11-18 13:06:16 作者：小新
来源：亿速云阅读：220

这篇文章给大家分享的是有关如何解决spring声明式事务@Transactional不回滚的多种情况问题的内容。小编觉得挺实用的，因此分享给大家做个参考，一起跟随小编过来看看吧。

一、 spring 事务原理

一、Spring事务原理

在使用JDBC事务操作数据库时，流程如下：

//获取连接 
1.Connection con = DriverManager.getConnection()
//开启事务
2.con.setAutoCommit(true/false);
3.执行CRUD
//提交事务/回滚事务 
4. con.commit() / con.rollback();
//关闭连接
5. conn.close();

Spring本身并不提供事务，而是对JDBC事务通过AOP做了封装，隐藏了2和4的操作，简化了JDBC的应用。

spring对JDBC事务的封装，是通过AOP动态代理来实现的，在调用目标方法(也就是第3步)前后会通过代理类来执行事务的开启、提交或者回滚操作。
spring事务使用的两个不可忽略点:

注意关键词 “动态代理”，这意味着要生成一个代理类，那么我们就不能在一个类内直接调用事务方法，否则无法代理，而且该事务方法必须是public，如果定义成 protected、private 或者默认可见性,则无法调用!

问题一、@Transactional 应该加到什么地方，如果加到Controller会回滚吗？

@Transactional 最好加到service层，加到Controller层也是生效的，但是为了规范起见，还是加到service层上。

下载代码并启动难项目进行验证：主要代码如下：
Controller层代码如下：

 @Autowired
    private TransactionalService transactionalService;

    @Autowired
    private UserDao userDao;

    @Autowired
    private JwtUserDao jwtUserDao;

    /**
     * 测试@Transactional 注解加到service层事务是否回滚
     */
    @RequestMapping("/tx")
    public void serviceTX(){
        transactionalService.controllerTX();
    }
    /**
     * 测试@Transactional 注解加到Controller层事务是否回滚
     */
    @Transactional(rollbackFor = Exception.class)
    @RequestMapping("/ctx2")
    public void cTX2(){
        userDao.update();
        System.out.println(2/0);
        jwtUserDao.update();
    }

 /**
     * 测试@Transactional 注解加到Controller层事务是否回滚
     * 这里在Controller层为了方便直接调用了dao层，在实际开发中dao层即可在Controller层调用也可以在service层调用，
     * 比如service层只是直接调用dao层一个方法，此外没有任何操作，那么这时候完全不用写service层的方法，直接在Controller调用dao层即可，
     * 当然如果公司有规范，必须严格按照mvc的模式进行开发，则另说
     */
    @Transactional(rollbackFor = Exception.class)
    @RequestMapping("/ctx2")
    public void cTX2(){
        userDao.update();
         //手动抛出一个RuntimeException
        System.out.println(2/0);
        jwtUserDao.update();
    }

service层的主要代码

 @Autowired
    private UserDao userDao;

    @Autowired
    private  JwtUserDao  jwtUserDao;

    @Transactional(rollbackFor = Exception.class)
    public void controllerTX(){
        userDao.update();
         //手动抛出一个RuntimeException
        System.out.println(2/0);
        jwtUserDao.update();
    }

dao层sql语句如下：

 <update id="update">
        UPDATE jwt_user SET username ='wangwuupdate' WHERE user_id= 2
    </update>
    
 <update id="update">
        UPDATE user SET username ='zsupdate' WHERE id= 2
    </update>

数据库原始数据：