1. 创建事务配置, 使用的是 TransactionTemplate
@SpringBootConfiguration
public class TransactionConfig {
@Bean
public TransactionTemplate transactionTemplate(DataSourceTransactionManager dataSourceTransactionManager) {
TransactionTemplate transactionTemplate = new TransactionTemplate(dataSourceTransactionManager);
// 可以设置事务隔离级别, 默认使用数据库默认隔离级别
// transactionTemplate.setIsolationLevel(TransactionDefinition.ISOLATION_DEFAULT);
// 可以设置事务传播方式
// transactionTemplate.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
// 可以设置事务超时时间
// transactionTemplate.setTimeout(TransactionDefinition.TIMEOUT_DEFAULT);
return transactionTemplate;
}
}
2. 在 service 方法中使用
导致事务回滚只有两种情况
1. 事务内代码抛出异常
2. transactionStatus.setRollbackOnly();
@Autowired
private TransactionTemplate transactionTemplate;
有返回值的如下
@Override
public Integer test() {
Integer count = transactionTemplate.execute(new TransactionCallback<Integer>() {
@Override
public Integer doInTransaction(TransactionStatus transactionStatus) {
Integer count = 0;
User user = new User();
user.setId(1L);
user.setName("张三");
count = count + userMapper.updateUser(user);
// int i = 1 / 0;
count = count + userMapper.deleteUser(2L);
// transactionStatus.setRollbackOnly();
return count;
}
});
return count;
}
无返回值的如下
@Override
public void test() {
transactionTemplate.executeWithoutResult(new Consumer<TransactionStatus>() {
@Override
public void accept(TransactionStatus transactionStatus) {
Integer count = 0;
User user = new User();
user.setId(1L);
user.setName("张三");
count = count + userMapper.updateUser(user);
// int i = 1 / 0;
count = count + userMapper.deleteUser(2L);
// transactionStatus.setRollbackOnly();
}
});
}
3. 最后总结
一些不能回滚的操作(如RPC调用, 消息发送, 缓存更新, 文件写入), 可能会被包在事务代码中, 如果数据库回滚, 那些不能回滚的操作会导致一系列问题, 所以在实际工作中请根据实际情况, 选择使用声明式事务@Transactional, 还是使用编程式事务.
如果在 SpringBoot 项目里使用声明式事务注解 @Transactional, 是不需要在项目启动类上添加 @EnableTransactionManagement 注解的