mysql - EclipseLink、JPA、Mysql 关闭自动提交

Question

当我执行entityManager.persist();时，MySQL 无法提交每一行；

我尝试过

JPAConnect.em.setFlushMode(FlushModeType.COMMIT);

没有任何运气。

或者有没有办法提交列表<>而不必循环每一行？

jpac.beginTransaction();

        for (BuyLateStrategyEntity buyLateEntity : buyLateList) {
            stockName = buyLateEntity.getStockName();

            freader.readRawData(stockName, buyLateEntity.getTradeDate());


            //persist() done here.
            runningTotal *= findSalePrice(buyLateEntity.getClosePrice());

            System.out.println("Running total: " + runningTotal + " At Date: " + 
            buyLateEntity.getTradeDate() + " Instrument: " + buyLateEntity.getStockName());
        }
        jpac.commitTransaction();

Answer 1

如果您希望行按特定顺序命中数据库，唯一的解决方法是刷新。只需阅读 FlushModeType here 的文档您会明白，它实际上会影响与执行查询结合的刷新时间，而不是与其他 persist() 调用结合使用。

如果您只是希望行以任何特定顺序命中数据库，我只需为每一行调用 em.persist()/merge() (在您的代码中是缺少)，但在提交之前 flush() 一次(尽管刷新会在事务提交时自动发生)。

但是，如果您的想法是刷新每一行:您是否正在尝试解决正确的问题:为什么需要在 for 循环中刷新？也许您只需要一个排序参数(如果该列表是另一个实体中的字段，JPA 可以为您做到这一点)？请记住，即使您刷新一个条目，在您提交之前，结果对其他事务也是不可见的(给定合理的事务隔离和支持事务的存储引擎，如 InnoDB)。

<小时/>

更新(在您明确表示希望尽可能减少与数据库的通信之后)

你已经尽力了，只提交(因此刷新)一次。附带说明:在 EclipseLink 中支持 Batch Write如果您的数据库支持，您可以启用它。问题是 MySQL 仅支持批量插入，而不支持更新，因此您不应该启用它。