查询超时不适用于春季启动中的 MS SQL 服务器

Question

我正在尝试在我的 Spring Boot Rest API 中设置查询超时。我正在执行一个存储过程（只读）。但是超时不起作用。

我使用 MS SQL 服务器作为数据源。

spring.datasource.url=jdbc:sqlserver://<servername>;instanceName=<instancename>;DatabaseName=<dbname>

春季开机版

2.4.4

尝试了以下选项 -

1. 使用超时设置@Transactional 注释

@Repository
public class StoredProcImpl  {

    @PersistenceContext
    private EntityManager entityManager;

    @Transactional (timeout = 30)
    public String getList() throws Exception {

        StoredProcedureQuery query = this.entityManager.createNamedStoredProcedureQuery("proc");
        query.setParameter("PAGE_NUMBER", offset);
        query.execute();

}

1. 在查询中设置提示

@Repository
public class StoredProcImpl  {

    @PersistenceContext
    private EntityManager entityManager;

    public String getList() throws Exception {

        StoredProcedureQuery query = this.entityManager.createNamedStoredProcedureQuery("proc");
        query.setHint("javax.persistence.query.timeout", 30);
        query.setParameter("PAGE_NUMBER", offset);
        query.execute();

}

还有

query.setHint("org.hibernate.timeout", 30)

所有选项都不起作用，即使 30 秒后查询也会继续等待。

感谢任何设置超时的帮助或指针。

Answer 1

您可以使用 JPA 的 javax.persistence.query.timeout 属性配置超时。该值是以毫秒为单位的超时时间。它是 JPA 规范的可选部分，但 Hibernate 支持它。您可以通过将以下内容添加到 application.properties 在 Spring Boot 中对其进行配置：

 spring.jpa.properties.javax.persistence.query.timeout=60000

为了使超时通用化，在您的 JpaConfiguration 中，当您声明 PlatformTransactionManager Bean 时，您可以设置事务的默认超时：

@Bean
public PlatformTransactionManager transactionManager() throws Exception {
    JpaTransactionManager txManager = new JpaTransactionManager();
    txManager.setEntityManagerFactory(entityManagerFactory().getObject());
    txManager.setDataSource(this.dataSource);
    txManager.setDefaultTimeout(10); //Put 10 seconds timeout
    return txManager;
}

PlatformTransactionManager 继承了包含该方法的 AbstractPlatformTransactionManager：

  public final void setDefaultTimeout(int defaultTimeout) {
        if (defaultTimeout < TransactionDefinition.TIMEOUT_DEFAULT) {
            throw new InvalidTimeoutException("Invalid default timeout", defaultTimeout);
        }
        this.defaultTimeout = defaultTimeout;
    }