av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

您的位置:首頁技術文章
文章詳情頁

詳解Spring事務回滾和事務提交

瀏覽:2日期:2023-07-18 17:47:18
事務回滾

回滾邏輯如下:

判斷是否存在事務,只有存在事務才執行回滾 根據異常類型判斷是否回滾。如果異常類型不符合,仍然會提交事務 回滾處理

詳細解析

判斷是否存在事務,只有存在事務才執行回滾,即是否有@Transactional事務注解或相關事務切面 根據異常類型判斷是否回滾。如果異常類型不符合,仍然會提交事務

根據@Transactional注解中rollbackFor、rollbackForClassName、noRollbackForClassName配置的值,找到最符合ex的異常類型,如果符合的異常類型不是NoRollbackRuleAttribute,則可以執行回滾。如果@Transactional沒有配置,則默認使用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沒有配置,默認調用父類的 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);}

回滾處理

如果存在安全點,則回滾事務至安全點,這個主要是處理嵌套事務,回滾安全點的操作還是交給了數據庫處理. 當前事務是一個新事務時,那么直接回滾,使用的是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); }}事務提交

事務提交邏輯如下:

判斷事務是否已經完成,如果完成拋出異常 判斷事務是否已經被標記成回滾,則執行回滾操作 嵌入事務標記回滾,如果嵌入事務拋出了異常執行了回滾,但是在調用方把嵌入事務的異常個捕獲沒有拋出,就會執行這一步。 提交事務

代碼如下:

@Overridepublic final void commit(TransactionStatus status) throws TransactionException { //1. 判斷事務是不是已經完成 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. 如果在事務鏈中已經被標記回滾,那么不會嘗試提交事務,直接回滾,不過我沒找到在哪設置這個值 if (defStatus.isLocalRollbackOnly()) { if (defStatus.isDebug()) { logger.debug('Transactional code has requested rollback'); } processRollback(defStatus); return; } //3. shouldCommitOnGlobalRollbackOnly()默認返回false,isGlobalRollbackOnly是在嵌入事務回滾的時候賦值的 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. 提交事務 processCommit(defStatus);}

以上就是詳解Spring事務回滾和事務提交的詳細內容,更多關于Spring事務回滾和事務提交的資料請關注好吧啦網其它相關文章!

標簽: Spring
相關文章:
主站蜘蛛池模板: 中国av在线免费观看 | 久久久久亚洲视频 | 久久久久国产一区二区三区 | 成人亚洲精品 | 精品国产精品一区二区夜夜嗨 | 欧美久久视频 | 日韩在线看片 | 亚洲日韩第一页 | 伊人狠狠 | 毛片免费视频 | 日韩在线播放一区 | 亚洲欧美一区二区三区国产精品 | 中文二区| 一区二区在线观看免费视频 | 精品欧美一区二区三区久久久 | 成人免费看片 | 超碰成人免费 | 精品国产一区二区三区久久影院 | 综合一区二区三区 | a级在线 | 久久综合一区 | 欧美综合在线观看 | 黄色一级电影在线观看 | 精品国产一区二区在线 | 91亚洲国产| 国产一区二区三区在线 | 欧美在线a | 日韩av在线一区 | 国产无人区一区二区三区 | 久久午夜国产精品www忘忧草 | 精品国产一区二区三区免费 | 亚洲精品久久久久久久久久吃药 | 中国黄色毛片视频 | 成人性视频免费网站 | 国产成人精品一区二区三区视频 | 91国内在线观看 | 欧美性大战久久久久久久蜜臀 | 亚洲一区二区三区在线视频 | 日本一区二区高清不卡 | 亚洲免费三级 | 亚洲福利在线视频 |