今日目标
能够掌握Spring事务配置
Spring事务管理
1 Spring事务简介【重点】
1.1 Spring事务作用
-
事务作用:在数据层保障一系列的数据库操作同成功同失败
-
Spring事务作用:在数据层或业务层保障一系列的数据库操作同成功同失败
1.2 案例分析Spring事务
-
需求:实现任意两个账户间转账操作
-
需求微缩:A账户减钱,B账户加钱
-
分析: ①:数据层提供基础操作,指定账户减钱(outMoney),指定账户加钱(inMoney) ②:业务层提供转账操作(transfer),调用减钱与加钱的操作 ③:提供2个账号和操作金额执行转账操作 ④:基于Spring整合MyBatis环境搭建上述操作
-
结果分析: ①:程序正常执行时,账户金额A减B加,没有问题 ②:程序出现异常后,转账失败,但是异常之前操作成功,异常之后操作失败,整体业务失败
-
结构:
1.3 代码实现
【前置工作】环境准备
创建数据库和表
CREATE DATABASE IF NOT EXISTS `spring_db2` DEFAULT CHARACTER SET utf8
USE `spring_db2`;
DROP TABLE IF EXISTS `tbl_account`;
CREATE TABLE `tbl_account` (
`id` INT(11) NOT NULL AUTO_INCREMENT,
`name` VARCHAR(20) DEFAULT NULL,
`money` DOUBLE DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=INNODB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;
INSERT INTO `tbl_account`(`id`,`name`,`money`) VALUES
(1,'Jack',1000),
(2,'Rose',1000);
DROP TABLE IF EXISTS `tbl_log`;
CREATE TABLE `tbl_log` (
`id` INT(11) NOT NULL AUTO_INCREMENT,
`info` VARCHAR(255) DEFAULT NULL,
`create_date` DATETIME DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=INNODB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;
INSERT INTO `tbl_log`(`id`,`info`,`create_date`) VALUES
(2,'Jack向Rose转账520.0元','2021-11-04 17:19:18');
pom.xml添加依赖
<dependencies>
<!--导入spring的坐标spring-context,对应版本是5.2.10.RELEASE-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>5.3.15</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.28</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
<version>5.3.15</version>
</dependency>
<!--mysql-->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.27</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.mybatis/mybatis -->
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
<version>3.5.13</version>
</dependency>
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis-spring</artifactId>
<version>1.3.0</version>
</dependency>
<!-- https://mvnrepository.com/artifact/com.alibaba/druid -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.2.18</version>
</dependency>
<!--junit,spring对junit4的要求必须是4.12版本以上-->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.13</version>
<scope>test</scope>
</dependency>
<!--spring-test-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>5.3.22</version>
<scope>test</scope>
</dependency>
</dependencies>
Spring整合Mybatis相关代码(依赖、JdbcConfig、MybatisConfig、SpringConfig) JdbcConfig
package com.zbbmeta.config;
import com.alibaba.druid.pool.DruidDataSource;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.PlatformTransactionManager;
import javax.sql.DataSource;
public class JdbcConfig {
@Value("${jdbc.driverClassName}")
private String driverClassName;
@Value("${jdbc.url}")
private String url;
@Value("${jdbc.username}")
private String userName;
@Value("${jdbc.password}")
private String password;
@Bean
public DataSource dataSource(){
DruidDataSource ds = new DruidDataSource();
ds.setDriverClassName(driverClassName);
ds.setUrl(url);
ds.setUsername(userName);
ds.setPassword(password);
return ds;
}
//spring提供的事务切面类:里面增强了事务管理功能,里面有事务提交和事务回滚功能
@Bean
public PlatformTransactionManager transactionManager(DataSource dataSource){
DataSourceTransactionManager ptm = new DataSourceTransactionManager();
ptm.setDataSource(dataSource);
return ptm;
}
}
MybatisConfig
package com.zbbmeta.config;
import org.apache.ibatis.logging.stdout.StdOutImpl;
import org.apache.ibatis.session.Configuration;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.mapper.MapperScannerConfigurer;
import org.springframework.context.annotation.Bean;
import javax.sql.DataSource;
public class MybatisConfig {
@Bean //不仅可以将返回值加入IOC容器,而且可以实现方法参数进行依赖注入,参数默认会根据类型从IOC容器中获取对象自动注入
public SqlSessionFactoryBean sqlSessionFactoryBean(DataSource dataSource){
SqlSessionFactoryBean ssfb = new SqlSessionFactoryBean();
ssfb.setTypeAliasesPackage("com.zbbmeta.entity"); //告诉mybatis,设置实体类包别名
ssfb.setDataSource(dataSource); //将IOC容器中连接池给到Mybatis
//注意:必须导入org.apache.ibatis.session.Configuration;
Configuration configuration = new Configuration();
//设置整合mybatis驼峰命名映射
configuration.setMapUnderscoreToCamelCase(true);
//设置打印日志
configuration.setLogImpl(StdOutImpl.class);
ssfb.setConfiguration(configuration);
return ssfb;
}
}
SpringConfig
@Configuration
@ComponentScan("com.zbbmeta")
@PropertySource("classpath:jdbc.properties")
@Import({JdbcConfig.class,MybatisConfig.class})
public class SpringConfig {
}
Account
@ToString
@Data
public class Account {
private Integer id;
private String name;
private Double money;
}
AccountDao
public interface AccountDao {
@Update("update tbl_account set money = money + #{money} where name = #{name}")
void inMoney(@Param("name") String name, @Param("money") Double money);
@Update("update tbl_account set money = money - #{money} where name = #{name}")
void outMoney(@Param("name") String name, @Param("money") Double money);
}
public interface AccountService {
/**
* 转账操作
* @param out 传出方
* @param in 转入方
* @param money 金额
*/
void transfer(String out,String in,Double money) ;
}
AccountServiceImpl
@Service
public class AccountServiceImpl implements AccountService {
@Autowired
private AccountDao accountDao;
public void transfer(String out, String in, Double money) {
//转出
accountDao.outMoney(out, money);
//模拟出现异常
//System.out.println(1 / 0);
//转入
accountDao.inMoney(in, money);
System.out.println("转账成功");
}
}
【第一步】在业务层接口上添加Spring事务管理
在转账的方法上添加@Transactional注解
/**
* 业务接口
*/
public interface AccountService {
/**
* 转账操作
* @param out 传出方
* @param in 转入方
* @param money 金额
*/
@Transactional
void transfer(String out,String in ,Double money) ;
}
注意事项
-
Spring注解式事务通常添加在业务层接口中而不会添加到业务层实现类中,降低耦合
-
注解式事务可以添加到业务方法上表示当前方法开启事务,也可以添加到接口上表示当前接口所有方法开启事务
【第二步】设置事务管理器(将事务管理器添加到IOC容器中)
说明:可以在JdbcConfig中配置事务管理器
//配置事务管理器,mybatis使用的是jdbc事务
@Bean
public PlatformTransactionManager transactionManager(DataSource dataSource){
DataSourceTransactionManager transactionManager = new DataSourceTransactionManager();
transactionManager.setDataSource(dataSource);
return transactionManager;
}
注意事项
-
事务管理器要根据实现技术进行选择
-
MyBatis框架使用的是JDBC事务
【第三步】开启注解式事务驱动
@EnableTransactionManagement
@Configuration
@ComponentScan("com.itheima")
@PropertySource("classpath:jdbc.properties")
@Import({JdbcConfig.class,MybatisConfig.class})
@EnableTransactionManagement //开启事务注解扫描
public class SpringConfig {
}
【第四步】运行测试类,查看结果
-
去掉@EnableTransactionManagement注解,即没有进行事务管理,当转账出现问题时结果
-
加上@EnableTransactionManagement注解,账户钱都恢复成1000
结果
-
转账成功的时候
结果:
@RunWith(SpringJUnit4ClassRunner.class) //指定第三方的运行器
@ContextConfiguration(classes = SpringConfig.class) //读取类配置文件
public class AccountDaoTest {
@Autowired //自动注入业务对象
private AccountService accountService;
@Test
public void testFindById() throws IOException {
//直接使用业务方法
accountService.transfer("Jack","Rose", 100d);
}
}
2 Spring事务角色【理解】
问题导入
什么是事务管理员,什么是事务协调员?
2.1 Spring事务角色
-
事务管理员:发起事务方,在Spring中通常指代业务层开启事务的方法
-
事务协调员:加入事务方,在Spring中通常指数据层方法,也可以是业务层方法
3 Spring事务相关配置
问题导入
什么样的异常,Spring事务默认是不进行回滚的?
3.1 @Transactional注解中与事务相关配置
属性 | 作用 | 示例 | |
---|---|---|---|
readOnly | 设置是否为只读事务 | readOnly=true 只读事务 | |
timeout | 设置事务超时时间 | timeout = -1(永不超时) | |
rollbackFor | 设置事务回滚异常(class) | rollbackFor = {FileNotFoundException.class} | |
rollbackForClassName | 设置事务回滚异常(String) | 同上格式为字符串 | |
noRollbackFor | 设置事务不回滚异常(class) | noRollbackFor = {FileNotFoundException.class} | |
noRollbackForClassName | 设置事务不回滚异常(String) | 同上格式为字符串 | |
propagation | 设置事务传播行为 | …… |
属性 | 作用 | 示例 |
readOnly | 设置是否为只读事务 | readOnly=true 只读事务 |
timeout | 设置事务超时时间 | timeout = -1(永不超时) |
rollbackFor | 设置事务回滚异常(class) | rollbackFor = {FileNotFoundException.class} |
rollbackForClassName | 设置事务回滚异常(String) | 同上格式为字符串 |
noRollbackFor | 设置事务不回滚异常(class) | noRollbackFor = {FileNotFoundException.class} |
noRollbackForClassName | 设置事务不回滚异常(String) | 同上格式为字符串 |
propagation | 设置事务传播行为 | …… |
说明:对于RuntimeException类型异常或者Error错误,Spring事务能够进行回滚操作。但是对于非运行时异常,Spring事务是不进行回滚的,所以需要使用rollbackFor来设置要回滚的异常。
3.2 案例:转账业务追加日志
需求和分析
-
需求:实现任意两个账户间转账操作,并对每次转账操作在数据库进行记录
-
需求微缩:A账户减钱,B账户加钱,数据库记录日志
-
分析: ①:基于转账操作案例添加日志模块,实现数据库中记录日志 ②:业务层转账操作(transfer),调用减钱、加钱与记录日志功能
-
实现效果预期: 无论转账操作是否成功,均进行转账操作的日志留痕
-
存在的问题: 日志的记录与转账操作隶属同一个事务,同成功同失败
-
实现效果预期改进: 无论转账操作是否成功,日志必须保留
-
事务传播行为:事务协调员对事务管理员所携带事务的处理态度
【准备工作】环境整备
创建新的LogDao接口
public interface LogDao {
@Insert("insert into tbl_log (info,create_date) values(#{info},now())")
void log(String info);
}
创建业务接口使用事务
public interface LogService {
/**
* 记录日志
* @param out 转出账户
* @param in 转入账户
* @param money 金额
* 设置事务属性:传播行为设置为需要新事务
*/
@Transactional
void log(String out, String in, Double money);
}
实现类
@Service
public class LogServiceImpl implements LogService {
@Autowired
private LogDao logDao;
public void log(String out, String in, Double money) {
logDao.log("转账操作由" + out + "到" + in + ",金额:" + money);
}
}
【第一步】在AccountServiceImpl中调用logService中添加日志的方法
因为无论成功与否,都需要记录日志,所以日志放在finally语句块中,但异常不需要捕获,要抛出用来激活事务的处理
/**
* 业务接口
*/
public interface AccountService {
/**
* 转账操作
* @param out 传出方
* @param in 转入方
* @param money 金额
*/
@Transactional
void transfer(String out,String in ,Double money) ;
}
@Service
public class AccountServiceImpl implements AccountService {
@Autowired
private AccountDao accountDao;
@Autowired
private LogService logService;
public void transfer(String out,String in ,Double money) {
try{
accountDao.outMoney(out,money);
//int i = 1/0;
accountDao.inMoney(in,money);
} finally {
logService.log(out,in,money);
}
}
}
【第二步】在LogService的log()方法上设置事务的传播行为
需求:无论有没有异常日志都要记录下来,不能被回滚
-
先只设置@Transactional,查看运行结果
-
设置成当前操作需要新事务再查看运行结果
public interface LogService {
//propagation设置事务属性:传播行为设置为当前操作需要新事务
@Transactional(propagation = Propagation.REQUIRES_NEW)
void log(String out, String in, Double money);
}
【第三步】运行测试类,查看结果
@RunWith(SpringJUnit4ClassRunner.class) //指定第三方的运行器
@ContextConfiguration(classes = SpringConfig.class) //读取类配置文件
public class AccountServiceTest {
@Autowired //自动注入业务对象
private AccountService accountService;
/**
* 转账的测试
*/
@Test
public void testTransfer() {
accountService.transfer("Jack", "Rose", 10d);
}
}
思考:为什么 在LogService的方法上设置propagation = Propagation.REQUIRES_NEW接可以创建新的事务?
这就是事务传播行为(经常会面试提问)
3.3 事务传播行为
传播属性 | Method1 | Method2 |
REQUIRED | 开启TI事务 | 加入T1事务 |
无 | 新建T2事务 | |
REQUIRES_NEW | 开启TI事务 | 新建T2事务 |
无 | 新建T2事务 | |
SUPPORTS | 开启TI事务 | 加入T1事务 |
无 | 无 | |
NOT_SUPPORTED | 开启TI事务 | 无 |
无 | 无 | |
MANDATORY | 开启TI事务 | 加入T1事务 |
无 | ERROR | |
NEVER | 开启TI事务 | ERROR |
无 | 无 | |
NESTED |
思考:事务会一直生效?有没有事务失效的情况?为什么会失效,大家可以思考一下,这也是一个长问面试题