如何用Spring Data MongoDB的updateMulti实现字段复制与映射

关于mongoTemplate.updateMulti()与updateMany()的等价性 #

是的，mongoTemplate.updateMulti()完全等价于Mongo Shell中的updateMany()，二者都会对所有匹配查询条件的文档执行批量更新操作，区别于只更新首个匹配文档的updateFirst()（对应Shell的updateOne()）。

Spring Data实现方案 #

要实现你需要的字段复制与映射逻辑，需要使用Spring Data MongoDB提供的AggregationUpdate来构建聚合管道式的更新（和你在Shell中使用的数组更新逻辑对应），具体代码如下：

方式一：使用Spring Data封装的操作符API #

import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.aggregation.AggregationUpdate;
import org.springframework.data.mongodb.core.aggregation.ArrayOperators;
import org.springframework.data.mongodb.core.query.Criteria;

// 注入MongoTemplate实例
private final MongoTemplate mongoTemplate;

public void batchUpdateListField() {
    // 构建查询条件：匹配存在listOfObjects字段的文档
    Criteria criteria = Criteria.where("listOfObjects").exists(true);

    // 构建更新逻辑：将listOfObjects映射为newList，item字段重命名为item1
    AggregationUpdate update = AggregationUpdate.update()
            .set("newList", ArrayOperators.Map.itemsOf("listOfObjects")
                    .as("itemObj")
                    .andApply(context -> context.document("item1", context.get("itemObj.item"))));

    // 执行批量更新，第三个参数为集合名称
    mongoTemplate.updateMulti(criteria, update, "myCollection");
}

方式二：直接使用原生MongoDB语法（更贴近Shell写法） #

如果你更习惯原生MongoDB的语法，可以直接通过AggregationExpression传入原生文档结构：

import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.aggregation.AggregationUpdate;
import org.springframework.data.mongodb.core.aggregation.AggregationExpression;
import org.springframework.data.mongodb.core.query.Criteria;
import org.bson.Document;

private final MongoTemplate mongoTemplate;

public void batchUpdateListField() {
    Criteria criteria = Criteria.where("listOfObjects").exists(true);

    AggregationUpdate update = AggregationUpdate.update()
            .set("newList", AggregationExpression.from(new Document("$map",
                    new Document("input", "$listOfObjects")
                            .append("in", new Document("item1", "$$this.item")))));

    mongoTemplate.updateMulti(criteria, update, "myCollection");
}

代码说明 #

• 两种方式的核心逻辑都和你在Shell中写的$map操作一致：遍历listOfObjects数组，将每个元素的item字段映射为item1，最终赋值给newList字段。
• AggregationUpdate是Spring Data MongoDB 3.0+版本引入的API，用于支持基于聚合管道的更新操作，完全兼容MongoDB 4.2+的批量更新语法。

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