我在 jpa 中使用 SpringFramework 3 和 Hibernate 4 以及 MySQL 5。我的测试代码看起来像...

@Repository
public class TestRepositoryImpl implements TestRepository {

  @PersistenceContext
  private EntityManager em;

  @Override
  @Transactional
  public void insertBulk() {
     Item it;
     for(int i= 0; i<1000;i++) {
        it = new Item();
        it.setPrice(Math.random()*100);
        em.persist(it);
     }
  }
}

我的 Spring 配置

 <bean id="entityManagerFactory"
    class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean">
    <property name="persistenceUnitName" value="application" />
</bean>

<bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager">
    <property name="entityManagerFactory" ref="entityManagerFactory" />
</bean>

<tx:annotation-driven transaction-manager="transactionManager" />

我的持久化.xml

<persistence xmlns="http://java.sun.com/xml/ns/persistence"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://java.sun.com/xml/ns/persistence http://java.sun.com/xml/ns/persistence/persistence_1_0.xsd"
version="1.0">

<persistence-unit name="application" transaction-type="RESOURCE_LOCAL">
    <provider>org.hibernate.ejb.HibernatePersistence</provider>
    <class>com.springapp.test.domain.Item</class>
    <class>com.springapp.test.domain.Order</class>
    <exclude-unlisted-classes>true</exclude-unlisted-classes>
    <properties>
        <property name="hibernate.show_sql" value="true" />
        <property name="hibernate.format_sql" value="false" />
        <property name="hibernate.connection.driver_class" value="com.mysql.jdbc.Driver" />
        <property name="hibernate.connection.url" value="jdbc:mysql://localhost:3306/testdb" />
        <property name="hibernate.connection.username" value="root" />
        <property name="hibernate.connection.password" value="" />
        <property name="hibernate.dialect" value="org.hibernate.dialect.MySQL5Dialect" />
        <property name="hibernate.hbm2ddl.auto" value="update" />
        <property name="hibernate.jdbc.batch_size" value="20" />
    </properties>
</persistence-unit>

</persistence>

当我调用运行我的代码时，它会触发 1000 次插入查询，而不是触发 50 次插入查询。问题是什么？ 请帮我使用hibernate在jpa中批量插入

最佳答案

请注意，如果插入表的主键是 GenerationType.Identity，Hibernate 将在 JDBC 级别透明地禁用插入批处理。

save() 只保存一条记录，然后 flush()，所以每次 flush 只处理一条 appending INSERT SQL。这就是为什么 Hibernate 不能帮你批量插入，因为只有一个 INSERT SQL 需要处理。在调用 flush() 之前，您应该 save() 达到一定数量的记录，而不是为每个 save() 都调用 flush()。

批量插入的最佳实践是这样的:

Session session = sessionFactory.openSession();
Transaction tx = session.beginTransaction();
for  ( int i=0; i<888888; i++ ) {
  TableA record = new TableA();
    record.setXXXX();
    session.save(record)
    if ( i % 50 == 0 ) { //50, same as the JDBC batch size
        //flush a batch of inserts and release memory:
        session.flush();
        session.clear();
    }
}
tx.commit();
session.close();

您逐批保存和刷新记录。在每个批处理结束时，您应该清除持久性上下文以释放一些内存以防止内存耗尽，因为每个持久性对象都被放入一级缓存(您的 JVM 内存)。您也可以禁用二级缓存以减少不必要的开销。

请查看此链接 http://docs.jboss.org/hibernate/orm/3.5/reference/en/html/batch.html

关于java - Hibernate JDBC 批量大小不起作用，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/21275379/