Spring事务的传播特性和隔离级别 传播特性 1. PROPAGATION_REQUIRED 2. PROPAGATION_SUPPORTS 3. PROPAGATION_MANDATORY 4. PROPAGATION_REQUIRES_NEW 5. PROPAGATION_NOT_SUPPORTED 6. PROPAGATION_NEVER 7. PROPAGATION_NESTED 隔离级别 未提交读 已提交读 可重复读 可序列化 Spring4 TransactionDefinition接口中定义了事务的隔离级别和事务的传播特性 传播特性 例子: class ClassA{ method(){ //逻辑处理1 classB.methodB(); //逻辑处理2 } } class ClassB{ //逻辑处理3 method(); //逻辑处理4 } 1. PROPAGATION_REQUIRED /** * Support a current transaction; create a new one if none exists. * Analogous to the EJB transaction attribute of the same name. * <p>This is typically the default setting of a transaction definition, * and typically defines a transaction synchronization scope. */ int PROPAGATION_REQUIRED = 0; 1 如果事务不存在则创建,如果存在使用存在的事务 例如: class ClassA{ @Transactional(propagation = Propagation.REQUIRED) method(){ //逻辑处理1 classB.methodB(); //逻辑处理2 } } class ClassB{ //逻辑处理3 @Transactional(propagation = Propagation.REQUIRED) method(); //逻辑处理4 } classA.method()创建PROPAGATION_REQUIRED 事务后,classB.mehtod()会使用classA.method()创建的事务,不会创建新的事务。如果逻辑处理2失败抛出异常则classB.mehtod()方法会被回滚。当classA.method()没有打上PROPAGATION_REQUIRED 标志,那么如果classB.mehtod()回滚后,classA.method()逻辑处理1的内容不会被回滚。 2. PROPAGATION_SUPPORTS /** * Support a current transaction; execute non-transactionally if none exists. * */ int PROPAGATION_SUPPORTS = 1; 如果当前存在事务,则使用存在的事务,如果不存在则使用非事务方式处理。 例如: class ClassA{ @Transactional(propagation = Propagation.REQUIRED) method(){ //逻辑处理1 classB.methodB(); //逻辑处理2 } } class ClassB{ //逻辑处理3 @Transactional(propagation = Propagation.SUPPORTS) method(); //逻辑处理4 } classA.method()创建PROPAGATION_REQUIRED 事务后,classB.mehtod()会使用classA.method()创建的事务.如果classA.method()没使用PROPAGATION_REQUIRED创建事务,则classB.mehtod()会以非事务方式运行。 3. PROPAGATION_MANDATORY /** * Support a current transaction; throw an exception if no current transaction * exists. Analogous to the EJB transaction attribute of the same name. * <p>Note that transaction synchronization within a {@code PROPAGATION_MANDATORY} * scope will always be driven by the surrounding transaction. */ int PROPAGATION_MANDATORY = 2; 如果当前存在事务,则使用存在的事务,如果不存在则抛出异常。 例如: class ClassA{ @Transactional(propagation = Propagation.REQUIRED) method(){ //逻辑处理1 classB.methodB(); //逻辑处理2 } } class ClassB{ //逻辑处理3 @Transactional(propagation = Propagation.MANDATORY) method(); //逻辑处理4 } classA.method()创建PROPAGATION_REQUIRED 事务后,classB.mehtod()会使用classA.method()创建的事务.如果classA.method()没使用PROPAGATION_REQUIRED创建事务,则classB.mehtod()会以非事务方式运行。则classB.mehtod()会抛出异常。 4. PROPAGATION_REQUIRES_NEW /** * Create a new transaction, suspending the current transaction if one exists. * Analogous to the EJB transaction attribute of the same name. * <p><b>NOTE:</b> Actual transaction suspension will not work out-of-the-box * on all transaction managers. This in particular applies to * {@link org.springframework.transaction.jta.JtaTransactionManager}, * which requires the {@code javax.transaction.TransactionManager} to be * made available it to it (which is server-specific in standard Java EE). * <p>A {@code PROPAGATION_REQUIRES_NEW} scope always defines its own * transaction synchronizations. Existing synchronizations will be suspended * and resumed appropriately. * @see org.springframework.transaction.jta.JtaTransactionManager#setTransactionManager */ int PROPAGATION_REQUIRES_NEW = 3; 永远创建新的事务,如果当前存在事务则挂起 例如: class ClassA{ @Transactional(propagation = Propagation.REQUIRED) method(){ //逻辑处理1 classB.methodB(); //逻辑处理2 } } class ClassB{ //逻辑处理3 @Transactional(propagation = Propagation.REQUIRES_NEW) method(); //逻辑处理4 } 当classB.method()打上PROPAGATION_REQUIRES_NEW的事务标志,执行classA.method()方法,当执行到classB.method()的时候,会检查上下文有没有事务,如果classA.method()有事务,则会挂起calssA.method()的事务,新建一个属于classB.method()的事务,当classB.method()的事务执行结束的时候,则会唤醒classA.method()的事务。PROPAGATION_REQUIRES_NEW和PROPAGATION_REQUIRED的差别在于回滚,当classB.method()的事务提交后,classA.method()执行失败,只会回滚classA.method不会回滚classB.method(),当classB.method()执行失败,异常被classA.methodA()方法 catch到的话,classA.method()事务不会回滚。 5. PROPAGATION_NOT_SUPPORTED /** * Do not support a current transaction; rather always execute non-transactionally. * Analogous to the EJB transaction attribute of the same name. * <p><b>NOTE:</b> Actual transaction suspension will not work out-of-the-box * on all transaction managers. This in particular applies to * {@link org.springframework.transaction.jta.JtaTransactionManager}, * which requires the {@code javax.transaction.TransactionManager} to be * made available it to it (which is server-specific in standard Java EE). * <p>Note that transaction synchronization is <i>not</i> available within a * {@code PROPAGATION_NOT_SUPPORTED} scope. Existing synchronizations * will be suspended and resumed appropriately. * @see org.springframework.transaction.jta.JtaTransactionManager#setTransactionManager */ int PROPAGATION_NOT_SUPPORTED = 4; 永远使用非事务方式执行,如果当前存在事务则挂起 例如: class ClassA{ @Transactional(propagation = Propagation.REQUIRED) method(){ //逻辑处理1 classB.methodB(); //逻辑处理2 } } class ClassB{ //逻辑处理3 @Transactional(propagation = Propagation.NOT_SUPPORTED) method(); //逻辑处理4 } 当执行到classB.method()方法的时候,检查上下文中存在事务,则挂起classA的事务执行,classB.method()方法执行完成后,唤醒classA.method()的事务。 6. PROPAGATION_NEVER /** * Do not support a current transaction; throw an exception if a current transaction * exists. Analogous to the EJB transaction attribute of the same name. * <p>Note that transaction synchronization is <i>not</i> available within a * {@code PROPAGATION_NEVER} scope. */ int PROPAGATION_NEVER = 5; 不支持事务执行方式,如果存在事务则抛出异常 例如: class ClassA{ @Transactional(propagation = Propagation.REQUIRED) method(){ //逻辑处理1 classB.methodB(); //逻辑处理2 } } class ClassB{ //逻辑处理3 @Transactional(propagation = Propagation.NEVER) method(); //逻辑处理4 } classA.method() 打上了PROPAGATION_REQUIRED标志,创建了事务,当执行到classB.method()方法时,检查到存在活动的事务,则抛出异常。 7. PROPAGATION_NESTED /** * Execute within a nested transaction if a current transaction exists, * behave like {@link #PROPAGATION_REQUIRED} otherwise. There is no * analogous feature in EJB. * <p><b>NOTE:</b> Actual creation of a nested transaction will only work on * specific transaction managers. Out of the box, this only applies to the JDBC * {@link org.springframework.jdbc.datasource.DataSourceTransactionManager} * when working on a JDBC 3.0 driver. Some JTA providers might support * nested transactions as well. * @see org.springframework.jdbc.datasource.DataSourceTransactionManager */ int PROPAGATION_NESTED = 6; 如果存在一个活动的事务,则运行在一个嵌套的事务中. 如果没有活动事务, 安按照PROPAGATION_REQUIRED 事务属性执行 例如:
当classB.method()打上PROPAGATION_NESTED的事务标志后,开始执行classA.method()方法,当执行到classB.method()的时候,此时classA.method()方法有事务,会用当前事务,如果 classB.method()执行失败,只会回滚 classB.method(),不会回滚classA.method()。只有当classA.method()执行完成后才会提交classB.method()的事务,如果classA.method()方法没有事务,classB.method()就会新建一个事务,类似打PROPAGATION_REQUIRED标志的事务。 隔离级别 未提交读 /** * Indicates that dirty reads, non-repeatable reads and phantom reads * can occur. * <p>This level allows a row changed by one transaction to be read by another * transaction before any changes in that row have been committed (a "dirty read"). * If any of the changes are rolled back, the second transaction will have * retrieved an invalid row. * @see java.sql.Connection#TRANSACTION_READ_UNCOMMITTED */ int ISOLATION_READ_UNCOMMITTED = Connection.TRANSACTION_READ_UNCOMMITTED; 未提交读级别容许A事务读取B事务未提交的数据,如果B事务进行了回滚,则A进行了脏读 例子:月末发工资5000RMB,你开启事务给你老婆打款5000RMB,当你还没提交事务的时候,你老婆查询自己的银行卡,发现余额多了5000块,你老婆心里美美的,想着晚上等你回来好好伺候你,但是你这时想留点私房钱,于是进行了事务回滚,修改2000RMB金额后进行了事务提交。最后你老婆收到的打款是2000RMB,这样子就知道你留了私房钱,心里会生气,你回家就被跪搓衣板。 已提交读 /** * Indicates that dirty reads are prevented; non-repeatable reads and * phantom reads can occur. * <p>This level only prohibits a transaction from reading a row * with uncommitted changes in it. * @see java.sql.Connection#TRANSACTION_READ_COMMITTED */ int ISOLATION_READ_COMMITTED = Connection.TRANSACTION_READ_COMMITTED; 可重复读 /** * Indicates that dirty reads and non-repeatable reads are prevented; * phantom reads can occur. * <p>This level prohibits a transaction from reading a row with uncommitted changes * in it, and it also prohibits the situation where one transaction reads a row, * a second transaction alters the row, and the first transaction re-reads the row, * getting different values the second time (a "non-repeatable read"). * @see java.sql.Connection#TRANSACTION_REPEATABLE_READ */ int ISOLATION_REPEATABLE_READ = Connection.TRANSACTION_REPEATABLE_READ; 可序列化 /** * Indicates that dirty reads, non-repeatable reads and phantom reads * are prevented. * <p>This level includes the prohibitions in {@link #ISOLATION_REPEATABLE_READ} * and further prohibits the situation where one transaction reads all rows that * satisfy a {@code WHERE} condition, a second transaction inserts a row * that satisfies that {@code WHERE} condition, and the first transaction * re-reads for the same condition, retrieving the additional "phantom" row * in the second read. * @see java.sql.Connection#TRANSACTION_SERIALIZABLE */ int ISOLATION_SERIALIZABLE = Connection.TRANSACTION_SERIALIZABLE; 原文链接:https://blog.csdn.net/m0_37852667/java/article/details/83831068 |
|