Spring Boot中从JpaRepository流式返回结果至REST API时出现java.sql.SQLException: Closed Resultset: next异常

这个问题我之前也踩过坑，核心原因是事务生命周期和流式返回的时机完全不匹配，咱们一步步拆解和解决：

问题根源 #

你当前的代码里，Controller层的@Transactional会在方法返回Stream<Entity>之后立刻提交事务，此时数据库连接被归还给连接池，对应的ResultSet也会被强制关闭。但Spring MVC并不会在方法返回时立刻遍历这个流——它会在后续的请求处理阶段（此时事务已经彻底结束）才开始序列化流中的数据，这时候再去调用ResultSet.next()自然就会抛出"Closed Resultset: next"异常。

而且JPA的Stream是和事务上下文强绑定的，只有在事务打开的状态下才能安全遍历，一旦事务提交/回滚，底层的ResultSet就会被销毁。

解决方法 #

我们需要把流的遍历操作牢牢锁在事务生效的范围内，同时用StreamingResponseBody实现真正的流式响应。下面是具体改造步骤：

1. 调整Service层，让流消费在事务内完成

修改Service方法，接受一个Consumer来处理每个实体，确保遍历流的全程都处于事务上下文之中：

@Service
public class EntityService {
    @Autowired
    private EntityRepository repository;
    
    @Transactional(readOnly = true)
    public void processEntitiesByFilter(String filter, Consumer<Entity> entityConsumer) {
        // 在这里遍历流，事务会保持打开直到遍历完成
        repository.findAllByFilter(filter).forEach(entityConsumer);
    }
}

2. 修改Controller层，用StreamingResponseBody返回流式响应

不再直接返回Stream<Entity>，而是用StreamingResponseBody控制响应的写入逻辑，让Service层在事务内完成实体的处理：

@RestController
@RequestMapping("/entities")
public class EntityController {
    @Autowired
    private EntityService service;
    @Autowired
    private ObjectMapper objectMapper; // 注入全局ObjectMapper，避免重复创建
    
    @GetMapping(value = "/filter/{filter}")
    public ResponseEntity<StreamingResponseBody> getEntitiesByFilter(@PathVariable("filter") String filter) {
        StreamingResponseBody responseBody = outputStream -> {
            // 调用Service方法，在事务内遍历并写入响应流
            service.processEntitiesByFilter(filter, entity -> {
                try {
                    // 将实体序列化为JSON并写入输出流
                    objectMapper.writeValue(outputStream, entity);
                    outputStream.write('\n'); // 可选：用换行分隔每个JSON对象，方便客户端解析
                } catch (IOException e) {
                    throw new RuntimeException("Failed to write entity to response", e);
                }
            });
        };
        
        return ResponseEntity.ok()
                .contentType(MediaType.APPLICATION_JSON)
                .body(responseBody);
    }
}

3. 清理不必要的Transactional注解

记得删掉Controller层原来的@Transactional——它不仅起不到作用，反而会导致事务提前关闭，直接触发问题。

额外优化建议 #

为了让Oracle的流式查询更高效，建议在application.properties里添加以下配置，设置合理的预取行数，避免一次性加载大量数据到内存：

# Hibernate层面设置fetch size
spring.jpa.properties.hibernate.jdbc.fetch_size=1000
# Oracle JDBC驱动层面设置默认预取行数
spring.datasource.hikari.data-source-properties.oracle.jdbc.defaultRowPrefetch=1000

这样改造后，流的遍历操作全程处于事务打开状态，底层的ResultSet不会被提前关闭，异常自然就消失了。

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