关于spring:四Spring事务回滚

68次阅读

共计 2758 个字符,预计需要花费 7 分钟才能阅读完成。

接第 2 节事务流程,这是第 5 点解析

回滚逻辑如下:

  1. 判断是否存在事务,只有存在事务才执行回滚
  2. 依据异样类型判断是否回滚。如果异样类型不合乎,依然会提交事务
  3. 回滚解决

具体解析

  1. 判断是否存在事务,只有存在事务才执行回滚,即是否有 @Transactional 事务注解或相干事务切面
  2. 依据异样类型判断是否回滚。如果异样类型不合乎,依然会提交事务

依据 @Transactional 注解中 rollbackFor、rollbackForClassName、noRollbackForClassName 配置的值,找到最合乎 ex 的异样类型,如果合乎的异样类型不是 NoRollbackRuleAttribute,则能够执行回滚。
如果 @Transactional 没有配置,则默认应用 RuntimeException 和 Error 异样。
代码如下:

@Override
public boolean rollbackOn(Throwable ex) {if (logger.isTraceEnabled()) {logger.trace("Applying rules to determine whether transaction should rollback on" + ex);
    }

    RollbackRuleAttribute winner = null;
    int deepest = Integer.MAX_VALUE;

    //rollbackRules 保留 @Transactional 注解中 rollbackFor、rollbackForClassName、noRollbackForClassName 配置的值
    if (this.rollbackRules != null) {for (RollbackRuleAttribute rule : this.rollbackRules) {int depth = rule.getDepth(ex);
            if (depth >= 0 && depth < deepest) {
                deepest = depth;
                winner = rule;
            }
        }
    }

    if (logger.isTraceEnabled()) {logger.trace("Winning rollback rule is:" + winner);
    }

    // User superclass behavior (rollback on unchecked) if no rule matches.
    // 若 @Transactional 没有配置,默认调用父类的
    if (winner == null) {logger.trace("No relevant rollback rule found: applying default rules");
        return super.rollbackOn(ex);
    }

    return !(winner instanceof NoRollbackRuleAttribute);
}

//super
@Override
public boolean rollbackOn(Throwable ex) {return (ex instanceof RuntimeException || ex instanceof Error);
}
  1. 回滚解决
  • 如果存在平安点,则回滚事务至平安点,这个次要是解决嵌套事务,回滚平安点的操作还是交给了数据库解决.
  • 以后事务是一个新事务时,那么间接回滚,应用的是 DataSourceTransactionManager 事务管理器,所以调用 DataSourceTransactionManager#doRollback, 间接调用数据库连贯的回滚办法。
  • 以后存在事务,但又不是一个新的事务,只把事务的状态标记为 read-only,等到事务链执行结束后,对立回滚, 调用 DataSourceTransactionManager#doSetRollbackOnly
  • 清空记录的资源并将挂起的资源复原

代码如下:

private void processRollback(DefaultTransactionStatus status) {
    try {
        try {triggerBeforeCompletion(status);
            // 如果有平安点,回滚至平安点
            if (status.hasSavepoint()) {if (status.isDebug()) {logger.debug("Rolling back transaction to savepoint");
                }
                status.rollbackToHeldSavepoint();}
            // 如果是新事务,回滚事务
            else if (status.isNewTransaction()) {if (status.isDebug()) {logger.debug("Initiating transaction rollback");
                }
                doRollback(status);
            }
            // 如果有事务但不是新事务,则把标记事务状态,等事务链执行结束后对立回滚
            else if (status.hasTransaction()) {if (status.isLocalRollbackOnly() || isGlobalRollbackOnParticipationFailure()) {if (status.isDebug()) {logger.debug("Participating transaction failed - marking existing transaction as rollback-only");
                    }
                    doSetRollbackOnly(status);
                }
                else {if (status.isDebug()) {logger.debug("Participating transaction failed - letting transaction originator decide on rollback");
                    }
                }
            }
            else {logger.debug("Should roll back transaction but cannot - no transaction available");
            }
        }
        catch (RuntimeException ex) {triggerAfterCompletion(status, TransactionSynchronization.STATUS_UNKNOWN);
            throw ex;
        }
        catch (Error err) {triggerAfterCompletion(status, TransactionSynchronization.STATUS_UNKNOWN);
            throw err;
        }
        triggerAfterCompletion(status, TransactionSynchronization.STATUS_ROLLED_BACK);
    }
    finally {
        // 清空记录的资源并将挂起的资源复原
        cleanupAfterCompletion(status);
    }
}

正文完
 0