如何为MongoDB的find查询结果添加钩子函数？

MongoDB的watch()方法确实只针对数据变更操作（insert、update、delete等），没法直接监听find这类读查询。要实现find查询的钩子，有几种可行的方案：

驱动层面直接封装拦截（以Node.js驱动为例） #

直接重写MongoDB驱动的查询方法，在调用原生逻辑前后插入钩子代码：

// 假设已获取目标集合实例
const targetCollection = db.collection('your-collection');
// 保存原生find方法
const originalFind = targetCollection.find;

targetCollection.find = function(query, options) {
  // 查询前的钩子逻辑
  console.log(`find查询触发，查询条件：`, query);
  
  // 调用原生find获取游标
  const cursor = originalFind.call(this, query, options);
  
  // 拦截游标执行方法（比如toArray）来捕获查询完成事件
  const originalToArray = cursor.toArray;
  cursor.toArray = async function() {
    const result = await originalToArray.call(this);
    // 查询完成后的钩子逻辑
    console.log(`find查询完成，返回结果：`, result);
    return result;
  };

  // 同理可封装其他游标方法，比如next、forEach等
  return cursor;
};

这种方式灵活可控，但需要覆盖所有可能执行查询的方法（比如findOne、aggregate），否则会有遗漏。

开启MongoDB审计日志 #

通过MongoDB的审计功能记录所有读操作，再监听审计日志获取查询事件：

1. 修改MongoDB配置文件启用审计，指定只记录find操作：

auditLog:
  destination: file
  path: /var/log/mongodb/audit.log
  format: JSON
  filter: '{ "atype": "find" }'

2. 可以选择直接解析审计日志文件，或者配置将审计日志输出到MongoDB集合，再通过watch()监听该集合的变更来获取查询事件。
   这种方式能捕获所有客户端的查询操作，但需要数据库管理员权限，且会增加服务器资源消耗。

利用ODM中间件（以Mongoose为例） #

如果项目用Mongoose，可以直接用它的预/post中间件功能：

const mongoose = require('mongoose');
const schema = new mongoose.Schema({
  // 你的集合字段定义
});

// 查询前触发的中间件
schema.pre('find', function(next) {
  console.log(`即将执行find查询，查询条件：`, this.getQuery());
  next();
});

// 查询完成后触发的中间件
schema.post('find', function(docs) {
  console.log(`find查询完成，返回结果：`, docs);
});

// 同理可给findOne、aggregate等方法添加中间件
const YourModel = mongoose.model('YourModel', schema);

这种方式简洁高效，适合使用Mongoose的项目，不需要直接操作底层驱动。

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