Hibernate更新时唯一约束冲突问题及解决方案咨询

场景说明 #

存在一张包含ID和PRIORITY列的表，PRIORITY列设有唯一约束。现有数据如下：

需要交换ID为1002和1003的PRIORITY值（即1002设为3，1003设为2），但使用Hibernate 5.6.5的session.saveOrUpdate(object)循环逐个更新时，首次更新就触发唯一约束冲突错误。

示例代码 #

实体类ExampleTable #

import jakarta.persistence.*;

@Entity
public class ExampleTable
{
  @Id
  @GeneratedValue(strategy = GenerationType.IDENTITY)
  private Long id;

  private Integer priority;

  public ExampleTable(Long id, Integer priority)
  {
    this.id = id;
    this.priority = priority;
  }

  public ExampleTable()
  {
  }
  // getters & setters
}

主程序代码 #

import org.example.domain.*;
import org.hibernate.Session;
import org.hibernate.cfg.Configuration;

import java.util.Arrays;
import java.util.List;

public class Main {
  public static void main(String[] args) {
    ExampleTable et1 = new ExampleTable(1002L, 3);
    ExampleTable et2 = new ExampleTable(1003L, 2);
    List<ExampleTable> list = Arrays.asList(et1, et2);

    Session session = new Configuration().configure().buildSessionFactory().openSession();
    session.beginTransaction();

    for (ExampleTable et : list)
    {
      session.saveOrUpdate(et);
    }

    session.getTransaction().commit();
  }
}

错误信息 #

[ERROR] Failed to execute goal org.codehaus.mojo:exec-maven-plugin:3.1.0:java (default-cli) on project hibernate-unique-constraint: An exception occurred while executing the Java class. could not execute statement [Duplicate entry '3' for key 'ExampleTable.ExampleTable_pk'] [update ExampleTable set priority=? where id=?]

解决方案及批量更新方式 #

原因分析 #

Hibernate默认的FlushMode.AUTO刷新模式会在执行查询或事务提交前自动刷新会话，将变更同步到数据库。循环更新时，第一个更新（1002→3）会立即发送到数据库，此时1003的PRIORITY仍为3，直接触发唯一约束冲突。

可行解决方法 #

方法一：使用中间值临时过渡

通过一个不存在的临时值规避中间状态的冲突，全程在同一事务中执行：

session.beginTransaction();

// 先将1002的优先级改为临时值（确保不与现有值重复）
ExampleTable temp = session.get(ExampleTable.class, 1002L);
temp.setPriority(0);
session.saveOrUpdate(temp);

// 更新1003的优先级为2
ExampleTable et3 = session.get(ExampleTable.class, 1003L);
et3.setPriority(2);
session.saveOrUpdate(et3);

// 最后将1002的优先级改为3
temp.setPriority(3);
session.saveOrUpdate(temp);

session.getTransaction().commit();

方法二：原生SQL批量更新

利用数据库事务的原子性，通过一条SQL完成交换，避免中间状态：

session.beginTransaction();

session.createNativeQuery("UPDATE ExampleTable SET priority = CASE id WHEN 1002 THEN 3 WHEN 1003 THEN 2 END WHERE id IN (1002,1003)")
       .executeUpdate();

session.getTransaction().commit();

方法三：HQL批量更新

用HQL语法实现和原生SQL一致的逻辑，保持ORM风格：

session.beginTransaction();

session.createQuery("UPDATE ExampleTable e SET e.priority = CASE e.id WHEN 1002 THEN 3 WHEN 1003 THEN 2 END WHERE e.id IN (:ids)")
       .setParameterList("ids", Arrays.asList(1002L, 1003L))
       .executeUpdate();

session.getTransaction().commit();

方法四：调整Hibernate刷新模式

将会话刷新模式改为FlushMode.COMMIT，让Hibernate仅在事务提交时批量发送所有更新语句，依赖数据库事务原子性避免中间约束检查：

Session session = new Configuration().configure().buildSessionFactory().openSession();
session.setFlushMode(FlushMode.COMMIT);
session.beginTransaction();

ExampleTable et1 = new ExampleTable(1002L, 3);
ExampleTable et2 = new ExampleTable(1003L, 2);
session.saveOrUpdate(et1);
session.saveOrUpdate(et2);

session.getTransaction().commit();

注意：该方式需数据库支持事务提交时才检查唯一约束（如MySQL InnoDB）。

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