Spring Data JPA返回ResultSet调用next()抛出IllegalArgumentException问题排查

问题原因 #

Spring Data JPA的Repository接口设计目标是返回实体类、DTO或基本数据类型，当你直接返回java.sql.ResultSet时，Spring会通过JDK动态代理（即你看到的com.sun.proxy.$Proxy197）包装这个对象。Spring的代理逻辑会将返回对象当作符合JavaBean规范的类处理，检查方法是否为访问器（getter/setter），而ResultSet.next()是JDBC操作方法，不符合访问器定义，因此抛出IllegalArgumentException。另外，ResultSet是JDBC底层资源，直接返回会存在资源泄漏风险——Spring不会自动帮你关闭它。

解决方案 #

方案1：封装结果为DTO/实体类（推荐） #

定义与查询结果字段匹配的DTO类，让Spring Data JPA自动映射结果，完全避免直接操作ResultSet。

示例：

1. 定义DTO类：

public class UserDTO {
    private Long id;
    private String username;

    // 构造方法参数顺序需与查询字段顺序一致
    public UserDTO(Long id, String username) {
        this.id = id;
        this.username = username;
    }

    // 按需添加getter方法
    public Long getId() { return id; }
    public String getUsername() { return username; }
}

2. 在Repository中编写查询：

@Repository
public interface UserRepository extends JpaRepository<User, Long> {
    @Query(value = "SELECT id, username FROM users WHERE age > ?1", nativeQuery = true)
    List<UserDTO> findUsersByAgeGreaterThan(int age);
}

调用该方法时直接获取封装好的List<UserDTO>，无需手动处理ResultSet。

方案2：使用EntityManager手动执行查询 #

如果必须直接操作ResultSet，可以通过EntityManager获取原生JDBC连接，手动执行SQL并管理资源：

@Service
public class UserService {
    @PersistenceContext
    private EntityManager entityManager;

    public void processResultSet() {
        Session session = entityManager.unwrap(Session.class);
        Connection connection = session.doReturningWork(conn -> conn);
        
        try (PreparedStatement stmt = connection.prepareStatement("SELECT id, username FROM users WHERE age > ?")) {
            stmt.setInt(1, 18);
            try (ResultSet rs = stmt.executeQuery()) {
                while (rs.next()) {
                    // 处理结果逻辑
                    Long id = rs.getLong("id");
                    String username = rs.getString("username");
                }
            }
        } catch (SQLException e) {
            // 异常处理
            e.printStackTrace();
        }
    }
}

通过try-with-resources语法自动关闭ResultSet、PreparedStatement等资源，避免泄漏。

方案3：自定义Repository实现 #

扩展Spring Data Repository的自定义实现，在实现类中处理原生JDBC操作：

1. 定义自定义接口：

public interface UserCustomRepository {
    void processNativeResultSet();
}

2. 实现自定义接口：

public class UserCustomRepositoryImpl implements UserCustomRepository {
    @PersistenceContext
    private EntityManager entityManager;

    @Override
    public void processNativeResultSet() {
        Session session = entityManager.unwrap(Session.class);
        Connection connection = session.doReturningWork(conn -> conn);
        
        try (PreparedStatement stmt = connection.prepareStatement("SELECT id, username FROM users");
             ResultSet rs = stmt.executeQuery()) {
            while (rs.next()) {
                // 自定义结果处理逻辑
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

3. 让主Repository继承自定义接口：

@Repository
public interface UserRepository extends JpaRepository<User, Long>, UserCustomRepository {
}

之后可通过UserRepository直接调用自定义方法处理ResultSet。

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