Hibernate使用ScrollableResults遍历数据时是否需要开启长事务？

核心结论 #

既不要长期持有事务，也不要完全依赖隐式自动提交事务，最优方案根据你的读写需求二选一：

• 纯读场景：短只读事务开启游标查询，提交事务后遍历结果集
• 有读写需求：批量拉取+短事务批量提交，避免长事务占用资源

常见误区说明 #

1. 无显式事务不等于没有事务：绝大多数数据库默认开启自动提交，你每执行一次结果集拉取操作都会隐式创建并提交一个事务，额外增加开销，且无法保证数据读取一致性。
2. 长事务的危害：长期持有事务会占用数据库连接池资源，导致数据库MVCC Undo日志无法清理，数据量大遍历时间久的情况下会严重拖慢数据库性能，甚至触发连接池耗尽。

落地实现方案 #

方案1：纯读场景（无数据回写） #

仅在开启游标查询的阶段持有短事务，标记查询为只读降低开销，事务提交后再遍历结果集，大多数主流数据库（PostgreSQL/MySQL 8.0+/Oracle）都支持事务提交后游标仍可正常访问：

EntityManager em = emf.createEntityManager();
int fetchSize = 200; // 按需调整每次从游标拉取到内存的记录数
try {
    EntityTransaction tx = em.getTransaction();
    tx.begin();
    ScrollableResults scrollableResults = em.unwrap(Session.class)
            .createQuery("my select query", MyEntity.class)
            .setReadOnly(true) // 标记为只读查询，减少事务开销
            .setFetchSize(fetchSize)
            .scroll(ScrollMode.FORWARD_ONLY); // 前向只读滚动，性能最优
    tx.commit(); // 直接提交事务，不需要等遍历完成

    // 遍历阶段不需要持有事务
    while (scrollableResults.next()) {
        MyEntity entity = (MyEntity) scrollableResults.get(0);
        someCalculation(entity);
    }
    scrollableResults.close();
} finally {
    em.close();
}

如果你的数据库不支持事务提交后游标保留，可以调整为分批次分页拉取，每次拉取一批数据后立即提交事务，再处理内存中的数据，循环直到拉取完成。

方案2：有读写需求（遍历后需要更新/插入数据） #

不要单条处理提交，攒到固定批次后再开启短事务批量写入，同时清理Hibernate一级缓存避免内存溢出：

EntityManager em = emf.createEntityManager();
int batchSize = 100;
List<MyEntity> processBatch = new ArrayList<>(batchSize);
try {
    EntityTransaction tx = em.getTransaction();
    tx.begin();
    ScrollableResults scrollableResults = em.unwrap(Session.class)
            .createQuery("my select query", MyEntity.class)
            .setFetchSize(batchSize)
            .scroll(ScrollMode.FORWARD_ONLY);
    tx.commit();

    while (scrollableResults.next()) {
        MyEntity entity = (MyEntity) scrollableResults.get(0);
        someCalculation(entity);
        processBatch.add(entity);

        // 攒够批次后批量写入
        if (processBatch.size() >= batchSize) {
            EntityTransaction writeTx = em.getTransaction();
            writeTx.begin();
            for (MyEntity item : processBatch) {
                em.merge(item);
            }
            writeTx.commit();
            processBatch.clear();
            em.clear(); // 清理一级缓存，避免内存溢出
        }
    }
    // 处理剩余未提交的批次
    if (!processBatch.isEmpty()) {
        EntityTransaction writeTx = em.getTransaction();
        writeTx.begin();
        for (MyEntity item : processBatch) {
            em.merge(item);
        }
        writeTx.commit();
    }
    scrollableResults.close();
} finally {
    em.close();
}

方案3：超大批量处理首选：无状态会话 #

如果完全不需要Hibernate的一级缓存、脏检查等特性，直接用StatelessSession，不需要显式事务即可执行查询，内存开销远低于普通Session，适合百万级以上数据处理：

StatelessSession session = emf.unwrap(SessionFactory.class).openStatelessSession();
try {
    ScrollableResults scrollableResults = session.createQuery("my select query", MyEntity.class)
            .setFetchSize(200)
            .scroll(ScrollMode.FORWARD_ONLY);
    while (scrollableResults.next()) {
        MyEntity entity = (MyEntity) scrollableResults.get(0);
        someCalculation(entity);
        // 回写直接调用session.update(entity)即可，自动提交不需要显式事务
    }
    scrollableResults.close();
} finally {
    session.close();
}

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