• Spring事务
  • Spring事务简介
  • 案例：银行账户转账
    • 需求
    • 分析
    • 结果分析
    • 实现
  • Spring事务角色
  • 事务相关配置
    • 案例：转账业务追加日志
      • 实现
    • 事务传播行为

Spring事务

Spring事务简介

• 事务作用：在数据层保障一系列的数据库操作同成功同失败
• Spring事务作用：在数据层或业务层保障一系列的数据库操作同成功同失败

public interface PlatformTransactionManager(
	void commit(TransactionStatus status) throws TransactionException;
	void rollback(TransactionStatus status) throws TransactionException;
)

public class DataSourceTransactionManager(
	......
)

案例：银行账户转账

模拟银行账户间转账业务

需求

实现任意两个账户间转账操作

• 需求微缩：A账户减钱，B账户加钱

分析

1. 数据层提供基础操作，指定账户减钱（outMoney），指定账户加钱（inMoney）
2. 业务层提供转账操作（transfer），调用减钱与加钱的操作
3. 提供2个账号和操作金额执行转账操作
4. 基于Spring整合MyBatis环境搭建上述操作

结果分析

1. 程序正常执行时，账户金额A减B加，没有问题
2. 程序出现异常后，转账失败，但是异常之前操作成功，异常之后操作失败，整体业务失败

实现

1. 在业务层接口上添加Spring事务管理

public interface AccountService {
    @Transactional
    public void transfer(String out,String in,Double money);
}

注意：

Spring注解式事务通常添加在业务层接口中而不会添加到业务层实现类中，降低耦合

注解式事务可以添加到业务方法上表示当前方法开启事务，也可以添加到接口上表示当前接口所有方法开启事务

2. 设置事务管理器

    @Bean
    public PlatformTransactionManager transactionManager(DataSource dataSource){
        DataSourceTransactionManager transactionManager = new DataSourceTransactionManager();
        transactionManager.setDataSource(dataSource);
        return transactionManager;
    }

注意：
事务管理器要根据实现技术进行选择
MyBatis框架使用的是JDBC事务

3. 开启注解式事务驱动

@Configuration
@ComponentScan("com.itheima")
@PropertySource("classpath:jdbc.properties")
@Import({JdbcConfig.class,MybatisConfig.class})
//开启注解式事务驱动
@EnableTransactionManagement
public class SpringConfig {
}

Spring事务角色

• 事务角色
  • 事务管理员：发起事务方，在Spring中通常指代业务层开启事务的方法
  • 事务协调员：加入事务方，在Spring中通常指代数据层方法，也可以是业务层方法

事务相关配置

案例：转账业务追加日志

需求：实现任意两个账户转账操作，并对每次转账操作在数据库进行留痕
需求微缩：A账户减钱，B账户加钱，数据库记录日志
分析：

1. 基于转账操作案例添加日志模块，实现数据库中记录日志
2. 业务层转账操作（transfer），调用减钱、加钱与记录日志功能

实现效果预期：
无论转账操作是否成功，均进行转账操作的日志留痕

存在的问题：
日志的记录与转账操作隶属同一个事务，同成功同失败

实现

1. 在业务层接口上添加Spring事务，设置事务传播行为REQUIRES_NEW（需要新事务）

@Service
public class LogServiceImpl implements LogService {
    @Autowired
    private LogDao logDao;
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public void log(String out, String in, Double money) {
        logDao.log("转账操作由" + out + "到" + in + "，金额：" + money);
    }
}

事务传播行为