Spring Boot集成MySQL时如何全局设置查询超时时间？

针对你遇到的问题，以下是几种无需逐个方法加注解的全局查询超时实现方式：

1. 利用HikariCP全局配置语句超时 #

Spring Boot默认使用HikariCP作为连接池，可直接通过配置参数全局设置所有SQL语句的执行超时：

在application.properties或application.yml中添加：

# 获取连接的超时时间（毫秒）
spring.datasource.hikari.connection-timeout=30000
# SQL语句执行的超时时间（秒，Hikari会自动转换为毫秒设置到Statement）
spring.datasource.hikari.statement-timeout=5

该配置会对所有通过Hikari连接执行的SQL生效，包括JPA的原生查询和JPQL查询，无需修改代码。

2. 自定义Hibernate拦截器统一设置超时 #

通过Hibernate的拦截器，在每次生成SQL语句时为Statement设置超时：

首先编写拦截器类：

import org.hibernate.EmptyInterceptor;
import org.hibernate.Session;
import org.hibernate.jpa.internal.EntityManagerImpl;

import javax.persistence.EntityManager;
import java.sql.Connection;
import java.sql.SQLException;

@Component
public class GlobalQueryTimeoutInterceptor extends EmptyInterceptor {
    // 全局查询超时时间（秒）
    private static final int QUERY_TIMEOUT_SECONDS = 5;

    @Override
    public String onPrepareStatement(String sql) {
        // 获取当前会话的连接
        Session session = getSession();
        if (session != null) {
            EntityManager em = new EntityManagerImpl(session);
            try (Connection conn = em.unwrap(Connection.class)) {
                // 设置Statement超时
                conn.setNetworkTimeout(null, QUERY_TIMEOUT_SECONDS * 1000);
            } catch (SQLException e) {
                // 异常处理，比如日志记录
            }
        }
        return super.onPrepareStatement(sql);
    }
}

然后在配置文件中指定该拦截器：

spring.jpa.properties.hibernate.ejb.interceptor=com.yourpackage.GlobalQueryTimeoutInterceptor

3. Spring AOP全局拦截仓库方法 #

通过AOP切面，为所有JPA仓库方法自动添加带超时的事务，无需逐个方法标注@Transactional：

编写切面类：

import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.support.TransactionTemplate;

@Aspect
@Component
public class RepositoryTimeoutAspect {
    private static final int QUERY_TIMEOUT = 5; // 秒
    private final TransactionTemplate transactionTemplate;

    @Autowired
    public RepositoryTimeoutAspect(PlatformTransactionManager transactionManager) {
        this.transactionTemplate = new TransactionTemplate(transactionManager);
        this.transactionTemplate.setTimeout(QUERY_TIMEOUT);
    }

    // 拦截所有仓库包下的方法
    @Around("execution(* com.yourpackage.repository..*(..))")
    public Object applyQueryTimeout(ProceedingJoinPoint joinPoint) throws Throwable {
        return transactionTemplate.execute(status -> {
            try {
                return joinPoint.proceed();
            } catch (Throwable e) {
                throw new RuntimeException("Query execution failed", e);
            }
        });
    }
}

注意：需确保项目中引入了Spring AOP依赖，若使用Spring Boot Starter，spring-boot-starter-aop已包含在web或data-jpa starter中。

4. JDBC URL层面设置Socket超时 #

在MySQL JDBC URL中添加socketTimeout参数，限制连接上的数据传输超时，可间接终止长时间无响应的查询：

spring.datasource.url=jdbc:mysql://localhost:3306/your_database?useSSL=false&serverTimezone=UTC&connectTimeout=30000&socketTimeout=5000

• connectTimeout：建立连接的超时（毫秒）
• socketTimeout：数据传输阶段的超时（毫秒），若查询执行过程中超过该时间无数据返回，会抛出SocketTimeoutException

内容的提问来源于stack exchange，提问作者Santanu Das