Node.js实现MongoDB文档版本化：如何获取findOneAndUpdate原始文档？

嘿，这个问题问到点子上了——我在几个Node.js项目里折腾过MongoDB的版本化功能，给你拆解下两个核心问题的解法：

一、如何获取findOneAndUpdate更新前的原始文档？ #

当然可以！MongoDB（以及对应的Node.js驱动）提供了直接获取原始文档的参数，分两种情况：

1. MongoDB 4.2+ 版本（推荐） #

用returnDocument: 'before'参数，这是官方现在主推的写法，明确指定返回更新前的文档：

const { MongoClient } = require('mongodb');

async function updateAndGetOriginal() {
  const client = new MongoClient('mongodb://localhost:27017');
  await client.connect();
  const db = client.db('my-project');
  const coll = db.collection('documents');

  const filter = { _id: 'your-doc-id' };
  const update = { $set: { content: 'Updated content' } };
  const options = {
    returnDocument: 'before' // 关键：返回更新前的原始文档
  };

  const originalDoc = await coll.findOneAndUpdate(filter, update, options);
  console.log('更新前的原始文档:', originalDoc);
  
  await client.close();
}

2. 旧版本MongoDB（4.2之前） #

用returnNewDocument: false，这个参数是旧版的写法，设置为false就会返回原始文档（默认其实就是false，但显式写出来更清晰）：

const options = {
  returnNewDocument: false // 返回更新前的文档
};

二、更优的MongoDB文档版本化实现方案 #

单纯获取原始文档只是第一步，要做健壮的版本化，得根据你的业务场景选合适的方案，我整理了三种常用的：

1. 内嵌版本数组（适合小文档、版本数量少的场景） #

在原文档里加一个versions数组，每次更新时把旧版本的快照push进去，优点是和原文档关联紧密，查询版本很方便，缺点是如果版本太多会导致原文档体积过大，影响性能。

可以配合$slice限制保留的版本数量，比如只存最近10个：

// 先获取原始文档
const originalDoc = await coll.findOne(filter);

// 执行更新，同时把旧版本加入versions数组
await coll.findOneAndUpdate(filter, {
  $set: { content: 'New content' },
  $push: {
    versions: {
      $each: [{
        ...originalDoc,
        updatedAt: new Date(),
        versionNumber: originalDoc.versionNumber + 1 // 自增版本号
      }],
      $slice: -10 // 只保留最近10个版本
    }
  }
}, { returnDocument: 'after' });

2. 单独的版本集合（适合大文档、需要保留大量版本的场景） #

专门建一个和业务集合对应的版本集合（比如业务集合是posts，版本集合就叫posts_versions），每次更新时先把原始文档插入版本集合，再更新原文档。

这种方案的优点是原文档体积小，版本管理更灵活，还能单独对版本集合做索引、清理等操作：

const client = new MongoClient('mongodb://localhost:27017');
await client.connect();
const db = client.db('my-project');
const postsColl = db.collection('posts');
const versionsColl = db.collection('posts_versions');

const filter = { _id: 'post-id' };
const update = { $set: { title: 'Updated Title' } };

// 1. 获取原始文档
const originalDoc = await postsColl.findOne(filter);
// 2. 插入版本集合，加上版本元信息
await versionsColl.insertOne({
  ...originalDoc,
  originalId: originalDoc._id,
  versionAt: new Date(),
  versionNumber: (await versionsColl.countDocuments({ originalId: originalDoc._id })) + 1
});
// 3. 更新原文档
await postsColl.updateOne(filter, update);

await client.close();

3. 变更流（Change Streams）自动追踪版本（适合全局版本追踪、解耦业务逻辑的场景） #

用MongoDB的变更流监听集合的所有更新操作，自动捕获变更前的文档并存入版本集合，优点是不用在业务代码里写版本逻辑，解耦性强，适合需要统一管理所有文档版本的场景：

const client = new MongoClient('mongodb://localhost:27017');
await client.connect();
const db = client.db('my-project');
const coll = db.collection('documents');
const versionsColl = db.collection('documents_versions');

// 监听更新操作
const changeStream = coll.watch([
  { $match: { operationType: 'update' } }
]);

changeStream.on('change', async (changeEvent) => {
  // 获取更新前的完整文档
  const originalDoc = changeEvent.fullDocumentBeforeChange;
  if (originalDoc) {
    await versionsColl.insertOne({
      ...originalDoc,
      originalId: originalDoc._id,
      changedAt: new Date(),
      operationType: changeEvent.operationType
    });
  }
});

// 保持监听
process.on('SIGINT', async () => {
  await changeStream.close();
  await client.close();
  process.exit(0);
});

额外注意点 #

• 原子性：如果用方案2，建议用MongoDB的事务保证“插入版本+更新原文档”的原子性，避免出现版本丢失的情况。
• 版本清理：定期清理旧版本（比如用定时任务删除3个月前的版本），防止版本集合体积过大。
• 版本号管理：可以用自增字段、时间戳或者UUID来标识版本，根据业务需求选择。

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