MongoDB 中使用聚合管道实现嵌套数组的更新与插入 upsert

本文介绍如何在 mongodb 中通过 update + 聚合管道语法，对“文档内数组中的子数组”执行条件更新：若指定 item 存在，则向其 sub_list 追加元素；若不存在，则在 list 中新增该 item 对象——全程支持 upsert。

本文介绍如何在 mongodb 中通过 update + 聚合管道语法，对“文档内数组中的子数组”执行条件更新：若指定 item 存在，则向其 sub_list 追加元素；若不存在，则在 list 中新增该 item 对象——全程支持 upsert。

在 MongoDB 5.0+ 中，update() 方法已支持聚合管道作为更新操作符（即 update({ filter }, [{ pipeline }], { upsert: true })），这为处理复杂嵌套结构（如数组内含对象、对象内含数组）提供了强大能力。传统 $ 或 $[] 操作符无法同时满足「按条件定位子文档 + 条件追加元素 + 不存在时创建」的需求，而聚合管道可精准控制逻辑分支。

以下是一个完整、可复用的解决方案，目标是：
✅ 给定 category（如 "A"）和 item 值（如 1），找到对应 list 元素；
✅ 若该元素存在且 valToAdd（如 68）尚未在 sub_list 中，则将其追加；
✅ 若该 item 在 list 中不存在，则新建 { item: 1, sub_list: [68] } 并加入 list；
✅ 若整个文档（category: "A"）不存在，则自动 upsert 创建。

✅ 推荐写法（参数化、健壮、防重复）

const categoryVal = "A";const itemToFind = 1;const valToAdd = 68;db.collection.update(  { "category": categoryVal },  [    {      $set: {        list: {          $cond: {            if: { $in: [itemToFind, { $ifNull: ["$list.item", []] }] },            then: {              $map: {                input: "$list",                in: {                  $cond: {                    if: {                      $and: [                        { $eq: ["$$this.item", itemToFind] },                        { $not: { $in: [valToAdd, { $ifNull: ["$$this.sub_list", []] }] } }                      ]                    },                    then: {                      $mergeObjects: [                        "$$this",                        {                          sub_list: {                            $concatArrays: [                              { $ifNull: ["$$this.sub_list", []] },                              [valToAdd]                            ]                          }                        }                      ]                    },                    else: "$$this"                  }                }              }            },            else: {              $concatArrays: [                [{ item: itemToFind, sub_list: [valToAdd] }],                { $ifNull: ["$list", []] }              ]            }          }        }      }    }  ],  { upsert: true })

? 关键设计说明

• $in: [itemToFind, "$list.item"]：快速判断目标 item 是否已在 list 中存在（利用数组投影 $list.item 得到所有 item 值）；
• $map + $cond：遍历 list，仅对匹配 item 且 valToAdd 不在 sub_list 中的项执行更新，避免重复添加；
• $ifNull 全覆盖：对 $list.item、$$this.sub_list 等可能为 null/缺失字段做安全兜底，确保表达式不报错；
• $concatArrays 构建新 sub_list：兼容 sub_list 为空、不存在或已有值的全部场景；
• else 分支实现 upsert item：当 item 未命中时，将新对象前置拼接到原 list（$concatArrays 保证顺序与空数组兼容）；
• 外层 upsert: true：保障 category 文档级不存在时也能创建。

⚠️ 注意事项

• 此方案要求 MongoDB ≥ 5.0（聚合管道更新于 4.2 引入，但 upsert + 管道组合在 5.0 完善支持）；
• 若需去重插入（即无论是否存在都确保唯一），当前逻辑中 $not: { $in: [...] } 已实现；若需强制覆盖/替换而非追加，请改用 $setUnion 或显式构造新数组；
• 性能上，$map 遍历整个 list 是必要开销，若 list 规模极大（>1000 项），建议评估是否应重构数据模型（例如用 item 作 _id 的嵌套集合）；
• 测试时推荐使用 Mongo Playground 快速验证逻辑边界（如空 list、缺失字段、重复添加等）。

掌握此模式后，你可轻松扩展至更深层嵌套（如 list[].sub_list[].tags），只需逐层嵌套 $map 与 $cond —— 真正实现“声明式嵌套更新”。