MongoDB生产环境更新字段时如何保留回退选项？

1. 先备份待修改记录的关键信息到回退集合 #

先把所有需要修改的记录的_id和原始accountInfo.accountNumber单独存到新集合（比如TransactionInfo_rollback），只保留必要字段避免冗余：

db.TransactionInfo.aggregate([
  // 筛选出accountNumber以0开头的记录
  { $match: {"accountInfo.accountNumber": /^0/} },
  // 只保留_id和原始账号字段，重命名方便后续回退
  { $project: {
      originalAccountNumber: "$accountInfo.accountNumber",
      _id: 1
    }
  },
  // 输出到回退集合，首次执行时若集合已存在会被覆盖
  { $out: "TransactionInfo_rollback" }
])

执行完可以验证备份数据：db.TransactionInfo_rollback.find()，确认每条记录都有_id和对应的原始账号。

2. 执行更新操作 #

修正后的更新聚合管道：

db.TransactionInfo.aggregate([
  { $match: {"accountInfo.accountNumber": /^0/} },
  { $set: {
      "accountInfo.accountNumber": { 
        $ltrim: { input: "$accountInfo.accountNumber", chars: "0" }
      }
    }
  },
  { $merge: { 
      into: "TransactionInfo", 
      on: "_id", 
      whenMatched: "replace", 
      whenNotMatched: "discard" 
    }
  }
])

3. 数据检查与回退操作 #

• 检查数据：验证更新结果的查询示例：

  // 排查是否还有未处理的前导0记录
  db.TransactionInfo.find({"accountInfo.accountNumber": /^0/})
  // 抽查修改后的记录，对比备份的原始数据
  db.TransactionInfo.aggregate([
    { $match: { _id: { $in: [/* 从备份集合选几个_id */] } } },
    { $project: { _id:1, modifiedAccountNumber: "$accountInfo.accountNumber" } }
  ])
  

• 回退操作：如果需要恢复原始数据，用备份集合批量还原：

  db.TransactionInfo_rollback.find().forEach(doc => {
    db.TransactionInfo.updateOne(
      { _id: doc._id },
      { $set: { "accountInfo.accountNumber": doc.originalAccountNumber } }
    )
  })
  

  这个操作只会修改备份过的记录，不会影响其他未改动的数据。

注意事项 #

• 备份操作必须在更新前执行，确保备份的是修改前的原始状态。
• 生产环境执行操作时，可短暂监控系统状态，避免写入冲突。
• 回退完成且确认无误后，可删除备份集合：db.TransactionInfo_rollback.drop()

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