为什么db连接在尝试和失败后关闭，无法获得一个与sping-data-jpa锁？

Question

因此，我想包装一个PessimisticLockingFailureExc，当尝试为已锁定的实体获取锁时，它会在jpahtml" target="_blank">存储库中引发。并在我的异常处理程序中处理包装的异常。

但是似乎当spring试图结束事务时，连接已经关闭了，spring抛出了一个新的异常，覆盖了我希望看到的异常。

在日志中，我得到了“应用程序异常被回滚异常覆盖”，我想避免这种情况。（回滚ex的原因是“连接已关闭”）

这个有解决办法吗？还是我做错了什么？

（这是我正在做的一些伪代码）

  String restControllerMethod(String args) {
    try {
      return service.serviceMethod(args);
    } catch (Exception e1) {
      throw e1; // org.springframework.orm.jpa.JpaSystemException caused by org.hibernate.TransactionException caused by java.sql.SQLException
    }
  }

  @Transactional
  String serviceMethod(String args) {
    Entity entity;
    try {
      entity = repo.repoFindMethod(args);
    } catch (Exception e2) {
      throw new WrappingException(e2); // org.springframework.dao.PessimisticLockingFailureException caused by org.hibernate.PessimisticLockException
    }
    // do some processing with entity
    return result;
  }

  @Lock(LockModeType.PESSIMISTIC_READ)
  String repoFindMethod(String args);

我正在使用 spring-boot-starter-parent 2.3.2.RELEASE 与 spring-boot-starter-web spring-boot-starter-data-jpa 和一个嵌入的 h2 db

Answer 1

通过添加com.zaxxer.hikari修复了此问题。SQLExceptionOverride实现并指向＜code＞spring.datasource.hikari。异常覆盖类名。

这导致hikari在db抛出带有指定错误代码的异常时不关闭连接。

我还将@QueryHint（{@QueryHint（name="javax.persistence.lock.timeout"， value="0"）}）添加到锁定查询中，因为默认锁定等待时间可能是供应商特定的

此解决方案的问题在于它是特定于供应商的（对于h2和hikari）。并不是所有的供应商都支持自定义超时来获取锁（例如h2不支持这个，但因为它的超时很短，所以没那么重要）

我的解决方案示例(针对h2):

spring.datasource.hikari.exception override class name=com.example。H2SQLExceptionOverride

public class H2SQLExceptionOverride implements SQLExceptionOverride {

  private static final Logger logger = LoggerFactory.getLogger(H2SQLExceptionOverride.class);
  public static final int LOCK_TIMOUT_ERROR_CODE = 50200;

  @java.lang.Override
  public Override adjudicate(SQLException sqlException) {
    if (sqlException.getErrorCode() == LOCK_TIMOUT_ERROR_CODE) {
      logger.debug("Diverting from default hikari impl and continuing transaction with errorCode: "
          + sqlException.getErrorCode() + " and sqlState: " + sqlException.getSQLState());
      return Override.DO_NOT_EVICT;
    }
    return Override.CONTINUE_EVICT;
  }
}