MongoDB+Node.js批量更新内层数组元素问题求助

需求说明 #

需要匹配嵌套数组sections.sectionData.media中指定_id的元素，批量更新它们的eligible字段，每个元素对应不同的更新值。

原始文档结构 #

{
        "_id": 7,
        "sections": [
            {
                "sectionData": {
                    "media": [
                        {
                            "_id": {
                                "$oid": "64a691e0c91b64aa2c0446ce"
                            },
                            "image": "1.jpg"
                        },
                        {
                            "_id": {
                                "$oid": "64a6922ac91b64aa2c0446d1"
                            },
                            "image": "1.jpg"
                        },
                        {
                            "_id": {
                                "$oid": "64a69240c91b64aa2c0446d2"
                            },
                            "image": "1.jpg"
                        },
                        {
                            "_id": {
                                "$oid": "64a6927dc91b64aa2c0446d3"
                            },
                            "image": "1.jpg"
                        }
                    ]
                },
                "_id": {
                    "$oid": "648847b944e80a387f627028"
                }
            },
            {
                "sectionData": {
                    "media": []
                },
                "_id": {
                    "$oid": "648aa5442b511184130685c7"
                }
            }
        ]
    }

待更新的ID与值数组 #

let ids = [
  { _id: "64a691e0c91b64aa2c0446ce", eligible: false },
  { _id: "64a6922ac91b64aa2c0446d1", eligible: false },
  { _id: "64a69240c91b64aa2c0446d2", eligible: true },
];

当前错误代码及问题 #

const albumId = 7;
const sectionId = "648847b944e80a387f627028";
let ids = [
  { _id: "64a691e0c91b64aa2c0446ce", eligible: false },
  { _id: "64a6922ac91b64aa2c0446d1", eligible: false },
  { _id: "64a69240c91b64aa2c0446d2", eligible: true },
];
await uploadAlbumSchema.updateMany(
  { _id: albumId, "sections._id": sectionId, "sections.sectionData.media._id": { $in: ids.map(obj => mongoose.Types.ObjectId(obj._id)) } },
  { $set: { "sections.$[outer].sectionData.media.$[inner].eligible": ids.map(obj => obj.eligible)  } },
  { arrayFilters: [{ "outer._id": sectionId }, { "inner._id": { $in: ids.map(obj => mongoose.Types.ObjectId(obj._id)) } }] }
)

执行后eligible字段被设置为数组（如[false, false, true]），而非对应单个元素的目标值。

预期效果 #

每个匹配_id的media元素应单独设置eligible值：

{
    "_id": {
           "$oid": "64a691e0c91b64aa2c0446ce"
           },
    "image": "1.jpg",
    "eligible":false
}

解决方案 #

方案一：循环执行单个更新（适合小数据量） #

针对每个待更新项单独执行updateOne，确保每个media元素匹配对应的值：

const albumId = 7;
const sectionId = mongoose.Types.ObjectId("648847b944e80a387f627028");
let ids = [
  { _id: "64a691e0c91b64aa2c0446ce", eligible: false },
  { _id: "64a6922ac91b64aa2c0446d1", eligible: false },
  { _id: "64a69240c91b64aa2c0446d2", eligible: true },
];

for (const item of ids) {
  await uploadAlbumSchema.updateOne(
    { 
      _id: albumId, 
      "sections._id": sectionId,
      "sections.sectionData.media._id": mongoose.Types.ObjectId(item._id)
    },
    { 
      $set: { 
        "sections.$[outer].sectionData.media.$[inner].eligible": item.eligible 
      } 
    },
    { 
      arrayFilters: [
        { "outer._id": sectionId }, 
        { "inner._id": mongoose.Types.ObjectId(item._id) }
      ] 
    }
  );
}

方案二：使用批量更新（高效处理多数据） #

通过bulkWrite构建批量更新操作，减少数据库请求次数：

const albumId = 7;
const sectionId = mongoose.Types.ObjectId("648847b944e80a387f627028");
let ids = [
  { _id: "64a691e0c91b64aa2c0446ce", eligible: false },
  { _id: "64a6922ac91b64aa2c0446d1", eligible: false },
  { _id: "64a69240c91b64aa2c0446d2", eligible: true },
];

const bulkOps = ids.map(item => ({
  updateOne: {
    filter: {
      _id: albumId,
      "sections._id": sectionId,
      "sections.sectionData.media._id": mongoose.Types.ObjectId(item._id)
    },
    update: {
      $set: {
        "sections.$[outer].sectionData.media.$[inner].eligible": item.eligible
      }
    },
    arrayFilters: [
      { "outer._id": sectionId },
      { "inner._id": mongoose.Types.ObjectId(item._id) }
    ]
  }
}));

await uploadAlbumSchema.bulkWrite(bulkOps);

错误原因说明 #

原代码中$set的值使用ids.map(obj => obj.eligible)会生成一个数组，MongoDB会直接将eligible字段赋值为该数组，无法自动根据arrayFilters的inner匹配关系分配对应的值。必须为每个目标元素单独指定更新值，才能实现预期效果。

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