Spring对事务的支持
16.1 事务概述
●什么是事务
○在一个业务流程当中，通常需要多条DML（insert delete update）语句共同联合才能完成，这多条DML语句必须同时成功，或者同时失败，这样才能保证数据的安全。
○多条DML要么同时成功，要么同时失败，这叫做事务。
○事务：Transaction（tx）
●事务的四个处理过程：
○第一步：开启事务 (start transaction)
○第二步：执行核心业务代码
○第三步：提交事务（如果核心业务处理过程中没有出现异常）(commit transaction)
○第四步：回滚事务（如果核心业务处理过程中出现异常）(rollback transaction)
●事务的四个特性：
○A 原子性：事务是最小的工作单元，不可再分。
○C 一致性：事务要求要么同时成功，要么同时失败。事务前和事务后的总量不变。
○I 隔离性：事务和事务之间因为有隔离性，才可以保证互不干扰。
○D 持久性：持久性是事务结束的标志。
16.2 引入事务场景
以银行账户转账为例学习事务。两个账户act-001和act-002。act-001账户向act-002账户转账10000，必须同时成功，或者同时失败。（一个减成功，一个加成功， 这两条update语句必须同时成功，或同时失败。）
连接数据库的技术采用Spring框架的JdbcTemplate。
采用三层架构搭建：
表现层
WEB前端
AJAX
业务逻辑层
后端
WEB
数据访问层(或持久层)
数据库
模块名：spring6-013-tx-bank（依赖如下）
第一步：准备数据库表
表结构：
对象
@SPRING6(LOCALHOST)-表
T ACT
个 上移
删除字段
下移
.保存
添加字段
插入字段
主键
字段
注释
触发器
SQL预览
索引
选项
外键
检查
不是NULL
名
类型
键
长度
虚拟
小数点
账号
255
VARCHAR
ACTNO
口
余额
DOUBLE
BALANCE
表数据：
TACT@SPRING6(LOCALHOST)-表
对象
68导入
目开始事务
筛选,三排序
文本
BALANCE
ACTNO
50000
ACT-001
ACT-002
第二步：创建包结构
com.powernode.bank.pojo
com.powernode.bank.service
com.powernode.bank.service.impl
com.powernode.bank.dao
com.powernode.bank.dao.impl
第三步：准备POJO类
第四步：编写持久层
第五步：编写业务层
第六步：编写Spring配置文件
第七步：编写表示层（测试程序）
执行结果：
TESTS PASSED:1 OF 1 TEST -1SEC 279MS
C:\DEV\JAVA\JDK-17.0.4\BIN\JAVA.EXE
10月 23,2022 12:01:00 下午
COM.ALIBABA.DRUID.SUP
信息:{DATASOURCE-1} INITED
转账成功
数据变化：
T.ACT@SPRING6(LOCALHOST)-表
对象
[6导入[6-
开始事务
自文本?筛选,三排序
BALANCE
ACTNO
40000
ACT-001
10000
ACT-002
模拟异常
执行结果：
TESTS PASSED:1 OF 1 TEST - 1SEC 187MS
C:|DEV|JAVALJDK-17.0.4\BIN\JAVA.EXE
4 下午 COM.ALIBABA.DRUID.SUPPORT.LOGGING.JAKARTACOMMONSLOGGINGIMPL INFO
10月 23, 2022 12:03:14 下
信息:{DATASOURCE-1} INITED
JAVA.LANG,LULLPOINTEREXCEPTION CREATE FREAKPOINT : CANNOT INVOKE "STRING:TOSTRINGO " BECAUSE "S" IS "
"S" IS NULL
)"BECAUSE
AT COM.POWERNODE.BANK.SERVICE.IMPL.ACCOUNTSERVICEIMPL.TRANSFER(ACCOUNTSERVICEIMPL.I
(JAVA:36)
<27
COM.POWERNODE.SPRING6.TEST.BANKTEST.TESTTRANSFER(BANKTEST.JAVA:20)
INTERNAL LINES>
AT
数据库表中数据：
T_ACT@SPRING6(LOCALHOST)-表
对象
T
月开始事务
自文本?筛选,三排序
BALANCE
ACTNO
30000
ACT-001
10000
ACT-002
丢了1万。
16.3 Spring对事务的支持
Spring实现事务的两种方式
●编程式事务
○通过编写代码的方式来实现事务的管理。
●声明式事务
○基于注解方式
○基于XML配置方式
Spring事务管理API
Spring对事务的管理底层实现方式是基于AOP实现的。采用AOP的方式进行了封装。所以Spring专门针对事务开发了一套API，API的核心接口如下：
G宁三云TEX
42 SCOPE: ALL
PLATFORMTRANSACTIONMANAGER (ORG.SPRINGFRAMEWORK.TRANSACTION)
CALLBACKPREFERRINGPLATFORMTRANSACTIONMANAGER (ORG-SPRINGTRAMEWORKION.SUP
ABSTRACTPLATFORMTRANSACTIONMANAGER (ORG.SPRINGFRAMEWORK.TRANSACTION.SUPPORT)
DATASOURCETRANSACTIONMANAGER (ORG.SPRINGFRAMEWORK.JDBC.DATASOURCE)
JDBCTRANSACTIONMANAGER (ORG.SPRINGFRAMEWORK.JDBC.SUPPORT)
C
JTATRANSACTIONMANAGER (ORG.SPRINGFRAMEWORK.TRANSACTIONJTA)
RESOURCETRANSACTIONMANAGER(ORQ.SPRINGFRAMEWORK.TRANSACTION.SUPPORT)
PlatformTransactionManager接口：spring事务管理器的核心接口。在Spring6中它有两个实现：
●DataSourceTransactionManager：支持JdbcTemplate、MyBatis、Hibernate等事务管理。
●JtaTransactionManager：支持分布式事务管理。
如果要在Spring6中使用JdbcTemplate，就要使用DataSourceTransactionManager来管理事务。（Spring内置写好了，可以直接用。）
声明式事务之注解实现方式
●第一步：在spring配置文件中配置事务管理器。
●第二步：在spring配置文件中引入tx命名空间。
●第三步：在spring配置文件中配置“事务注解驱动器”，开始注解的方式控制事务。
●第四步：在service类上或方法上添加@Transactional注解
在类上添加该注解，该类中所有的方法都有事务。在某个方法上添加该注解，表示只有这个方法使用事务。
当前数据库表中的数据：
T_ACT@SPRING6(LOCALHOST)-表
对急
[6导入[9 -
排序
开始事务
筛选
BALANCE
ACTNO
30000
ACT-001
10000
ACT-002
执行测试程序：
TESTS PASSED:1 TEST TEST - 1SEC 400MS
C:\DEV\JAVA\JDK-17.0.4\BIN\JAVA.EXE
10月 23, 2022 2:88:56 下午 CAM.ALIBABA.DRUID.SUPPORT.LOGGING,JAKARTACOMMONSLOGGINGINGIMPL INFO
信息:{DATASOURCE-1} INITED
JAVA.LANG.NULLPOINTEREXCEPTION CREATEBREAKPOINT : CANNOT INVOKE "STRING.TOSTRING("
"S" IS NULL
BECAUSE
<4 INTER
AT COM.POWERNODE.BANK.SERVICE.IMPL.ACCOUNTSERVICEIMPL.TRANSFER(ACCOUNTSERVICEIMPL.JAVA:3S)
AT ORG:SPRINGFRAMEWORK.AOP.SUPPORT.AOPUTILS.INVOKEJOINPOINPOINTUSINGREFLECTION(AOPUTILS-JAVAI343)
AT ORA SNRINGFRAMEWORK AON FRAMEW
O FRAMEWORK REFLECTIVEMETHODINYOCATION
虽然出现异常了，再次查看数据库表中数据：
T_ACT@SPRING6(LOCALHOST)-表
对急
[6导入[9 -
排序
开始事务
筛选
BALANCE
ACTNO
30000
ACT-001
10000
ACT-002
通过测试，发现数据没有变化，事务起作用了。
事务属性
事务属性包括哪些
TRANSACTIONAL
PUBLIC@INTERFACE
@ALIASFOR("TRANSACTIONMANAGER")
STRING VALUE() DEFAULT
@ALIASFOR("VALUE")
STRING TRANSACTIONMANAGER()
DEFAULT
STRING[] LABEL() DEFAULT {};
DEFAULT PROPAGATION.REQUIRED;
PROPAGATION PROPAGATION()
ISOLATION ISOLATION()
ISOLATION.DEFAULT;
DEFAULT
INT TIMEOUT()
DEFAULT
DEFAULT
STRING TIMEOUTSTRING()
BOOLEAN READONLY() DEFAULT FALSE;
THROWABLE>[]
丹;
CLASS<?
ROLLBACKFOR()
DEFAULT
EXTENDS
STRING[] ROLLBACKFORCLASSNAME() DEFAULT
丹;
NOROLTBACKFOR()
THROWABLE>[]
DEFAULT
CLASS<?
EXTENDS
丹;
STRING[] NOROLLBACKFORCLASSNAME()
DEFAULT
子
事务中的重点属性：
●事务传播行为
●事务隔离级别
●事务超时
●只读事务
●设置出现哪些异常回滚事务
●设置出现哪些异常不回滚事务
事务传播行为
什么是事务的传播行为？
在service类中有a()方法和b()方法，a()方法上有事务，b()方法上也有事务，当a()方法执行过程中调用了b()方法，事务是如何传递的？合并到一个事务里？还是开启一个新的事务？这就是事务传播行为。
事务传播行为在spring框架中被定义为枚举类型：
ORG.SPRINGFRAMEWORK.TRANSACTION.ANNOTATION;
6
PACKAGE
7
予
PROPAGATION
PUBLIC
ENUM
REQUIRED(VALUE: 0),
9
SUPPORTS(VALUE:1),
10
MANDATORY( VALUE: 2),
11
REQUIRES_NEW(VALUE:3),
12
NOT_SUPPORTED(VALUE: 4),
13
NEVER(VALUE: 5),
NESTED(VALUE: 6);
15
一共有七种传播行为：
●REQUIRED：支持当前事务，如果不存在就新建一个(默认)【没有就新建，有就加入】
●SUPPORTS：支持当前事务，如果当前没有事务，就以非事务方式执行【有就加入，没有就不管了】
●MANDATORY：必须运行在一个事务中，如果当前没有事务正在发生，将抛出一个异常【有就加入，没有就抛异常】
●REQUIRES_NEW：开启一个新的事务，如果一个事务已经存在，则将这个存在的事务挂起【不管有没有，直接开启一个新事务，开启的新事务和之前的事务不存在嵌套关系，之前事务被挂起】
●NOT_SUPPORTED：以非事务方式运行，如果有事务存在，挂起当前事务【不支持事务，存在就挂起】
●NEVER：以非事务方式运行，如果有事务存在，抛出异常【不支持事务，存在就抛异常】
●NESTED：如果当前正有一个事务在进行中，则该方法应当运行在一个嵌套式事务中。被嵌套的事务可以独立于外层事务进行提交或回滚。如果外层事务不存在，行为就像REQUIRED一样。【有事务的话，就在这个事务里再嵌套一个完全独立的事务，嵌套的事务可以独立的提交和回滚。没有事务就和REQUIRED一样。】
在代码中设置事务的传播行为：
可以编写程序测试一下传播行为：
一定要集成Log4j2日志框架，在日志信息中可以看到更加详细的信息。
事务隔离级别
事务隔离级别类似于教室A和教室B之间的那道墙，隔离级别越高表示墙体越厚。隔音效果越好。
数据库中读取数据存在的三大问题：（三大读问题）
●脏读：读取到没有提交到数据库的数据，叫做脏读。
●不可重复读：在同一个事务当中，第一次和第二次读取的数据不一样。
●幻读：读到的数据是假的。
事务隔离级别包括四个级别：
●读未提交：READ_UNCOMMITTED
○这种隔离级别，存在脏读问题，所谓的脏读(dirty read)表示能够读取到其它事务未提交的数据。
●读提交：READ_COMMITTED
○解决了脏读问题，其它事务提交之后才能读到，但存在不可重复读问题。
●可重复读：REPEATABLE_READ
○解决了不可重复读，可以达到可重复读效果，只要当前事务不结束，读取到的数据一直都是一样的。但存在幻读问题。
●序列化：SERIALIZABLE
○解决了幻读问题，事务排队执行。不支持并发。
大家可以通过一个表格来记忆：
隔离级别 |
脏读 |
不可重复读 |
幻读 |
读未提交 |
有 |
有 |
有 |
读提交 |
无 |
有 |
有 |
可重复读 |
无 |
无 |
有 |
序列化 |
无 |
无 |
无 |
在Spring代码中如何设置隔离级别？
隔离级别在spring中以枚举类型存在：
ISOLATION
ENUM
PUBLIC
DEFAULT(VALUE:-1),
READ_UNCOMMITTED( VALUE: 1),
READ_COMMITTED( VALUE: 2),
REPEATABLE_READ( VALUE: 4)
SERIALIZABLE( VALUE:8);
测试事务隔离级别：READ_UNCOMMITTED 和 READ_COMMITTED
怎么测试：一个service负责插入，一个service负责查询。负责插入的service要模拟延迟。
测试程序
通过执行结果可以清晰的看出隔离级别不同，执行效果不同。
事务超时
代码如下：
以上代码表示设置事务的超时时间为10秒。
表示超过10秒如果该事务中所有的DML语句还没有执行完毕的话，最终结果会选择回滚。
默认值-1，表示没有时间限制。
这里有个坑，事务的超时时间指的是哪段时间？
在当前事务当中，最后一条DML语句执行之前的时间。如果最后一条DML语句后面很有很多业务逻辑，这些业务代码执行的时间不被计入超时时间。
当然，如果想让整个方法的所有代码都计入超时时间的话，可以在方法最后一行添加一行无关紧要的DML语句。
只读事务
代码如下：
将当前事务设置为只读事务，在该事务执行过程中只允许select语句执行，delete insert update均不可执行。
该特性的作用是：启动spring的优化策略。提高select语句执行效率。
如果该事务中确实没有增删改操作，建议设置为只读事务。
设置哪些异常回滚事务
代码如下：
表示只有发生RuntimeException异常或该异常的子类异常才回滚。
设置哪些异常不回滚事务
代码如下：
表示发生NullPointerException或该异常的子类异常不回滚，其他异常则回滚。
事务的全注解式开发
编写一个类来代替配置文件，代码如下：
测试程序如下：
执行结果：
TESTS PASSED;1 OF 1 TEST - 1SEC 303MS
C:\DEV\JAVA\JDK-17.0.4\BIN\JAVA.EXE
下午 COM.ALIBABA.DRUID.SUPPORT.LOGGING.JAKARTACOMMONSLOGGINGIMPL INFO
10月 23, 2022 3:49:25
信息:{DATASOURCE-1} INITED
JAVA.LANG.NULLPOINTEREXCEPTION CREATEBREAKPOINT : CANNOT INVOKE "STRING.TOSTRING()
"S" IS NULL
BECAUSE
AT COM.POWERNODE.BANK.SERVICE.IMPL.ACC
<4 INT
L.ACCOUNTSERVICEIMPL.TRANSFER(ACCOUNTSERVICEIMPL.JAVA:41)
田
AT ORG:SPRINGTRAMEWORK.AOP.SUPPORT. AOPUTILS.INVOKEJOINPOINPOINTUSINGREFLECTION(AOPUTILS,JAVAI363)
AT ORG,SPRINGFRAMENORK.AOP.FRANENORK.REFLECTIVEHETHODINVOCATION,INVOKEJOINPOINPOINT(REFLECTIVEHETHAD
AT ORG,SPRINGFRAMEWORK.3OP.FRAMEWORK.REFLECTIVEHETHODINVOSATION.PROCEEDCEEDCREFLECTIVEHETHODINVOCATI
数据库表中数据：
对象
TACT@SPRING6(LOCALHOST)-表
[6导
?筛选,三排序
目开始事务
文本
BALANCE
ACTNO
30000
ACT-001
10000
ACT-002
声明式事务之XML实现方式
配置步骤：
●第一步：配置事务管理器
●第二步：配置通知
●第三步：配置切面
记得添加aspectj的依赖：
Spring配置文件如下：
记得添加aop的命名空间。
XML
复制代码
<?xml version="1.0" encoding="UTF-8"?>
<!--配置切面-->
<aop:config>
<aop:pointcutid="txPointcut"expression="execution(* com.powernode.bank.service..*(..))"/>
<!--切面 = 通知 + 切点-->
<aop:advisoradvice-ref="txAdvice"pointcut-ref="txPointcut"/>
</aop:config>
</beans>
将AccountServiceImpl类上的@Transactional注解删除。
编写测试程序：
Java
复制代码
@Test
publicvoidtestTransferXml(){
ApplicationContextapplicationContext=newClassPathXmlApplicationContext("spring2.xml");
AccountServiceaccountService=applicationContext.getBean("accountService",AccountService.class);
try{
accountService.transfer("act-001","act-002",10000);
System.out.println("转账成功");
}catch(Exceptione){
e.printStackTrace();
}
}
执行结果：
OF 1 TEST- 1 T12MS
C:\DEV\JAVA\JDK-17.0.4\BIN\JAVA.EXE
下午:COM.ALIBABA.DRUID.SUPPORT.LOGGING.JAKARTACOMMONSLOGGINGIMPL INFO
10月 23, 2022 3:29:59
信息:{DATASOURCE-1} INITED
ECAUSE "S" IS NULL
JAVA.LANG.NULLPOINTEREXCEPTION CREATE BREAKPOINT : CANNOT INVOKE "STRING.TOSTRING()" BECAUSE
<4 IN
AT COM.POVERNODE:DANK.SERVICE:ZMPL-ACCOUNTSERVICEINDL:TRANSFER(AGEOUNTSERVICEIMPL.JAVA;FAVA:60)
A:343
AT ORG:SPRINGFRAMEWORK.BOP.SUPPORT.AOPUTILSC,INVOKEJOKEJOINPOZNTUSINGREFLECTIONCAOPUT3LS-TAVA;3L
REFLECTIVEMETHODINVOCATION.INVOKEJOINPOINT(REFLECTIVEMETHOD
AT ORG.SPRINGFRAMEWORK.AOP.FRAMEWORK.
数据库表中记录：
TACT@SPRING6(LOCALHOST)-表
对急
目开始事务
6导入
园文本?筛选,三排序
BALANCE
ACTNO
30000
ACT-001
10000
ACT-002
通过测试可以看到配置XML已经起作用了。
