SpringBoot 手动开启数据库事务的几种实现方式

概要

某些情况下我们可能需要手动开启事务，比如由多个业务组合的功能，其中某一段业务报错我们需要进行回滚操作，或者是使用数据库事务实现分布式锁。那么该如何开启事务呢。

开启事务

方式一：使用@Transactional 注解，Spring 会自动帮我们管理事务，包括开启事务、提交事务、回滚事务。

方式二：从数据源 DataSource 中获取一个 Connection，DataSource 是自动装配的，SpringBoot 默认使用的是 HikariDataSource。将 Connection 自动提交设置为 false，用此 Connection 执行业务 SQL，然后提交事务、回滚事务。

方式三：借助 Spring 中的事务管理器 PlatformTransactionManager 来开启事务。

方式四：使用 TransactionTemplate（自动注入即可），调用其 execute 方法来执行业务逻辑。

PlatformTransactionManager

方式一是自动管理事务。方式二虽然能手动管理事务，但实际操作起来不太优雅。方式四本质上还是方式三只不过把开启事务、提交事务、回滚事务做了封装，通过 lambda 函数回调执行我们的业务，可以认为还是自动管理了事务，这里重点介绍方式三。

先看一段代码和运行效果

@Resource
private UserMapper userMapper;

@Resource
private PlatformTransactionManager transactionManager;

@GetMapping(value = "/transaction", produces = MediaType.APPLICATION_JSON_VALUE)
public ResponseEntity<String> transaction() throws InterruptedException {
    TransactionStatus transaction = null;
    try {
        // 开启事务
        transaction = transactionManager.getTransaction(new DefaultTransactionDefinition());
        User user = userMapper.findById(1L);
        System.out.println("更新前：" + user);
        user.setAge(28);
        userMapper.updateById(user);
        // 事务未提交前其他线程读取数据
        Thread otherThread = new Thread(() -> {
               userMapper.findById();
            System.out.println( + newUser);
        });
        otherThread.start();
        otherThread.join();
           userMapper.findById();
        System.out.println( + newUser);
    }  {
         (transaction != ) {
            
            transactionManager.commit(transaction);
            
                (() -> {
                   userMapper.findById();
                System.out.println( + user);
            });
            otherThread.start();
            otherThread.join();
        }
    }
     ResponseEntity.ok();
}