使用JOIN FETCH的JPA自定义Repository Stream抛出JDBC异常求助

核心原因 #

使用root.fetch()做关联抓取时，Hibernate会尝试调用isBeforeFirst()或isAfterLast()判断结果集是否为空，但返回Stream的JPA查询默认使用**仅向前（forward-only）**的ResultSet类型（TYPE_FORWARD_ONLY），该类型不支持滚动相关方法，因此触发报错。而root.join()不会触发这类检查逻辑，所以能正常运行。

可行解决办法 #

1. 显式指定查询使用滚动结果集 #

在自定义Repository的查询实现中，通过EntityManager创建查询时，强制设置结果集类型为可滚动的SCROLL_INSENSITIVE，同时保留Stream返回类型：

@Repository
public class CustomEntityRepositoryImpl implements CustomEntityRepository {

    @PersistenceContext
    private EntityManager em;

    @Override
    @Transactional
    public Stream<Entity> findEntitiesWithFetchedVariable() {
        CriteriaBuilder cb = em.getCriteriaBuilder();
        CriteriaQuery<Entity> query = cb.createQuery(Entity.class);
        Root<Entity> root = query.from(Entity.class);
        root.fetch("variable", JoinType.LEFT); // 保留fetch关联抓取

        return em.createQuery(query)
                .unwrap(org.hibernate.query.Query.class)
                .setResultSetType(ResultSetType.SCROLL_INSENSITIVE)
                .stream();
    }
}

可选优化：添加setHint(QueryHints.HINT_FETCH_SIZE, 50)设置分批读取大小，平衡性能与内存占用。

2. 先将Stream转换为集合再遍历 #

若不想修改查询配置，可先把Stream收集为List再遍历，让Hibernate提前处理完结果集，避免遍历Stream时操作未关闭的ResultSet：

@Transactional
public void processEntities() {
    try (Stream<Entity> stream = customEntityRepository.findEntitiesWithFetchedVariable()) {
        List<Entity> entityList = stream.collect(Collectors.toList());
        entityList.forEach(entity -> {
            // 业务处理逻辑
        });
    }
}

注意：此方式会将所有结果加载到内存，数据量极大时需评估内存占用情况。

3. 全局配置Hibernate的Stream结果集类型 #

在配置文件中添加参数，强制所有返回Stream的JPA查询使用滚动结果集：

# Spring Boot 配置示例
spring.jpa.properties.hibernate.query.stream.result_set_type=SCROLL_INSENSITIVE

该配置全局生效，适合需要统一处理的场景。

验证注意事项 #

• 确保所有Stream操作都在@Transactional注解的方法内执行，避免ResultSet提前关闭
• 使用try-with-resources包裹Stream，确保资源正确释放

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