springboot 手动回滚事务
有时我们需要捕获一些错误信息后不适合抛异常,又需要进行事务回滚,这时我们就需要用到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的默认配置(即是由自己定义的配置信息,自己解析创建的数据源),则需要手动创建事务管理器,因为SpringBoot无法识别配置信息,无法完成自动注入。
//DynamicDataSource 是自定义的数据源
@Bean
public PlatformTransactionManager transactionManager(DynamicDataSource dataSource){
return new DataSourceTransactionManager(dataSource);
}
- SpringBoot1.x需要在启动类上添加@EnableTransactionManagement,SpringBoot2.x则不需要。