MongoDB Java同查询更新嵌套数组元素并删除指定项冲突问题求解

问题原因 #

你遇到的是MongoDB的更新路径冲突错误，错误码40对应的就是同路径下多更新运算符冲突场景：单条更新操作中，不允许同时使用$set和$pull两个运算符作用于同层级的嵌套数组路径，MongoDB会判定两个操作在同一路径下存在修改冲突，无法在单次原子操作中同时执行。

解决方案1：拆分为两条有序批量操作（全版本兼容，最稳妥） #

你可以把两个操作放到有序批量写列表中，MongoDB会按顺序执行两个操作，既避免冲突又能保证执行顺序和原子性，Java代码示例如下：

import com.mongodb.client.model.*;
import org.bson.Document;
import java.util.ArrayList;
import java.util.List;

// 构造批量操作列表
List<WriteModel<Document>> writeOperations = new ArrayList<>();

// 第一个操作：更新_id为101的元素quantity为20
writeOperations.add(new UpdateOneModel<>(
    Filters.eq("firstArray.nestedArray._id", "101"),
    Updates.set("firstArray.$[outer].nestedArray.$[inner].quantity", 20),
    new UpdateOptions().arrayFilters(List.of(
        Filters.exists("outer.nestedArray._id"),
        Filters.eq("inner._id", "101")
    ))
));

// 第二个操作：移除_id为201的嵌套元素
writeOperations.add(new UpdateOneModel<>(
    Filters.eq("firstArray.nestedArray._id", "201"),
    Updates.pull("firstArray.$[outer].nestedArray", Filters.eq("_id", "201")),
    new UpdateOptions().arrayFilters(List.of(
        Filters.exists("outer.nestedArray._id")
    ))
));

// 执行有序批量写
collection.bulkWrite(writeOperations, new BulkWriteOptions().ordered(true));

解决方案2：聚合管道单语句更新（MongoDB 4.2+版本支持） #

如果必须在单条更新语句中完成需求，可以使用MongoDB 4.2新增的聚合管道更新能力，直接重构嵌套数组，避免$set和$pull的组合冲突，Mongo Shell语法参考如下：

db.collection.updateOne(
  { "_id": "123" },
  [
    {
      $set: {
        firstArray: {
          $map: {
            input: "$firstArray",
            as: "outer",
            in: {
              $mergeObjects: [
                "$$outer",
                {
                  nestedArray: {
                    $filter: {
                      input: {
                        $map: {
                          input: "$$outer.nestedArray",
                          as: "inner",
                          in: {
                            $cond: [
                              { $eq: ["$$inner._id", "101"] },
                              { $mergeObjects: ["$$inner", { quantity: 20 }] },
                              "$$inner"
                            ]
                          }
                        }
                      },
                      cond: { $ne: ["$$this._id", "201"] }
                    }
                  }
                }
              ]
            }
          }
        }
      }
    }
  ]
)

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