欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

SpringBoot各種事務(wù)操作實(shí)戰(zhàn)(自動(dòng)回滾、手動(dòng)回滾、部分回滾)

 更新時(shí)間:2024年05月30日 17:01:51   作者:Young丶  
本文主要介紹了SpringBoot各種事務(wù)操作實(shí)戰(zhàn),包含自動(dòng)回滾、手動(dòng)回滾、部分回滾這三種,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

概念

事務(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();】

默認(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)文章

最新評(píng)論