一. 事務的傳播機制/required 跟 required new 的使用與區別
基礎回顧
1.1 事務的隔離級別:
ISOLATION_READ_UNCOMMITTED(讀未提交)
ISOLATION_READ_COMMITTED(讀已提交)
ISOLATION_REPEATABLE_READ(可重復讀)
ISOLATION_SERIALIZABLE(序列化)
ISOLATION_DEFAULT(使用數據庫默認隔離級別)
1.2 臟讀,不可重復讀以及幻讀
臟讀:一個事務讀取到另一事務未提交的更新新據。
不可重復讀:在同一事務中,多次讀取同一數據返回的結果有所不同。換句話說就是,后續讀取可以讀到另一事務已提交的更新數據。
幻讀:事務1正常查詢一次,之后事務2插入滿足事務1查詢條件的新行,再次用事務1查詢,得到多出來的數據。
1.3 事務的傳播屬性:
PROPAGATION_REQUIRED: ?支持當前事務,沒有則新建
PROPAGATION_REQUIRESNEW: ?新建事務,如果當前存在事務,把當前事務掛起
PROPAGATION_SUPPORTS:支持當前事務,如果當前沒有事務,就以非事務方式執行
PROPAGATION_MANDATORY:支持當前事務,如果當前沒有事務,就拋出異常
PROPAGATION_NOT_SUPPORTED:以非事務方式執行,如果當前存在事務,就把當前事務掛起。也就是說業務方法不需要事務
PROPAGATION_NEVER:以非事務方式執行,如果當前存在事務,則拋出異常。也就是說業務方法絕對不能在事務范圍內執行
PROPAGATION_NESTED:如果一個活動的事務存在,則運行在一個嵌套的事務中。 如果沒有活動事務, 則按REQUIRED屬性執行
二. 事務的回滾及傳播機制總結
1. 首先要注意的是 spring 的默認回滾,roll-back = “runtimeException”,即 spring 只回滾接收到的運行時異常,對于其他異常則不回滾;
源碼解析:
/*** Handle a throwable, completing the transaction.* We may commit or roll back, depending on the configuration.* @param txInfo information about the current transaction* @param ex throwable encountered*/protected void completeTransactionAfterThrowing(TransactionInfo txInfo, Throwable ex) {if (txInfo != null && txInfo.hasTransaction()) {if (logger.isTraceEnabled()) {logger.trace("Completing transaction for [" + txInfo.getJoinpointIdentification() +"] after exception: " + ex);}if (txInfo.transactionAttribute.rollbackOn(ex)) {try {txInfo.getTransactionManager().rollback(txInfo.getTransactionStatus());}catch (TransactionSystemException ex2) {logger.error("Application exception overridden by rollback exception", ex);ex2.initApplicationException(ex);throw ex2;} ...
注意上述有一段是?txInfo.transactionAttribute.rollbackOn(ex) 方法,跟進此方法:
/*** The default behavior is as with EJB: rollback on unchecked exception.* Additionally attempt to rollback on Error.* <p>This is consistent with TransactionTemplate's default behavior.*/public boolean rollbackOn(Throwable ex) {return (ex instanceof RuntimeException || ex instanceof Error);}
所以,默認不修改的話,只回滾 RuntimeException 或者 Error;
2. 對此我們可以針對性的添加需要回滾的策略,或者直接顯示設置 roll-back = “Exception”,即回滾所有異常;
3. 需要注意的是:普通情況下,如果異常被 try-catch 處理了,并為進一步拋出異常,那么由于 spring 并未接受到異常, 所以也不會回滾;
?本周討論補充知識:
4. 異常分為 應用層拋出 的異常,以及 數據庫 的異常,如果是前者,可以正常應用 spring 的事務傳播規則,如果是后者,那么一旦發生,數據庫端就已經放棄事務,也就沒有回滾一說();
例: int 10/0 為應用層的異常,可以正常回滾; insert 提交一個已存在的 唯一字段,那么數據庫會報錯,由于事務本身也是由 spring 告之數據庫處理,這種情況下,由于 數據庫已經放棄事務,那么 spring 層面也不能進行事務回滾;
5. 正常情況下不會出現一個接口的 bean 進行嵌套調用,如果有,該情況下,由于代理類不再使用 spring 動態代理中的接口實現的方式,而是采用 cglib 的繼承實現方式,同樣也會導致傳播失效;
6. 事務的傳播機制較為常用的為:required,required-new,support。討論結果為 required-new 跟 required 相比,使用應較為謹慎,原因:同一事務粒度更細更可控,同時也能避免 嵌套事務 可能導致的復雜情況,當然,具體情況需要根據具體業務來定,比如本次討論中的項目,由于每一次操作的對象都要及時被可能存在的另一進程知悉,這種情況下需要 required-new 來實時開啟事務告之其他進程;
查詢總結過程中發現的其它知識點
1. 注意的小點,MySQL 中 InnoDB 支持事務,MyIsam 并不支持事務;
2. spring 已經提供了異常處理機制,其基類為?DataAccessException ,它是 RuntimeExcption 的一個子類,據此可以知道,所有從 數據庫返回的異常,都會被 spring 處理后 歸屬于 RuntimeException 中,其體系如下:
2. 在?org.springframework.jdbc.support包下有sql-error-codes.xml文件,里面預定義了一些錯誤代碼和信息,其 bean 為 HSQL,在 第8行,我們可以發現重復插入的 code 為 -104;
bean id="HSQL" class="org.springframework.jdbc.support.SQLErrorCodes" property name="databaseProductName" valueHSQL Database Engine/value /property property name="badSqlGrammarCodes" value-22,-28/value /property property name="duplicateKeyCodes" value-104/value /property property name="dataIntegrityViolationCodes" value-9/value /property property name="dataAccessResourceFailureCodes" value-80/value /property /bean
3. 此外,我們可以知道發散性的看,我們完全可以自定義數據庫異常的信息,方法如下:
3.1?重新新建一個sql-error-codes.xml代碼,并將它放到類路徑的根目錄下,這樣Spring會發現它并使用我們自定義的文件。同時HSQL的bean的名稱不要改,并將useSqlStateForTranslation置為false,就可以使用我們自己定義的異常類;
bean id="HSQL" class="org.springframework.jdbc.support.SQLErrorCodes" property name="databaseProductName" value="HSQL Database Engine" / property name="useSqlStateForTranslation" value="false" / property name="customTranslations" list ref local="vehicleDuplicateKeyTranslation" / /list /property /bean bean id="vehicleDuplicateKeyTranslation" class="org.springframework.jdbc.support.CustomSQLErrorCodesTranslation" property name="errorCodes" value="-104" / property name="exceptionClass" value="org.ourpioneer.vehicle.exception.VehicleDuplicateKeyException" / /bean
3.2 可以看到結果,控制臺所打印的異常類型為我們自己定義的異常類型;
3.3?除此之外,還可以實現SQLExceptionTranslator接口,并在JDBC模板中注入其實例來實現異常控制
1. package org.ourpioneer.vehicle.exception; 2. import java.sql.SQLException; 3. import org.springframework.dao.DataAccessException; 4. import org.springframework.jdbc.UncategorizedSQLException; 5. import org.springframework.jdbc.support.SQLExceptionTranslator; 6. public class VehicleDuplicateKeyTranslator implements SQLExceptionTranslator { 7. public DataAccessException translate(String task, String sql, 8. SQLException ex) { 9. if (task == null) { 10. task = ""; 11. } 12. if (sql == null) { 13. } 14. if (ex.getErrorCode() == -104) { 15. return new VehicleDuplicateKeyException(buildMessage(task, sql, ex)); 16. } else { 17. return new UncategorizedSQLException(task, sql, ex); 18. } 19. } 20. private String buildMessage(String task, String sql, SQLException ex) { 21. return "數據庫操作異常:" + task + "; SQL [" + sql + "]; " + ex.getMessage(); 22. } 23. }
3.4?translate方法有三個參數,task表示當前操作要進行的任務是什么,sql就是執行的sql語句,ex表示SQLException,我們可以從中獲取異常信息,其處理代碼僅僅捕捉了錯誤碼為-104(HSQL數據庫)的錯誤,其余的配置信息可以根據需要來自行添加。之后要在Spring中重新配置它們:
1. bean id="vehicleDuplicateKeyTranslator" 2. class="org.ourpioneer.vehicle.exception.VehicleDuplicateKeyTranslator"/bean 3. bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate" 4. property name="exceptionTranslator" ref="vehicleDuplicateKeyTranslator" / 5. property name="dataSource" ref="dataSource" / 6. /bean 7. bean id="vehicleDAO" class="org.ourpioneer.vehicle.dao.VehicleDAOImpl" 8. property name="jdbcTemplate" ref="jdbcTemplate" / 9. /bean
3.5 測試結果
?
三. 總結
其實之前對事務的理解是比較基礎的,經過周六的交流和學習,才對事務有了略深一層的理解,但同時也愈發覺得事務的博大精深應遠不止于此,本文大部分都是結合各位?同事的理解和網上的一些資料整理的文章,所以本文作用更多的督促自己的學習進步,希望以后自己能不斷的吸收,整理和提煉知識?。
?
參考文獻:
mysql隔離級別及事務傳播:https://gist.github.com/JagoWang/4555317
mysql事務管理及spring聲明式事務中主動異常拋出使數據庫回滾:http://www.cnblogs.com/wanglonghai/p/4866512.html
Spring訪問數據庫異常的處理方法:http://kb.cnblogs.com/page/89216/