Java事务&&SpringBoot事务注解

程序员文章站 2022-05-23 11:29:40

...

之前就用到，最近整理下思路、参考一些资料写个小总结，以后可以更方便看咯

事务： 事务是为解决数据安全操作提出的，事务控制实际上就是控制数据的安全访问。

自动提交事务：每条单独的语句都是一个事务。每个语句后都隐含一个commit。（默认）
显式事务：以begin transaction显示开始，以commit或rollback结束。

隐式事务：当连接以隐式事务模式进行操作时，sql server数据库引擎实例将在提交或回滚当前事务后自动启动新事务。无须描述事物的开始，只需提交或回滚每个事务。但每个事务仍以commit或rollback显式结束。连接将隐性事务模式设置为打开之后，当数据库引擎实例首次执行下列任何语句时，都会自动启动一个隐式事务：alter table，insert，create，open ，delete，revoke ，drop，select， fetch ，truncate table，grant，update在发出commit或rollback语句之前，该事务将一直保持有效。在第一个事务被提交或回滚之后，下次当连接执行以上任何语句时，数据库引擎实例都将自动启动一个新事务。该实例将不断地生成隐性事务链，直到隐性事务模式关闭为止。

特性： 事务必须服从ISO/IEC所制定的ACID原则。ACID是原子性（atomicity）、一致性（consistency）、隔离性
（isolation）和持久性（durability）的缩写。

原子性：表示事务执行过程中的任何失败都将导致事务所做的任何修改失效。要么都成功，要么都失败。
一致性：表示当事务执行失败时，所有被该事务影响的数据都应该恢复到事务执行前的状态。
隔离性：表示在事务执行过程中对数据的修改，在事务提交之前对其他事务不可见。一个事务的执行不能被其他事务所影响。
持久性：表示已提交的数据在事务执行失败时，数据的状态都应该正确。一个事务一旦提交，事物的操作便永久性的保存在DB中。即便是在数据库系统遇到故障的情况下也不会丢失提交事务的操作。

**事务并发处理可能引起的问题：**脏读、不可重复读、幻读

脏读(dirty read)：一个事务读取了另一个事务尚未提交的数据，
不可重复读(non-repeatable read) ：一个事务的操作导致另一个事务前后两次读取到不同的数据
幻读(phantom read) ：一个事务的操作导致另一个事务前后两次查询的结果数据量不同。
举例：
事务A、B并发执行时，当A事务update后，B事务select读取到A尚未提交的数据，此时A事务rollback，则B读到的数据是无效的”脏”数据。
当B事务select读取数据后，A事务update操作更改B事务select到的数据，此时B事务再次读去该数据，发现前后两次的数据不一样。
当B事务select读取数据后，A事务insert或delete了一条满足A事务的select条件的记录，此时B事务再次select，发现查询到前次不存在的记录(“幻影”)，或者前次的某个记录不见了。

事务属性包含了5个方面:
传播行为、隔离规则、回滚规则、事务超时、是否只读

7种传播行为：
PROPAGATION_REQUIRED：如果当前没有事务，就新建一个事务，如果已经存在一个事务中，加入到这个事务中。这是最常见的选择。
PROPAGATION_SUPPORTS：支持当前事务，如果当前没有事务，就以非事务方式执行。
PROPAGATION_MANDATORY：支持当前事务，如果当前没有事务，就抛出异常。
PROPAGATION_REQUIRES_NEW：新建事务，如果当前存在事务，把当前事务挂起。
PROPAGATION_NOT_SUPPORTED：以非事务方式执行操作，如果当前存在事务，就把当前事务挂起。
PROPAGATION_NEVER：以非事务方式执行，如果当前存在事务，则抛出异常。
虽然有7种，但是常用的就第一种REQUIRED和第四种REQUIRES_NEW

五个隔离级别：
ISOLATION_DEFAULT：这是一个PlatfromTransactionManager默认的隔离级别，使用数据库默认的事务隔离级别.
另外四个与JDBC的隔离级别相对应；
ISOLATION_READ_UNCOMMITTED：这是事务最低的隔离级别，它充许别外一个事务可以看到这个事务未提交的数据。
这种隔离级别会产生脏读，不可重复读和幻像读。
ISOLATION_READ_COMMITTED：保证一个事务修改的数据提交后才能被另外一个事务读取。另外一个事务不能读取该事务未提交的数据。
这种事务隔离级别可以避免脏读出现，但是可能会出现不可重复读和幻像读。
ISOLATION_REPEATABLE_READ：这种事务隔离级别可以防止脏读，不可重复读。但是可能出现幻像读。
它除了保证一个事务不能读取另一个事务未提交的数据外，还保证了避免下面的情况产生(不可重复读)。
ISOLATION_SERIALIZABLE：这是花费最高代价但是最可靠的事务隔离级别。事务被处理为顺序执行。
除了防止脏读，不可重复读外，还避免了幻像读。

事务类型： JDBC事务、JTA（Java Transaction API）事务、容器事务。

JDBC事务：JDBC 事务是用 Connection 对象控制的。JDBC Connection 接口（ java.sql.Connection ）提供了两种事务模式：自动提交和手工提交。默认是开启的，并且是默认提交。
JDBC定义了保存点SavePoint接口，提供在一个更细粒度的事务控制机制。当设置了一个保存点后，可以rollback到该保存点处的状态，而不是rollback整个事务。DatabaseMetaData接口，提供了一系列JDBC特性支持情况的获取方法。比如，通过DatabaseMetaData.supportsTransactionIsolationLevel方法可以判断对事务隔离级别的支持情况，通过DatabaseMetaData.supportsSavepoints方法可以判断对保存点的支持情况。

java.sql.Connection 的三个方法与事务有关：

setAutoCommit（boolean）:设置是否为自动提交事务，如果true（默认值为true）表示自动提交，也就是每条执行的SQL语句都是一个单独的事务，如果设置为false，需要手动提交事务。
commit（）：提交结束事务。
rollback（）：回滚结束事务。
boolean getAutoCommit()获取事物自动提交方式。

缺点：可以将多个sql放在一个事务里面，JDBC 事务的一个缺点是事务的范围局限于一个数据库连接。一个 JDBC 事务不能跨越多个数据库。
附：1.冗长、重复 2.显示事务控制 3.每个步骤不可获取 4.显示处理受检查异常
//todo写一个完整的jdbc事务

private Connection conn = null;

private PreparedStatement ps = null;

try {
    conn.setAutoCommit(false);  //将自动提交设置为false

    ps.executeUpdate("修改SQL"); //执行修改操作

    ps.executeQuery("查询SQL");  //执行查询操作

    conn.commit();      //当两个操作成功后手动提交

} catch (Exception e) {

    conn.rollback();    //一旦其中一个操作出错都将回滚，使两个操作都不成功

    e.printStackTrace();

}

传统JDBC操作流程：

  1).获取JDBC连接   2).声明SQL   3).预编译SQL   4).执行SQL   5).处理结果集   

  6).释放结果集  7).释放Statement  8).提交事务  9).处理异常并回滚事务 10).释放JDBC连接

Spring容器事务
配置事务属性可通过配置文件或者注解
事务管理器接口PlatformTransactionManager通过getTransaction(TransactionDefinition definition)方法来得到事务，这个方法里面的参数是TransactionDefinition类，这个类就定义了一些基本的事务属性。

public interface TransactionDefinition {
    int getPropagationBehavior(); // 返回事务的传播行为
    int getIsolationLevel(); // 返回事务的隔离级别，事务管理器根据它来控制另外一个事务可以看到本事务内的哪些数据
    int getTimeout();  // 返回事务必须在多少秒内完成
    boolean isReadOnly(); // 事务是否只读，事务管理器能够根据这个返回值进行优化，确保事务是只读的
}

Spring并不直接管理事务，而是提供了多种事务管理器，他们将事务管理的职责委托给Hibernate或者JTA等持久化机制所提供的相关平台框架的事务来实现。 Spring事务管理器的接口是org.springframework.transaction.PlatformTransactionManager，通过这个接口，Spring为各个平台如JDBC、Hibernate等都提供了对应的事务管理器，关于使用不同的事务管理器在配置文件中的使用，请参考Spring容器事务

Public interface PlatformTransactionManager{  
       // 由TransactionDefinition得到TransactionStatus对象
       TransactionStatus getTransaction(TransactionDefinition definition) throws TransactionException;
    // 提交
       Void commit(TransactionStatus status) throws TransactionException;  
       // 回滚
       Void rollback(TransactionStatus status) throws TransactionException;  
}

配置文件(aop拦截器方式)

<tx:advice id="advice" transaction-manager="txManager">
          <tx:attributes>
            <!-- tx:method的属性:
                * name 是必须的,表示与事务属性关联的方法名(业务方法名),对切入点进行细化。通配符 
                     （*）可以用来指定一批关联到相同的事务属性的方法。
                      如：'get*'、'handle*'、'on*Event'等等.
                * propagation：不是必须的,默认值是REQUIRED表示事务传播行为,
                  包括REQUIRED,SUPPORTS,MANDATORY,REQUIRES_NEW,NOT_SUPPORTED,NEVER,NESTED
                * isolation：不是必须的 默认值DEFAULT ，表示事务隔离级别(数据库的隔离级别)
                * timeout：不是必须的 默认值-1(永不超时)，表示事务超时的时间（以秒为单位）
                * read-only：不是必须的 默认值false不是只读的表示事务是否只读？
                * rollback-for： 不是必须的表示将被触发进行回滚的 Exception(s)；以逗号分开。
                   如：'com.foo.MyBusinessException,ServletException'
                * no-rollback-for：不是必须的表示不被触发进行回滚的 Exception(s),以逗号分开。                                        
                   如：'com.foo.MyBusinessException,ServletException'   
                任何 RuntimeException 将触发事务回滚，但是任何 checked Exception 将不触发事务回滚                     
            -->
             <tx:method name="save*" propagation="REQUIRED" isolation="DEFAULT" read-only="false"/>
             <tx:method name="update*" propagation="REQUIRED" isolation="DEFAULT" read-only="false"/>
             <tx:method name="delete*" propagation="REQUIRED" isolation="DEFAULT" read-only="false"  rollback-for="Exception"/>
             <!-- 其他的方法之只读的 -->
             <tx:method name="*" read-only="true"/>
          </tx:attributes>
</tx:advice>

注解(SpringBoot默认使用这个)

@Transactional只能被应用到public方法上,对于其它非public的方法,如果标记了@Transactional也不会报错,但方法没有事务功能.一般注解在serviceImpl上
默认情况下,一个有事务方法, 遇到RuntimeException 时会回滚 . 遇到受检查的异常是不会回滚的. 要想所有异常都回滚,要加上 @Transactional( rollbackFor={Exception.class,其它异常})

@Transactional(
    readOnly = false, //读写事务
    timeout = -1 ,     //事务的超时时间，-1为无限制
    noRollbackFor = ArithmeticException.class, //遇到指定的异常不回滚
    isolation = Isolation.DEFAULT, //事务的隔离级别，此处使用后端数据库的默认隔离级别
    propagation = Propagation.REQUIRED //事务的传播行为
)

回滚
默认配置下 Spring 只会回滚运行时只有未检查异常（继承自 RuntimeException 的异常）或者 Error会回滚。

启动类加上@EnableTransactionManagement注解，开启事务支持（其实默认是开启的）。
添加注解@Transactional
try{}catch{}抛出异常
1、catch内抛出异常：throw new RuntimeException();
2、catch内手动回滚： TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();

让Exception异常也进行回滚操作，在调用该方法前加上: @Transactional(rollbackFor = Exception.class)
让RuntimeException不进行回滚操作，在调用该方法前加上： @Transactional(noRollbackFor = RuntimeException.class)

在service层添加注解，成功执行，controller其他位置出现异常，则不会回滚

关于注解加载源码分析：注解加载源码分析
感谢：1、https://www.cnblogs.com/lmyupupblogs/p/10248099.html#2267044042
2、https://blog.csdn.net/m0_37779570/article/details/81352587?utm_medium=distribute.pc_relevant.none-task-blog-BlogCommendFromMachineLearnPai2-3.nonecase&depth_1-utm_source=distribute.pc_relevant.none-task-blog-BlogCommendFromMachineLearnPai2-3.nonecase
3、https://blog.csdn.net/baidu_39322753/article/details/100073169?utm_medium=distribute.pc_relevant_right.none-task-blog-BlogCommendFromMachineLearnPai2-2.nonecase&depth_1-utm_source=distribute.pc_relevant_right.none-task-blog-BlogCommendFromMachineLearnPai2-2.nonecase

Java事务&&SpringBoot事务注解

小白的springboot之路（七）、事务支持

Java基于JDBC实现事务，银行转账及货物进出库功能示例

Java与Oracle实现事务（JDBC事务）实例详解

java事务回滚失败问题分析

Springboot-dubbo-fescar 阿里分布式事务的实现方法

Java基于JDBC实现事务，银行转账及货物进出库功能示例

java事务回滚失败问题分析

springboot中事务管理@Transactional的注意事项与使用场景

详解Springboot事务管理

浅谈SpringBoot之事务处理机制