Spring中如何基于对象属性编写带参数的原生Upsert查询？

问题根源 #

你当前的错误有两个核心原因：

• 原生SQL查询不支持JPQL的:authorEntity.getId()这种对象属性访问语法，原生查询只能直接引用独立参数。
• PostgreSQL的ON CONFLICT DO UPDATE语句不完整，必须明确指定冲突时要更新的字段。

解决方案1：拆分实体参数为独立参数 #

将AuthorEntity的属性拆分为单独的@Param参数，直接在原生SQL中引用：

import java.util.Optional;
import java.util.UUID;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository;

@Repository
public interface AuthorRepo extends JpaRepository<AuthorEntity, UUID> {
    
    @Query(
            value = """
                    INSERT INTO author (id, name)
                    VALUES (:id, :name)
                    ON CONFLICT (name) 
                    DO UPDATE SET id = EXCLUDED.id
                    RETURNING *
                    """,
            nativeQuery = true
    )
    AuthorEntity saveByName(@Param("id") UUID id, @Param("name") String name);

    Optional<AuthorEntity> findByName(String name);
}

说明 #

• 明确指定INSERT的列名，避免因表结构变更导致的错误。
• ON CONFLICT (name) DO UPDATE SET id = EXCLUDED.id：EXCLUDED代表插入语句中原本要插入的行数据，这里指定当name冲突时更新id字段（可根据需求调整要更新的字段）。
• RETURNING *会返回插入或更新后的完整行，Spring Data JPA会自动映射到AuthorEntity。

解决方案2：使用Spring SpEL表达式访问实体属性（Spring Data JPA 2.1+支持） #

如果希望直接传递AuthorEntity对象，可以在原生查询中使用Spring的SpEL表达式，通过:#{#authorEntity.id}这种方式访问对象属性：

import java.util.Optional;
import java.util.UUID;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository;

@Repository
public interface AuthorRepo extends JpaRepository<AuthorEntity, UUID> {
    
    @Query(
            value = """
                    INSERT INTO author (id, name)
                    VALUES (#{#authorEntity.id}, #{#authorEntity.name})
                    ON CONFLICT (name) 
                    DO UPDATE SET id = EXCLUDED.id
                    RETURNING *
                    """,
            nativeQuery = true
    )
    AuthorEntity saveByName(@Param("authorEntity") AuthorEntity authorEntity);

    Optional<AuthorEntity> findByName(String name);
}

说明 #

• 这种方式需要Spring Data JPA版本在2.1及以上，支持在原生查询中嵌入SpEL表达式。
• 同样要确保ON CONFLICT DO UPDATE语句完整，指定更新逻辑。

额外注意事项 #

• 确保AuthorEntity的字段和数据库表author的列名完全匹配，或者通过@Column注解指定映射关系。
• 如果不需要返回实体，可以将方法返回值改为void或int（受影响的行数）。

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