事務(wù)回滾

回滾邏輯如下:

判斷是否存在事務(wù)，只有存在事務(wù)才執(zhí)行回滾 根據(jù)異常類型判斷是否回滾。如果異常類型不符合，仍然會提交事務(wù) 回滾處理

詳細(xì)解析

判斷是否存在事務(wù)，只有存在事務(wù)才執(zhí)行回滾，即是否有@Transactional事務(wù)注解或相關(guān)事務(wù)切面 根據(jù)異常類型判斷是否回滾。如果異常類型不符合，仍然會提交事務(wù)

根據(jù)@Transactional注解中rollbackFor、rollbackForClassName、noRollbackForClassName配置的值，找到最符合ex的異常類型，如果符合的異常類型不是NoRollbackRuleAttribute，則可以執(zhí)行回滾。如果@Transactional沒有配置，則默認(rèn)使用RuntimeException和Error異常。代碼如下：

@Overridepublic 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沒有配置，默認(rèn)調(diào)用父類的 if (winner == null) { logger.trace('No relevant rollback rule found: applying default rules'); return super.rollbackOn(ex); } return !(winner instanceof NoRollbackRuleAttribute);}//super@Overridepublic boolean rollbackOn(Throwable ex) { return (ex instanceof RuntimeException || ex instanceof Error);}

回滾處理

如果存在安全點，則回滾事務(wù)至安全點，這個主要是處理嵌套事務(wù)，回滾安全點的操作還是交給了數(shù)據(jù)庫處理. 當(dāng)前事務(wù)是一個新事務(wù)時，那么直接回滾，使用的是DataSourceTransactionManager事務(wù)管理器，所以調(diào)用DataSourceTransactionManager#doRollback,直接調(diào)用數(shù)據(jù)庫連接的回滾方法。 當(dāng)前存在事務(wù)，但又不是一個新的事務(wù)，只把事務(wù)的狀態(tài)標(biāo)記為read-only，等到事務(wù)鏈執(zhí)行完畢后，統(tǒng)一回滾,調(diào)用DataSourceTransactionManager#doSetRollbackOnly 清空記錄的資源并將掛起的資源恢復(fù)

代碼如下：

private void processRollback(DefaultTransactionStatus status) { try { try { triggerBeforeCompletion(status); //如果有安全點，回滾至安全點 if (status.hasSavepoint()) { if (status.isDebug()) { logger.debug('Rolling back transaction to savepoint'); } status.rollbackToHeldSavepoint(); } //如果是新事務(wù)，回滾事務(wù) else if (status.isNewTransaction()) { if (status.isDebug()) { logger.debug('Initiating transaction rollback'); } doRollback(status); } //如果有事務(wù)但不是新事務(wù)，則把標(biāo)記事務(wù)狀態(tài)，等事務(wù)鏈執(zhí)行完畢后統(tǒng)一回滾 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 { //清空記錄的資源并將掛起的資源恢復(fù) cleanupAfterCompletion(status); }}事務(wù)提交

事務(wù)提交邏輯如下：

判斷事務(wù)是否已經(jīng)完成，如果完成拋出異常 判斷事務(wù)是否已經(jīng)被標(biāo)記成回滾，則執(zhí)行回滾操作 嵌入事務(wù)標(biāo)記回滾，如果嵌入事務(wù)拋出了異常執(zhí)行了回滾，但是在調(diào)用方把嵌入事務(wù)的異常個捕獲沒有拋出，就會執(zhí)行這一步。 提交事務(wù)

代碼如下：

@Overridepublic final void commit(TransactionStatus status) throws TransactionException { //1. 判斷事務(wù)是不是已經(jīng)完成 if (status.isCompleted()) { throw new IllegalTransactionStateException( 'Transaction is already completed - do not call commit or rollback more than once per transaction'); } DefaultTransactionStatus defStatus = (DefaultTransactionStatus) status; //2. 如果在事務(wù)鏈中已經(jīng)被標(biāo)記回滾，那么不會嘗試提交事務(wù)，直接回滾，不過我沒找到在哪設(shè)置這個值 if (defStatus.isLocalRollbackOnly()) { if (defStatus.isDebug()) { logger.debug('Transactional code has requested rollback'); } processRollback(defStatus); return; } //3. shouldCommitOnGlobalRollbackOnly()默認(rèn)返回false，isGlobalRollbackOnly是在嵌入事務(wù)回滾的時候賦值的 if (!shouldCommitOnGlobalRollbackOnly() && defStatus.isGlobalRollbackOnly()) { if (defStatus.isDebug()) { logger.debug('Global transaction is marked as rollback-only but transactional code requested commit'); } processRollback(defStatus); // Throw UnexpectedRollbackException only at outermost transaction boundary // or if explicitly asked to. if (status.isNewTransaction() || isFailEarlyOnGlobalRollbackOnly()) { throw new UnexpectedRollbackException( 'Transaction rolled back because it has been marked as rollback-only'); } return; } //4. 提交事務(wù) processCommit(defStatus);}

以上就是詳解Spring事務(wù)回滾和事務(wù)提交的詳細(xì)內(nèi)容，更多關(guān)于Spring事務(wù)回滾和事務(wù)提交的資料請關(guān)注好吧啦網(wǎng)其它相關(guān)文章！