5 - 声明式事务

传统事务流程：

Connection connection = JdbcUtils.getConnection();
try {
    //1. 先设置事务不要自动提交
    connection.setAutoCommit(false);
    //2. 进行各种 crud
    //多个表的修改，添加 ，删除
    select from 商品表 => 获取价格
    //修改用户余额
    update ...
    //修改库存量
    update
    //3. 提交
    connection.commit();
} catch (Exception e) {
    //4. 回滚
    conection.rollback();
}

使用 Spring 的声明式事务处理，可以将上面三个子步骤分别写成一个方法，然后统一管理

1. 使用实例

1.1 创建 src\tx_ioc.xml 文件

<!-- 引入外部属性文件 -->
<context:property-placeholder location="classpath:jdbc.properties"/>
<!-- 配置数据源 -->
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
    <property name="user" value="${jdbc.userName}"></property>
    <property name="password" value="${jdbc.password}"></property>
    <property name="driverClass" value="${jdbc.driverClass}"></property>
    <property name="jdbcUrl" value="${jdbc.url}"></property>
</bean>
<!-- 配置 JdbcTemplate -->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
    <!-- 将上面的数据源分配给 jdbcTemplate -->
    <property name="dataSource" ref="dataSource"/>
</bean>
<!-- 配置事务管理器 -->
<bean id="dataSourceTransactionManager"
    class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <property name="dataSource" ref="dataSource"/>
</bean>
<!-- 开启基于注解的声明式事务功能 -->
<tx:annotation-driven transaction-manager="dataSourceTransactionManager"/>
<!-- 加入自动扫描包 dao -->
<context:component-scan base-package="com.hspedu.spring.tx.dao"/>

1.2 修改对象

修改 GoodsService.java，加入声明式事务注解

@Transactional
public void buyGoodsByTx(int user_id, int goods_id, int num) {
    //查询到商品价格
    Float goods_price = goodsDao.queryPriceById(goods_id);
    //购买商品，减去余额
    goodsDao.updateBalance(user_id, goods_price * num);
    //模拟一个异常, 会发生数据库数据不一致现象
    // int i = 10 / 0;
    //更新库存
    goodsDao.updateAmount(goods_id, num);
}

1.3 声明式事务机制

使用@Transactional 可以进行声明式事务控制；即将标识的方法中的，对数据库的操作作为一个事务管理
@Transactional 底层使用的仍然是AOP机制
底层是使用动态代理对象来调用buyGoodsByTx

执行流程：

在执行buyGoodsByTx() 方法先调用事务管理器的 doBegin()，主要是将自动提交关掉
然后调用 buyGoodsByTx()
如果执行没有发生异常，则调用事务管理器的 doCommit()
如果发生异常调用事务管理器的 doRollback()

2. 事务的传播机制

当有多个事务处理并存时，如何控制?

2.1 事务的传播机制种类

REQUIRED：如果现在有事务在运行，当前的方法就是在这个事务内运行
REQUIRED_NEW：当前方法必须新启动一个事务，在自己的事务内运行
SUPPORTS：如果现在有事务在运行，当前方法就在这个事务内运行，否则它可以不运行在事务中
NOT_SUPPORTE：当前方法不应该运行在事务内，如果有事务，该方法将挂起
MANDATORY：当前方法必须运行在事务内，如果没有运行在事务，则抛出异常
NEVER：当前方法不可以运行在事务内，如果运行在事务，则抛出异常
NESTED：如果现在有事务在运行，当前的方法就应该在这个事务的嵌套事务内运行，否则就启动一个新的事务，并运行在自己的事务里

重点分析 REQUIRED 和 REQUIRED_NEW

1）REQUIED(默认事务传播机制)

2）REQUIRES_NEW

3）事务的传播机制的设置方法

4）例子

如果设置为 REQUIRES_NEW：

buyGoods2 如果错误，不会影响到 buyGoods()，即它们的事务是独立的

如果设置为 REQUIRED：

buyGoods2 和 buyGoods 是一个整体，只要有方法的事务错误，那么两个方法都不会执行成功.!

3. 事务的隔离级别

这个概念参考 MySQL

3.1 说明

默认的隔离级别, 就是 mysql 数据库默认的隔离级别 一般为 REPEATABLE_READ

查看数据库默认的隔离级别：

SELECT @@global.tx_isolation

3.2 事务隔离级别的设置及测试

1）默认

@Transactional(propagation = Propagation.REQUIRES_NEW)
public void buyGoodsByTxISOLATION(int user_id, int goods_id, int num) {
    //查询到商品价格
    Float goods_price = goodsDao.queryPriceById(goods_id);
    System.out.println("第一次读取的价格 =" + goods_price);
    //测试一下隔离级别，在同一个事务中，查询一下价格
    goods_price = goodsDao.queryPriceById(goods_id);
    System.out.println("第二次读取的价格 =" + goods_price);
}

过程：在读完第一次数据后，通过 mysql 进行修改该数据

结果：两次读取到的价格是一样的，不会受到 MySQL 修改影响