一、事务管理简介

1、事务基本概念

一组业务操作ABCD，要么全部成功，要么全部不成功。

2、特性：ACID

• 原子性：整体
• 一致性：完成
• 隔离性：并发
• 持久性：结果

3、隔离问题

• 脏读：一个事务读到另一个事务没有提交的数据
• 不可重复读：一个事务读到另一个事务已提交的数据（update）
• 虚读(幻读)：一个事务读到另一个事务已提交的数据（insert）

4、隔离级别

• read uncommitted：读未提交。
• read committed：读已提交。解决脏读。
• repeatable read：可重复读。解决：脏读、不可重复读。
• serializable ：串行化。都解决，单事务。

二、顶级接口

• PlatformTransactionManager

平台事务管理器，spring要管理事务，必须使用事务管理器进行事务配置时，必须配置事务管理器。

• TransactionDefinition

事务详情（事务定义、事务属性），spring用于确定事务具体详情，例如：隔离级别、是否只读、超时时间等,进行事务配置时，必须配置详情。spring将配置项封装到该对象实例。

• TransactionStatus

事务状态，spring用于记录当前事务运行状态。例如：是否有保存点，事务是否完成。spring底层根据状态进行相应操作。

三、SpringBoot2事务

基于转账的案例演示，基于druid连接池配置。druid连接池在文章。

1、转账表结构

CREATE TABLE account(
  id INT PRIMARY KEY AUTO_INCREMENT,
  username VARCHAR(50),
  money INT
)ENGINE=InnoDB DEFAULT CHARSET=utf8;
INSERT INTO account(username,money) VALUES('jack','10000');
INSERT INTO account(username,money) VALUES('rose','10000');
SELECT * FROM account;

2、事务手动管理

该配置用于测试事务的手动管理。

/**
 * 事物管理器
 */
@Bean(name = "transactionManager")
public PlatformTransactionManager transactionManager (DruidDataSource dataSource){
    LOGGER.info("【transactionManager 初始化...】");
    DataSourceTransactionManager transactionManager = new DataSourceTransactionManager();
    transactionManager.setDataSource(dataSource);
    return transactionManager;
}
/**
 * 创建事物手动管理模板
 */
@Bean(name = "transactionTemplate")
public TransactionTemplate transactionTemplate(PlatformTransactionManager transactionManager)
    LOGGER.info("【transactionTemplate 初始化...】");
    TransactionTemplate transactionTemplate = new TransactionTemplate() ;
    transactionTemplate.setTransactionManager(transactionManager);
    return transactionTemplate;
}

3、封装转账接口

接口方法

public interface AccountService {
    /**
     * 汇款
     */
    void out (String outer , Integer money);
    /**
     * 收款
     */
    void in (String inner , Integer money);
}

接口实现

@Service
public class AccountServiceImpl implements AccountService {
    @Resource
    private JdbcTemplate jdbcTemplate ;
    public void out(String outer, Integer money) {
        String sql = "update account set money = money - ? where username = ?";
        jdbcTemplate.update(sql, money,outer);
    }
    public void in(String inner, Integer money) {
        String sql = "update account set money = money + ? where username = ?";
        jdbcTemplate.update(sql, money,inner);
    }
}

4、封装测试接口

测试接口

public interface TradeService {
    /**
     * 转账交易：没有事务管理
     */
    void trade1(String outer ,String inner ,Integer money);
    /**
     * 转账交易：手动管理事务
     */
    void trade2(String outer ,String inner ,Integer money);
    /**
     * 转账交易：注解管理事务
     */
    void trade3(String outer ,String inner ,Integer money);
}

接口实现

@Service
public class TradeServiceImpl implements TradeService {

    @Resource
    private AccountService accountService ;
    @Resource
    private TransactionTemplate transactionTemplate ;

    @Override
    public void trade1(String outer, String inner, Integer money) {
        accountService.out(outer, money);
        // 抛出异常
        int i = 1/0;
        accountService.in(inner, money);
    }

    @Override
    public void trade2(String outer, String inner, Integer money) {
        transactionTemplate.execute(new TransactionCallbackWithoutResult() {
            public void doInTransactionWithoutResult(TransactionStatus arg0) {
                accountService.out(outer, money);
                // 抛出异常
                int i = 1/0;
                accountService.in(inner, money);
            }
        });
    }

    @Transactional(value="transactionManager",propagation= Propagation.REQUIRED)
    @Override
    public void trade3(String outer, String inner, Integer money) {
        accountService.out(outer, money);
        // 抛出异常
        int i = 1/0;
        accountService.in(inner, money);
    }
}

5、编写测试类

@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest(classes = TransactionApplication.class)
public class TradeTest {
    @Resource
    private TradeService tradeService ;
    /**
     * 没有事务管理
     * jack 减少了1000块钱，但是rose得到1000块钱
     * 1	jack	9000
     * 2	rose	10000
     */
    @Test
    public void testTrade1 (){
        tradeService.trade1("jack", "rose", 1000);
    }
    /**
     * 手动管理事务
     * 1	jack	10000
     * 2	rose	10000
     */
    @Test
    public void testTrade2 (){
        tradeService.trade2("jack", "rose", 1000);
    }
    /**
     * 注解管理事务
     * 1	jack	10000
     * 2	rose	10000
     */
    @Test
    public void testTrade3 (){
        tradeService.trade3("jack", "rose", 1000);
    }
}