如何用JPQL模拟PostgreSQL的ON CONFLICT语句，基于JPA(EclipseLink)实现原子操作

针对你提到的两条PostgreSQL原生UPSERT语句，我来分享几种在EclipseLink中实现的方案，既能完美匹配原生SQL的行为，又能保证原子性：

一、直接使用原生SQL查询（最直观，完全对齐PostgreSQL行为） #

因为JPA标准并未原生支持PostgreSQL的ON CONFLICT语法，所以直接执行原生SQL是最稳妥的方式，和你原来的语句一样，天然保证原子性。

1. 实现INSERT ... ON CONFLICT (id) DO NOTHING #

在Repository接口中定义原生查询：

@Repository
public interface MyTableRepository extends JpaRepository<MyTable, Long> {
    @Modifying
    @Query(value = "INSERT INTO my_table (id, some_data) VALUES (?1, ?2) ON CONFLICT (id) DO NOTHING", nativeQuery = true)
    void insertOrIgnore(Long id, String someData);
}

• 加上@Modifying注解标记这是修改类操作；
• nativeQuery = true告诉JPA执行的是原生SQL而非JPQL；
• 调用该方法时，PostgreSQL会原子性地处理：如果id不存在则插入，存在则忽略，不会抛出冲突异常。

2. 实现INSERT ... ON CONFLICT DO UPDATE SET other_data = ?2 #

同样用原生SQL，这里推荐使用PostgreSQL的EXCLUDED关键字（代表待插入的行数据），避免重复绑定参数：

@Repository
public interface OtherTableRepository extends JpaRepository<OtherTable, Long> {
    @Modifying
    @Query(value = "INSERT INTO other_table (id, other_data) VALUES (?1, ?2) ON CONFLICT (id) DO UPDATE SET other_data = EXCLUDED.other_data", nativeQuery = true)
    void insertOrUpdate(Long id, String otherData);
}

这个方法会原子性地完成：id不存在则插入，存在则更新other_data字段，完全匹配原生SQL的逻辑。

二、利用EclipseLink的JPA扩展API（更贴合ORM模型） #

如果你希望尽量使用JPA的对象操作而非原生SQL，EclipseLink提供了特定的扩展来支持这类UPSERT场景：

1. 实现DO NOTHING逻辑 #

使用EclipseLink的InsertObjectQuery并开启忽略重复项：

@Service
@Transactional
public class MyTableService {
    @PersistenceContext
    private EntityManager entityManager;

    public void insertOrIgnore(MyTable myTableEntity) {
        InsertObjectQuery insertQuery = new InsertObjectQuery(myTableEntity);
        insertQuery.setIgnoreDuplicates(true); // 对应ON CONFLICT DO NOTHING
        entityManager.createQuery(insertQuery).executeUpdate();
    }
}

• setIgnoreDuplicates(true)会让EclipseLink生成带有ON CONFLICT DO NOTHING的原生SQL，原子性执行；
• 必须加上@Transactional确保操作在事务上下文内执行。

2. 实现DO UPDATE逻辑 #

使用EclipseLink的InsertObjectQuery并指定冲突时的更新行为，还能指定仅更新特定字段：

@Service
@Transactional
public class OtherTableService {
    @PersistenceContext
    private EntityManager entityManager;

    public void upsertOtherTable(OtherTable otherTableEntity) {
        InsertObjectQuery insertQuery = new InsertObjectQuery(otherTableEntity);
        // 指定冲突时执行更新
        insertQuery.setConflictAction(ConflictUpdateAction.UPDATE);
        // 仅更新otherData字段，避免更新所有实体属性
        insertQuery.setUpdateFields(Collections.singletonList("otherData"));
        entityManager.createQuery(insertQuery).executeUpdate();
    }
}

这个方法会生成对应的ON CONFLICT DO UPDATE语句，只更新你指定的字段，同样是原子性操作。

关键注意点 #

• 原子性保障：不管用哪种方案，只要是单语句执行（或在同一个事务内），PostgreSQL都会保证操作的原子性，不会出现部分成功的情况；
• 版本兼容性：EclipseLink的扩展API（如setIgnoreDuplicates、ConflictUpdateAction）需要对应版本支持，建议使用EclipseLink 2.7及以上版本；
• 事务管理：所有修改类操作都需要在@Transactional注解标记的方法内执行，确保事务上下文正确。

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