Mongoose遍历关联Schema更新数据时，仅添加最后一个ObjectId的问题求助

开发者阿泽

2026-4-22

嘿，我完全懂你碰到的麻烦！现在你的代码每次更新都是直接把cities_object_ids替换成当前遍历到的City的_id，而不是往数组里追加元素，所以最后自然就只剩最后一个匹配的ID啦。

先给你揪出问题核心：你用的是直接赋值{ cities_object_ids: e._id }，这会直接覆盖数组里之前的所有内容。MongoDB要往数组里添加元素，得用专门的数组更新操作符——$push（允许重复添加）或者$addToSet（自动去重，避免同一个ID多次插入）。

另外还有个小细节要注意：你在map里直接调用updateMany，会导致大量异步操作并发执行，可能出现性能或者顺序问题，建议用Promise.all统一处理，或者用for...of遍历，能更好地控制异步流程。

下面是修正后的updateCountries函数：

const updateCountries = async () => {
  try {
    const cities = await Cities.find({});
    // 用Promise.all统一处理所有异步更新任务
    await Promise.all(
      cities.map(async (city) => {
        // 使用$push往数组追加ID，若要去重就换成$addToSet
        await Countries.updateMany(
          { city_name: city.city_name },
          { $push: { cities_ObjectIds: city._id } }
          // 去重版本：{ $addToSet: { cities_ObjectIds: city._id } }
        );
      })
    );
    console.log("所有国家文档更新完成！");
  } catch (error) {
    console.error("更新过程出错：", error);
  }
};

再给你拆解下改动点：

把直接赋值改成$push操作符，这样每次匹配到的国家文档，都会把当前City的ID追加到cities_ObjectIds数组里，而不是覆盖原有内容。
用Promise.all包裹所有updateMany操作，确保所有异步任务都完成后再结束函数，还能统一捕获错误。
加了try/catch块处理异步错误，避免程序意外崩溃。

还有个容易忽略的细节：你的Countries Schema里字段名是cities_ObjectIds，但原代码里写的是cities_object_ids（大小写不一致），这会导致字段匹配失败！一定要把代码里的字段名改成和Schema一致的cities_ObjectIds，不然更新根本不会生效哦。

确认下你的Countries Schema字段定义：

const CountriesSchema = new mongoose.Schema(
  {
    city_name: String,
    cities_ObjectIds: [
      {
        type: mongoose.Schema.Types.ObjectId,
        ref: 'Cities',
      },
    ],
  }
);

这样修改后，应该就能把所有匹配的City ID都正确添加到对应Countries文档的数组里啦！

备注：内容来源于stack exchange，提问作者Java wanna bee