事務場景中，手動捕獲異常時記得顯式回滾事務

 

阿里巴巴《Java開發手冊》：事務場景中，拋出異常被catch后，如果需要回滾，一定要手動回滾事務。

今天裝了一個ali編碼規約插件，在對工程做編碼規約掃描時，也給出了這個提示。

 

 

下述發布貼現方法，要求先創建票據再創建貼現交易，整體是一個事務。如果不加異常捕獲，那么一旦程序執行出現異常后，AOP捕獲異常后默認會先回滾事務再throw，只不過這樣對調用方（有時）不“友好”； 加了try..catch捕獲到異常后，如果不顯式回滾，那么，前面的“創建票據”就提交到db了，所以，為保證事務的一致性，就要手動回滾事務，並返回創單失敗。

public class TradeOrderServiceImpl{
    @Autowired
    TradeOrderServiceImpl tradeOrderService;

    @Autowired
    DraftInfoServiceImpl draftInfoService;
    
    /**
     * 發布貼現
     *
     */
    @Transactional
    public ResponseModel publish(String merId, String openBank, BigDecimal amt){
        DraftInfoModel draftInfoModel = new DraftInfoModel();
        draftInfoModel.setMerchantId(merId);
        draftInfoModel.setAmt(amt);
        ... ...
        // 創建票據
        DraftInfoModel res_draftInfoModel = draftInfoService.addDraftInfo(draftInfoModel);
        
        try{
            TradeOrderModel tradeOrderModel = new TradeOrderModel();
            tradeOrderModel.setSellerMerchantId(merId);
            tradeOrderModel.setOpenBank(openBank); //openBank超長會導致mySQL的Data truncated for column異常。
            tradeOrderModel.setPlatFeeAmt(amt);
            tradeOrderModel.setDraftId(res_draftInfoModel.getDraftId());
            ... ...
            // 創建貼現交易
            TradeOrderModelRes tradeOrderModelRes = tradeOrderService.publishDraftDiscount(tradeOrderModel);
        }catch(Exception e){
            // 手動回滾事務
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
            // 返回創單失敗
            return new ResponseModel(false, ExceptionUtils.getMessage(e));
        }
        
        // 返回創單完成
        return new ResponseModel(true);
    } 
}

 

 

如下testcase作用是新增轉賬原因，使用@Transactional注解開啟了事務，當執行第二個insert時，由於數據超長報異常：### Error updating database. Cause: com.mysql.jdbc.MysqlDataTruncation: Data truncation: Data too long for column 'transfer_reason' at row 1。此時會整體回滾事務，兩個轉賬原因都未持久化。

@Test
@Transactional
public void insertTransferReason(){
    List<BatchPayRecordDetail> batchPayRecordDetails = batchPayRecordDetailMapper.selectByExample(new BatchPayRecordDetailExample());
    if(CollectionUtils.isEmpty(batchPayRecordDetails)){
        Assert.fail("no data");
    }
    String auditMan="test";
    BatchPayRecordDetail recordDetail=batchPayRecordDetails.get(0);
    System.out.println("==============================");

    recordDetail.setPayReason(UUID.randomUUID().toString());
    int i1 = managerBll.insertTransferReason(recordDetail, auditMan);
    System.out.println(i1);

    recordDetail.setPayReason(UUID.randomUUID().toString()+"測試(String), 39c535de-79ff-4fc4-a514-5c431ad4157d2019-04-04 11:26:43,147 DEBUG [main] (BaseJdbcLogger.java:145) 6219 - ==>  Preparing: insert into transfer_account_reason (transfer_reason_(String), 0(String), SUCCES(String), test(String), null, null\n" +
            "2019-04-04 11:28:42,975 DEBUG [main] (BaseJdbcLogger.java:145) 6611 - <==    Updates: 1");
    int i = managerBll.insertTransferReason(recordDetail, auditMan);
    System.out.println(i);
}