25

这是我在阅读了几个关于 jpa 批量插入的主题后创建的简单示例，我有 2 个持久对象用户和站点。一个用户可以有多个站点，所以我们在这里有一对多的关系。假设我想创建用户并将多个站点创建/链接到用户帐户。考虑到我愿意为 Site 对象使用批量插入，代码如下所示。

User user = new User("John Doe");

user.getSites().add(new Site("google.com", user));
user.getSites().add(new Site("yahoo.com", user));

EntityTransaction tx = entityManager.getTransaction();
tx.begin();
entityManager.persist(user);
tx.commit();

但是当我运行这段代码（我使用hibernate作为jpa实现提供者）时，我看到以下sql输出：

Hibernate: insert into User (id, name) values (null, ?)
Hibernate: call identity()
Hibernate: insert into Site (id, url, user_id) values (null, ?, ?)
Hibernate: call identity()
Hibernate: insert into Site (id, url, user_id) values (null, ?, ?)
Hibernate: call identity()

所以，我的意思是“真正的”批量插入不起作用或者我很困惑？

这是此示例项目的源代码，这是 maven 项目，因此您只需下载并运行 mvn install 即可检查输出。

更新：

在肯刘好心的建议之后，我禁用了站点对象 id 自动生成：

    User user = new User("John Doe");
    user.getSites().add(new Site(1, "google.com", user));
    user.getSites().add(new Site(2, "yahoo.com", user));
    entityManager.setFlushMode(FlushModeType.COMMIT);
    EntityTransaction tx = entityManager.getTransaction();
    tx.begin();
    entityManager.persist(user);
    tx.commit();

现在我在调试输出中有以下行：

调试：org.hibernate.jdbc.AbstractBatcher - 执行批量大小：2

有用！

4

3 回答 3

21

如果您使用数据库生成 id，那么 Hibernate 必须执行查询来为每个实体生成主键。

于 2010-05-05T13:15:29.273 回答
7

我发现绕过休眠进行批量插入更有效。您必须取消 ORM（对象关系映射），但您仍然可以利用与当前会话和事务管理关联的连接。

虽然您暂时失去了 ORM 的便利性，但收益是显着的，特别是如果您有本地生成的 Id，因为 hibernate 通常会SELECT为每个INSERT.

Session.doWork对于促进这一点非常方便。

private MyParentObject saveMyParentObject(final MyParentObject parent, final List<MyChildObject> children)
{
    transaction = session.beginTransaction();
    try
    {
        session.save(parent); // NOTE: parent.parentId assigned and returned here

        session.doWork(new Work()
        {
            public void execute(Connection con) throws SQLException
            {
                // hand written insert SQL - can't use hibernate
                PreparedStatement st = con.prepareStatement("INSERT INTO my_child (parent_id, name, ...) values (?, ?, ...)");

                for (MyChildObject child : children)
                {
                    MyChildObject child = new MyChildObject();
                    child.setParentId(parent.getParentId()); // assign parent id for foreign key

                    // hibernate can't help, determine jdbc parameters manually
                    st.setLong(1, child.getParentId());
                    st.setString(2, child.getName());
                    ...
                    st.addBatch();
                }

                // NOTE: you may want to limit the size of the batch
                st.executeBatch();
            }
        });

        // if your parent has a OneToMany relationship with child(s), refresh will populate this 
        session.refresh(parent);
        transaction.commit();
        return parent;
    }
    catch(Throwable e)
    {
        transaction.rollback();
        throw new RuntimeException(e);
    }   
}
于 2014-10-28T23:53:41.310 回答
5

我写了一篇简短的博客，其中讨论了批量插入问题，并且还提供了指向具有所有正确配置的小型项目的指针，可以开始使用 Hibernate 进行批量插入。请参阅http://sensiblerationalization.blogspot.com/2011/03/quick-tip-on-hibernate-batch-operation.html上的详细信息

于 2011-03-09T03:21:09.510 回答