所有数据访问技术都有事务机制,这些技术提供了API来开启事务、提交事务完成数据操作, 或者在发生错误的时候回滚数据。
Spring采用统一的机制来处理不同的数据访问技术的事务,
Spring的事务提供一个PlatformTransactionManager
的接口,不同的数据访问技术使用不同的接口实现。
Data Tech | 实现 |
---|---|
JDBC | DataSourceTransactionManager |
JPA | JPATransactionManager |
Hibernate | HibernateTransactionManager |
JDO | JDOTransactionManager |
分布式事务 | JtaTransactionManager |
而得益于SpringBoot的自动配置机制,为我们自动开启了声明式事务支持,
我们无需添加注解@EnableTransactionManagement
事务基础
Spring提供一个@EnableTransactionManagement注解在配置类上开启声明式事务支持, 自动扫描加了@Transactional注解的类和方法,加入事务支持。
这里重点讲下@Transactional注解的几个属性
propagation
事务的传播机制,主要有以下几种,默认是REQUIRED:
- REQUIRED - 方法A调用时候没有事务新建一个事务,在方法A中调用方法B,将使用相同的事务,如果方法B发生异常需要回滚,整个事务回滚。
- REQUIRES_NEW - 方法A调用方法B时,无论是否存在事务都开启一个新事务,这样B方法异常不会导致A的数据回滚。
- NESTED - 和REQUIRES_NEW类似,但是只支持JDBC,不支持JPA或Hibernate
- SUPPORTS - 方法调用时有事务就用事务,没事务就不用事务
- NOT_SUPPORTED - 强制方法不在事务中执行,若有事务,在方法调用到结束阶段先挂起事务。
- NEVER - 强制不能有事务,若有事务就抛出异常
- MANDATORY - 强制必须有事务,如果没有事务就抛出异常
isolation
事务的隔离级别,决定了事务的完整性,主要一下几种,默认是DEFAULT:
- READ_UNCOMMITTED - A事务修改记录但没提交,B事务可读取到修改后的值。可导致脏读、不可重复读、幻读。
- READ_COMMITTED - A事务修改并提交后,B事务才能读取到修改后的值,阻止了脏读,但可能导致不可重复读和幻读。
- REPEATABLE_READ - A事务读取了一条记录,B事务将不能修改这条记录,阻止脏读和不可重复读,但是可能出现幻读。
- SERIALIZABLE - 事务是顺序执行的,可避免所有缺陷,但是开销很大。
- DEFAULT - 使用当前数据库默认隔离级别,入Oracle、SQL Server是READ_COMMITTED,MySQL是REPEATABLE_READ
timeout
事务过期时间,默认是当前数据库默认事务过期时间。
readOnly
指定是否为只读事务,默认是false
如果你一次执行单条查询语句,则没有必要启用事务支持,数据库默认支持SQL执行期间的读一致性;
如果你一次执行多条查询语句,例如统计查询,报表查询,在这种场景下,多条查询SQL必须保证整体的读一致性, 否则,在前条SQL查询之后,后条SQL查询之前,数据被其他用户改变,则该次整体的统计查询将会出现读数据不一致的状态, 此时,应该启用只读事务支持。
只读事务与读写事务区别:
对于只读查询,可以指定事务类型为readonly,即只读事务。由于只读事务不存在数据的修改, 因此数据库将会为只读事务提供一些优化手段,例如Oracle对于只读事务,不启动回滚段,不记录回滚log。
rollbackFor
指定哪些异常可以导致事务回滚,默认是Throwable的子类
noRollbackFor
执行哪些异常不可用引起事务回滚,默认是Throwable的子类
实战篇
实际项目中,使用SpringBoot的默认配置就已经足够满足我们的需求了。 本篇将通过几个例子来演示如何使用@Transactional注解,在出现异常时候回滚或不回滚数据。
使用我最喜欢的DAO技术就是MyBatis进行数据访问,使用druid数据库连接池, 另外配合mybatis-plus,实现数据访问层。
引入依赖:
1 | <dependency> |
配置数据库连接:
1 | ################### spring配置 ################### |
然后增加mybatis个性化配置:
1 | ################### mybatis-plus配置 ################### |
增加实体类User:
1 | "t_user") (value = |
增加UserMapper类:
1 | public interface UserMapper extends BaseMapper<User> { |
增加Mybatis配置类:
1 |
|
定义Service,并注入UserMapper:
1 |
|
增加Controller,注入Service,定义几个url来做测试用:
1 |
|
到此为止项目初始化完成,可以在Service中添加方法进行声明式事务测试了。
异常回滚
@Transactional注解可以放到类也可以放到方法上,如果放到类上面会对所有public方法添加注解, 不过你仍然可以在方法上面加这个注解,会覆盖类上面声明的事务注解。
先实验一个抛出异常会回滚的方法:
1 | /** |
然后在Controller里面添加一个url调用此方法:
1 | "/errorUpdate") ( |
数据库里面先插入一条数据:1|admin|123
启动应用后访问地址:http://localhost:8092/errorUpdate
控制台打印异常:
1 | Caused by: java.lang.RuntimeException: runtime |
查看数据库中记录:1|admin|123
,没有变动,说明回滚成功。
异常不会滚
你还可以指定特定异常不回滚,比如自定义一个MyException,抛出这个异常不回滚。
1 | public class MyException extends RuntimeException { |
然后通过指定这个异常不回滚:
1 | false, noRollbackFor = {MyException.class}) (readOnly = |
然后再定义一个url来验证:
1 | "/errorUpdate2") ( |
重启服务器,访问地址:http://localhost:8092/errorUpdate2
控制台仍然报异常:
1 | Caused by: com.xncoding.trans.exception.MyException: runtime |
看看数据库中记录:1|admin|admin
,更改成功,说明抛出这个MyException异常后并不会回滚。