NestJS/Mongoose中如何通过API调用基于ObjectId过滤集合文档

针对API传参时ObjectId被序列化为字符串导致查询失败的问题，两类方案均可落地，按需选择即可。

方案一：兼容字符串类型id查询 #

• 优先利用Mongoose自带的类型转换能力：只要Schema中对应嵌套路径的id字段明确定义为Schema.Types.ObjectId类型，且没有把嵌套字段声明为Mixed类型，普通查询场景下直接传入字符串格式的id，Mongoose会自动完成类型转换，不需要手动实例化ObjectId即可正常匹配。
• 如果是聚合管道、动态透传查询等自动转换不生效的场景，不需要同时存储两种类型的id（会导致索引失效、数据冗余），写一个通用递归预处理函数即可：在查询执行前遍历所有条件，把配置的ObjectId字段对应的字符串值统一转为ObjectId实例，再传入Mongoose查询方法。
• 检查点：如果字符串查询不生效，优先确认Schema嵌套结构是否完整声明、传入的id是否为合法24位十六进制ObjectId格式、是否绕过了Mongoose的标准查询流程。

方案二：自定义$oid操作符自动转换 #

完全支持自定义$oid操作符实现自动类型转换，推荐用Mongoose全局插件+预处理钩子实现，全场景覆盖不需要在业务代码里重复写转换逻辑：

1. 先写递归转换工具函数，处理任意嵌套层级、$or/$and等数组查询条件、聚合管道内的匹配条件：

import { ObjectId } from 'mongoose';

function convertOidOperator(input: any): any {
  if (Array.isArray(input)) {
    return input.map(item => convertOidOperator(item));
  }
  if (typeof input === 'object' && input !== null) {
    if (Object.prototype.hasOwnProperty.call(input, '$oid')) {
      return new ObjectId(input.$oid);
    }
    const res = {};
    for (const [k, v] of Object.entries(input)) {
      res[k] = convertOidOperator(v);
    }
    return res;
  }
  return input;
}

2. 注册全局Mongoose插件，在所有查询、聚合、更新操作执行前自动转换条件：

import mongoose from 'mongoose';

// 项目初始化Mongoose连接时调用即可全局生效
mongoose.plugin((schema) => {
  schema.pre(/^find|^count|^updateOne|^updateMany|^delete/, function(next) {
    const query = this.getQuery();
    this.setQuery(convertOidOperator(query));
    next();
  });

  schema.pre('aggregate', function(next) {
    const pipeline = this.pipeline();
    pipeline.forEach(stage => {
      if (stage.$match) {
        stage.$match = convertOidOperator(stage.$match);
      }
    });
    next();
  });
});

配置完成后，接口传入的{"$or":[{"key3.prop3.id":{"$oid":"62ceb429804e78434d21af4e"}}]}格式查询，会被自动转换为Mongoose可识别的标准ObjectId查询格式，不需要额外处理。如果不想全局生效，也可以在NestJS拦截器层单独处理接口传入的查询参数，转换后再传入Service层，效果一致。

注意：开放动态查询能力时，必须对查询字段做白名单校验，禁止直接透传前端传入的原始查询条件，避免查询注入风险。

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