如何在Mongoose的insertMany方法中触发post save中间件？

Mongoose的insertMany()默认不会触发save中间件，也没有特定参数能强制触发——因为save中间件是绑定在单个文档的save()操作上的，而insertMany底层直接调用MongoDB的批量写API，不会走单文档的save流程。

下面是几种不用改用create/save就能实现需求的方案：

方案1：遍历文档逐个调用save() #

如果你的种子数据量不大，可以直接遍历每个数据，实例化文档后调用save()，这样会触发你定义的post('save')中间件：

// 假设customers是你的种子数据数组
for (const customerData of customers) {
  const customer = new Customer(customerData);
  await customer.save(); // 触发post save中间件
}

方案2：改用insertMany专属中间件 #

Mongoose支持针对insertMany的中间件，你可以直接定义post('insertMany')来处理批量插入后的逻辑，不用修改原有的insertMany调用：

// 替换原有的post('save')中间件，或者新增这个中间件
CustomerSchema.post('insertMany', async function (docs) {
  try {
    for (const doc of docs) {
      const year = doc.birthDate.getFullYear();
      console.log({ year });
      // 在这里添加代际分类逻辑，比如将文档保存到对应代际集合
    }
  } catch (error) {
    throw error;
  }
});

// 原有insertMany调用保持不变
await Customer.insertMany(customers);

注意：post('insertMany')的参数是插入成功的文档数组，需要遍历处理每个文档。

方案3：封装自定义静态方法 #

如果想保留insertMany的调用风格，同时触发save中间件，可以给Schema添加一个自定义静态方法：

CustomerSchema.statics.insertManyWithMiddleware = async function (docs) {
  const results = [];
  for (const docData of docs) {
    const doc = new this(docData);
    await doc.save(); // 触发post save中间件
    results.push(doc);
  }
  return results;
};

// 调用时使用这个自定义方法
await Customer.insertManyWithMiddleware(customers);

各方案对比 #

• 方案1：实现简单，适合小批量种子数据；缺点是批量插入效率低于原生insertMany。
• 方案2：性能和原生insertMany一致，适合大批量数据；只需调整中间件定义，无需修改调用逻辑。
• 方案3：兼顾调用习惯和中间件触发，效率和方案1相同。

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