1. 程式人生 > >Spring事務不回滾,捕獲異常後不丟擲不回滾

Spring事務不回滾,捕獲異常後不丟擲不回滾

專案中一個對外提供的介面用try catch捕獲異常後不會滾

類似這樣的方法不會回滾 (一個方法出錯,另一個方法不會回滾) :

if(userSave){          
    try {         
        userDao.save(user);          
        userCapabilityQuotaDao.save(capabilityQuota);         
     } catch (Exception e) {          
        logger.info("haha:"+e);         
     }         
 }  

下面的方法回滾(一個方法出錯,另一個方法會回滾):

if(userSave){         
     try {          
        userDao.save(user);          
        userCapabilityQuotaDao.save(capabilityQuota);         
       } catch (Exception e) {         
        logger.info("haha:"+e);          
        throw new RuntimeException();         
     }          
} 

或者:

if(userSave){          
    try {          
        userDao.save(user);          
        userCapabilityQuotaDao.save(capabilityQuota);          
    } catch (Exception e) {          
        logger.info("haha:"+e);          
        TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();         
    }         
 } 

為什麼不會滾呢??是對Spring的事務機制就不明白。!!
預設spring事務只在發生未被捕獲的 runtimeexcetpion時才回滾。
spring aop 異常捕獲原理:被攔截的方法需顯式丟擲異常,並不能經任何處理,這樣aop代理才能捕獲到方法的異常,才能進行回滾,預設情況下aop只捕獲runtimeexception的異常,但可以通過配置來捕獲特定的異常並回滾
換句話說在service的方法中不使用try catch 或者在catch中最後加上throw new runtimeexcetpion(),這樣程式異常時才能被aop捕獲進而回滾
解決方案:
方案1.例如service層處理事務,那麼service中的方法中不做異常捕獲,或者在catch語句中最後增加throw new RuntimeException()語句,以便讓aop捕獲異常再去回滾,並且在service上層(webservice客戶端,view層action)要繼續捕獲這個異常並處理
方案2.在service層方法的catch語句中增加:TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();語句,手動回滾,這樣上層就無需去處理異常(現在專案的做法)

還有一種方法是加上一個註解,類似於:

@Transactional(rollbackForClassName={"Exception"})
或者
@Transactional(rollbackFor={Exception.class})

這樣try catch中丟擲Exception異常也可以回滾了,如下:

@Transactional(rollbackForClassName={"Exception"})
public void servicefn() {
    try {          
            userDao.save(user);          
            userCapabilityQuotaDao.save(capabilityQuota);         
           } catch (Exception e) {         
            logger.info("haha:"+e);          
            throw new RuntimeException();         
         }       
}