MongoDB如何实现数组按place字段匹配：不存在则插入、匹配则更新

你的代码核心问题有以下三点：

• 变量名拼写错误：代码中定义了存储新states数组的对象newStates，但构造更新参数时误用了未定义的newSquad变量，导致$set操作没有有效内容，这是更新场景不生效的直接原因。
• 并发安全隐患：当前采用「先查询文档修改内存数组、再全量覆盖写回」的模式，若同一时间有多个请求修改同一条文档的states数组，会出现后提交的修改覆盖之前修改的问题，无法保证数据一致性。
• 异步处理不规范：代码混用了Promise的then方法和回调函数，成功场景没有返回正确响应，异常处理逻辑也不完整，容易出现请求卡死的情况。

方案1：快速修复现有代码 #

仅修正变量名和异步逻辑，适配你现有写法：

const query  = {"_id": ObjectId(xxx)}
// 用findOne代替find+toArray，性能更优
db.collection('Regions').findOne(query).then((data) => {
  const arr = data.states;
  const index = arr.findIndex((e) => e.place === reqBody.place);
  const obj = {"place":reqBody.place,"skId":reqBody.skId};
  if (index > -1) {
    arr[index] = obj;
  } else {
    arr.push(obj);
  }
  // 修正变量名错误，直接构造更新参数
  const newStateValue = {$set: {"states": arr}};
  return db.collection("Regions").updateOne(query, newStateValue);
}).then(result => {
  resolve({
    "statuscode": "200",
    "message": "操作成功"
  })
}).catch(err => {
  resolve({
    "error": err.toString(),
    "statuscode": "404"
  });
})

方案2：原子操作实现（更推荐） #

无需先查询文档，用MongoDB原生操作符实现原子更新，无并发问题：

适配所有MongoDB版本的实现 #

const query  = {"_id": ObjectId(xxx), "states.place": reqBody.place}
const updateMatch = {
  $set: {
    "states.$": {"place": reqBody.place, "skId": reqBody.skId}
  }
}
// 先尝试更新匹配place的元素
db.collection("Regions").updateOne(query, updateMatch).then(result => {
  if (result.matchedCount === 0) {
    // 无匹配元素时追加新对象
    return db.collection("Regions").updateOne(
      {"_id": ObjectId(xxx)},
      {$push: {"states": {"place": reqBody.place, "skId": reqBody.skId}}}
    )
  }
  return result
}).then(res => {
  resolve({
    "statuscode": "200",
    "message": "操作成功"
  })
}).catch(err => {
  resolve({
    "error": err.toString(),
    "statuscode": "404"
  });
})

MongoDB 4.2+ 版本极简实现 #

用聚合更新管道，一次请求覆盖两种场景：

db.collection("Regions").updateOne(
  {"_id": ObjectId(xxx)},
  [{
    $set: {
      states: {
        $concatArrays: [
          // 过滤掉原有place相同的元素
          {$filter: {input: "$states", cond: {$ne: ["$$this.place", reqBody.place]}}},
          // 加入新对象
          [{"place": reqBody.place, "skId": reqBody.skId}]
        ]
      }
    }
  }]
)

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