存储过程调用失败时如何阻止事务回滚并同事务执行实体保存

你当前的核心矛盾是：主事务中执行实体保存+存储过程调用，但存储过程失败时不能触发主事务回滚。问题根源在于@TransactionalEventListener(phase = TransactionPhase.BEFORE_COMMIT)默认和主事务绑定，监听器内未完全拦截的异常会传播到主事务上下文，触发全局回滚。

以下是三种可行的解决方案，兼顾事务一致性和异常隔离需求：

方案1：完全拦截监听器内所有异常 #

扩大异常捕获范围，确保监听器内的所有错误（包括Error和Exception）都被拦截，不传播到主事务。同时将invokeStoreProcedure内的捕获逻辑上移到监听器方法，统一处理异常：

class EventListener {

    final EntityManager entityManager;
    private static final Logger log = LoggerFactory.getLogger(EventListener.class);

    @TransactionalEventListener(phase = TransactionPhase.BEFORE_COMMIT)
    public void handleCustom(SPInvocationEvent event) {
        try {
            entityManager.flush();
            invokeStoreProcedure(OUTBOUND_STORED_PROC, event);
        } catch (Throwable e) { // 捕获所有Throwable类型，覆盖Error和Exception
            log.error("存储过程调用失败: {}", e.getMessage(), e);
            // 异常在此处终止，不会触发主事务回滚
        }
    }

    void invokeStoreProcedure(String outProcName, SPInvocationEvent event) {
        StoredProcedureQuery outsumSP = entityManager.createStoredProcedureQuery(outProcName);
        outsumSP.execute(); // 不再单独捕获，统一交给上层处理
    }
}

优势：无需修改事务传播属性，仅通过异常拦截实现需求，兼容性强。

方案2：用嵌套事务隔离存储过程执行 #

如果存储过程执行可能污染主事务的持久化上下文（比如导致实体状态不一致），可以用嵌套事务隔离存储过程的执行。嵌套事务回滚不会影响主事务提交，但需要数据库支持Savepoint（如MySQL InnoDB、PostgreSQL）：

class EventListener {

    final EntityManager entityManager;
    private static final Logger log = LoggerFactory.getLogger(EventListener.class);

    @TransactionalEventListener(phase = TransactionPhase.BEFORE_COMMIT)
    @Transactional(propagation = Propagation.NESTED) // 创建嵌套事务
    public void handleCustom(SPInvocationEvent event) {
        try {
            entityManager.flush();
            invokeStoreProcedure(OUTBOUND_STORED_PROC, event);
        } catch (Throwable e) {
            log.error("存储过程调用失败: {}", e.getMessage(), e);
            // 手动标记嵌套事务回滚，不影响主事务
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
        }
    }

    void invokeStoreProcedure(String outProcName, SPInvocationEvent event) {
        StoredProcedureQuery outsumSP = entityManager.createStoredProcedureQuery(outProcName);
        outsumSP.execute();
    }
}

注意：若数据库不支持Savepoint，Propagation.NESTED会退化为Propagation.REQUIRED，无法实现隔离效果。

方案3：放弃事件解耦，直接在主事务内调用 #

如果不需要事件的解耦特性，最直接的方式是在主服务方法内直接调用存储过程并捕获异常，彻底避免事务同步的关联问题：

@Transactional
void saveAndInvokeSP() {
   repo.save(entity);
   try {
       invokeStoreProcedure(OUTBOUND_STORED_PROC); // 直接调用存储过程
   } catch (Throwable e) {
       log.error("存储过程调用失败: {}", e.getMessage(), e);
   }
}

// 将存储过程调用逻辑移到服务类或注入对应Bean实现
void invokeStoreProcedure(String outProcName) {
    StoredProcedureQuery outsumSP = entityManager.createStoredProcedureQuery(outProcName);
    outsumSP.execute();
}

优势：逻辑简单直接，无事务同步的潜在问题，测试维护成本低。

验证要点 #

1. 测试存储过程失败场景，确认实体正常保存到数据库
2. 测试不调用存储过程的场景，确保原有保存功能不受影响
3. 若使用嵌套事务，提前验证数据库是否支持Savepoint特性

内容的提问来源于stack exchange，提问作者Anish Chatterjee