如何在Spring Data Neo4j 6中使用UNWIND查询实现批量更新？

一、自定义Cypher查询结合UNWIND（高效首选） #

SDN 6完全支持UNWIND语法，之前失效大概率是参数传递或查询写法有误。下面是正确的实现步骤：

1. 先定义用于传递更新数据的DTO：

public class UserUpdateDTO {
    private Long userId;
    private String newName;
    private Integer newAge;

    // 带参构造、getter/setter自行补充
    public UserUpdateDTO(Long userId, String newName, Integer newAge) {
        this.userId = userId;
        this.newName = newName;
        this.newAge = newAge;
    }
}

2. 在Repository接口中编写带UNWIND的自定义查询：

@Repository
public interface UserRepository extends Neo4jRepository<User, Long> {

    @Query("""
        UNWIND $updates AS update
        MATCH (u:User {id: update.userId})
        SET u.name = update.newName, u.age = update.newAge
        RETURN u
        """)
    List<User> batchUpdateUsers(@Param("updates") List<UserUpdateDTO> updates);
}

关键注意点：参数名$updates要和@Param注解指定的名称完全一致，DTO的属性名要和Cypher里引用的字段对应上。

二、使用SDN自带的saveAll方法 #

如果你的实体已经和Neo4j节点正确映射，且需要更新实体的全部属性，直接用saveAll最省心：

// 先查出要更新的实体列表，修改属性后批量保存
List<User> usersToUpdate = userRepository.findAllById(Arrays.asList(1L, 2L, 3L));
usersToUpdate.forEach(user -> {
    user.setName("更新后的名称");
    user.setAge(28);
});
userRepository.saveAll(usersToUpdate);

提示：这种方式会先查询实体再执行更新，适合小规模批量操作；数据量大的话，还是用UNWIND自定义查询更高效，能减少客户端和数据库之间的网络往返次数。

三、通过Neo4jTemplate执行灵活批量更新 #

如果需要更复杂的更新逻辑，直接用Neo4jTemplate执行Cypher语句是更灵活的选择：

@Autowired
private Neo4jTemplate neo4jTemplate;

public void batchUpdateWithTemplate(List<UserUpdateDTO> updates) {
    String cypher = """
        UNWIND $updates AS update
        MATCH (u:User {id: update.userId})
        SET u.name = coalesce(update.newName, u.name), 
            u.age = coalesce(update.newAge, u.age)
        """;
    // 执行查询，这里用subscribe()触发执行
    neo4jTemplate.query(cypher, Map.of("updates", updates)).subscribe();
}

上面的例子用了coalesce函数，实现“只更新非空属性”的逻辑，适合部分字段更新的场景。

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