Hibernate 5 和带有拦截器的事务回滚检测

Question

我们有一个 Hibernate Interceptor 正在拦截 afterTransactionCommit 并检查 wasCommited() 的事务，但我们最近升级到 Hibernate 5.0.7.Final，并且 hibernate 5 不再有这个调用，当我们调用 @ 987654323@ 函数我们似乎只得到ACTIVE 或NOT_ACTIVE 而不管事务状态如何。

我查看了afterTransactionBegin，交易标记为ACTIVE，这是预期的，在beforeTransactionCompletion 中仍标记为ACTIVE，这又是预期的，但随后在afterTransactionCommit 中标记为NOT_ACTIVE，这对我来说没有意义。我会期待COMMITTED, ROLLED_BACK, FAILED_COMMIT 之一。无论事务状态如何，我都会得到这个，即使我抛出一个导致回滚的异常，我仍然看不到NOT_ACTIVE以外的任何状态。

我们查找此信息的原因是确定我们是否需要将一些消息发布到队列中。基本上，如果未提交交易，请不要发布。截至目前，使用 Hibernate 5，我似乎无法找出如何以编程方式确定事务是否成功。

Answer 1

Hibernate 5 删除了在其拦截器中检测回滚的能力。相反，可以捕获该事务已回滚，并在未提交时推断回滚。

例如：

public class MyInterceptor extends EmptyInterceptor {
.
.
.

private static ThreadLocal<Boolean> wasCommited = new ThreadLocal();

@Override
public void beforeTransactionCompletion(Transaction tx) {
    // not called for rollback
    wasCommited.set(Boolean.TRUE);
}


@Override
public void afterTransactionCompletion(Transaction tx) {

    if ( !Boolean.TRUE.equals(wasCommited.get()) ) {
        try {
           // handle transaction rolled back
        }
        finally {
            wasCommited.set(null);
        }
    }
}
}

Answer 2

如果你使用 Spring 事务，你可以使用 TransactionSynchronization 来处理这类事情。例如：

TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization(){
           void afterCommit() {
                ..
           }
});

见TransactionSynchronizationManager

Answer 3

我成功使用了javax.transaction.Synchronization，它可以在交易中注册并收到正确的状态。可以使用 Hibernate 拦截器注册：

  @Override
  public void afterTransactionBegin(Transaction tx) {
    tx.registerSynchronization(new Synchronization() {
      @Override
      public void afterCompletion(int status) {
        // Here the status is correct
      }
    });
  }

---

编辑：

不幸的是，此解决方案仅在提交或回滚成功时才有效，否则不会调用回调。我最初一定是做错了测试。在JdbcResourceLocalTransactionCoordinatorImpl.TransactionDriverControlImpl的代码中可以看到。

Answer 4

经过一番挣扎，我最终将vnov's answer 用于Hibernate 5 解决方案（以替换现在缺少的org.hibernate.Transaction.wsComitted() 方法）。这个答案更深入地阐述了问题的解决方案。我正在通过 Spring AOP 使用org.hibernate.EmptyInterceptor。

@Before("bean(emptyInterceptor) && 执行（公共 * *.afterTransactionBegin(..)） && args(tx)") 受保护的无效afterTransactionBegin（org.hibernate.Transaction tx）{ tx.registerSynchronization(新 javax.transaction.Synchronization() { @覆盖 公共无效 beforeCompletion() { } @覆盖 public void afterCompletion(int status) { /* 状态是例如javax.transaction.Status.STATUS_COMMITTED 在这里做我的事， 即把身体的身体移到这里 afterTransactionCompletion(Transaction) 方法 */ } }); }

在 JdbcResourceLocalTransactionCoordinatorImpl.TransactionDriverControlImpl类源我看到了：

• 如果提交失败，将捕获 RuntimeException 并回滚事务。因此，在成功回滚的情况下，将使用 status == Status.STATUS_UNKNOWN 调用 Synchronization.afterCompletion(int) 方法。
• 如果回滚失败出现异常，则根本不会调用Synchronization.afterCompletion(int)方法。

编辑 (2021-11-24)

由于我们需要一个同时考虑回滚失败可能性的解决方案，我们想出了这个解决方案（在回滚失败后也会调用afterTransactionCompletion 方法）。

私有 ThreadLocal txCommitted = ThreadLocal.withInitial(() -> false); @Before("bean(emptyInterceptor) && 执行（公共 * *.afterTransactionBegin(..)） && args(tx)") 受保护的无效afterTransactionBegin（org.hibernate.Transaction tx）{ tx.registerSynchronization（新同步（）{ @覆盖 公共无效 beforeCompletion() { } @覆盖 public void afterCompletion(int status) { txCommitted.set(status == Status.STATUS_COMMITTED); } }); } @Before("bean(emptyInterceptor) && 执行（公共 * *.afterTransactionCompletion(..)） && args(tx)") 受保护的无效 afterTransactionCompletion（org.hibernate.Transaction tx）{ 如果 (txCommitted.get()) { /* 在这里做我提交时的东西 */ } 别的 { /* 在这里做我其他的事情 */ } }