Mongoose：如何将现有Product文档转换为新子文档Schema

你的代码存在多个关键问题，导致无法完成数据的正确转换，以下是具体问题点和修正方案：

核心问题点 #

• 异步操作处理失效：forEach不支持异步函数，内部的Category.findOne()是异步操作，会直接返回Promise而非实际的文档ID，最终存入的是Promise对象而非预期的ObjectId。
• 字段赋值错误：name: Category是错误写法，应该赋值为原字符串类型的分类名称category。
• 未持久化修改：修改后的product对象没有调用save()方法，数据库中的数据不会被更新。
• 无异常处理：没有处理查询或保存时的错误，也未处理找不到对应Category文档的情况。
• 范围限制：原代码只查询了特定名称的产品，若要更新所有现有Product文档，需移除该查询条件。

修正后的代码 #

router.get('/convertCategories', async function (req, res) {
  try {
    // 查询所有Product文档（需指定范围可保留原查询条件）
    const products = await Product.find();

    // 使用for...of循环支持异步操作
    for (const product of products) {
      // 跳过已转换的文档（避免重复执行）
      if (product.categories[0]?._id) continue;

      // 转换分类数组：遍历原字符串分类，匹配对应的Category文档
      const convertedCategories = await Promise.all(
        product.categories.map(async (categoryName) => {
          const categoryDoc = await Category.findOne({ name: categoryName });
          // 处理找不到对应分类的情况，可按需调整（跳过或创建新分类）
          if (!categoryDoc) {
            console.warn(`未找到分类：${categoryName}，已跳过`);
            return null;
          }
          return {
            name: categoryName,
            _id: categoryDoc._id
          };
        })
      );

      // 过滤掉null值（即找不到的分类）
      product.categories = convertedCategories.filter(item => item !== null);
      // 保存修改后的文档到数据库
      await product.save();
      console.log(`已更新产品：${product._id}`);
    }

    res.send('所有产品分类转换完成');
  } catch (error) {
    console.error('转换过程出错：', error);
    res.status(500).send(`转换失败：${error.message}`);
  }
});

额外优化建议 #

• 幂等性保障：通过检查categories数组第一个元素是否包含_id字段，避免重复转换已处理过的文档。
• 批量操作优化：如果数据量较大，使用bulkWrite代替逐个save()可提升性能，减少数据库请求次数。
• 缺失分类处理：若存在原分类名称在Category集合中不存在的情况，可在if (!categoryDoc)分支中添加自动创建分类的逻辑，而非直接跳过。

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