學習的文章

小姐姐非要問我：spring編程式事務是啥？ (qq.com)

一文搞懂什么是事務 - 知乎 (zhihu.com)

阿里3面：Spring宣告式事務連環炮，讓我措手不及，， (qq.com)

帶你讀懂Spring 事務——事務的傳播機制 - 知乎 (zhihu.com)

spring 事務失效的 12 種場景_事務什么時候失效_hanjq_code的博客-CSDN博客

什么是事務

事務是并發操作的單位
是用戶定義的操作序列
事務如果成功，則會提交
事務如果失敗，則會回滾

事務的四大特性

原子性
- 事務中操作，要么不做，要么都做
持久性
- 一個事務一旦提交，它對資料庫的改變是永久的
一致性
- 事務讓資料庫從一個一致性狀態轉移到另一個一致性狀態
- 比如
  - 事務前，A有50，B有50，總共有100
  - 事務中，A送給B20
  - 事務后，A有30，B有70，總共還是有100
隔離性
- 一個事務的執行不能被其他事務所干擾
- 分成不同的等級

事務并發訪問導致的資料問題

臟讀

讀到了修改但還沒有提交的資料

A事務修改了某條記錄的欄位c，但還沒有提交
B事務在此時讀取了欄位c
A事務發生了回滾，欄位c恢復了修改前的狀態
但B事務持有的還是修改后的狀態

不可重復讀

某個事務在執行程序中，兩次讀同一個條記錄，但結果不一樣

A事務讀取了記錄c，值為10
B事務修改了記錄c，值為0
A事務再次讀取記錄c，值為0

幻讀

某個事務在執行程序中，前后兩次讀取記錄，資料總量不一樣

A事務統計了表c中的記錄總數，結果為10
B事務洗掉了表c中的5條記錄
A事務再次統計了表c中的記錄總數，結果為5

和不可重復讀的區別在于，幻讀針對的是記錄條數，不可重復讀針對的是記錄內容

事務的隔離級別

針對事務并發訪問時出現的問題，設定了四種事務的隔離級別

讀未提交

可以的讀取還沒有提交的資料

沒有限制，三種問題都有可能發生

讀已提交

只能讀取已經提交了的資料

不會發生臟讀，但是會發生不可重復讀和幻讀

可重復讀

一個事務前后讀取的同一條記錄的結果必須一致

不會發生臟讀和不可重復讀，但會發生幻讀

mysql中默認的事務隔離級別

串行化

所有的事務必須依次執行

不會發生臟讀、不可重讀讀和幻讀

效率比較低

Spring事務的使用方法

Spring分為兩種控制事務的方法

編程式事務
- 方法1：通過PlatformTransactionManager控制事務
- 方法2：通過TransactionTemplate控制事務
宣告式事務
- 常用

編程式事務的使用

使用PlatformTransactionManager

@Test
public void test1() throws Exception {
    //定義一個資料源
    org.apache.tomcat.jdbc.pool.DataSource dataSource = new org.apache.tomcat.jdbc.pool.DataSource();
    dataSource.setDriverClassName("com.mysql.jdbc.Driver");
    dataSource.setUrl("jdbc:mysql://localhost:3306/javacode2018?characterEncoding=UTF-8");
    dataSource.setUsername("root");
    dataSource.setPassword("root123");
    dataSource.setInitialSize(5);
    //定義一個JdbcTemplate，用來方便執行資料庫增刪改查
    JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
    //1.定義事務管理器，給其指定一個資料源（可以把事務管理器想象為一個人，這個人來負責事務的控制操作）
    PlatformTransactionManager platformTransactionManager = new DataSourceTransactionManager(dataSource);
    //2.定義事務屬性：TransactionDefinition，TransactionDefinition可以用來配置事務的屬性資訊，比如事務隔離級別、事務超時時間、事務傳播方式、是否是只讀事務等等，
    TransactionDefinition transactionDefinition = new DefaultTransactionDefinition();
    //3.開啟事務：呼叫platformTransactionManager.getTransaction開啟事務操作，得到事務狀態(TransactionStatus)物件
    TransactionStatus transactionStatus = platformTransactionManager.getTransaction(transactionDefinition);
    //4.執行業務操作，下面就執行2個插入操作
    try {
        System.out.println("before:" + jdbcTemplate.queryForList("SELECT * from t_user"));
        jdbcTemplate.update("insert into t_user (name) values (?)", "test1-1");
        jdbcTemplate.update("insert into t_user (name) values (?)", "test1-2");
        //5.提交事務：platformTransactionManager.commit
        platformTransactionManager.commit(transactionStatus);
    } catch (Exception e) {
        //6.回滾事務：platformTransactionManager.rollback
        platformTransactionManager.rollback(transactionStatus);
    }
    System.out.println("after:" + jdbcTemplate.queryForList("SELECT * from t_user"));
}

使用TransactionTemplate

@Test
public void test1() throws Exception {
    //定義一個資料源
    org.apache.tomcat.jdbc.pool.DataSource dataSource = new org.apache.tomcat.jdbc.pool.DataSource();
    dataSource.setDriverClassName("com.mysql.jdbc.Driver");
    dataSource.setUrl("jdbc:mysql://localhost:3306/javacode2018?characterEncoding=UTF-8");
    dataSource.setUsername("root");
    dataSource.setPassword("root123");
    dataSource.setInitialSize(5);
    //定義一個JdbcTemplate，用來方便執行資料庫增刪改查
    JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
    //1.定義事務管理器，給其指定一個資料源（可以把事務管理器想象為一個人，這個人來負責事務的控制操作）
    PlatformTransactionManager platformTransactionManager = new DataSourceTransactionManager(dataSource);
    //2.定義事務屬性：TransactionDefinition，TransactionDefinition可以用來配置事務的屬性資訊，比如事務隔離級別、事務超時時間、事務傳播方式、是否是只讀事務等等，
    DefaultTransactionDefinition transactionDefinition = new DefaultTransactionDefinition();
    transactionDefinition.setTimeout(10);//如：設定超時時間10s
    //3.創建TransactionTemplate物件
    TransactionTemplate transactionTemplate = new TransactionTemplate(platformTransactionManager, transactionDefinition);
    /**
     * 4.通過TransactionTemplate提供的方法執行業務操作
     * 主要有2個方法：
     * （1）.executeWithoutResult(Consumer<TransactionStatus> action)：沒有回傳值的，需傳遞一個Consumer物件，在accept方法中做業務操作
     * （2）.<T> T execute(TransactionCallback<T> action)：有回傳值的，需要傳遞一個TransactionCallback物件，在doInTransaction方法中做業務操作
     * 呼叫execute方法或者executeWithoutResult方法執行完畢之后，事務管理器會自動提交事務或者回滾事務，
     * 那么什么時候事務會回滾，有2種方式：
     * （1）transactionStatus.setRollbackOnly();將事務狀態標注為回滾狀態
     * （2）execute方法或者executeWithoutResult方法內部拋出例外
     * 什么時候事務會提交？
     * 方法沒有例外 && 未呼叫過transactionStatus.setRollbackOnly();
     */
    transactionTemplate.executeWithoutResult(new Consumer<TransactionStatus>() {
        @Override
        public void accept(TransactionStatus transactionStatus) {
            jdbcTemplate.update("insert into t_user (name) values (?)", "transactionTemplate-1");
            jdbcTemplate.update("insert into t_user (name) values (?)", "transactionTemplate-2");

        }
    });
    System.out.println("after:" + jdbcTemplate.queryForList("SELECT * from t_user"));
}

宣告式事務的使用

在配置類上使用@EnableTransactionManagement
- Springboot可以加在啟動類上

定義事務管理器

@Bean
public PlatformTransactionManager transactionManager(DataSource dataSource) {
    return new DataSourceTransactionManager(dataSource);
}

springboot中有默認的事務管理器

在需要事務的目標上加上@Transaction注解
- 作用位置
  - 注意：@Transaction只對public方法有效
  - @Transacion放在介面上，介面的所有實作類中所有的public方法都自動加上事務
  - @Transaction放在類上，當前類以及其下無限級子類中的public方法都被加上事務
  - @Transaction放在public方法上，方法被加上事務
- 屬性
  - "transactionManager"或"value"
    - 指定事務管理器的bean物件
    - 為空的話，默認按型別獲取
  - “propagation”
    - 指定事務的傳播型別
    - 默認為REQUIRED
  - “rollbackFor”
    - 自定義回滾例外

事務的傳播型別

REQUIRED
- 如果當前有事務，則加入當前事務
- 如果當前沒有事務，則自己新建一個事務
SUPPORTS
- 如果當前有事務，則加入當前事務
- 如果當前沒有事務，則以非事務方式執行
MANDATORY
- 如果當前有事務，則加入當前事務
- 如果當前沒有事務，則拋出例外
REQUIERES_NEW
- 如果當前有事務，則將該事務掛起，另外新創建一個事務
- 如果當前沒有事務，則新創建一個事務
NOT_SUPPORTED
- 如果當前有事務，則將該事務掛起，以非事務方式執行
- 如果當前沒有事務，則以非事務方式執行
NEVER
- 如果當前有事務，則拋出例外
- 如果當前沒有事務，以非事務方式執行
NESTED
- 如果當前有事務，則在當前事務中嵌套一個事務執行
- 如果當前沒有事務，則新建一個事務執行

事務失效或回滾例外的12種情況

事務失效

訪問權限問題
- 事務只能對public的方法方法生效
方法用final或static修飾
- spring事務是使用動態代理的方式實作的
- 如果加了final或public方法，則方法無法被代理

方法內部呼叫

@Service
public class UserService {
 
    @Autowired
    private UserMapper userMapper;
 
  
    public void add(UserModel userModel) {
        userMapper.insertUser(userModel);
        updateStatus(userModel);
    }
 
    @Transactional
    public void updateStatus(UserModel userModel) {
        doSameThing();
    }
}

在add方法中是通過this來呼叫updateStatus方法的，沒有通過代理

解決方法：

1.注入自己

@Servcie
public class ServiceA {
   @Autowired
   prvate ServiceA serviceA;
 
   public void save(User user) {
         queryData1();
         queryData2();
         serviceA.doSave(user);
   }
 
   @Transactional(rollbackFor=Exception.class)
   public void doSave(User user) {
       addData1();
       updateData2();
    }
 }

2.通過AopContext.currentProxy()獲取代理物件

@Servcie
public class ServiceA {
 
   public void save(User user) {
         queryData1();
         queryData2();
         ((ServiceA)AopContext.currentProxy()).doSave(user);
   }
 
   @Transactional(rollbackFor=Exception.class)
   public void doSave(User user) {
       addData1();
       updateData2();
    }
 }

未被spring管理
- 忘了給類添加注釋了
- 沒有被放到IOC容器中
多執行緒呼叫
- spring事務是通過資料庫連接來實作的
- 在多執行緒中，每一個執行緒用的都是不同的資料庫連接
表不支持事務
- MyISAM引擎的表不支持事務
未開啟事務
- springboot需要在啟動類上加上@EnableTransactionManagement的注解
- 傳統spring專案需要在applicationContext.xml中進行相關的配置

事務回滾例外

使用了錯誤的傳播特性
手動捕獲了例外
- 如果想要spring事務能夠正常回滾，必須拋出它能夠處理的例外
- 使用try/catch將例外捕獲，將導致事務不會回滾
拋得例外型別不正確
- spring事務，默認情況下只會回滾RuntimeException或Error
自定義回滾例外不匹配
- 比如定義了BusinessException，但拋出的是SqlException

嵌套事務回滾范圍多了

public class UserService {
 
    @Autowired
    private UserMapper userMapper;
 
    @Autowired
    private RoleService roleService;
 
    @Transactional
    public void add(UserModel userModel) throws Exception {
        userMapper.insertUser(userModel);
        roleService.doOtherThing();
    }
}
 
@Service
public class RoleService {
 
    @Transactional(propagation = Propagation.NESTED)
    public void doOtherThing() {
        System.out.println("保存role表資料");
    }
}

roleService.doOtherThing()如果發生回滾，它拋出的例外沒有被處理，會繼續往上級拋
add()在捕獲到向上拋的例外后也會發生回滾

應該手動進行捕獲

@Slf4j
@Service
public class UserService {
 
    @Autowired
    private UserMapper userMapper;
 
    @Autowired
    private RoleService roleService;
 
    @Transactional
    public void add(UserModel userModel) throws Exception {
 
        userMapper.insertUser(userModel);
        try {
            roleService.doOtherThing();
        } catch (Exception e) {
            log.error(e.getMessage(), e);
        }
    }
}

轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/553187.html

標籤：Java

上一篇：【2023.03.20】P4710 「物理」平拋運動

下一篇：返回列表

學習筆記-Spring事務