Transaction rollback and record exception information at the same time

demand

When an exception occurs , Rollback the operation on the database , At the same time, insert an exception message into the database .

Realization principle

Start a new business , Perform database operation of abnormal information

Realization

1、 rely on HTTP Resend request

Before throwing an exception , rely on http, Send an asynchronous request , An interface stores exception information , Then the main program throws an exception .

2、 Start a new business , Insert exception information

@Autowired
private DataSourceTransactionManager dstManager;

@Transactional
@Override
public void create(Payment payment) throws Exception {
    
    try {
    
        paymentDao.create(payment);
        System.out.println(1 / 0);
    } catch (Exception e) {
    
        TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
        // Here you can add exception thrown information , Does not affect the existing logic 
    } finally {
    
        //  Isolation level of things , Start a new business , It'll be safer .
        DefaultTransactionDefinition def = new DefaultTransactionDefinition();
        def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);
        //  Get transaction state 
        TransactionStatus transaction = dstManager.getTransaction(def);
        try {
    
            payment.setSerial(" Report an error, Lala Lala ");
            paymentDao.create(payment);
            dstManager.commit(transaction);
        } catch (Exception e) {
    
            dstManager.rollback(transaction);
            logger.error(" Temporary table insertion failed :" + e.getMessage(), e);
        }
    }
}

A way of implementation , The same idea as the above code

@Transactional
@Override
public void create(Payment payment) {
    
    paymentDao.create(payment);
    paymentService.newTransCreate(payment);
    System.out.println(1 / 0);
}

@Override
@Transactional(propagation = Propagation.REQUIRES_NEW, rollbackFor = Exception.class)
public void newTransCreate(Payment payment) {
    
    payment.setSerial(" This is a new error message ");
    paymentDao.create(payment);
}