如果没有事务，第⼀步执⾏成功了，第⼆步执⾏失败了，那么 A 账户平⽩⽆故的 100 元就“⼈间蒸发”了。⽽如果使⽤事务就可以解决这个问题，让这⼀组操作要么⼀起成功，要么⼀起失败。

（当异常中断了，会将事务的执行过程记录到日志里，当台式电脑断电恢复之后，MySQL重新启动时会首先进行自检，发现某个事务执行了一半，没有结束符，此时会进行补偿机制，业务进行回滚，执行完上次没有执行完的操作，再提交事务。）

2.MySQL中事务的使用

事务在 MySQL 中有 3 个重要的操作：开启事务、提交事务、回滚事务，对应的操作命令如下：

--开启事务
start transaction;

--业务执行


--提交事务
commit;

--回滚事务
rollback;

MySQL中的事务都是单独执行的，不存在Spring中多个事务之间进行传递。

3.Spring中事务的实现

3.1.编程式事务（手动写代码操作事务）

灵活性大，但麻烦。

Spring ⼿动操作事务和上⾯ MySQL 操作事务类似，它也是有 3 个重要操作步骤：

• ①开启事务（获取事务）
• ②提交事务 或 ③回滚事务

SpringBoot 内置了两个对象，DataSourceTransactionManager ⽤来获取事务（开启事务）、提交或回滚事务的；而TransactionDefinition 是事务的属性，在获取事务的时候需要将TransactionDefinition 传递进去从⽽获得⼀个事务TransactionStatus，实现代码如下：

# 配置数据库的连接字符串
spring:
  datasource:
    url: jdbc:mysql://127.0.0.1/mycnblog?characterEncoding=utf8  #utf8不支持一些复杂的中文
    username: root
    password: 12345678
    driver-class-name: com.mysql.cj.jdbc.Driver  #底层驱动的名称(8.0之前版本不加.cj,8.0之后版本加.cj)

# 配置mybatis xml的文件路径，在resource包下建立mybatis(其命名自定义)包，在resource/mybatis创建所有表的xml文件
mybatis:
  mapper-locations: classpath:mapper/**Mapper.xml
  configuration:  # 配置打印MyBatis最终执行的SQL
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

# 配置打印MyBatis最终执行的SQL
logging:
  level:
    com:
      example:
        demo: debug

保存起来，以后直接用就行。

创建model层下的实体类：

import lombok.Data;

@Data
public class UserInfo {
    private int id;
    private String username;
    private String password;
    private String photo;
    private String createtime;
    private String updatetime;
    private String state;
}

创建mapper层下的UserMapper接口写方法声明：

import com.example.demo.model.UserInfo;
import org.apache.ibatis.annotations.Mapper;

@Mapper //此注解一定不要忘记添加
public interface UserMapper {
    public int add(UserInfo userInfo);
}

创建mapper层下的UserMapper.xml文件写对应SQL标签：

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.example.demo.mapper.UserMapper">
    <insert id="add">
        insert into userinfo(username, password)
        values(#{username}, #{password})
    </insert>
</mapper>

创建service层下的UserService类：

import com.example.demo.mapper.UserMapper;
import com.example.demo.model.UserInfo;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;

@Service
public class UserService {
    @Resource
    private UserMapper userMapper;

    public int add(UserInfo userInfo) {
        return userMapper.add(userInfo);
    }
}

创建controller层下的UserController类：

import com.example.demo.model.UserInfo;
import com.example.demo.service.UserService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.TransactionStatus;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/user")
@Slf4j
public class UserController {
    @Autowired
    private UserService userService;

    //事务管理器
    @Autowired
    private DataSourceTransactionManager transactionManager;

    //事务属性对象
    @Autowired
    private TransactionDefinition transactionDefinition;

    @RequestMapping("/add")
    public int add(UserInfo userInfo) {
        //获取事务（开启事务）
        TransactionStatus transactionStatus = transactionManager.getTransaction(transactionDefinition);
        int result = userService.add(userInfo);
        log.info("添加结果：" + result);
//        //提交事务
//        transactionManager.commit(transactionStatus);
        //回滚事务
        transactionManager.rollback(transactionStatus);
        return result;
    }
}

事务回滚成功！若是提交事务，数据库会新增添加的数据。

以上代码虽然可以实现事务，但操作也很繁琐，更简单的实现⽅法——声明式事务。

3.2.声明式事务（利用注解自动开启和提交事务）(使用为主)

简单，但出现问题难解决。

声明式事务只需要在需要的⽅法上添加 @Transactional 注解就可以实现了，⽆需⼿动开启事务和提交事务，进⼊⽅法时自动开启事务，方法成功执行完会自动提交事务，如果中途发生了没有处理的异常会⾃动回滚事务。

（区别：单元测试里只要给要测试的方法上加上@Transactional注解，不管程序怎么执行，最终一定会回滚）

正常情况：

import com.example.demo.model.UserInfo;
import com.example.demo.service.UserService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/user")
@Slf4j
public class UserController {
    @Autowired
    private UserService userService;
    
    @Transactional //开启声明式事务（进入方法自动开启事务，方法正常执行完自动提交事务，如果发生了未处理的异常会自动回滚事务）
    @RequestMapping("/add2")
    public int add2(UserInfo userInfo) {
        int result = userService.add(userInfo);
        log.info("添加功能II, 执行结果：" + result);
        return result;
    }
}

异常情况：

@Transactional 
@RequestMapping("/add2")
public int add2(UserInfo userInfo) {
    int result = userService.add(userInfo);
    log.info("添加功能II, 执行结果：" + result);
    int num = 10 / 0; //声明式事务执行到此行发生了未处理的异常会自动回滚事务
    return result;
}

 

3.2.1.@Transactional作用范围

@Transactional 可以⽤来修饰⽅法或类：

• 修饰方法时：需要注意只能应用到 public 方法上，否则不生效。推荐此种⽤法。
• 修饰类时：表明该注解对该类中所有的 public ⽅法都⽣效。

3.2.2.@Transactional参数说明

timeout事务的超时时间：

 

 当遇到问题：

查看对应API文档。

3.2.3.注意事项：@Transactional + try-catch 有异常不回滚的问题

当（在异常被捕获的情况下） @Transactional 遇到try catch之后，即使程序执行一半出现了异常，那么事务也不会⾃动回滚。

原因——Spring设计理念：

• 当程序有异常时，在没有加try catch时，Spring团队会认为当前的程序发生了一个始料未及的意外，开发者没有解决方案，会帮我们自动回滚；
• 在加了try catch后，Spring团队会认为开发者预料到了代码可能会出现异常，认为开发者有责任和能力去解决这个异常，所以此时不会人为干预，会自动提交事务。

import com.example.demo.model.UserInfo;
import com.example.demo.service.UserService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/user")
@Slf4j
public class UserController {
    @Autowired
    private UserService userService;

    @Transactional
    @RequestMapping("/add2")
    public int add2(UserInfo userInfo) throws InterruptedException {
        int result = 0;
        try {
            result = userService.add(userInfo);
            log.info("添加功能II, 执行结果：" + result);
            int num = 10 / 0;
        } catch (Exception e) {
        }
        return result;
    }
}

解决方案1：对于捕获的异常，将异常重新抛出，交给Spring处理，事务就会⾃动回滚了。对前端不友好。一般不用。

@Transactional
@RequestMapping("/add2")
public int add2(UserInfo userInfo) throws InterruptedException {
    int result = 0;
    try {
        result = userService.add(userInfo);
        log.info("添加功能II, 执行结果：" + result);
        int num = 10 / 0;
    } catch (Exception e) {
        throw e; //将异常重新抛出去
    }
    return result;
}

解决方案2：手动回滚事务，在⽅法中使⽤ TransactionAspectSupport.currentTransactionStatus() 可以得到当前的事务，然后设置回滚⽅法 setRollbackOnly 就可以实现回滚了。推荐使用。

import com.example.demo.model.UserInfo;
import com.example.demo.service.UserService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.interceptor.TransactionAspectSupport;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/user")
@Slf4j
public class UserController {
    @Autowired
    private UserService userService;

    @Transactional
    @RequestMapping("/add2")
    public int add2(UserInfo userInfo) throws InterruptedException {
        int result = 0;
        try {
            result = userService.add(userInfo);
            log.info("添加功能II, 执行结果：" + result);
            int num = 10 / 0;
        } catch (Exception e) {
            log.info("程序执行出现异常：" + e.getMessage());
            //手动回滚事务
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
        }
        return result;
    }
}

3.2.4.@Transactional工作原理

@Transactional 是基于 AOP 实现的，AOP ⼜是使⽤动态代理实现的。如果⽬标对象实现了接⼝，默认情况下会采⽤ JDK 的动态代理，如果⽬标对象没有实现了接⼝,会使⽤ CGLIB 动态代理。 @Transactional 在开始执⾏业务之前，通过代理先开启事务，在执⾏成功之后再提交事务。如果中途遇到的异常，则回滚事务。

@Transactional 实现思路预览：

@Transactional 具体执⾏细节如下图所示：

4.事务隔离级别

4.1.事务特性

事务有4 ⼤特性（ACID）：原⼦性、持久性、⼀致性、隔离性。

①原子性（Atomicity，或称不可分割性）

⼀个事务（transaction）中的所有操作，要么全部完成，要么全部不完成，不会结束在中间某个环节。事务在执⾏过程中发⽣错误，会被回滚（Rollback）到事务开始前的状态，就像这个事务从来没有执⾏过⼀样。

②一致性（Consistency）

在事务开始之前和事务结束以后，数据库的完整性没有被破坏。这表示写⼊的资料必须完全符合所有的预设规则，这包含资料的精确度、串联性以及后续数据库可以⾃发性地完成预定的⼯作。例如转账操作，张三和李四账户各有50元，张三给李四转账20元，不管是转账之前还是转账之后，他们俩账户的总额一定是和开始一致的。

③隔离性（Isolation，又称独立性）

数据库允许多个并发事务同时对其数据进⾏读写和修改的能⼒，隔离性可以防⽌多个事务并发执⾏时由于交叉执⾏⽽导致数据的不⼀致。事务隔离分为不同级别，包括读未提交（Read uncommitted）、读提交（read committed）、可重复读（repeatable read）和串行化（Serializable）。

④持久性（Durability）

事务处理结束后，对数据的修改就是永久的，即便系统故障也不会丢失。

而这 4 种特性中，只有隔离性（隔离级别）是可以设置的。

为什么要设置事务的隔离级别？

是⽤来保障多个并发事务执⾏更可控，更符合操作者预期的。

什么是可控？

⽐如近⼏年⽐较严重的新冠病毒，我们会把直接接触到确证病例的⼈员隔离到酒店，⽽把间接接触者（和直接接触着但未确诊的⼈）隔离在⾃⼰的家中，也就是针对不同的⼈群，采取不同的隔离级别，这种隔离⽅式就和事务的隔离级别类似，都是采取某种⾏动让某个事件变的“更可控”。而事务的隔离级别就是为了防止，其他的事务影响当前事务执行的一种策略。

4.2.MySQL 事务隔离级别有4种

①READ UNCOMMITTED：读未提交(Read Uncommitted)

也叫未提交读，该隔离级别的事务可以看到其他事务中未提交的数据。该隔离级别因为可以读取到其他事务中未提交的数据，⽽未提交的数据可能会发⽣回滚， 因此我们把该级别读取到的数据称之为脏数据，把这个问题称之为脏读。

②READ COMMITTED：读已提交(Read Committed)

也叫提交读，（是 Oracle 数据库的默认事务隔离级别），该隔离级别的事务能读取到已经提交事务的数据，因此它不会有脏读问题。但由于在事务的执⾏中可以读取到其他事务提交的结果，所以在不同时间的相同 SQL 查询中，可能会得到不同的结果，这种现象叫做不可重复读（描述的是对同一数据的修改）。

③REPEATABLE READ：可重复读(Repeatable Read)

是 MySQL 数据库的默认事务隔离级别，它能确保同⼀事务多次查询的结果⼀致。但也会有新的问题，⽐如此级别的事务正在执⾏时，另⼀个事务成功的插⼊了某条数据，但因为它每次查询的结果都是⼀样的，所以会导致查询不到这条数据，⾃⼰重复插⼊时⼜失败（因为唯⼀约束的原因）。明明在事务中查询不到这条信息，但⾃⼰就是插⼊不进去，这就叫幻读（Phantom Read）（描述的是数据的增加和删除）。

④SERIALIZABLE：序列化(Serializable)

事务最⾼隔离级别，它会强制事务排序，使之不会发生冲突，从⽽解决了脏读、不可重复读和幻读问题，但因为执⾏效率低，所以真正使⽤的场景并不多。

• 脏读：⼀个事务读取到了另⼀个事务修改的数据之后，后⼀个事务⼜进⾏了回滚操作，从⽽导致第⼀个事务读取的数据是错误的。

• 不可重复读：⼀个事务两次查询得到的结果不同，因为在两次查询中间，有另⼀个事务把数据修改了。

• 幻读：⼀个事务两次查询中得到的结果集不同，因为在两次查询中另⼀个事务有新增了⼀部分数据。