MongoDB bulkWrite中如何基于key字段使用$addToSet避免重复添加对象

你当前遇到的问题是$addToSet会对比整个对象的完整性，只要新对象和数组中已有对象的任一字段（或引用）不同，就会被当成新元素添加，哪怕key字段重复。要实现仅基于key字段判断是否添加，需要调整bulkWrite的过滤条件和更新逻辑。

解决方案 #

通过在filter中同时指定账号_id和数组中不存在目标key的条件，配合$push完成添加操作，同时保留upsert: true处理账号不存在的场景。

完整bulkWrite代码示例 #

bulkWrite([{
  updateOne: {
    filter: {
      _id: commands[0].accountId,
      "codes.key": { $ne: commands[0].advantageCode }
    },
    update: {
      $push: {
        codes: {
          key: commands[0].advantageCode,
          dateBegin: commands[0].dateBegin,
          dateEnd: commands[0].dateEnd
        }
      }
    },
    upsert: true
  }
}])

逻辑说明 #

• filter部分："codes.key": { $ne: ... }确保只有当目标账号的codes数组中没有对应key的对象时，才会执行更新
• $push用于向数组添加新对象，替代原来的$addToSet（过滤条件已完成去重判断）
• upsert: true：如果目标账号不存在，会自动创建新文档，并将codes数组初始化为包含当前新对象的数组

批量处理多组数据 #

如果需要一次性处理多个commands条目，可以循环生成批量操作数组：

const bulkOps = commands.map(cmd => ({
  updateOne: {
    filter: {
      _id: cmd.accountId,
      "codes.key": { $ne: cmd.advantageCode }
    },
    update: {
      $push: {
        codes: {
          key: cmd.advantageCode,
          dateBegin: cmd.dateBegin,
          dateEnd: cmd.dateEnd
        }
      }
    },
    upsert: true
  }
}));

bulkWrite(bulkOps);

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