动态创建Mongoose模型/集合时，如何校验文档ID有效性？

核心思路是在创建动态评论模型前，先校验对应的父文档（产品/店铺）是否存在，通过前置校验拦截无效ID，避免创建不必要的动态集合。

1. 编写父文档校验函数 #

先实现一个通用校验函数，根据动态模型类型，去对应的静态模型（Product/Store）中验证ID的有效性：

import mongoose from 'mongoose';
import { AppError } from './path-to-your-error-class';

// 假设你已定义并注册了静态模型Product和Store
const Product = mongoose.model('Product');
const Store = mongoose.model('Store');

async function validateParentDocument(modelType: 'product' | 'store', documentId: string): Promise<void> {
  // 先校验ID格式是否合法
  if (!mongoose.Types.ObjectId.isValid(documentId)) {
    throw new AppError(400, `无效的${modelType} ID格式`);
  }

  // 校验文档是否存在
  let exists = false;
  switch(modelType) {
    case 'product':
      exists = await Product.exists({ _id: documentId });
      break;
    case 'store':
      exists = await Store.exists({ _id: documentId });
      break;
    default:
      throw new AppError(400, `不支持的模型类型：${modelType}`);
  }

  if (!exists) {
    throw new AppError(404, `${modelType}（ID：${documentId}）不存在`);
  }
}

2. 修改动态模型获取函数 #

将getDynamicModel改为异步函数，在创建/获取动态模型前执行校验：

export async function getDynamicModel<T extends mongoose.Document>(model: DynamicModel, modelId: string): Promise<mongoose.Model<T>> {
  // 前置校验：确保父文档存在
  await validateParentDocument(model as 'product' | 'store', modelId);

  // 原有的动态模型创建逻辑
  const { modelName, schema, collection } = getDynamicModelData(model, modelId);

  if (!schema) throw new AppError(500, `未找到模型${model}对应的Schema`);

  if (!lruCache.has(modelName) || !mongoose.connection.modelNames().includes(modelName)) {
    createDynamicModel(modelName, schema, collection);
  }
    
  return lruCache.get(modelName) as mongoose.Model<T>;
}

3. （可选）封装为API中间件 #

如果需要在路由层面统一校验，可以封装成Express中间件，在接口处理前拦截无效请求：

import { Request, Response, NextFunction } from 'express';

export async function validateParentDocumentMiddleware(req: Request, res: Response, next: NextFunction) {
  // 从路由参数中获取模型类型和ID（根据你的路由结构调整）
  const { modelType, documentId } = req.params;

  try {
    await validateParentDocument(modelType as 'product' | 'store', documentId);
    next();
  } catch (err) {
    next(err);
  }
}

路由使用示例 #

import express from 'express';
const router = express.Router();

router.post('/product/:productId/reviews', validateParentDocumentMiddleware, async (req, res, next) => {
  try {
    const reviewModel = await getDynamicModel('product', req.params.productId);
    // 后续创建评论的业务逻辑
    const newReview = await reviewModel.create(req.body);
    res.status(201).json(newReview);
  } catch (err) {
    next(err);
  }
});

关键说明 #

• 该方案完全保留了动态集合的设计逻辑，只是增加了前置校验，不会让静态模型的引用逻辑“失去意义”。
• 提前校验ObjectId格式可以减少无效的数据库查询，提升性能。
• 校验失败时直接抛出错误，阻止后续动态模型的创建，避免生成无用的集合。

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