如何使用Spring Data JPA创建批量更新查询

需要实现全量更新逻辑：在调用saveAll同步数据库前，将Dom实体所有记录的isValid字段统一设置为false，单批次处理数据量为6000-7000条。
原有代码如下：

import org.springframework.data.repository.CrudRepository;
public interface  DomRepository extends CrudRepository<Dom, String> {

    public Domaine findDomByName(String dom);
    public List<Dom> findAll();
    public void setIsValidAll(boolean isValid);

}

import javax.persistence.*;
import org.hibernate.annotations.DynamicUpdate;
import org.springframework.data.annotation.CreatedDate;
@Entity
@DynamicUpdate
public class Dom{
    
    @Id
    @GeneratedValue(strategy=GenerationType.AUTO)
    private int id;
    private String name;
    // 其余属性
    private boolean isValid;
}

运行后抛出异常：

Caused by: org.springframework.data.mapping.PropertyReferenceException: No property 'setIsValidAll' found for type 'Dom'!

• Spring Data JPA默认会根据Repository中的方法名自动派生查询，声明setIsValidAll方法时，框架会按照命名规则匹配Dom实体的属性，实体中不存在setIsValidAll对应的字段，因此抛出属性不存在的异常。
• 框架的派生查询能力不支持全表批量更新字段的场景，这类操作需要主动声明自定义更新语句。
• 原有代码还存在隐藏bug：Dom实体主键类型为int，但CrudRepository的主键泛型声明为String，即使解决了方法名问题，后续也会出现主键类型不匹配的报错。

方案1：自定义批量更新语句（推荐，性能最优） #

直接通过JPQL声明全量更新逻辑，仅需执行1条SQL即可完成全表字段更新，适合6000-7000条数据的批量处理场景，性能远高于查询后逐行更新的方式。
修正后的Repository代码：

import org.springframework.data.jpa.repository.Modifying;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.CrudRepository;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;

// 修正主键泛型为Integer，和实体id类型匹配
public interface DomRepository extends CrudRepository<Dom, Integer> {

    Dom findDomByName(String dom);
    List<Dom> findAll();

    @Modifying(clearAutomatically = true, flushAutomatically = true)
    @Transactional // 事务注解也可以加在调用该方法的业务层，根据项目分层规范调整
    @Query("UPDATE Dom d SET d.isValid = :isValid")
    void setIsValidAll(boolean isValid);
}

参数说明：

• @Modifying：标识该方法是数据修改操作，框架不会按查询方法解析
• clearAutomatically = true：执行更新后清空JPA一级缓存，避免后续查询拿到更新前的旧数据
• flushAutomatically = true：执行更新前先刷出一级缓存中待持久化的数据，避免更新覆盖未提交的改动

方案2：查询后逐行更新（不推荐，仅兼容原有saveAll流程） #

如果必须走saveAll的更新流程，需要先查询全量数据，逐行设置字段值后再调用保存方法，该方案会执行1次全表查询+N条更新语句，数据量越大性能损耗越高。
业务层实现示例：

@Transactional
public void syncData(List<Dom> incomingData) {
    // 先将存量数据的isValid置为false
    List<Dom> existData = domRepository.findAll();
    existData.forEach(item -> item.setIsValid(false));
    domRepository.saveAll(existData);

    // 再处理待同步的新数据，设置isValid为true后保存
    incomingData.forEach(item -> item.setIsValid(true));
    domRepository.saveAll(incomingData);
}

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