Express函数执行完成后获取MongoDB受影响记录及实现自动化自定义日志

其实MongoDB的官方驱动（包括常用的Mongoose）在执行写操作时，都会返回包含操作详情的结果对象，你可以从中拿到受影响记录的数量，甚至具体的文档内容，分两种场景来说：

• 只需要统计受影响的数量：
  不管是updateOne/updateMany还是deleteOne/deleteMany，执行后返回的结果里都有对应的统计字段。比如Mongoose里，updateMany返回的结果包含matchedCount（匹配到的记录数）和modifiedCount（实际被修改的记录数）；deleteMany返回deletedCount。原生驱动的返回结构类似，比如UpdateResult对象里的modifiedCount和matchedCount。

  举个Mongoose的实际例子：

  app.patch('/users/activate', async (req, res) => {
    try {
      const opResult = await User.updateMany(
        { status: 'inactive' },
        { $set: { status: 'active' } }
      );
      // 直接从结果里提取统计数据
      console.log(`匹配了${opResult.matchedCount}条，实际修改了${opResult.modifiedCount}条`);
      res.json({ success: true, stats: opResult });
    } catch (err) {
      res.status(500).send(err.message);
    }
  });
  

• 需要获取具体的受影响文档：
  如果是单条修改，用findOneAndUpdate并设置{ new: true }，会直接返回修改后的文档；如果是批量操作，默认不会返回所有修改后的文档，这时候你有两个可行选择：

  1. 先查询匹配的记录，再执行更新操作（要注意中间可能有其他操作修改数据，存在一致性风险）；
  2. 在操作完成后，用相同的查询条件再查一次数据库，拿到更新后的文档。

  示例代码：

  app.patch('/users/activate', async (req, res) => {
    try {
      const filter = { status: 'inactive' };
      // 执行更新
      await User.updateMany(filter, { $set: { status: 'active' } });
      // 查询更新后的受影响记录
      const updatedDocs = await User.find(filter);
      res.json({ success: true, affectedRecords: updatedDocs });
    } catch (err) {
      res.status(500).send(err.message);
    }
  });
  

当然可以实现！核心思路是把日志逻辑和业务逻辑解耦，不用在每个业务函数里重复写日志调用，推荐两种实用方案：

方案1：用Mongoose的钩子（Middleware） #

如果你的项目用了Mongoose，那它的**后置钩子（post middleware）**简直是为这个场景量身定做的。你可以在模型上定义钩子，指定当某个数据库操作（比如updateMany、findOneAndUpdate、deleteMany）执行成功后，自动触发日志逻辑。

示例代码：

// 定义User模型时添加钩子
const userSchema = new mongoose.Schema({
  name: String,
  status: String
});

// 针对updateMany操作的后置钩子
userSchema.post('updateMany', async function(next) {
  // this指向当前的查询对象，能拿到查询条件和操作结果
  const filter = this.getQuery();
  const opResult = this.result;

  if (opResult.modifiedCount > 0) {
    // 查询实际受影响的记录
    const affectedDocs = await User.find(filter);
    // 执行自定义日志逻辑：比如存入日志集合、写文件等
    console.log(`[操作日志] 成功修改${opResult.modifiedCount}条用户记录：`, affectedDocs);
    // 也可以把日志写入数据库，比如：
    // await Log.create({ action: 'update', affectedRecords: affectedDocs, timestamp: new Date() });
  }
  next();
});

// 同样给单条修改操作加钩子
userSchema.post('findOneAndUpdate', async function(doc, next) {
  if (doc) { // doc是修改后的文档
    console.log(`[操作日志] 成功修改单条用户记录：`, doc);
  }
  next();
});

const User = mongoose.model('User', userSchema);

这样，不管你在哪个Express路由里调用User.updateMany()或者User.findOneAndUpdate()，只要操作成功，钩子就会自动触发日志记录，完全不用在业务代码里手动调用日志函数！

方案2：封装数据库操作工具函数 #

如果没用Mongoose，或者更倾向于自己控制逻辑，可以封装一层带有日志功能的数据库操作函数，业务代码里直接调用封装后的函数即可。

示例（原生MongoDB驱动）：

// 封装带日志的updateMany函数
async function updateManyWithLog(collection, filter, update) {
  const opResult = await collection.updateMany(filter, update);
  if (opResult.modifiedCount > 0) {
    // 查询受影响的记录
    const affectedDocs = await collection.find(filter).toArray();
    // 执行日志逻辑
    console.log(`[操作日志] 成功修改${opResult.modifiedCount}条记录：`, affectedDocs);
    // 可选：存入日志数据库
    // await collection.db.collection('logs').insertOne({
    //   action: 'update',
    //   collection: collection.collectionName,
    //   affectedRecords: affectedDocs,
    //   timestamp: new Date()
    // });
  }
  return opResult;
}

// 在Express路由里使用
app.patch('/users/activate', async (req, res) => {
  try {
    const db = req.app.locals.db; // 假设已连接数据库
    const result = await updateManyWithLog(
      db.collection('users'),
      { status: 'inactive' },
      { $set: { status: 'active' } }
    );
    res.json({ success: true, modifiedCount: result.modifiedCount });
  } catch (err) {
    res.status(500).send(err.message);
  }
});

这种方式的好处是不依赖ORM，灵活性更高，而且所有需要日志的数据库操作都统一调用封装后的函数，避免重复代码。

另外提个小建议：如果是高并发场景，日志记录可以做成异步的（比如放到消息队列里），避免日志操作拖慢主业务流程。

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