I. 配置
本文的 case,將使用聲明式事務,首先我們創建一個 SpringBoot 項目,版本為2.2.1.RELEASE,使用 mysql 作為目標數據庫,存儲引擎選擇Innodb,事務隔離級別為 RR
1. 項目配置
在項目pom.xml文件中,加上spring-boot-starter-jdbc,會注入一個DataSourceTransactionManager的 bean,提供了事務支持
<code><dependency> <groupid>mysql/<groupid> <artifactid>mysql-connector-java/<artifactid>/<dependency><dependency> <groupid>org.springframework.boot/<groupid> <artifactid>spring-boot-starter-jdbc/<artifactid>/<dependency>/<code>
2. 數據庫配置
進入 spring 配置文件application.properties,設置一下 db 相關的信息
<code>## DataSourcespring.datasource.url=jdbc:mysql://127.0.0.1:3306/story?useUnicode=true&characterEncoding=UTF-8&useSSL=falsespring.datasource.username=rootspring.datasource.password=/<code>
3. 數據庫
新建一個簡單的表結構,用於測試
<code>CREATE TABLE `money` ( `id` int(11) unsigned NOT NULL AUTO_INCREMENT, `name` varchar(20) NOT NULL DEFAULT '' COMMENT '用戶名', `money` int(26) NOT NULL DEFAULT '0' COMMENT '錢', `is_deleted` tinyint(1) NOT NULL DEFAULT '0', `create_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '創建時間', `update_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新時間', PRIMARY KEY (`id`), KEY `name` (`name`)) ENGINE=InnoDB AUTO_INCREMENT=551 DEFAULT CHARSET=utf8mb4;/<code>
II. 不生效 case
在聲明式事務的使用教程200119-SpringBoot 系列教程之聲明式事務 Transactional 中,也提到了一些事務不生效的方式,比如聲明式事務註解@Transactional主要是結合代理實現,結合 AOP 的知識點,至少可以得出放在私有方法上,類內部調用都不會生效,下面進入詳細說明
1. 數據庫
事務生效的前提是你的數據源得支持事務,比如 mysql 的 MyISAM 引擎就不支持事務,而 Innodb 支持事務
下面的 case 都是基於 mysql + Innodb 引擎
為後續的演示 case,我們準備一些數據如下
<code>@Servicepublic class NotEffectDemo { @Autowired private JdbcTemplate jdbcTemplate; @PostConstruct public void init() { String sql = "replace into money (id, name, money) values" + " (520, '初始化', 200)," + "(530, '初始化', 200)," + "(540, '初始化', 200)," + "(550, '初始化', 200)"; jdbcTemplate.execute(sql); }}/<code>
2. 類內部訪問
簡單來講就是指非直接訪問帶註解標記的方法 B,而是通過類普通方法 A,然後由 A 訪問 B
下面是一個簡單的 case
<code>/** * 非直接調用,不生效 * * @param id * @return * @throws Exception */@Transactional(rollbackFor = Exception.class)public boolean testCompileException2(int id) throws Exception { if (this.updateName(id)) { this.query("after update name", id); if (this.update(id)) { return true; } } throw new Exception("參數異常");}public boolean testCall(int id) throws Exception { return testCompileException2(id);}/<code>
上面兩個方法,直接調用testCompleException方法,事務正常操作;通過調用testCall間接訪問,在不生效
測試 case 如下:
<code>@Componentpublic class NotEffectSample { @Autowired private NotEffectDemo notEffectDemo; public void testNotEffect() { testCall(530, (id) -> notEffectDemo.testCall(530)); } private void testCall(int id, CallFunc<integer> func) { System.out.println("============ 事務不生效case start ========== "); notEffectDemo.query("transaction before", id); try { // 事務可以正常工作 func.apply(id); } catch (Exception e) { } notEffectDemo.query("transaction end", id); System.out.println("============ 事務不生效case end ========== \\n"); } @FunctionalInterface public interface CallFunc{ R apply(T t) throws Exception; }} /<integer>/<code>
輸出結果如下:
<code>============ 事務不生效case start ==========transaction before >>>> {id=530, name=初始化, money=200, is_deleted=false, create_at=2020-02-03 13:44:11.0, update_at=2020-02-03 13:44:11.0}after update name >>>> {id=530, name=更新, money=200, is_deleted=false, create_at=2020-02-03 13:44:11.0, update_at=2020-02-03 13:44:11.0}transaction end >>>> {id=530, name=更新, money=210, is_deleted=false, create_at=2020-02-03 13:44:11.0, update_at=2020-02-03 13:44:11.0}============ 事務不生效case end ==========/<code>
從上面的輸出可以看到,事務並沒有回滾,主要是因為類內部調用,不會通過代理方式訪問
3. 私有方法
在私有方法上,添加@Transactional註解也不會生效,私有方法外部不能訪問,所以只能內部訪問,上面的 case 不生效,這個當然也不生效了
<code>/** * 私有方法上的註解,不生效 * * @param id * @return * @throws Exception */@Transactionalprivate boolean testSpecialException(int id) throws Exception { if (this.updateName(id)) { this.query("after update name", id); if (this.update(id)) { return true; } } throw new Exception("參數異常");}/<code>
直接使用時,下面這種場景不太容易出現,因為 IDEA 會有提醒,文案為: Methods annotated with '@Transactional' must be overridable
4. 異常不匹配
@Transactional註解默認處理運行時異常,即只有拋出運行時異常時,才會觸發事務回滾,否則並不會如
<code>/** * 非運行異常,且沒有通過 rollbackFor 指定拋出的異常,不生效 * * @param id * @return * @throws Exception */@Transactionalpublic boolean testCompleException(int id) throws Exception { if (this.updateName(id)) { this.query("after update name", id); if (this.update(id)) { return true; } } throw new Exception("參數異常");}/<code>
測試 case 如下
<code>public void testNotEffect() { testCall(520, (id) -> notEffectDemo.testCompleException(520));}/<code>
輸出結果如下,事務並未回滾(如果需要解決這個問題,通過設置@Transactional的 rollbackFor 屬性即可)
<code>============ 事務不生效case start ==========transaction before >>>> {id=520, name=初始化, money=200, is_deleted=false, create_at=2020-02-03 13:44:11.0, update_at=2020-02-03 13:44:11.0}after update name >>>> {id=520, name=更新, money=200, is_deleted=false, create_at=2020-02-03 13:44:11.0, update_at=2020-02-03 13:44:11.0}transaction end >>>> {id=520, name=更新, money=210, is_deleted=false, create_at=2020-02-03 13:44:11.0, update_at=2020-02-03 13:44:11.0}============ 事務不生效case end ==========/<code>
5. 多線程
這個場景可能並不多見,在標記事務的方法內部,另起子線程執行 db 操作,此時事務同樣不會生效
下面給出兩個不同的姿勢,一個是子線程拋異常,主線程 ok;一個是子線程 ok,主線程拋異常
a. case1
<code>/** * 子線程拋異常,主線程無法捕獲,導致事務不生效 * * @param id * @return */@Transactional(rollbackFor = Exception.class)public boolean testMultThread(int id) throws InterruptedException { new Thread(new Runnable() { @Override public void run() { updateName(id); query("after update name", id); } }).start(); new Thread(new Runnable() { @Override public void run() { boolean ans = update(id); query("after update id", id); if (!ans) { throw new RuntimeException("failed to update ans"); } } }).start(); Thread.sleep(1000); System.out.println("------- 子線程 --------"); return true;}/<code>
上面這種場景不生效很好理解,子線程的異常不會被外部的線程捕獲,testMultThread這個方法的調用不拋異常,因此不會觸發事務回滾
<code>public void testNotEffect() { testCall(540, (id) -> notEffectDemo.testMultThread(540));}/<code>
輸出結果如下
<code>============ 事務不生效case start ==========transaction before >>>> {id=540, name=初始化, money=200, is_deleted=false, create_at=2020-02-03 13:44:11.0, update_at=2020-02-03 13:44:11.0}after update name >>>> {id=540, name=更新, money=200, is_deleted=false, create_at=2020-02-03 13:44:11.0, update_at=2020-02-03 13:44:11.0}Exception in thread "Thread-3" java.lang.RuntimeException: failed to update ansat com.git.hui.boot.jdbc.demo.NotEffectDemo$2.run(NotEffectDemo.java:112)at java.lang.Thread.run(Thread.java:748)after update id >>>> {id=540, name=更新, money=210, is_deleted=false, create_at=2020-02-03 13:44:11.0, update_at=2020-02-03 13:44:11.0}------- 子線程 --------transaction end >>>> {id=540, name=更新, money=210, is_deleted=false, create_at=2020-02-03 13:44:11.0, update_at=2020-02-03 13:44:11.0}============ 事務不生效case end ==========/<code>
b. case2
<code>/** * 子線程拋異常,主線程無法捕獲,導致事務不生效 * * @param id * @return */@Transactional(rollbackFor = Exception.class)public boolean testMultThread2(int id) throws InterruptedException { new Thread(new Runnable() { @Override public void run() { updateName(id); query("after update name", id); } }).start(); new Thread(new Runnable() { @Override public void run() { boolean ans = update(id); query("after update id", id); } }).start(); Thread.sleep(1000); System.out.println("------- 子線程 --------"); update(id); query("after outer update id", id); throw new RuntimeException("failed to update ans");}/<code>
上面這個看著好像沒有毛病,拋出線程,事務回滾,可惜兩個子線程的修改並不會被回滾
測試代碼
<code>public void testNotEffect() { testCall(550, (id) -> notEffectDemo.testMultThread2(550));}/<code>
從下面的輸出也可以知道,子線程的修改並不在同一個事務內,不會被回滾
<code>============ 事務不生效case start ==========transaction before >>>> {id=550, name=初始化, money=200, is_deleted=false, create_at=2020-02-03 13:52:38.0, update_at=2020-02-03 13:52:38.0}after update name >>>> {id=550, name=更新, money=200, is_deleted=false, create_at=2020-02-03 13:52:38.0, update_at=2020-02-03 13:52:40.0}after update id >>>> {id=550, name=更新, money=210, is_deleted=false, create_at=2020-02-03 13:52:38.0, update_at=2020-02-03 13:52:40.0}------- 子線程 --------after outer update id >>>> {id=550, name=更新, money=220, is_deleted=false, create_at=2020-02-03 13:52:38.0, update_at=2020-02-03 13:52:41.0}transaction end >>>> {id=550, name=更新, money=210, is_deleted=false, create_at=2020-02-03 13:52:38.0, update_at=2020-02-03 13:52:40.0}============ 事務不生效case end ==========/<code>
6. 傳播屬性
上一篇關於傳播屬性的博文中,介紹了其中有幾種是不走事務執行的,所以也需要額外注意下,詳情可以參考博文 200202-SpringBoot 系列教程之事務傳遞屬性
7. 小結
下面小結幾種@Transactional註解事務不生效的 case
- 數據庫不支持事務
- 註解放在了私有方法上
- 類內部調用
- 未捕獲異常
- 多線程場景
- 傳播屬性設置問題
來源:https://my.oschina.net/u/566591/blog/3163325
閱讀更多 Java技術前沿 的文章