mybatis 事務回滾配置操作
在mybatis進行批量操作的時候,插入多條數據時,設置回滾但是前面幾條還是插入,經過嘗試
問題所在:
官網api上openSession(false)就可以回滾瞭,但是用session.getConnection().getAutoCommit()查看還是true
解決方法:
將DataSource配置改為AutoCommit(false)
將conn設置setAutoCommit(false),用conn進行提交,回滾操作
例子:
SqlSession session = sqlSessionFactory.openSession(false); Connection conn = session.getConnection(); conn.setAutoCommit(false); try { UserMapper mapper = session.getMapper(UserMapper.class); for (String name : names) { //各種操作 User user = new User(); user.setName(name); //插入,需要回滾 mapper.insert(user); } conn.commit(); } catch (Exception e) { //有重復回滾 conn.rollback(); throw e; } finally { session.close(); }
補充:Spring Boot + Mybatis Plus手動觸發事務回滾
使用第一種方法(省略瞭操作數據庫的代碼)操作Mybatis Plus的事務,若出現異常進入catch之後,不會執行數據庫操作的回滾,反而會報No transaction aspect-managed TransactionStatus in scope的錯誤,修改為第二種可以正常進行事務管理和回滾
看到一個關於此情況的解釋:
@Transactional 必須觸發aop代理才能生效,故非public方法,不執行事務,public方法在本類中被引用,也不執行事務
第一種方法:
@PostMapping("/save1") public boolean action01() { return action00(); } @PostMapping("/save2") public boolean action02() { return action00(); } @Transactional private boolean action00() { String result = true; try { System.out.println(1/0); } catch (Exception e) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); result = false; } return result; }
第二種方法:
@PostMapping("/save1") @Transactional public boolean action01() { boolean result = action00(); if (!result){ TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); } return result; } @PostMapping("/save2") @Transactional public boolean action02() { boolean result = action00(); if (!result){ TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); } return result; } private boolean action00() { String result = true; try { System.out.println(1/0); } catch (Exception e) { result = false; } return result; }
以上為個人經驗,希望能給大傢一個參考,也希望大傢多多支持WalkonNet。如有錯誤或未考慮完全的地方,望不吝賜教。
推薦閱讀:
- @Transactional遇到try catch失效的問題
- 解決try-catch捕獲異常信息後Spring事務失效的問題
- Java @Transactional指定回滾條件
- 解決@Transaction註解導致動態切換更改數據庫失效問題
- 關於controller的異常處理及service層的事務控制方式