为什么在尝试使用spring-data-jpa锁定失败后无法关闭数据库连接？

问题描述

因此，我想包装一个PessimisticLockingFailureException，它在尝试为已锁定的实体获取锁时会在jpa存储库中引发。并在我的异常处理程序中处理包装的异常。

但是似乎当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

解决方法

通过添加com.zaxxer.hikari.SQLExceptionOverride实现并指向 spring.datasource.hikari.exception-override-class-name。

这会导致在数据库引发具有指定错误代码的异常时，hikari无法关闭连接。

我还向锁定查询中添加了@QueryHints({@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;
  }
}