@Transactional 注释不适用于方法

Question

我正在使用 oracleDB 和 elasticsearch 进行持久化，如果该方法出现任何问题，它会引发自定义异常。现在，如果弹性也出现任何问题，我需要从 DB 回滚。

我已经在服务类上添加了@transactional 注释。以及我在网络上找到的所有内容。

@Transactional(rollbackOn = BaseException.class)
public void transaction(ab ab, a a) {
    persistenceService.save(a);
    persistenceService.updateSignalCountDb(a.abc(), a.bcd(), ab);
    elasticService.saveSignal(a);

    try {
        elasticService.updateSignalCountElastic(a);
    } catch (Exception e) {
        throw new BaseException(ErrorCodes.FAILED_ELASTIC_SEARCH_UPDATE, e);
    }
}

persistenceService.save() 方法保存在数据库中。 persistenceService.updateSignalCountDb() 方法更新数据库中的另一个表。 elasticService.saveSignal() 方法保存在弹性中。在失败的情况下抛出基本异常。 elasticService.updateSignalCountElastic() 方法更新弹性中的另一个索引。它还调用 elasticService.delete() 方法来删​​除保存在 elastic 中的任何内容，以防失败并引发基本异常。

我预计如果整个方法出现任何故障，这将起作用。但是，如果弹性上出现任何故障，我会得到一个基本异常，但我来自 oracle db 的数据不会回滚。

Answer 1

乍一看，您似乎做的一切都是正确的。但是在你寻找它不起作用的原因之前，你的代码中的小改动会首先防止问题发生：

  @Transactional(rollbackOn = BaseException.class)
  public void transaction(ab ab, a a){
    try {
      elasticService.saveSignal(a);
      elasticService.updateSignalCountElastic(a);
      persistenceService.save(a);
      persistenceService.updateSignalCountDb(a.abc(), a.bcd(), ab);
    }catch (Exception e){
      throw new BaseException(ErrorCodes.FAILED_ELASTIC_SEARCH_UPDATE, e);
    }
  }

在这种情况下，您的异常将在您保存到数据库之前发生，您不会遇到问题

Answer 2

1. 如果您使用的是 Spring @Transactional，我研究过只有 rollbackFor 选项，但不是 rollbackOn（我不确定），比如 这个：@Transactional(rollbackFor = BaseException.class)。

2. 确保在 spring 配置中启用 Transactional：@EnableTransactionManagement

3. 在您的情况下，只有BaseException 会触发回滚，其他Exception 不会。