springboot 手动回滚事务

手动回滚事务有时我们需要捕获一些错误信息，又需要进行事务回滚，这时我们就需要用到Spring提供的事务切面支持类TransactionAspectSupport。@Transactional(rollbackFor = Exception.class)@Overridepublic void saveEntity() throws Exception{try {userDao.saveUser()

loveLifeLoveCoding

4119人浏览 · 2021-07-14 14:45:32

loveLifeLoveCoding · 2021-07-14 14:45:32 发布

手动回滚事务

有时我们需要捕获一些错误信息，又需要进行事务回滚，这时我们就需要用到Spring提供的事务切面支持类TransactionAspectSupport。

@Transactional(rollbackFor = Exception.class)
@Override
public void saveEntity() throws Exception{
    try {
        userDao.saveUser();
        studentDao.saveStudent();
    }catch (Exception e){
        System.out.println("异常了=====" + e);
        //手动强制回滚事务，这里一定要第一时间处理
        TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
    }
}

回滚部分异常

设置回滚点

Object savePoint = TransactionAspectSupport.currentTransactionStatus().createSavepoint();

回滚到savePoint
TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint);

@Transactional(rollbackFor = Exception.class)
@Override
public void saveEntity() throws Exception{
    Object savePoint = null;
    try {
        userDao.saveUser();
        //设置回滚点
        savePoint = TransactionAspectSupport.currentTransactionStatus().createSavepoint();
        studentDao.saveStudent(); //执行成功
        int a = 10/0; //这里因为除数0会报异常,进入catch块
    }catch (Exception e){
        System.out.println("异常了=====" + e);
        //手工回滚异常
        TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint);
    }
}

手动提交事务

springboot 开启事务以及手动提交事务，可以在服务类上加上两个注解。

@Autowired
DataSourceTransactionManager dataSourceTransactionManager;
@Autowired
TransactionDefinition transactionDefinition;

手动开启事务
TransactionStatus transactionStatus = dataSourceTransactionManager.getTransaction(transactionDefinition);
手动提交事务
dataSourceTransactionManager.commit(transactionStatus);//提交
手动回滚事务
dataSourceTransactionManager.rollback(transactionStatus);//最好是放在catch 里面,防止程序异常而事务一直卡在哪里未提交

解决springboot设置@Transactional 失效

默认spring事务只在发生未被捕获的 RuntimeException 时才回滚。

spring aop 异常捕获原理：被拦截的方法需显式抛出异常，并不能经任何处理，这样aop代理才能捕获到方法的异常，才能进行回滚，默认情况下aop只捕获 RuntimeException 的异常，但可以通过配置来捕获特定的异常并回滚。

换句话说在service的方法中不使用try catch 或者在catch中最后加上throw new RuntimeException ()，这样程序异常时才能被aop捕获进而回滚。

解决方案：

方案1：例如service层处理事务，那么service中的方法中不做异常捕获，或者在catch语句中最后增加throw new RuntimeException()语句，以便让aop捕获异常再去回滚，并且在service上层（webservice客户端，view层action）要继续捕获这个异常并处理。
方案2：在service层方法的catch语句中增加：TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();语句，手动回滚，这样上层就无需去处理异常。

注意

1. 默认地，如果使用的数据源不是SpringBoot的默认配置（即是由自己定义的配置信息，自己解析创建的数据源），则需要手动创建事务管理器，因为SpringBoot无法识别配置信息，无法完成自动注入。

 //DynamicDataSource 是自定义的数据源 
    @Bean
    public PlatformTransactionManager transactionManager(DynamicDataSource dataSource){
        return  new DataSourceTransactionManager(dataSource);
    }

2. SpringBoot1.x需要在启动类上添加@EnableTransactionManagement，SpringBoot2.x则不需要。

参考链接： https://www.cnblogs.com/myitnews/p/12364455.html