如何在Spring JPA原生查询中为PostgreSQL传递动态值实现Update

完全可以通过Spring JPA原生查询实现你需要的动态批量更新操作，下面提供两种安全且常用的实现方式：

方式一：使用EntityManager动态构建参数占位符 #

这种方式适合动态行数不固定的场景，通过绑定参数避免SQL注入：

1. 先定义一个用于存储每行更新数据的DTO：

public class UpdatePair {
    private String columnB;
    private Integer columnA;

    public UpdatePair(String columnB, Integer columnA) {
        this.columnB = columnB;
        this.columnA = columnA;
    }

    // getter方法
    public String getColumnB() { return columnB; }
    public Integer getColumnA() { return columnA; }
}

2. 在Service或Repository中使用EntityManager执行更新：

@Autowired
private EntityManager entityManager;

@Transactional
public void batchUpdateTestTable(List<UpdatePair> updatePairs) {
    // 动态生成每行的占位符(?, ?)
    String valuePlaceholders = updatePairs.stream()
            .map(p -> "(?, ?)")
            .collect(Collectors.joining(", "));

    // 拼接完整SQL
    String sql = String.format("""
        UPDATE test AS t SET
            column_a = c.column_a
        FROM (VALUES %s) AS c(column_b, column_a)
        WHERE c.column_b = t.column_b
        """, valuePlaceholders);

    Query query = entityManager.createNativeQuery(sql);

    // 逐个绑定参数
    int paramIdx = 1;
    for (UpdatePair pair : updatePairs) {
        query.setParameter(paramIdx++, pair.getColumnB());
        query.setParameter(paramIdx++, pair.getColumnA());
    }

    query.executeUpdate();
}

方式二：结合Spring Data JPA的@Modifying注解与PostgreSQL数组函数 #

利用PostgreSQL的unnest函数处理数组参数，无需手动拼接占位符：

1. 定义Repository接口：

@Repository
public interface TestRepository extends JpaRepository<TestEntity, Long> {

    @Modifying
    @Transactional
    @Query(value = """
        UPDATE test AS t SET
            column_a = c.column_a
        FROM (
            SELECT unnest(?1) AS column_b, unnest(?2) AS column_a
        ) AS c
        WHERE c.column_b = t.column_b
        """, nativeQuery = true)
    void batchUpdate(List<String> columnBs, List<Integer> columnAs);
}

2. 调用更新方法时，传入长度一致的两个参数列表：

// 动态生成的更新数据
List<String> columnBs = List.of("123", "345");
List<Integer> columnAs = List.of(1, 2);
testRepository.batchUpdate(columnBs, columnAs);

注意事项 #

• 两种方式都需要添加@Transactional注解，确保更新操作在事务中执行。
• 方式二中必须保证两个参数列表的长度完全一致，否则会导致数据匹配错误。
• 确保项目配置的JPA方言为PostgreSQL对应的版本（如org.hibernate.dialect.PostgreSQLDialect），以支持PostgreSQL特有的语法和函数。

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