Mongoose对象数组如何更新已有数据、追加新数据避免重复

问题原因 #

你之前全程用$push做数组写入，这个操作的逻辑就是不管数组里有没有同questionId的内容，都会直接追加新元素，必然会出现重复questionId的脏数据。
不需要先查库判断再分逻辑写，用MongoDB原生的原子更新能力就能单条操作实现需求，还能避免并发下的数据异常。 #

方案1：聚合管道更新（推荐，MongoDB 4.2+支持） #

这是最简洁的原子实现方案，一条更新语句直接完成判断、替换/追加全流程，没有并发风险。

第一步：优化Schema定义（可选但建议） #

之前直接把数组元素设为通用Object的写法太松散，建议明确子文档结构，兼容多种答案类型的同时方便后续校验：

const customerSchema = new mongoose.Schema({
  email: { type: String, required: true },
  // 其余业务字段...
  userResponse: [{
    questionId: { type: Number, required: true },
    question: String,
    questionRes: mongoose.Schema.Types.Mixed // 兼容数字、字符串、对象等任意格式答案
  }]
})

第二步：核心更新代码 #

const data = req.body; // 前端提交的单题响应对象，包含questionId、question、questionRes字段
await customerManager.updateCustomer(
  { email: "kehom35319@nzaif.com" },
  [
    {
      $set: {
        userResponse: {
          $cond: {
            // 判断当前数组里是否已经存在同questionId的答题记录
            if: { $in: [data.questionId, "$userResponse.questionId"] },
            then: {
              // 存在则遍历数组，匹配到对应questionId的条目替换为新答案，其余保留
              $map: {
                input: "$userResponse",
                in: {
                  $cond: [
                    { $eq: ["$$this.questionId", data.questionId] },
                    data,
                    "$$this"
                  ]
                }
              }
            },
            // 不存在则把新答案拼接到数组末尾
            else: { $concatArrays: ["$userResponse", [data]] }
          }
        }
      }
    }
  ]
);

方案2：有序批量写入（兼容MongoDB 4.2以下版本） #

如果你的MongoDB版本低于4.2不支持聚合管道更新，可以用有序bulkWrite实现，同样是原子操作：

const data = req.body;
await customerManager.model.bulkWrite([
  // 第一步：尝试更新已存在的同questionId答题记录
  {
    updateOne: {
      filter: {
        email: "kehom35319@nzaif.com",
        "userResponse.questionId": data.questionId
      },
      update: {
        $set: {
          "userResponse.$": data // 数组定位符$自动指向第一个匹配到的同questionId元素
        }
      }
    }
  },
  // 第二步：如果不存在同questionId记录，才追加新条目
  {
    updateOne: {
      filter: {
        email: "kehom35319@nzaif.com",
        "userResponse.questionId": { $ne: data.questionId }
      },
      update: {
        $push: { userResponse: data }
      }
    }
  }
], { ordered: true }); // 开启有序执行，前一步匹配成功时不会改动数据，前一步未匹配才会执行追加

注意事项 #

• 不要用「先查询用户数据，判断questionId是否存在，再手动选择更新/追加」的写法，这类先查后写的逻辑不是原子操作，高并发提交场景下依然可能出现重复questionId的脏数据。
• 如果业务允许，建议给userResponse子文档的questionId加普通索引，能大幅提升数组更新、查询的效率。

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