使用 JPA/EJB3 批量插入

Question

JPA/EJB3框架是否提供了执行批量插入操作的标准方法...？ 我们使用hibernate作为持久化框架，所以我可以回退到Hibernate Session并使用组合session.save()/session.flush()实现批量插入。 但想知道 EJB3 是否支持这个......

Answer 1

特别是对于 hibernate，核心手册的第 13 章解释方法。

但是您说您希望通过 Hibernate 使用 EJB 方法，因此实体管理器文档也有一章关于该内容 此处。 我建议您阅读两者（核心和实体管理器）。

在 EJB 中，它只是使用 EJB-QL（有一些限制）。 如果您需要更多灵活性，Hibernate 提供了更多机制。

Answer 2

是的，如果您希望获得您定义的控制，您可以回滚到您的 JPA 实现。

JPA 1.0 丰富了 EL-HQL，但缺乏 Criteria API 支持，不过这个问题已在 2.0 中得到解决。

Session session = (Session) entityManager.getDelegate();
session.setFlushMode(FlushMode.MANUAL);

Answer 3

Pascal

在您插入 100000 条记录的示例中，它是在单个事务中完成的，因为 commit() 仅在最后调用。它会给数据库带来很大的压力吗？ 而且万一出现回滚，成本也太大了。

下面的做法会不会更好呢？

EntityManager em = ...;
for ( int i=0; i<100000; i++ ) {
   if(!em.getTransaction().isActive()) {
      em.getTransaction().begin();
   }
   Customer customer = new Customer(.....);
   em.persist(customer);
   if ((i+1) % 20 == 0 ) { //20, same as the JDBC batch size
      //flush and commit of inserts and release memory:
      em.getTransaction().commit(); 
      em.clear();
   }
}

session.close();

Answer 4

JPA 和 Hibernate 都不提供对批量插入的特殊支持，并且使用 JPA 进行批量插入的习惯用法与使用 Hibernate 相同：

EntityManager em = ...;
EntityTransaction tx = em.getTransaction();
tx.begin();

for ( int i=0; i<100000; i++ ) {
    Customer customer = new Customer(.....);
    em.persist(customer);
    if ( i % 20 == 0 ) { //20, same as the JDBC batch size
        //flush a batch of inserts and release memory:
        em.flush();
        em.clear();
    }
}

tx.commit();
session.close();

在我看来，在这种情况下使用 Hibernate 的专有 API 不会提供任何优势。

参考

• JPA 1.0 规范
  • 第 4.10 节“批量更新和删除操作”
• Hibernate Core 参考指南
  • 第 13 章 批处理< /a>

  
  

Answer 5

对于中等记录数，您可以使用这种方式：

em.getTransaction().begin();
for (int i = 1; i <= 100000; i++) {
     Point point = new Point(i, i);
     em.persist(point);
     if ((i % 10000) == 0) {
          em.flush();
          em.clear();
     }
}
em.getTransaction().commit();

但是对于大记录数，您应该在多个事务中执行此任务：

em.getTransaction().begin();
for (int i = 1; i <= 1000000; i++) {
      Point point = new Point(i, i);
      em.persist(point);
      if ((i % 10000) == 0) {
          em.getTransaction().commit();
          em.clear();          
          em.getTransaction().begin();
      }
}
em.getTransaction().commit();

参考：JPA 批量存储