Spring Data JPA流式查询触发InvalidDataAccessApiUsageException问题求助

我之前也碰到过一模一样的问题，这个报错的核心原因是流式查询需要一个持续活跃的事务来保持数据库连接打开，直到整个流被完全消费。咱们来拆解下你的代码里的问题：

问题根源分析 #

1. Service层事务传播行为不匹配：你在handleRequest方法上用了propagation = Propagation.SUPPORTS，这个传播行为的逻辑是「如果当前有事务就加入，没有就不创建新事务」。当这个方法被调用时，如果没有外层事务，就不会开启任何事务。
2. Repository层事务范围太窄：你的streamAll方法标注了@Transactional(readOnly = true)，这个事务只会覆盖Repository方法的执行过程——也就是查询返回Stream的那一刻。一旦方法执行完毕，事务就会提交，数据库连接被释放，而这时候你才刚拿到Stream准备开始消费，自然会报错说没有环绕事务。

具体解决方案 #

1. 调整Service层的事务传播行为 #

把handleRequest方法上的事务传播行为改成Propagation.REQUIRED（这也是默认值，可以直接省略不写），这样不管有没有外层事务，都会确保整个方法执行过程（包括Stream的消费）都处于一个活跃的事务中：

@Override
@Transactional(readOnly = true) // 默认传播行为就是REQUIRED，可省略propagation参数
public void handleRequest(Object request, Message msg) {
    try (Stream<MyBeanData> data = myBeanDao.streamAll()) {
        // 这里的Stream消费逻辑会全程处于事务中
    } catch (Exception e) {
        // 异常处理逻辑
    }
}

2. 移除Repository层的@Transactional注解 #

既然Service层已经提供了覆盖整个流消费过程的事务，Repository层的方法级事务就不需要了——它反而会导致事务嵌套，让Repository方法执行完就提前关闭连接：

@Repository
public interface MyBeanDao extends JpaRepository<MyBeanData, Long> {
    @QueryHints(value = @QueryHint(name = HINT_FETCH_SIZE, value = "" + Integer.MIN_VALUE))
    @Query(value = "SELECT * FROM MY_TABLE", nativeQuery = true)
    // 移除这里的@Transactional(readOnly = true)
    Stream<MyBeanData> streamAll();
}

3. 清理重复的@EnableTransactionManagement配置 #

你在MySpringBootApplication和MySpringBootApplicationConfiguration两个类上都加了@EnableTransactionManagement，虽然Spring Boot不会直接报错，但建议只保留在一个地方（比如主启动类MySpringBootApplication），避免潜在的配置冲突。

为什么这样能解决问题？ #

调整后，事务的范围覆盖了从调用Repository获取Stream，到整个Stream被消费完毕的全过程。数据库连接会在整个事务周期内保持打开状态，直到handleRequest方法执行完成（或者try-with-resources自动关闭Stream后），事务才会提交，连接被释放，完美匹配流式查询的需求。

内容的提问来源于stack exchange，提问作者flo-ferox