非事务场景下如何强制JPA的saveAll()执行提交操作？

你的核心需求是每批数据保存后立即提交事务，避免单事务过大导致内存溢出，同时让后续独立连接能读取到已保存的数据。以下是具体分析和实现方案：

1. 为什么flush()解决不了问题 #

flush()的作用是将JPA持久化上下文的变更同步到数据库，但不会提交事务。在默认的READ COMMITTED隔离级别下，未提交的事务变更对其他连接是不可见的，所以单独调用flush()无法让doSomethingElse的独立连接读到全部数据，必须提交事务才行。

2. JPA实现每批提交的正确方式 #

不需要退回到JDBC，利用Spring的事务传播特性就能实现每批独立提交：

步骤1：抽取批量保存方法并设置事务传播 #

将原来的saveAll逻辑抽成一个独立方法，添加@Transactional(propagation = Propagation.REQUIRES_NEW)注解。这个传播特性会让每次调用该方法时，开启一个全新的事务，执行完毕后自动提交，与外层（如果有的话）事务完全隔离。

@Service
public class MyThingService {

    private final MyThingRepository myThingRepository;
    private final EntityManager entityManager;

    // 构造函数注入依赖
    public MyThingService(MyThingRepository myThingRepository, EntityManager entityManager) {
        this.myThingRepository = myThingRepository;
        this.entityManager = entityManager;
    }

    public void importThings() {
        int rowsReadInThisBatch;
        int batchSize = 1000; // 根据内存调整合适的批次大小
        do {
            rowsReadInThisBatch = 0;
            List<MyThing> things = new ArrayList<>();

            while (rs.next() && (rowsReadInThisBatch < batchSize)) {
                MyThing thing = new MyThing(readThing());
                things.add(thing); // 原代码中favLeague应为笔误，替换为thing
                rowsReadInThisBatch++;
            }

            if (rowsReadInThisBatch > 0) {
                saveBatch(things); // 调用独立事务的保存方法
                // 清理持久化上下文，释放内存
                entityManager.clear();
            }
        } while (rowsReadInThisBatch == batchSize);

        doSomethingElse();
    }

    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public void saveBatch(List<MyThing> things) {
        myThingRepository.saveAll(things);
        // 事务提交时会自动flush并提交，无需手动操作
    }

    // ... 其他方法
}

步骤2：清理持久化上下文 #

由于你的服务内存只有0.5GB，每批处理完后调用entityManager.clear()可以清空JPA的一级缓存（持久化上下文），避免大量实体对象占用内存，防止内存溢出。

3. 为什么不能用方法级@Transactional #

如果在importThings上直接加@Transactional，整个方法会处于一个大事务中，所有批次的saveAll都会延迟到方法结束时才提交，不仅会导致内存占用飙升（持久化上下文缓存所有实体），还会让doSomethingElse在方法结束前读不到任何已保存的数据，完全违背你的需求。

4. 验证效果 #

每批调用saveBatch时，新事务会在方法执行完毕后立即提交，doSomethingElse的独立连接使用默认的READ COMMITTED隔离级别就能读取到所有已提交的批次数据，解决你现在只能读到少量数据的问题。

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