如何在MongoDB中实现类似SELECT FOR UPDATE的ACID式用户历史操作？

结论：只用MongoDB自带函数就能搞定，不用额外搞应用层锁或分布式锁 #

MongoDB的findOneAndUpdate支持原子性的upsert操作，配合聚合表达式就能在单个原子操作里完成所有要求的逻辑，完全满足ACID特性（MongoDB单文档操作本身就是原子的）。

具体实现方法 #

用findOneAndUpdate，加上upsert: true参数，再通过聚合管道来处理更新逻辑：

核心代码示例 #

db.user_history.findOneAndUpdate(
  { userId: "要操作的用户ID" }, // 按唯一键userId查询
  [
    // 用聚合管道写更新逻辑
    {
      $set: {
        // 处理history数组：如果文档存在就追加新元素，不存在就初始化为[{sequence: 0}]
        history: {
          $cond: {
            if: { $exists: "$history" },
            then: {
              $concatArrays: [
                "$history",
                [{ sequence: "$auto_increment" }] // 拿当前的auto_increment当新元素的sequence
              ]
            },
            else: [{ sequence: 0 }]
          }
        },
        // 处理auto_increment：存在就加1，不存在就设为1
        auto_increment: {
          $cond: {
            if: { $exists: "$auto_increment" },
            then: { $add: ["$auto_increment", 1] },
            else: 1
          }
        }
      }
    }
  ],
  {
    upsert: true, // 找不到匹配文档就自动插入新的
    returnDocument: "after" // 返回更新后的完整文档，满足你要获取更新结果的需求
  }
)

关键细节说明 #

• 原子性保障：MongoDB单文档操作是原子的，这个findOneAndUpdate要么全成要么全败，不会出现半中间的状态，效果等同于MySQL里用SELECT FOR UPDATE加后续更新的原子操作。
• 并发处理：不用额外加锁，MongoDB的upsert本身会处理并发场景——如果多个请求同时操作同一个userId，只有一个会触发插入，其他会自动转为更新操作，不会出现数据乱掉的情况。
• 必须加唯一索引：一定要给userId字段建唯一索引，防止同一个userId插出多个文档：

  db.user_history.createIndex({ userId: 1 }, { unique: true })
  

为啥这方法可行？ #

MongoDB 4.2及以上版本允许在更新操作里用聚合管道，这就让我们能直接基于文档现有值（比如当前的auto_increment）计算新值，不用在应用层先查再改，从根源上避免了并发竞态问题。

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