如果存在则更新 Many，否则为每个不存在的 LeadId 创建一个新 Document答案

【问题标题】：Update Many if exists , otherwise create for each LeadId that doesn't exists a new Document如果存在则更新 Many，否则为每个不存在的 LeadId 创建一个新 Document
【发布时间】：2019-12-28 17:34:03
【问题描述】：

考虑架构：

const mongoose = require("mongoose");
const Schema = mongoose.Schema;
const EightWeekGamePlanSchema = new Schema({
  Week: {
    type: Number,
    required: true
  },
  LeadId: {
    type: String,
    required: true
  },
  PackageId: {
    type: String,
    required: true
  },
  BusinessName: {
    type: String,
    required: true
  },
  PhoneNumberMasque: {
    type: String,
    required: true
  },
  City: {
    type: String,
    required: true
  },
  Rooms: {
    type: Number,
    required: true
  },
  LeadStartDate: {
    type: Date
  },
  LeadEndDate: {
    type: Date
  },

  TargetedToBeClaimedByClientType: {
    type: Number,
    required: true
  },
  TotalClaimsLeftToBeClaimedByClientType: {
    // incresed by 1 every time it's claimed
    type: Number,
    required: true
  },
  TotalClaimsToBeClaimedByClientType: {
    // Stays fixed
    type: Number,
    required: true
  },
  Status: {
    type: Number,
    required: true
  },

  InsertDate: {
    type: Date,
    default: Date.now
  }
});

module.exports = EightWeekGamePlan = mongoose.model(
  "eightweekgameplan",
  EightWeekGamePlanSchema
);

我正在尝试编写一个非常复杂的查询：如果它们的 LeadID 出现在给定数组 winnerLeads 中并且它们的 TargetedToBeClaimedByClientType 属性等于给定的 groupTarget ：

router.post("/add-claims-to-group", auth, async (req, res) => {
    const { howManyClaims, groupTarget, winnerLeads, week } = req.body;
    EightWeekGamePlan.updateMany(
        {
          LeadId: {
            $in: winnerLeads
          },
          TargetedToBeClaimedByClientType: groupTarget
        },
        { $inc: { TotalClaimsToBeClaimedByClientType: howManyClaims } },
        { multi: true },
        (err, writeResult) => {
          if (err) {
            console.log(err);
          } else {
            console.log(writeResult);
          }
        }
      );
}

否则，请执行某种Create：获取属于LeadID 的现有EightWeekGamePlan 文档之一，复制它并将其TotalClaimsToBeClaimedByClientType 属性设置为howManyClaims。

是否可以在一个查询中结合更新和创建操作？

【问题讨论】：

@srinivasy：感谢您的帮助，部分工作，如果插入代码插入一个只有 4 个属性的新文档 (LeadId , TargetedToBeClaimedByClientType, Week , _id) ，但我要插入所有属性，而不仅仅是 4 个。是否可以在插入文档时告诉 Mongo 运行一个函数，然后在该函数中处理文档的创建？
它只会插入你在过滤器或更新对象中传递的字段，所以它不能插入所有字段或未传递的字段，所以你的意思是如果你插入默认值不通过一个领域？尝试检查“{setOnInsert : }”，但即使在那里你也需要传递字段
@srinivasy：你的回答很好，所以我接受它。我会尽力管理

标签： javascript node.js mongodb mongoose

【解决方案1】：

根据您的查询，由于您正在执行.updateMany()，因此您不必执行{ multi: true }。无论如何，通常您可以使用{upset: true} 进行更新插入，但理想情况下，只有在数据库中找不到匹配项时，它才会根据输入查询的更新字段的过滤条件创建一个新文档。但由于这里我们在过滤条件中有一个列表 ($in)，它可能无法正常工作，试试这个：

let winnerLeads = [1, 2, 3, 31, 5]
let groupTarget = 1
let howManyClaims = 2
let bulkArr = []
for (i of winnerLeads) {
    bulkArr.push({
        updateOne: {
            "filter": {
                LeadId: i,
                TargetedToBeClaimedByClientType: groupTarget
            },
            // If you wanted it to be incremented rather than replace the field, then try `$inc` instead of `$set`.
            "update": { $set: { TotalClaimsToBeClaimedByClientType: howManyClaims } },
            "upsert": true
        }
    })
}
db.EightWeekGamePlan.bulkWrite(bulkArr);

收集数据：

/* 1 */
{
    "_id" : ObjectId("5e06eb8f400289966e00fac2"),
    "LeadId" : 1,
    "TotalClaimsToBeClaimedByClientType" : 1.0,
    "TargetedToBeClaimedByClientType" : 1
}

/* 2 */
{
    "_id" : ObjectId("5e06eb98400289966e00fb88"),
    "LeadId" : 2,
    "TotalClaimsToBeClaimedByClientType" : 1.0,
    "TargetedToBeClaimedByClientType" : 1
}

/* 3 */
{
    "_id" : ObjectId("5e06eba0400289966e00fc47"),
    "LeadId" : 3,
    "TotalClaimsToBeClaimedByClientType" : 0,
    "TargetedToBeClaimedByClientType" : 11
}

/* 4 */
{
    "_id" : ObjectId("5e06ebac400289966e00fd4b"),
    "LeadId" : 4,
    "TotalClaimsToBeClaimedByClientType" : 1,
    "TargetedToBeClaimedByClientType" : 11
}

/* 5 */
{
    "_id" : ObjectId("5e06ecef400289966e01273a"),
    "LeadId" : 5,
    "TotalClaimsToBeClaimedByClientType" : 1.0,
    "TargetedToBeClaimedByClientType" : 1
}

结果：

/* 1 */
{
    "_id" : ObjectId("5e06eb8f400289966e00fac2"),
    "LeadId" : 1,
    "TotalClaimsToBeClaimedByClientType" : 2.0,
    "TargetedToBeClaimedByClientType" : 1
}

/* 2 */
{
    "_id" : ObjectId("5e06eb98400289966e00fb88"),
    "LeadId" : 2,
    "TotalClaimsToBeClaimedByClientType" : 2.0,
    "TargetedToBeClaimedByClientType" : 1
}

/* 3 */
{
    "_id" : ObjectId("5e06eba0400289966e00fc47"),
    "LeadId" : 3,
    "TotalClaimsToBeClaimedByClientType" : 0,
    "TargetedToBeClaimedByClientType" : 11
}

/* 4 */
{
    "_id" : ObjectId("5e06ebac400289966e00fd4b"),
    "LeadId" : 4,
    "TotalClaimsToBeClaimedByClientType" : 1,
    "TargetedToBeClaimedByClientType" : 11
}

/* 5 */
{
    "_id" : ObjectId("5e06ecef400289966e01273a"),
    "LeadId" : 5,
    "TotalClaimsToBeClaimedByClientType" : 2,
    "TargetedToBeClaimedByClientType" : 1
}

/* 6 */
{
    "_id" : ObjectId("5e071eb1400289966e0597a0"),
    "TargetedToBeClaimedByClientType" : 1.0,
    "LeadId" : 3.0,
    "TotalClaimsToBeClaimedByClientType" : 2.0
}

/* 7 */
{
    "_id" : ObjectId("5e071e62400289966e059168"),
    "TargetedToBeClaimedByClientType" : 1.0,
    "LeadId" : 31.0,
    "TotalClaimsToBeClaimedByClientType" : 2.0
}

bulkWrite 基本上不返回除写入结果之外的任何文档，您可以在 DB 中验证更新操作结果，同样从上面的结果6 得到插入为LeadId : 3 + TargetedToBeClaimedByClientType" : 1.0（所以LeadId:3 是重复的）组合不是存在于 DB 中 & 7 已插入，因为 LeadId : 31 不存在于 DB 中，剩余的 1,2,5 的 TotalClaimsToBeClaimedByClientType 已更新。

参考： bulkWrite

【讨论】：