使用JPA原生INSERT查询时出现重复键错误求助

你遇到的核心问题是：原生INSERT语句手动指定了id字段，但新创建的MyEntity实例id默认值为0，重复插入时就会触发主键唯一约束冲突。

JPA的@GeneratedValue注解仅在使用JPA内置的persist/merge方法时生效，原生SQL查询会完全绕开JPA的主键自动生成逻辑，所以即使修改GenerationType为IDENTITY也无法解决问题。

方案1：让数据库自动生成主键（推荐） #

修改原生SQL，不指定id字段，让PostgreSQL通过序列自动生成主键：

@Repository
public class MyEntityRepository {

    @PersistenceContext
    private EntityManager entityManager;

    @Modifying
    @Transactional
    public void save(MyEntity me) {
        // 只插入value字段，id由数据库自动生成
        Query query = entityManager.createNativeQuery("INSERT INTO my_entity (value) VALUES (?)");
        query.setParameter(1, me.getValue());
        query.executeUpdate();
    }
}

如果需要获取插入后生成的主键，可以用PostgreSQL的RETURNING子句：

@Modifying
@Transactional
public Long saveAndReturnId(MyEntity me) {
    Query query = entityManager.createNativeQuery("INSERT INTO my_entity (value) VALUES (?) RETURNING id");
    query.setParameter(1, me.getValue());
    // 获取生成的id并返回
    return (Long) query.getSingleResult();
}

拿到返回的id后，可以手动设置回MyEntity实例。

方案2：使用JPA内置方法替代原生查询 #

既然使用JPA，完全没必要写原生插入语句，直接用EntityManager的persist方法，它会自动触发主键生成策略：

@Repository
public class MyEntityRepository {

    @PersistenceContext
    private EntityManager entityManager;

    @Transactional
    public void save(MyEntity me) {
        entityManager.persist(me);
    }
}

这种方式下，JPA会根据@GeneratedValue的配置自动生成主键，彻底避免手动指定id的冲突问题。

方案3：手动获取序列值再插入（仅适用于必须用原生查询的场景） #

如果一定要用原生查询指定id，可以先查询PostgreSQL的序列（默认序列名为my_entity_id_seq，需和数据库实际序列名一致）获取下一个值：

@Repository
public class MyEntityRepository {

    @PersistenceContext
    private EntityManager entityManager;

    @Modifying
    @Transactional
    public void save(MyEntity me) {
        // 查询序列的下一个值
        Query seqQuery = entityManager.createNativeQuery("SELECT nextval('my_entity_id_seq')");
        Long nextId = (Long) seqQuery.getSingleResult();
        
        // 使用序列值插入
        Query query = entityManager.createNativeQuery("INSERT INTO my_entity (id, value) VALUES (?, ?)");
        query.setParameter(1, nextId);
        query.setParameter(2, me.getValue());
        query.executeUpdate();
        
        // 将生成的id设置回实体
        me.setId(nextId);
    }
}

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