使用@Transactional 設(shè)置嵌套事務(wù)不回滾
@Transactional 設(shè)置嵌套事務(wù)不回滾
@Transactional(rollbackFor = Exception.class)
public void testA(RequestSchedulingVO requestSchedulingVO) {
...業(yè)務(wù)...
BService.testB(param);
}
@Override
@Transactional(propagation = Propagation.REQUIRES_NEW, readOnly = false, noRollbackFor = BusinessException.class)
// @Transactional(propagation = Propagation.NOT_SUPPORTED)
public void testB(Long param) throws BusinessException {
...業(yè)務(wù)...
try{
}cach(Exception e){
throw new BusinessException(BaiduFaceErrorCode.FACE_CREATE_CONVERSATION_ERROR);
}
}
這里的事務(wù)要求是方法testB報(bào)錯(cuò)(BusinessException異常)時(shí)，testB事務(wù)不回滾，testA事務(wù)回滾.
方案一：
testB設(shè)置事務(wù)為REQUIRES_NEW(創(chuàng)建一個(gè)新的事務(wù)，如果當(dāng)前存在事務(wù)，則把當(dāng)前事務(wù)掛起)，并設(shè)置不回滾的異常類
方案二：
testB設(shè)置事務(wù)為NOT_SUPPORTED(以非事務(wù)方式運(yùn)行，如果當(dāng)前存在事務(wù)，則把當(dāng)前事務(wù)掛起)。
@Transactional回滾問(wèn)題（try catch、嵌套）
Spring 事務(wù)注解 @Transactional 本來(lái)可以保證原子性，如果事務(wù)內(nèi)有報(bào)錯(cuò)的話，整個(gè)事務(wù)可以保證回滾，但是加上try catch或者事務(wù)嵌套，可能會(huì)導(dǎo)致事務(wù)回滾失敗。測(cè)試一波。
準(zhǔn)備
建兩張表，模擬兩個(gè)數(shù)據(jù)操作
CREATE TABLE `user` ( `id` int(11) NOT NULL AUTO_INCREMENT, `name` varchar(20) DEFAULT NULL, `age` smallint(3) DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8; CREATE TABLE `role` ( `id` int(11) NOT NULL AUTO_INCREMENT, `role_name` varchar(20) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;
測(cè)試
根據(jù)排列組合原理，我們進(jìn)行四種測(cè)試：1、無(wú)try catch、無(wú)嵌套；2、有try catch、無(wú)嵌套；3、無(wú)try catch、有嵌套；4、都有。
最簡(jiǎn)單測(cè)試
如果我們單純@Transactional，事務(wù)可以正常回滾嗎？
@GetMapping("/saveNormal0")
@Transactional
public void saveNormal0() throws Exception {
int age = random.nextInt(100);
User user = new User().setAge(age).setName("name:"+age);
userService.save(user);
throw new RuntimeException();
}
如果事務(wù)內(nèi)報(bào)了RuntimeException錯(cuò)誤，事務(wù)可以回滾。
@GetMapping("/saveNormal0")
@Transactional
public void saveNormal0() throws Exception {
int age = random.nextInt(100);
User user = new User().setAge(age).setName("name:"+age);
userService.save(user);
throw new Exception();
}
如果事務(wù)內(nèi)報(bào)了Exception錯(cuò)誤（非RuntimeException錯(cuò)誤），事務(wù)不可以回滾。
@GetMapping("/saveNormal0")
@Transactional( rollbackFor = Exception.class)
public void saveNormal0() throws Exception {
int age = random.nextInt(100);
User user = new User().setAge(age).setName("name:"+age);
userService.save(user);
throw new Exception();
}
如果是Exception錯(cuò)誤（非RuntimeException），加上 rollbackFor = Exception.class 參數(shù)也可以實(shí)現(xiàn)回滾。
結(jié)論一：對(duì)于@Transactional可以保證RuntimeException錯(cuò)誤的回滾，如果想保證非RuntimeException錯(cuò)誤的回滾，需要加上rollbackFor = Exception.class 參數(shù)。
try catch 影響
經(jīng)過(guò)博主多種情況測(cè)試，發(fā)現(xiàn)try catch對(duì)回滾這個(gè)事本身沒(méi)有什么影響，結(jié)論一照樣成立。try catch只是對(duì)異常是否可以被@Transactional 感知 到有影響。如果錯(cuò)誤拋到切面可以感知到的地步，那就可以起作用。
@GetMapping("/saveTryCatch")
@Transactional( rollbackFor = Exception.class)
public void saveTryCatch() throws Exception{
try{
int age = random.nextInt(100);
User user = new User().setAge(age).setName("name:"+age);
userService.save(user);
throw new Exception();
}catch (Exception e){
throw e;
}
}
比如上面一段代碼就回滾了。
@GetMapping("/saveTryCatch")
@Transactional( rollbackFor = Exception.class)
public void saveTryCatch() throws Exception{
try{
int age = random.nextInt(100);
User user = new User().setAge(age).setName("name:"+age);
userService.save(user);
throw new Exception();
}catch (Exception e){
}
}
然而，將catch中的錯(cuò)誤不繼續(xù)網(wǎng)上拋，切面無(wú)法感知到錯(cuò)誤，無(wú)法進(jìn)行處理，那么事務(wù)就無(wú)法回滾了。
結(jié)論二：try catch只是對(duì)異常是否可以被@Transactional 感知 到有影響。如果錯(cuò)誤拋到切面可以感知到的地步，那就可以起作用。
事務(wù)嵌套 影響
首先經(jīng)過(guò)實(shí)驗(yàn)，結(jié)論一仍然成立，即，當(dāng)不加上rollbackFor = Exception.class 的時(shí)候，無(wú)論內(nèi)外報(bào)RuntimeException，都會(huì)回滾；無(wú)論內(nèi)外報(bào) 非RuntimeException 錯(cuò)誤，都不會(huì)回滾。如果加上rollbackFor = Exception.class，無(wú)論內(nèi)外怎么報(bào)錯(cuò)，都會(huì)回滾。這些代碼就不給出了。接下來(lái)，試下下面兩種情況：
@GetMapping("/out")
@Transactional( rollbackFor = Exception.class)
public void out() throws Exception{
innerService.inner();
int age = random.nextInt(100);
User user = new User().setAge(age).setName("name:" + age);
userService.save(user);
throw new Exception();
}
@Transactional
public void inner() throws Exception{
Role role = new Role();
role.setRoleName("roleName:"+new Random().nextInt(100));
roleService.save(role);
// throw new Exception();
}
情況一，外面事務(wù)加上rollbackFor = Exception.class，里面事務(wù)不加，測(cè)試內(nèi)外分別報(bào)錯(cuò)的情況（為了簡(jiǎn)化代碼量，只給出了外面報(bào)錯(cuò)的代碼），都可以回滾。因?yàn)?，無(wú)論如何，錯(cuò)誤都拋給了外面那個(gè)事務(wù)進(jìn)行處理，而外面那個(gè)加上了rollbackFor = Exception.class，具備處理非RuntimeException錯(cuò)誤的能力，所以都可以讓事務(wù)進(jìn)行正常回滾。
下面看情況二，里面的事務(wù)加上rollbackFor = Exception.class，外面不加，外面報(bào)錯(cuò)。
@GetMapping("/out")
@Transactional
public void out() throws Exception{
innerService.inner();
int age = random.nextInt(100);
User user = new User().setAge(age).setName("name:" + age);
userService.save(user);
throw new Exception();
}
@Transactional( rollbackFor = Exception.class)
public void inner() throws Exception{
Role role = new Role();
role.setRoleName("roleName:"+new Random().nextInt(100));
roleService.save(role);
}
事務(wù)都無(wú)法回滾，這是我們有個(gè)疑問(wèn)，里面的事務(wù)明明有很強(qiáng)的處理能力啊，為什么和外面一起回滾失敗呢，別著急，等等聊這個(gè)。
然后試下里面報(bào)錯(cuò)：
@GetMapping("/out")
@Transactional
public void out() throws Exception{
innerService.inner();
int age = random.nextInt(100);
User user = new User().setAge(age).setName("name:" + age);
userService.save(user);
}
@Transactional( rollbackFor = Exception.class)
public void inner() throws Exception{
Role role = new Role();
role.setRoleName("roleName:"+new Random().nextInt(100));
roleService.save(role);
throw new Exception();
}
咦，這回都進(jìn)行了正常的回滾。我的天，這回外面沒(méi)有處理能力，為什么接受里面拋出來(lái)的錯(cuò)誤，也進(jìn)行了回滾?。?！看上去，就好像里外事務(wù)總是同生共死的對(duì)不對(duì)？原來(lái)，@Transactional還有個(gè)參數(shù)，看下源碼，這個(gè)注解還有默認(rèn)值：
Propagation propagation() default Propagation.REQUIRED;
REQUIRED的意思是說(shuō)，事務(wù)嵌套的時(shí)候，如果發(fā)現(xiàn)已經(jīng)有事務(wù)存在了，就加入這個(gè)事務(wù)，而不是新建一個(gè)事務(wù)，所以根本就不存在兩個(gè)事務(wù)，一直只有一個(gè)！至于，此參數(shù)其他值，本文不進(jìn)行測(cè)試?；氐缴厦娴膯?wèn)題，當(dāng)外面報(bào)錯(cuò)的時(shí)候，此時(shí)查看事務(wù)，沒(méi)有增加rollbackFor = Exception.class參數(shù)，即沒(méi)有處理非RuntimeException能力，所以代碼走完，貌似“兩個(gè)事務(wù)”，都回滾失敗了。當(dāng)里面報(bào)錯(cuò)的時(shí)候，事務(wù)已經(jīng)添加上了處理非RuntimeException能力，所以，代碼走完就回滾成功了。
結(jié)論三：由于REQUIRED屬性，“兩個(gè)事務(wù)”其實(shí)是一個(gè)事務(wù)，處理能力看報(bào)錯(cuò)時(shí)刻，是否添加了處理非RuntimeException的能力。
try catch和事務(wù)嵌套 共同影響
在結(jié)論一二三成立的條件下，探索共同影響的問(wèn)題就簡(jiǎn)單多了，由于情況太多，就不進(jìn)行過(guò)多的代碼展示了。
結(jié)論
結(jié)論一：
對(duì)于@Transactional可以保證RuntimeException錯(cuò)誤的回滾，如果想保證非RuntimeException錯(cuò)誤的回滾，需要加上rollbackFor = Exception.class 參數(shù)。
結(jié)論二：
try catch只是對(duì)異常是否可以被@Transactional 感知 到有影響。如果錯(cuò)誤拋到切面可以感知到的地步，那就可以起作用。
結(jié)論三：
由于REQUIRED屬性，“兩個(gè)事務(wù)”其實(shí)是一個(gè)事務(wù)，處理能力看報(bào)錯(cuò)時(shí)刻，是否添加了處理非RuntimeException的能力。
以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。
相關(guān)文章
這篇文章主要為大家詳細(xì)介紹了Java如何使用ProcessBuilder來(lái)拉取RTSP流并推送到另一個(gè)RTSP服務(wù)器,感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2024-11-11
Mybatis千萬(wàn)級(jí)數(shù)據(jù)查詢的解決方式,避免OOM問(wèn)題
這篇文章主要介紹了Mybatis千萬(wàn)級(jí)數(shù)據(jù)查詢的解決方式,避免OOM問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-01-01
Map 使用 Lambda 的 forEach 實(shí)現(xiàn)跳出循環(huán)操作
這篇文章主要介紹了Map 使用 Lambda 的 forEach 實(shí)現(xiàn)跳出循環(huán)操作，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2020-09-09
這篇文章主要介紹了導(dǎo)入SpringCloud依賴踩的坑及解決方案，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2023-04-04
這篇文章主要介紹了Java線程間共享實(shí)現(xiàn)方法詳解,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-10-10
微信公眾號(hào)測(cè)試賬號(hào)自定義菜單的實(shí)例代碼
這篇文章主要介紹了微信公眾號(hào)測(cè)試賬號(hào)自定義菜單的實(shí)例代碼,非常不錯(cuò)，具有參考借鑒價(jià)值，需要的朋友可以參考下2017-02-02
SpringBoot+MyBatis實(shí)現(xiàn)MD5加密數(shù)據(jù)庫(kù)用戶密碼的方法
MD5技術(shù)主要用于對(duì)用戶密碼加密,增加賬戶的安全性,他具有不可逆的特性,不會(huì)被輕易解密,這篇文章給大家介紹SpringBoot+MyBatis實(shí)現(xiàn)MD5加密數(shù)據(jù)庫(kù)用戶密碼的方法,感興趣的朋友跟隨小編一起看看吧2024-03-03
數(shù)組實(shí)現(xiàn)Java 自定義Queue隊(duì)列及應(yīng)用操作
這篇文章主要介紹了數(shù)組實(shí)現(xiàn)Java 自定義Queue隊(duì)列及應(yīng)用操作，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-06-06
springboot常用的請(qǐng)求參數(shù)的接收方式
在Spring?Boot中,接收請(qǐng)求參數(shù)的方式有多種,這篇文章主要為大家整理了9個(gè)常用的方式,文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2024-12-12
java集合中HashSet LinkedHashSet TreeSet三者異同面試精講
這篇文章主要為大家介紹了java集合中HashSet LinkedHashSet TreeSet三者異同面試精講,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-10-10