SpringBoot各種事務(wù)操作實(shí)戰(zhàn)(自動(dòng)回滾、手動(dòng)回滾、部分回滾)
概念
事務(wù)定義
事務(wù),就是一組操作數(shù)據(jù)庫的動(dòng)作集合。事務(wù)是現(xiàn)代數(shù)據(jù)庫理論中的核心概念之一。如果一組處理步驟或者全部發(fā)生或者一步也不執(zhí)行,我們稱該組處理步驟為一個(gè)事務(wù)。當(dāng)所有的步驟像一個(gè)操作一樣被完整地執(zhí)行,我們稱該事務(wù)被提交。由于其中的一部分或多步執(zhí)行失敗,導(dǎo)致沒有步驟被提交,則事務(wù)必須回滾到最初的系統(tǒng)狀態(tài)。
事務(wù)特點(diǎn)
- 原子性:一個(gè)事務(wù)中所有對(duì)數(shù)據(jù)庫的操作是一個(gè)不可分割的操作序列,要么全做要么全不做
- 一致性:數(shù)據(jù)不會(huì)因?yàn)槭聞?wù)的執(zhí)行而遭到破壞
- 隔離性:一個(gè)事務(wù)的執(zhí)行,不受其他事務(wù)的干擾,即并發(fā)執(zhí)行的事務(wù)之間互不干擾
- 持久性:一個(gè)事務(wù)一旦提交,它對(duì)數(shù)據(jù)庫的改變就是永久的。
事務(wù)實(shí)現(xiàn)機(jī)制
Spring為事務(wù)管理提供了豐富的功能支持。Spring 事務(wù)管理分為編程式和聲明式的兩種方式。
- 編程式事務(wù)管理: 編程式事務(wù)管理使用 TransactionTemplate 或者直接使用底層的 PlatformTransactionManager。對(duì)于編程式事務(wù)管理,spring 推薦使用 TransactionTemplate。
- 聲明式事務(wù)管理: 建立在 AOP 之上的。其本質(zhì)是對(duì)方法前后進(jìn)行攔截,然后在目標(biāo)方法開始之前創(chuàng)建或者加入一個(gè)事務(wù),在執(zhí)行完目標(biāo)方法之后根據(jù)執(zhí)行情況提交或者回滾事務(wù)。
- 聲明式事務(wù)管理不需要入侵代碼,更快捷而且簡單,推薦使用。
聲明式事務(wù)有兩種方式:
- 一種是在配置文件(xml)中做相關(guān)的事務(wù)規(guī)則聲明(因?yàn)楹苌儆帽疚牟恢v解)
- 另一種是基于 @Transactional 注解的方式。注釋配置是目前流行的使用方式,推薦使用。
在應(yīng)用系統(tǒng)調(diào)用聲明了 @Transactional 的目標(biāo)方法時(shí),Spring Framework 默認(rèn)使用 AOP 代理,在代碼運(yùn)行時(shí)生成一個(gè)代理對(duì)象,根據(jù) @Transactional 的屬性配置信息,這個(gè)代理對(duì)象決定該聲明 @Transactional 的目標(biāo)方法是否由攔截器 TransactionInterceptor 來使用攔截,在 TransactionInterceptor 攔截時(shí),會(huì)在目標(biāo)方法開始執(zhí)行之前創(chuàng)建并加入事務(wù),并執(zhí)行目標(biāo)方法的邏輯,最后根據(jù)執(zhí)行情況是否出現(xiàn)異常,利用抽象事務(wù)管理器 AbstractPlatformTransactionManager 操作數(shù)據(jù)源 DataSource 提交或回滾事務(wù)。
Spring AOP 代理有 CglibAopProxy 和 JdkDynamicAopProxy 兩種,以 CglibAopProxy 為例,對(duì)于 CglibAopProxy,需要調(diào)用其內(nèi)部類的 DynamicAdvisedInterceptor 的 intercept 方法。對(duì)于 JdkDynamicAopProxy,需要調(diào)用其 invoke 方法。
開啟事務(wù)
注解 @Transactional 的使用
注解 @Transactional 常用配置
參 數(shù) 名 稱 | 功 能 描 述 |
---|---|
readOnly | 用于設(shè)置當(dāng)前事務(wù)是否為只讀事務(wù),設(shè)置為 true 表示只讀,false 則表示可讀寫,默認(rèn)值為 false。例如:@Transactional(readOnly=true) |
rollbackFor | 用于設(shè)置需要進(jìn)行回滾的異常類數(shù)組,當(dāng)方法中拋出指定異常數(shù)組中的異常時(shí),則進(jìn)行事務(wù)回滾。例如:指定單一異常類:@Transactional(rollbackFor=RuntimeException.class);指定多個(gè)異常類:@Transactional(rollbackFor={RuntimeException.class, Exception.class}) |
transactionManager / value | 多個(gè)事務(wù)管理器托管在 Spring 容器中時(shí),指定事務(wù)管理器的 bean 名稱 |
rollbackForClassName | 用于設(shè)置需要進(jìn)行回滾的異常類名稱數(shù)組,當(dāng)方法中拋出指定異常名稱數(shù)組中的異常時(shí),則進(jìn)行事務(wù)回滾。例如:指定單一異常類名稱 @Transactional(rollbackForClassName=”RuntimeException”) 指定多個(gè)異常類名稱:@Transactional(rollbackForClassName={“RuntimeException”,”Exception”}) |
noRollbackFor | 用于設(shè)置不需要進(jìn)行回滾的異常類數(shù)組,當(dāng)方法中拋出指定異常數(shù)組中的異常時(shí),不進(jìn)行事務(wù)回滾。例如:指定單一異常類:@Transactional(noRollbackFor=RuntimeException.class) 指定多個(gè)異常類:@Transactional(noRollbackFor={RuntimeException.class, Exception.class}) |
noRollbackForClassName | 用于設(shè)置不需要進(jìn)行回滾的異常類名稱數(shù)組,當(dāng)方法中拋出指定異常名稱數(shù)組中的異常時(shí),不進(jìn)行事務(wù)回滾。例如:指定單一異常類名稱:@Transactional(noRollbackForClassName=”RuntimeException”) 指定多個(gè)異常類名稱:@Transactional(noRollbackForClassName={“RuntimeException”, ”Exception”}) |
propagation | 用于設(shè)置事務(wù)的傳播行為。例如:@Transactional(propagation=Propagation.NOT_SUPPORTED, readOnly=true) |
isolation | 用于設(shè)置底層數(shù)據(jù)庫的事務(wù)隔離級(jí)別,事務(wù)隔離級(jí)別用于處理多事務(wù)并發(fā)的情況,通常使用數(shù)據(jù)庫的默認(rèn)隔離級(jí)別即可,基本不需要進(jìn)行設(shè)置 |
timeout | 該屬性用于設(shè)置事務(wù)的超時(shí)秒數(shù),默認(rèn)值為 - 1 表示永不超時(shí) 事物超時(shí)設(shè)置:@Transactional(timeout=30) ,設(shè)置為 30 秒 |
Propagation 的屬性(事務(wù)的傳播行為)
例如:@Transactional(propagation=Propagation.NOT_SUPPORTED,readOnly=true)
Propagation 屬性 | 含義 |
---|---|
REQUIRED | 默認(rèn)值 在有 transaction 狀態(tài)下執(zhí)行;如當(dāng)前沒有 transaction,則創(chuàng)建新的 transaction; |
SUPPORTS | 如當(dāng)前有 transaction,則在 transaction 狀態(tài)下執(zhí)行;如果當(dāng)前沒有 transaction,在無 transaction 狀態(tài)下執(zhí)行; |
MANDATORY | 必須在有 transaction 狀態(tài)下執(zhí)行,如果當(dāng)前沒有 transaction,則拋出異常 IllegalTransactionStateException; |
REQUIRES_NEW | 創(chuàng)建新的 transaction 并執(zhí)行;如果當(dāng)前已有 transaction,則將當(dāng)前 transaction 掛起; |
NOT_SUPPORTED | 在無 transaction 狀態(tài)下執(zhí)行;如果當(dāng)前已有 transaction,則將當(dāng)前 transaction 掛起; |
NEVER | 在無 transaction 狀態(tài)下執(zhí)行;如果當(dāng)前已有 transaction,則拋出異常 IllegalTransactionStateException。 |
事務(wù) 5 種隔離級(jí)別
例如:@Transactional(isolation = Isolation.READ_COMMITTED)
隔離級(jí)別 | 含義 |
---|---|
DEFAULT | 這是一個(gè) PlatfromTransactionManager 默認(rèn)的隔離級(jí)別,使用數(shù)據(jù)庫默認(rèn)的事務(wù)隔離級(jí)別另外四個(gè)與 JDBC 的隔離級(jí)別相對(duì)應(yīng); |
READ_UNCOMMITTED | 最低的隔離級(jí)別。事實(shí)上我們不應(yīng)該稱其為隔離級(jí)別,因?yàn)樵谑聞?wù)完成前,其他事務(wù)可以看到該事務(wù)所修改的數(shù)據(jù)。而在其他事務(wù)提交前,該事務(wù)也可以看到其他事務(wù)所做的修改??赡軐?dǎo)致臟,幻,不可重復(fù)讀 |
READ_COMMITTED | 大多數(shù)數(shù)據(jù)庫的默認(rèn)級(jí)別。在事務(wù)完成前,其他事務(wù)無法看到該事務(wù)所修改的數(shù)據(jù)。遺憾的是,在該事務(wù)提交后,你就可以查看其他事務(wù)插入或更新的數(shù)據(jù)。這意味著在事務(wù)的不同點(diǎn)上,如果其他事務(wù)修改了數(shù)據(jù),你就會(huì)看到不同的數(shù)據(jù)??煞乐古K讀,但幻讀和不可重復(fù)讀仍可以發(fā)生。 |
REPEATABLE_READ | 比 ISOLATION_READ_COMMITTED 更嚴(yán)格,該隔離級(jí)別確保如果在事務(wù)中查詢了某個(gè)數(shù)據(jù)集,你至少還能再次查詢到相同的數(shù)據(jù)集,即使其他事務(wù)修改了所查詢的數(shù)據(jù)。然而如果其他事務(wù)插入了新數(shù)據(jù),你就可以查詢到該新插入的數(shù)據(jù)??煞乐古K讀,不可重復(fù)讀,但幻讀仍可能發(fā)生。 |
SERIALIZABLE | 完全服從 ACID 的隔離級(jí)別,確保不發(fā)生臟讀、不可重復(fù)讀和幻影讀。這在所有隔離級(jí)別中也是最慢的,因?yàn)樗ǔJ峭ㄟ^完全鎖定當(dāng)前事務(wù)所涉及的數(shù)據(jù)表來完成的。代價(jià)最大、可靠性最高的隔離級(jí)別,所有的事務(wù)都是按順序一個(gè)接一個(gè)地執(zhí)行。避免所有不安全讀取。 |
使用注意事項(xiàng)(防止事務(wù)失效)
在具體的類(或類的方法)上使用 @Transactional 注解,而不要使用在類所要實(shí)現(xiàn)的任何接口上。
@Transactional 注解應(yīng)該只被應(yīng)用在 public 修飾的方法上。 如果你在 protected、private 或者 package-visible 的方法上使用 該注解,它也不會(huì)報(bào)錯(cuò)(IDEA 會(huì)有提示), 但事務(wù)并沒有生效。
被外部調(diào)用的公共方法 A 有兩個(gè)進(jìn)行了數(shù)據(jù)操作的子方法 B 和子方法 C 的事務(wù)注解說明:
被外部調(diào)用的公共方法 A 未聲明事務(wù) @Transactional,子方法 B 和 C 若是其他類的方法且各自聲明事務(wù),則事務(wù)由子方法 B 和 C 各自控制
被外部調(diào)用的公共方法 A 未聲明事務(wù) @Transactional,子方法 B 和 C 若是本類的方法,則無論子方法 B 和 C 是否聲明事務(wù),事務(wù)均不會(huì)生效
被外部調(diào)用的公共方法 A 聲明事務(wù) @Transactional,無論子方法 B 和 C 是不是本類的方法,無論子方法 B 和 C 是否聲明事務(wù),事務(wù)均由公共方法 A 控制
被外部調(diào)用的公共方法 A 聲明事務(wù) @Transactional,子方法運(yùn)行異常,但運(yùn)行異常被子方法自己
try-catch
處理了,則事務(wù)回滾是不會(huì)生效的!如果想要事務(wù)回滾生效,需要將子方法的事務(wù)控制交給調(diào)用的方法來處理:
- 方案 1:子方法中不用
try-catch
處理運(yùn)行異常 - 方案 2:子方法的 catch 里面將運(yùn)行異常拋出【throw new RuntimeException();】
- 方案 1:子方法中不用
默認(rèn)情況下,Spring 會(huì)對(duì) unchecked 異常進(jìn)行事務(wù)回滾,也就是默認(rèn)對(duì) RuntimeException() 異?;蚴瞧渥宇愡M(jìn)行事務(wù)回滾。
如果是 checked 異常則不回滾,例如空指針異常、算數(shù)異常等會(huì)被回滾;文件讀寫、網(wǎng)絡(luò)問題 Spring 就沒法回滾。
若想對(duì)所有異常(包括自定義異常)都起作用,注解上面需配置異常類型:@Transactional(rollbackFor = Exception.class
數(shù)據(jù)庫要支持事務(wù),如果是 mysql,要使用 innodb 引擎,myisam 不支持事務(wù)
事務(wù) @Transactional 由 spring 控制時(shí),它會(huì)在拋出異常的時(shí)候進(jìn)行回滾。如果自己使用 try-catch 捕獲處理了,是不生效的。如果想事務(wù)生效可以進(jìn)行手動(dòng)回滾或者在 catch 里面將異常拋出【throw new RuntimeException();】
方案一:手動(dòng)拋出運(yùn)行時(shí)異常(缺陷是不能在 catch 代碼塊自定義返回值)
try{ .... }catch(Exception e){ logger.error("",e); throw new RuntimeException(e); }
方案二:手動(dòng)進(jìn)行回滾【 TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); 】
try{ ... }catch(Exception e){ log.error("fail",e); TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return false; }
@Transactional 可以放在 Controller 下面直接起作用,看到網(wǎng)上好多同學(xué)說要放到 @Component 下面或者 @Service 下面,經(jīng)過試驗(yàn),可以不用放在這兩個(gè)下面也起作用。
@Transactional 引入包問題,它有兩個(gè)包:
import javax.transaction.Transactional; // 和 import org.springframework.transaction.annotation.Transactional; // 推薦
這兩個(gè)都可以用,對(duì)比了一下他們兩個(gè)的方法和屬性,發(fā)現(xiàn)后面的比前面的強(qiáng)大。建議使用后面的。
使用場(chǎng)景
自動(dòng)回滾
直接拋出,不 try/catch
@Override @Transactional(rollbackFor = Exception.class) public Object submitOrder() throws Exception { success(); //假如exception這個(gè)操作數(shù)據(jù)庫的方法會(huì)拋出異常,方法success()對(duì)數(shù)據(jù)庫的操作會(huì)回滾。 exception(); return ApiReturnUtil.success(); }
手動(dòng)回滾
進(jìn)行 try/catch,回滾并拋出
@Override @Transactional(rollbackFor = Exception.class) public Object submitOrder (){ success(); try { exception(); } catch (Exception e) { e.printStackTrace(); // 手動(dòng)回滾事務(wù) TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return ApiReturnUtil.error(); } return ApiReturnUtil.success(); }
回滾部分異常
使用【Object savePoint = TransactionAspectSupport.currentTransactionStatus().createSavepoint(); 】設(shè)置回滾點(diǎn)。
使用【TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint);】回滾到 savePoint。
@Override @Transactional(rollbackFor = Exception.class) public Object submitOrder (){ success(); //只回滾以下異常, Object savePoint = TransactionAspectSupport.currentTransactionStatus().createSavepoint(); try { exception(); } catch (Exception e) { e.printStackTrace(); // 手工回滾事務(wù) TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint); return ApiReturnUtil.error(); } return ApiReturnUtil.success(); }
手動(dòng)創(chuàng)建、提交、回滾事務(wù)
PlatformTransactionManager 這個(gè)接口中定義了三個(gè)方法 getTransaction 創(chuàng)建事務(wù),commit 提交事務(wù),rollback 回滾事務(wù)。它的實(shí)現(xiàn)類是 AbstractPlatformTransactionManager。
@Autowired priDataSourceTransactionManager dataSourceTransactionManager; @Autowired TransactionDefinition transactionDefinition; // 手動(dòng)創(chuàng)建事務(wù) TransactionStatus transactionStatus = dataSourceTransactionManager.getTransaction(transactionDefinition); // 手動(dòng)提交事務(wù) dataSourceTransactionManager.commit(transactionStatus); // 手動(dòng)回滾事務(wù)。(最好是放在catch 里面,防止程序異常而事務(wù)一直卡在哪里未提交) dataSourceTransactionManager.rollback(transactionStatus);
PlatformTransactionManager 手動(dòng)提交事務(wù),設(shè)置隔離級(jí)別
@Autowired private PlatformTransactionManager transactionManager; public void test() { DefaultTransactionDefinition defaultTransactionDefinition = new DefaultTransactionDefinition(); defaultTransactionDefinition.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED); TransactionStatus transactionStatus = transactionManager.getTransaction(defaultTransactionDefinition); try { // 數(shù)據(jù)庫操作 //提交事務(wù) transactionManager.commit(transactionStatus); } catch (Exception e) { log.error("xxxx", e); //回滾事務(wù) transactionManager.rollback(transactionStatus); } }
事務(wù)失效不回滾的原因及解決方案
異常被捕獲導(dǎo)致事務(wù)失效
在 spring boot 中,使用事務(wù)非常簡單,直接在方法上面加入 @Transactional 就可以實(shí)現(xiàn)。
@GetMapping("delete") @ResponseBody @Transactional public void delete(@RequestParam("id") int id) { try { //delete country this.repository.delete(id); if(id == 1){ throw Exception("測(cè)試事務(wù)"); } //delete city this.repository.deleteByCountryId(id); }catch (Exception e){ logger.error("delete false:" + e.getMessage()); } }
發(fā)現(xiàn)事務(wù)不回滾,即 this.repository.delete(id);成功把數(shù)據(jù)刪除了。
原因:
默認(rèn) spring 事務(wù)只在發(fā)生未被捕獲的 RuntimeException 時(shí)才回滾。
spring aop 異常捕獲原理:被攔截的方法需顯式拋出異常,并不能經(jīng)任何處理,這樣 aop 代理才能捕獲到方法的異常,才能進(jìn)行回滾,默認(rèn)情況下 aop 只捕獲 RuntimeException 的異常,但可以通過配置來捕獲特定的異常并回滾。
換句話說在 service 的方法中不使用 try catch 或者在 catch 中最后加上 throw new RuntimeExcetpion() 拋出運(yùn)行異常,這樣程序異常時(shí)才能被 aop 捕獲進(jìn)而回滾。
解決方案:
<dependency> <groupId>org.springframework</groupId> <artifactId>spring-aspects</artifactId> <version>4.3.2.RELEASE</version> </dependency> <dependency> <groupId>org.aspectj</groupId> <artifactId>aspectjrt</artifactId> <version>1.8.9</version> </dependency> <plugin> <groupId>org.codehaus.mojo</groupId> <artifactId>aspectj-maven-plugin</artifactId> <version>1.9</version> <configuration> <showWeaveInfo>true</showWeaveInfo> <aspectLibraries> <aspectLibrary> <groupId>org.springframework</groupId> <artifactId>spring-aspects</artifactId> </aspectLibrary> </aspectLibraries> </configuration> <executions> <execution> <goals> <goal>compile</goal> <goal>test-compile</goal> </goals> </execution> </executions> </plugin>
解決方案
方案 1、在類上(或者最外層的公共方法)加事務(wù)
@Service @Slf4j public class MyTransactional { // 最外層公共方法。自動(dòng)回滾事務(wù)方式,insertOrder()方法報(bào)錯(cuò)后事務(wù)回滾,且線程中止,后續(xù)邏輯無法執(zhí)行 @Transactional public void test1() { this.insertOrder(); System.out.println("11111111111111111"); } // 最外層公共方法。手動(dòng)回滾事務(wù)方式,insertOrder()方法報(bào)錯(cuò)后事務(wù)回滾,可以繼續(xù)執(zhí)行后續(xù)邏輯 @Transactional public void test2() { try { insertOrder(); } catch (Exception e) { log.error("faild to ...", e); // 手動(dòng)回滾事務(wù) TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); // 其他操作 } // 其他操作 } // 進(jìn)行數(shù)據(jù)庫操作的方法(private 或 public 均可) private void insertOrder() { //insert log info //insertOrder //updateAccount } }
方案 2、使用 AspectJ 取代 Spring AOP 代理
上面的兩個(gè)問題 @Transactional 注解只應(yīng)用到 public 方法和自調(diào)用問題,是由于使用 Spring AOP 代理造成的。為解決這兩個(gè)問題,可以使用 AspectJ 取代 Spring AOP 代理。
需要將下面的 AspectJ 信息添加到 xml 配置信息中。
AspectJ 的 xml 配置信息
<tx:annotation-driven mode="aspectj" /> <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property /> </bean> </bean class="org.springframework.transaction.aspectj.AnnotationTransactionAspect" factory-method="aspectOf"> <property /> </bean>
同時(shí)在 Maven 的 pom 文件中加入 spring-aspects 和 aspectjrt 的 dependency 以及 aspectj-maven-plugin。
AspectJ 的 pom 配置信息
方案 1:例如 service 層處理事務(wù),那么 service 中的方法中不做異常捕獲,或者在 catch 語句中最后增加
throw new RuntimeException();
語句,以便讓 aop 捕獲異常再去回滾,并且在 service 的上層要繼續(xù)捕獲這個(gè)異常。
方案 2:在 service 層方法的 catch 語句中進(jìn)行手動(dòng)回滾,這樣上層就無需去處理異常。
@GetMapping("delete") @ResponseBody @Transactional public Object delete(@RequestParam("id") int id){ if (id < 1){ return new MessageBean(101,"parameter wrong: id = " + id) ; } try { //delete country this.countryRepository.delete(id); //delete city this.cityRepository.deleteByCountryId(id); return new MessageBean(200,"delete success"); }catch (Exception e){ logger.error("delete false:" + e.getMessage()); // 手動(dòng)回滾 TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return new MessageBean(101,"delete false"); } }
自調(diào)用導(dǎo)致事務(wù)失效
問題描述及原因
在 Spring 的 AOP 代理下,只有目標(biāo)方法由外部調(diào)用,目標(biāo)方法才由 Spring 生成的代理對(duì)象來管理,否則會(huì)造成自調(diào)用問題。
若同一類中的 沒有 @Transactional 注解的方法 內(nèi)部調(diào)用 有 @Transactional 注解的方法,有 @Transactional 注解的方法的事務(wù)被忽略,不會(huì)發(fā)生回滾。見 示例代碼展示。
自調(diào)用問題示例:
@Service public class OrderService { private void insert() { insertOrder(); } @Transactional public void insertOrder() { //insert log info //insertOrder //updateAccount } } // insertOrder() 盡管有@Transactional 注解,但它被內(nèi)部方法 insert()調(diào)用,事務(wù)被忽略,出現(xiàn)異常事務(wù)不會(huì)發(fā)生回滾,并且會(huì)報(bào)錯(cuò)類似于:org.springframework.transaction.NoTransactionException: No transaction aspect-managed TransactionStatus in scope(翻譯:沒有Transaction無法回滾事務(wù)。自調(diào)用導(dǎo)致@Transactional 失效。)
自調(diào)用失效原因:
spring 里事務(wù)是用注解配置的,當(dāng)一個(gè)方法沒有接口,單單只是一個(gè)內(nèi)部方法時(shí),事務(wù)的注解是不起作用的,需要回滾時(shí)就會(huì)報(bào)錯(cuò)。
出現(xiàn)這個(gè)問題的根本原因是:
@Transactional 的實(shí)現(xiàn)原理是 AOP,AOP 的實(shí)現(xiàn)原理是動(dòng)態(tài)代理,而自調(diào)用時(shí)并不存在代理對(duì)象的調(diào)用,也就不會(huì)產(chǎn)生基于 AOP 的事務(wù)回滾操作
雖然可以直接從容器中獲取代理對(duì)象,但這樣有侵入之嫌,不推薦。
<dependency> <groupId>org.springframework</groupId> <artifactId>spring-aspects</artifactId> <version>4.3.2.RELEASE</version> </dependency> <dependency> <groupId>org.aspectj</groupId> <artifactId>aspectjrt</artifactId> <version>1.8.9</version> </dependency> <plugin> <groupId>org.codehaus.mojo</groupId> <artifactId>aspectj-maven-plugin</artifactId> <version>1.9</version> <configuration> <showWeaveInfo>true</showWeaveInfo> <aspectLibraries> <aspectLibrary> <groupId>org.springframework</groupId> <artifactId>spring-aspects</artifactId> </aspectLibrary> </aspectLibraries> </configuration> <executions> <execution> <goals> <goal>compile</goal> <goal>test-compile</goal> </goals> </execution> </executions> </plugin>
其他
事務(wù)提交方式
默認(rèn)情況下,數(shù)據(jù)庫處于自動(dòng)提交模式。每一條語句處于一個(gè)單獨(dú)的事務(wù)中,在這條語句執(zhí)行完畢時(shí),如果執(zhí)行成功則隱式的提交事務(wù),如果執(zhí)行失敗則隱式的回滾事務(wù)。
對(duì)于正常的事務(wù)管理,是一組相關(guān)的操作處于一個(gè)事務(wù)之中,因此必須關(guān)閉數(shù)據(jù)庫的自動(dòng)提交模式。不過,這個(gè)我們不用擔(dān)心,spring 會(huì)將底層連接的【自動(dòng)提交特性】設(shè)置為 false 。也就是在使用 spring 進(jìn)行事務(wù)管理的時(shí)候,spring 會(huì)將【是否自動(dòng)提交】設(shè)置為 false,等價(jià)于 JDBC 中的 connection.setAutoCommit(false); ,在執(zhí)行完之后在進(jìn)行提交 connection.commit(); 。
事務(wù)回滾規(guī)則
指示 spring 事務(wù)管理器回滾一個(gè)事務(wù)的推薦方法是在當(dāng)前事務(wù)的上下文內(nèi)拋出異常。spring 事務(wù)管理器會(huì)捕捉任何未處理的異常,然后依據(jù)規(guī)則決定是否回滾拋出異常的事務(wù)。
默認(rèn)配置下,spring 只有在拋出的異常為運(yùn)行時(shí) unchecked 異常時(shí)才回滾該事務(wù),也就是拋出的異常為 RuntimeException 的子類 (Errors 也會(huì)導(dǎo)致事務(wù)回滾),而拋出 checked 異常則不會(huì)導(dǎo)致事務(wù)回滾。
可以明確的配置在拋出那些異常時(shí)回滾事務(wù),包括 checked 異常。也可以明確定義那些異常拋出時(shí)不回滾事務(wù)。
事務(wù)并發(fā)會(huì)產(chǎn)生的問題
術(shù)語 | 含義 |
---|---|
臟讀 | A 事務(wù)讀取到了 B 事務(wù)還未提交的數(shù)據(jù),如果 B 未提交的事務(wù)回滾了,那么 A 事務(wù)讀取的數(shù)據(jù)就是無效的,這就是數(shù)據(jù)臟讀 |
不可重復(fù)讀 | 在同一個(gè)事務(wù)中,多次讀取同一數(shù)據(jù)返回的結(jié)果不一致,這是由于讀取事務(wù)在進(jìn)行操作的過程中,如果出現(xiàn)更新事務(wù),它必須等待更新事務(wù)執(zhí)行成功提交完成后才能繼續(xù)讀取數(shù)據(jù),這就導(dǎo)致讀取事務(wù)在前后讀取的數(shù)據(jù)不一致的狀況出現(xiàn) |
幻讀 | A 事務(wù)讀取了幾行記錄后,B 事務(wù)插入了新數(shù)據(jù),并且提交了插入操作,在后續(xù)操作中 A 事務(wù)就會(huì)多出幾行原本不存在的數(shù)據(jù),就像 A 事務(wù)出現(xiàn)幻覺,這就是幻讀 |
第一類丟失更新
在沒有事務(wù)隔離的情況下,兩個(gè)事務(wù)都同時(shí)更新一行數(shù)據(jù),但是第二個(gè)事務(wù)卻中途失敗退出, 導(dǎo)致對(duì)數(shù)據(jù)的兩個(gè)修改都失效了。
例如:
張三的工資為 5000,事務(wù) A 中獲取工資為 5000,事務(wù) B 獲取工資為 5000,匯入 100,并提交數(shù)據(jù)庫,工資變?yōu)?5100;
與此同時(shí),事務(wù)B正在讀取張三的工資,讀取到張三的工資為8000。
隨后,事務(wù)A發(fā)生異常,回滾了事務(wù),張三的工資又回滾為5000。
最后,事務(wù)B讀取到的張三工資為8000的數(shù)據(jù)即為臟數(shù)據(jù),事務(wù)B做了一次臟讀。
臟讀
臟讀就是指當(dāng)一個(gè)事務(wù)正在訪問數(shù)據(jù),并且對(duì)數(shù)據(jù)進(jìn)行了修改,而這種修改還沒有提交到數(shù)據(jù)庫中,這時(shí),另外一個(gè)事務(wù)也訪問這個(gè)數(shù)據(jù),然后使用了這個(gè)數(shù)據(jù)。
例如:
張三的工資為 5000,事務(wù) A 中把他的工資改為 8000,但事務(wù) A 尚未提交。
與此同時(shí),事務(wù)B正在讀取張三的工資,讀取到張三的工資為8000。
隨后,事務(wù)A發(fā)生異常,回滾了事務(wù),張三的工資又回滾為5000。
最后,事務(wù)B讀取到的張三工資為8000的數(shù)據(jù)即為臟數(shù)據(jù),事務(wù)B做了一次臟讀。
不可重復(fù)讀
是指在一個(gè)事務(wù)內(nèi),多次讀同一數(shù)據(jù)。在這個(gè)事務(wù)還沒有結(jié)束時(shí),另外一個(gè)事務(wù)也訪問該同一數(shù)據(jù)。那么,在第一個(gè)事務(wù)中的兩次讀數(shù)據(jù)之間,由于第二個(gè)事務(wù)的修改,那么第一個(gè)事務(wù)兩次讀到的的數(shù)據(jù)可能是不一樣的。這樣就發(fā)生了在一個(gè)事務(wù)內(nèi)兩次讀到的數(shù)據(jù)是不一樣的,因此稱為是不可重復(fù)讀。
例如:
在事務(wù) A 中,讀取到張三的工資為 5000,操作沒有完成,事務(wù)還沒提交。
與此同時(shí),事務(wù) B 把張三的工資改為 8000,并提交了事務(wù)。
隨后,在事務(wù) A 中,再次讀取張三的工資,此時(shí)工資變?yōu)?8000。在一個(gè)事務(wù)中前后兩次讀取的結(jié)果并不致,導(dǎo)致了不可重復(fù)讀。
第二類丟失更新
不可重復(fù)讀的特例。
有兩個(gè)并發(fā)事務(wù)同時(shí)讀取同一行數(shù)據(jù),然后其中一個(gè)對(duì)它進(jìn)行修改提交,而另一個(gè)也進(jìn)行了修改提交。這就會(huì)造成第一次寫操作失效。
例如:
在事務(wù) A 中,讀取到張三的存款為 5000,操作沒有完成,事務(wù)還沒提交。
與此同時(shí),事務(wù) B 存入 1000,把張三的存款改為 6000,并提交了事務(wù)。
隨后,在事務(wù) A 中,存儲(chǔ) 500,把張三的存款改為 5500,并提交了事務(wù),這樣事務(wù) A 的更新覆蓋了事務(wù) B 的更新。
幻讀
是指當(dāng)事務(wù)不是獨(dú)立執(zhí)行時(shí)發(fā)生的一種現(xiàn)象,例如第一個(gè)事務(wù)對(duì)一個(gè)表中的數(shù)據(jù)進(jìn)行了修改,這種修改涉及到表中的全部數(shù)據(jù)行。同時(shí),第二個(gè)事務(wù)也修改這個(gè)表中的數(shù)據(jù),這種修改是向表中插入一行新數(shù)據(jù)。那么,以后就會(huì)發(fā)生操作第一個(gè)事務(wù)的用戶發(fā)現(xiàn)表中還有沒有修改的數(shù)據(jù)行,就好象發(fā)生了幻覺一樣。
例如:
目前工資為 5000 的員工有 10 人,事務(wù) A 讀取到所有的工資為 5000 的人數(shù)為 10 人。
此時(shí),事務(wù) B 插入一條工資也為 5000 的記錄。
這時(shí),事務(wù) A 再次讀取工資為 5000 的員工,記錄為 11 人。此時(shí)產(chǎn)生了幻讀。
不可重復(fù)讀和幻讀的區(qū)別
不可重復(fù)讀的重點(diǎn)是修改,同樣的條件,你讀取過的數(shù)據(jù),再次讀取出來發(fā)現(xiàn)值不一樣了
幻讀的重點(diǎn)在于新增或者刪除,同樣的條件,第 1 次和第 2 次讀出來的記錄數(shù)不一樣
到此這篇關(guān)于SpringBoot各種事務(wù)操作實(shí)戰(zhàn)(自動(dòng)回滾、手動(dòng)回滾、部分回滾)的文章就介紹到這了,更多相關(guān)SpringBoot自動(dòng)回滾、手動(dòng)回滾、部分回滾內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
JAVA多線程Thread和Runnable的實(shí)現(xiàn)
java中實(shí)現(xiàn)多線程有兩種方法:一種是繼承Thread類,另一種是實(shí)現(xiàn)Runnable接口。2013-03-03淺談Java中Int、Integer、Integer.valueOf()、new Integer()之間的區(qū)別
本文主要介紹了淺談Java中Int、Integer、Integer.valueOf()、new Integer()之間的區(qū)別,文中通過示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2021-11-11hibernate 中 fetch=FetchType.LAZY 懶加載失敗處理方法
這篇文章主要介紹了hibernate 中 fetch=FetchType.LAZY 懶加載失敗處理方法,需要的朋友可以參考下2017-09-09IDEA2022中部署Tomcat Web項(xiàng)目的流程分析
這篇文章主要介紹了IDEA2022中部署Tomcat Web項(xiàng)目,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2023-03-03SpringBoot實(shí)現(xiàn)文件上傳下載實(shí)時(shí)進(jìn)度條功能(附源碼)
這篇文章主要為大家詳細(xì)介紹了SpringBoot如何實(shí)現(xiàn)文件上傳下載實(shí)時(shí)進(jìn)度條功能,文中的示例代碼講解詳細(xì),感興趣的小伙伴可以學(xué)習(xí)一下2022-10-10