Spring事务方法未捕获异常：更新产品时自定义异常处理失效

这问题我之前踩过坑，核心确实是Spring事务代理机制+JPA持久化上下文的延迟执行在搞鬼，咱们一步步理清楚：

为什么updateProduct里捕获不到异常？ #

你猜的没错，和Spring事务代理有关，但更关键的是事务提交时机：

• 当方法标注@Transactional时，Spring会通过动态代理创建事务上下文，JPA的save()操作并不会立即执行SQL，只是将实体加入到持久化上下文，真正的SQL执行要等到事务提交阶段（也就是updateProduct方法执行完毕后）。
• 这时候saveProduct里的try-catch块早就执行完了，约束冲突的DataIntegrityViolationException是在方法外部的事务提交环节抛出的，自然没法被内部的catch捕获。
• 而ProductNotFoundException是查询操作，JPA会立即执行SQL并抛出异常，这时候还没到事务提交阶段，所以能被正常处理。

解决方案（无需额外查询，服务层内处理） #

推荐三种方案，按简洁度排序：

方案1：手动触发持久化上下文flush（最简便） #

修改你的saveProduct方法，在save之后手动调用flush()，强制JPA立即执行SQL，这样约束异常会当场被catch块捕获：

private Product saveProduct(Product product) throws ProductAlreadyExistsException {
    try {
        Product saved = productRepository.save(product);
        productRepository.flush(); // 手动触发SQL执行，提前抛出异常
        return saved;
    } catch (DataIntegrityViolationException ex) {
        throw new ProductAlreadyExistsException(product.getName());
    }
}

这个方案不需要改动原有代码结构，也不会降低效率，只是提前触发了SQL执行，完美贴合你的需求。

方案2：抽离保存逻辑到独立Bean，使用新事务 #

创建一个专门处理持久化操作的辅助Bean，给它的保存方法设置REQUIRES_NEW事务传播级别，强制开启新事务并立即提交：

@Service
@RequiredArgsConstructor
public class ProductPersistenceHelper {
    private final ProductRepository productRepository;

    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public Product saveProduct(Product product) throws ProductAlreadyExistsException {
        try {
            return productRepository.save(product);
        } catch (DataIntegrityViolationException ex) {
            throw new ProductAlreadyExistsException(product.getName());
        }
    }
}

然后在ProductServiceImpl里注入这个Bean，替换原有的私有方法调用：

// 注入helper
private final ProductPersistenceHelper persistenceHelper;

// 在updateProduct里调用
Product updateProduct = productWasUpdated ? persistenceHelper.saveProduct(foundProduct) : foundProduct;

新事务会在saveProduct执行完毕后立即提交，异常当场被捕获，缺点是多了一个类，但逻辑拆分更清晰。

方案3：使用TransactionTemplate手动管理保存事务 #

注入TransactionTemplate，用它来执行保存逻辑，强制立即执行并捕获异常：

// 在ProductServiceImpl里注入
private final TransactionTemplate transactionTemplate;

private Product saveProduct(Product product) throws ProductAlreadyExistsException {
    return transactionTemplate.execute(status -> {
        try {
            return productRepository.save(product);
        } catch (DataIntegrityViolationException ex) {
            throw new ProductAlreadyExistsException(product.getName());
        }
    });
}

这种方式手动控制事务执行时机，异常会在模板执行时立即抛出，适合需要更细粒度事务控制的场景。

总结 #

优先选方案1，改动最小，完全满足你“不额外查询、服务层处理异常、保留事务”的需求。

内容的提问来源于stack exchange，提问作者João Dias