Spring Boot中JDBCTemplate单查询设置超时并支持RowMapper的方案

1. 可以仅对单个查询设置超时，不影响全局事务 #

完全可以实现单查询级别的超时控制，无需修改JDBC全局超时配置。核心思路是利用JdbcTemplate提供的带PreparedStatementCreator参数的重载方法，在创建PreparedStatement时直接设置查询超时时间，该配置只会作用于当前这一次查询。

当查询超时后，JDBC驱动会抛出SQLTimeoutException，若该查询处于Spring事务管理范围内（比如方法标注了@Transactional），Spring会自动触发事务回滚——因为SQLTimeoutException属于RuntimeException子类，符合默认的事务回滚规则。

2. PreparedStatement完全支持RowMapper #

RowMapper的作用是将ResultSet中的行数据映射为Java对象，它不依赖具体的Statement类型（Statement/PreparedStatement/CallableStatement），只要能获取到ResultSet即可。JdbcTemplate本身就提供了结合PreparedStatement和RowMapper的重载方法，完全满足你的需求。

代码示例 #

假设你要查询User对象，同时设置5秒的查询超时：

import org.springframework.jdbc.core.PreparedStatementCreator;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.transaction.annotation.Transactional;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

@Transactional
public User queryUserWithTimeout(Long userId) {
    String sql = "SELECT id, username, email FROM user WHERE id = ?";
    
    return jdbcTemplate.query(new PreparedStatementCreator() {
        @Override
        public PreparedStatement createPreparedStatement(Connection con) throws SQLException {
            PreparedStatement ps = con.prepareStatement(sql);
            ps.setLong(1, userId);
            // 设置查询超时，单位：秒
            ps.setQueryTimeout(5);
            return ps;
        }
    }, new RowMapper<User>() {
        @Override
        public User mapRow(ResultSet rs, int rowNum) throws SQLException {
            User user = new User();
            user.setId(rs.getLong("id"));
            user.setUsername(rs.getString("username"));
            user.setEmail(rs.getString("email"));
            return user;
        }
    }).stream().findFirst().orElse(null);
}

用Lambda表达式简化后的代码：

@Transactional
public User queryUserWithTimeout(Long userId) {
    String sql = "SELECT id, username, email FROM user WHERE id = ?";
    
    return jdbcTemplate.query(
            con -> {
                PreparedStatement ps = con.prepareStatement(sql);
                ps.setLong(1, userId);
                ps.setQueryTimeout(5);
                return ps;
            },
            (rs, rowNum) -> {
                User user = new User();
                user.setId(rs.getLong("id"));
                user.setUsername(rs.getString("username"));
                user.setEmail(rs.getString("email"));
                return user;
            }
    ).stream().findFirst().orElse(null);
}

注意事项 #

• setQueryTimeout的参数单位是秒，主流数据库驱动（MySQL、PostgreSQL等）均支持该设置，但具体超时逻辑可能略有差异。
• 必须确保查询方法处于Spring事务上下文内（比如标注@Transactional），否则超时异常无法触发事务回滚。
• 若需自定义事务回滚规则，可在@Transactional注解中通过rollbackFor属性指定异常类型。

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