如何实现EntityManager.persist暂不提交至DB，仅手动flush且无需@Transactional？

首先明确一个核心误解：JPA的persist方法（包括getReference）必须在活动事务上下文里执行，这是JPA规范的强制要求，和FlushMode无关。FlushMode只控制EntityManager何时自动将持久化上下文的变更同步到数据库，而不是persist操作是否需要事务。你遇到的TransactionRequiredException正是因为add方法不在事务中调用persist导致的。

要实现“多次调用add托管实体，仅在commit时批量写入DB”的需求，有两种可行方案：

方案1：业务层统一控制事务边界（推荐，符合CDI/JPA最佳实践） #

容器管理的EntityManager默认是事务范围的，即每个事务会绑定一个EntityManager实例。你可以在业务逻辑层（而非Repository层）设置事务边界，让所有add操作和commit操作共享同一个事务：

1. 编写业务Service类，在处理数据集的方法上添加@Transactional：

@ApplicationScoped
public class DataService {
    private final DataRepository dataRepository;

    @Inject
    public DataService(DataRepository dataRepository) {
        this.dataRepository = dataRepository;
    }

    @Transactional
    public void processAndSaveLargeDataset(List<Data> dataset) {
        for (Data data : dataset) {
            dataRepository.add(data);
        }
        dataRepository.commitCurrentDataToDb();
    }
}

2. 修改DataRepository的commitCurrentDataToDb方法，去掉@Transactional（或改为@Transactional(propagation = Propagation.SUPPORTS)），避免创建新事务：

public void commitCurrentDataToDb() {
    entityManager.flush();
    totalAmountOfCachedData = 0;
}

此时，整个processAndSaveLargeDataset方法在一个事务中执行：

• 每次调用add时，persist将实体加入当前事务绑定的持久化上下文，不会立即写入数据库；
• 调用flush时，所有托管实体的变更会批量同步到DB；
• 方法执行完毕后，事务自动提交，完成最终持久化。

方案2：手动管理EntityManager与事务（适合高度自定义场景） #

如果需要更灵活的事务控制，可以不依赖容器管理的EntityManager，手动创建并控制事务生命周期：

@ApplicationScoped
public class DataRepository {
    private EntityManager entityManager;
    private int totalAmountOfCachedData = 0;

    @Inject
    public DataRepository(EntityManagerFactory emf) {
        this.entityManager = emf.createEntityManager();
        this.entityManager.setFlushMode(FlushModeType.COMMIT);
    }

    // 手动开启事务
    public void startBatch() {
        if (!entityManager.getTransaction().isActive()) {
            entityManager.getTransaction().begin();
        }
    }

    public void add(Data data) {
        setReferences(data);
        entityManager.persist(data);
        totalAmountOfCachedData++;
    }

    public void commitCurrentDataToDb() {
        if (entityManager.getTransaction().isActive()) {
            entityManager.flush();
            entityManager.getTransaction().commit();
            totalAmountOfCachedData = 0;
            // 若需继续批量操作，可重新开启事务
            entityManager.getTransaction().begin();
        }
    }

    // 应用关闭时清理资源
    @PreDestroy
    public void cleanup() {
        if (entityManager.isOpen()) {
            entityManager.close();
        }
    }

    private void setReferences(Data data) {
        // 执行entityManager.getReference操作
    }
}

使用方式：

// 开启批量事务
dataRepository.startBatch();
// 多次调用add托管实体
for (Data data : largeDataset) {
    dataRepository.add(data);
}
// 提交批量数据
dataRepository.commitCurrentDataToDb();

关键注意点 #

• 容器管理的EntityManager不能跨事务使用，每次事务结束后容器会自动清理EntityManager；
• FlushModeType.COMMIT的作用是禁止EntityManager在查询前自动flush，但不会改变persist需要事务的要求；
• 处理超大数据集时，建议定期调用flush并clearEntityManager，避免持久化上下文过大导致内存溢出（比如每添加N条数据就flush+clear一次）。

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