Hibernate 6.4批量插入报NonUniqueObjectException问题求助

问题核心原因 #

你遇到的矛盾问题本质是Hibernate序列预取策略与数据库序列配置不匹配，再加上Spring Batch chunk处理的Session管理细节：

1. 默认情况下，Hibernate的@SequenceGenerator默认allocationSize为50，会一次性预取50个序列值用于ID生成。如果数据库中CMN_TXN_ID_SEQ的INCREMENT BY值不是50（比如默认是1），多个Session会重复拿到相同的序列段，插入时就会触发NonUniqueObjectException。
2. 强制设allocationSize=1后，Hibernate每次插入都要去数据库拉取序列值，彻底丧失批量预取的性能优势，导致1000条数据耗时极长。
3. 隐性可能：映射源表数据到TransactionEntity时，误将源表ID赋值给新实体的ID字段，Hibernate会把它当成已存在于Session的对象，引发冲突。

分步解决方案 #

1. 对齐数据库序列与Hibernate配置 #

这是最关键的一步，必须保证两者的步长完全一致：

• 查看数据库序列配置（以Oracle为例，其他数据库命令类似）：

  SELECT increment_by FROM user_sequences WHERE sequence_name = 'CMN_TXN_ID_SEQ';
  

• 调整实体类配置：把@SequenceGenerator的allocationSize设为和数据库序列INCREMENT BY相同的值。比如数据库序列步长是50，实体配置如下：

  @Id
  @GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "txnSeq")
  @SequenceGenerator(
      name = "txnSeq",
      sequenceName = "CMN_TXN_ID_SEQ",
      allocationSize = 50 // 和数据库序列INCREMENT BY值严格一致
  )
  private Long id;
  

2. 检查实体映射逻辑 #

确认从源表读取数据后，映射为TransactionEntity时绝对不要手动赋值ID字段，让Hibernate完全通过序列自动生成ID。如果误把源表ID传给新实体，Hibernate会判定它是已持久化对象，触发Session内的ID冲突。

3. 用Spring Batch官方JpaItemWriter替代手动saveAll #

JpaItemWriter是Spring Batch专为JPA批量操作设计的组件，会自动管理Hibernate Session和批量提交逻辑，比手动调用repository.saveAll()更高效且避免Session冲突：

@Bean
public JpaItemWriter<TransactionEntity> jpaItemWriter(EntityManagerFactory entityManagerFactory) {
    JpaItemWriter<TransactionEntity> writer = new JpaItemWriter<>();
    writer.setEntityManagerFactory(entityManagerFactory);
    return writer;
}

然后在Step配置中使用该Writer：

@Bean
public Step batchInsertStep(ItemReader<SourceEntity> reader,
                            ItemProcessor<SourceEntity, TransactionEntity> processor,
                            JpaItemWriter<TransactionEntity> writer) {
    return stepBuilderFactory.get("batchInsertStep")
            .<SourceEntity, TransactionEntity>chunk(50) // chunk大小建议和Hibernate batch_size匹配
            .reader(reader)
            .processor(processor)
            .writer(writer)
            .build();
}

4. 开启Hibernate批量插入优化 #

在application.yml中添加以下配置，进一步提升批量插入性能：

spring:
  jpa:
    properties:
      hibernate:
        jdbc:
          batch_size: 50 // 和chunk大小、序列allocationSize保持一致
        order_inserts: true // 按表排序插入语句，提升数据库批量执行效率
        order_updates: true
        batch_versioned_data: true

5. 可选：改用pooled-lo序列优化器 #

如果上述配置仍偶发冲突，可改用Hibernate的pooled-lo优化器，它比默认的pooled策略更安全，适合高并发场景：

@Id
@GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "txnSeq")
@GenericGenerator(
    name = "txnSeq",
    strategy = "org.hibernate.id.enhanced.SequenceStyleGenerator",
    parameters = {
            @Parameter(name = "sequence_name", value = "CMN_TXN_ID_SEQ"),
            @Parameter(name = "initial_value", value = "1"),
            @Parameter(name = "increment_size", value = "50"), // 和数据库序列步长一致
            @Parameter(name = "optimizer", value = "pooled-lo")
    }
)
private Long id;

内容的提问来源于stack exchange，提问作者Pulak Sinha