java - 使用 Spring Data JPA 捕获 SQL 异常

Question

以下方法尝试将数据写入数据库(firmRepository.save())和 ElasticSearch(firmSearchRepository.save())。

问题是，如果数据库保存失败，我不想写入 ES 存储库。我试图用 DataAccessException 捕获异常，但通过我的测试，我发现诸如违反唯一约束的异常 -> get through 和 ElasticSearch 中的持久性仍然执行。

@Override
public FirmDTO save (FirmDTO firmDTO) {
    log.info("Database Request to save Firm: {}", firmDTO.getFirmId());
    Firm firm = firmMapper.firmDTOtoFirm(firmDTO);
    try {
        firm = firmRepository.save(firm);
        firmSearchRepository.save(firm);
        return firmMapper.firmToFirmDTO(firm);
    } catch (DataAccessException ex) {
        log.error(ex.getLocalizedMessage());
        return null;
    }
}

有没有办法捕获与 SQL 相关的特定异常？

Answer 1

使用 saveAndFlush() JPA 存储库方法可以捕获 Spring Data 异常。

@Override
    @Transactional
    public FirmDTO save (FirmDTO firmDTO) {
        log.info("Database Request to save Firm: {}", firmDTO.getFirmId());
        Firm firm = firmMapper.firmDTOtoFirm(firmDTO);
        try {
            firm = firmRepository.saveAndFlush(firm);
            firmSearchRepository.save(firm);
            return firmMapper.firmToFirmDTO(firm);
        } catch (DataAccessException ex) {
            log.error("my exception");
            log.error(ex.getLocalizedMessage());
            return null;
        }
    }