Node.js中无需聚合操作，如何填充MongoDB跨集合引用数据？

根据你的集合结构（coll2的coll1_ids字段存储多个coll1的引用ID，每个coll1仅对应一个coll2），可以用以下两种无需聚合的简便方法实现需求：

方法一：使用Mongoose ORM（推荐） #

Mongoose支持通过虚拟字段+populate实现反向关联查询，无需手动写聚合：

1. 定义Schema并设置虚拟关联 #

const mongoose = require('mongoose');

// 定义coll2的Schema
const coll2Schema = new mongoose.Schema({
  coll1_ids: [{ type: mongoose.Schema.Types.ObjectId, ref: 'coll1' }]
});
const Coll2 = mongoose.model('coll2', coll2Schema);

// 定义coll1的Schema，并添加虚拟字段关联coll2
const coll1Schema = new mongoose.Schema({
  name: String
});

// 虚拟字段：通过coll1的_id匹配coll2的coll1_ids数组，且只取第一个匹配的coll2（因为每个coll1仅对应一个）
coll1Schema.virtual('coll2', {
  ref: 'coll2',
  localField: '_id',
  foreignField: 'coll1_ids',
  justOne: true
});

// 配置让虚拟字段在JSON/对象输出中可见
coll1Schema.set('toJSON', { virtuals: true });
coll1Schema.set('toObject', { virtuals: true });

const Coll1 = mongoose.model('coll1', coll1Schema);

2. 查询时填充coll2数据 #

// 连接数据库
await mongoose.connect('mongodb://localhost:27017/your-db-name');

// 查询所有coll1文档并自动填充对应的coll2数据
const populatedColl1 = await Coll1.find().populate('coll2');

// 每个coll1文档中会新增coll2字段，包含对应的coll2完整数据
console.log(populatedColl1);

方法二：使用原生MongoDB驱动 #

如果不用ORM，可通过手动查询+映射的方式实现，同样无需聚合：

const { MongoClient } = require('mongodb');

async function populateColl1() {
  // 连接数据库
  const client = await MongoClient.connect('mongodb://localhost:27017/your-db-name');
  const db = client.db();

  // 1. 获取所有coll1文档
  const coll1Docs = await db.collection('coll1').find().toArray();
  if (!coll1Docs.length) return [];

  // 2. 收集所有coll1的ID
  const coll1Ids = coll1Docs.map(doc => doc._id);

  // 3. 查询包含这些ID的所有coll2文档
  const coll2Docs = await db.collection('coll2').find({ coll1_ids: { $in: coll1Ids } }).toArray();

  // 4. 建立coll1 ID到对应coll2的映射表
  const coll1ToColl2Map = new Map();
  coll2Docs.forEach(coll2 => {
    coll2.coll1_ids.forEach(coll1Id => {
      if (!coll1ToColl2Map.has(coll1Id)) {
        coll1ToColl2Map.set(coll1Id, coll2);
      }
    });
  });

  // 5. 给每个coll1文档添加对应的coll2数据
  const populatedColl1 = coll1Docs.map(doc => ({
    ...doc,
    coll2: coll1ToColl2Map.get(doc._id) || null
  }));

  await client.close();
  return populatedColl1;
}

// 调用函数
populateColl1().then(result => console.log(result));

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