从零开始 Spring Boot 6：事务

图源：简书 (jianshu.com)

本篇文章的示例代码是在learn_spring_boot (github.com)基础上修改的，你可通过以上链接获取。

有时候，在执行SQL时，多条SQL之间具备某种关联性。比如要添加一个用户订单的同时要从商品表中将库存减少，这两个操作必须是“要么都成功，要么都失败”，如果用普通的两条SQL执行，就可能发生商品库存扣减了，订单没有生成，或者订单生成了，商品库存没有扣减。

在这种情况下，就需要将这两个SQL当做一个事务进行处理。一个事务中包含的SQL执行过程中如果产生错误，就会导致整个事务“回滚”，对于数据库来说，就好像这个事务没有发生过一样，这样就可以避免脏数据的出现。

事务就好像是多线程编程中对共享数据的同步或加锁，其实两者概念是相似的。

我们看一个示例，这里给我们之前的简单Web应用添加一个可以批量生成用户的Service：

@Service
public class UserServiceMPImpl extends ServiceImpl<UserMapper, User> implements UserServiceMP, UserServiceInterface {
​
    @Override
    public void addSomeUsers(boolean broken) {
        final int SIZE = 3;
        for(int i=0;i<SIZE;i++){
            User user = new User();
            user.setAge(10);
            user.setName("test");
            this.addUser(user);
            if(i == SIZE-2){
                if (broken) {
                    throw new RuntimeException("someting broken the data save.");
                }
            }
        }
    }
    ...
}

在Controller中添加一个方法用于处理URL请求：

@RestController
@RequestMapping("/user")
public class UserController {
    ...
    @PostMapping("/some/{flag}")
    public String addSomeUsers(@PathVariable int flag) {
        boolean broken = false;
        if (flag == 1) {
            broken = true;
        }
        Result result = new Result();
        userServiceInterface.addSomeUsers(broken);
        return result.toString();
    }
    ...
}

此时如果通过HTTP客户端调用POST http://localhost:8080/user/some/1就会发现数据库插入了2条数据，第三条因为产生异常而没有成功插入。

如果我们希望这个一次性插入3条新用户的“功能”是一个事务，在部分成功部分失败的情况下能够回滚，可以用@Transactional注解来修饰相应的Service方法：

    ...
    @Override
    @Transactional
    public void addSomeUsers(boolean broken) {
        ...
    }

如果再次请求相应的URL，就会发现不会插入部分数据。

参考资料

• Spring Boot 2.x基础教程：事务管理入门 | 程序猿DD (didispace.com)