如何在MongoDB中实现类似SQL内连接的查询？求助

别担心，刚上手MongoDB的聚合查询时，确实容易在关联表这块摸不清头绪，我来一步步帮你把SQL逻辑转成MongoDB的聚合语句～

首先，你的需求是模拟SQL的INNER JOIN，同时保留原来tableA.find()里的过滤条件，我们可以通过聚合管道的多个阶段组合来实现：

步骤1：把原find条件转为聚合的$match阶段 #

先过滤tableA中符合条件的数据，这样后续关联时只处理需要的文档，能大幅提升效率。你原来的find条件可以直接放到$match里：

{
  $match: {
    $and: [
      { schedule: { $gte: new Date(from), $lte: new Date(to) } },
      { f1: { $in: [/* 你的some values */] } }
    ]
  }
}

步骤2：用$lookup关联collectionB #

这一步就是你已经尝试的关联操作，但要注意：$lookup默认是左外连接，会保留所有tableA的文档，哪怕在collectionB里没有匹配项。如果要实现SQL的INNER JOIN（只保留两边都匹配的文档），我们需要后续再加过滤。

{
  $lookup: {
    from: 'collectionB',
    localField: 'f1',
    foreignField: 'f1',
    as: 'b'
  }
}

步骤3：过滤掉未匹配的文档（实现Inner Join） #

因为$lookup返回的b是一个数组，如果没有匹配到数据，数组会是空的。我们可以用$match过滤掉b数组为空的文档，这样就和SQL的内连接效果完全一致了：

{
  $match: {
    'b': { $ne: [] }
  }
}

步骤4：展开b数组（可选但推荐） #

$lookup返回的b是数组格式（哪怕只有一个匹配项），如果想把它当成普通对象来处理字段，可以用$unwind展开数组：

{
  $unwind: '$b'
}

步骤5：选择需要返回的字段（$project） #

最后用$project来指定要返回的字段，就像SQL里的SELECT子句：

• 如果只需要特定字段：

{
  $project: {
    'a_f1': '$f1', // 可以给字段重命名，避免和b的f1混淆
    'a_f2': '$f2',
    'b_f1': '$b.f1',
    'b_f3': '$b.f3',
    // 如果需要保留原来的schedule字段，也要加上
    'schedule': 1
  }
}

• 如果要返回collectionB的所有字段，直接写'b': 1即可：

{
  $project: {
    'f1': 1,
    'f2': 1,
    'b': 1, // 保留b的所有字段
    'schedule': 1
  }
}

完整的聚合语句 #

把所有阶段组合起来，就是最终的可运行代码：

collectionA.aggregate([
  // 第一步：过滤tableA的原始数据
  {
    $match: {
      $and: [
        { schedule: { $gte: new Date(from), $lte: new Date(to) } },
        { f1: { $in: [/* 你的some values */] } }
      ]
    }
  },
  // 第二步：关联collectionB
  {
    $lookup: {
      from: 'collectionB',
      localField: 'f1',
      foreignField: 'f1',
      as: 'b'
    }
  },
  // 第三步：过滤掉未匹配的文档，实现Inner Join
  {
    $match: {
      'b': { $ne: [] }
    }
  },
  // 第四步：展开b数组（可选）
  {
    $unwind: '$b'
  },
  // 第五步：选择需要的字段
  {
    $project: {
      'f1': 1,
      'f2': 1,
      'b.f1': 1,
      'b.f3': 1,
      'schedule': 1
    }
  }
])

额外说明 #

• 如果你的f1字段在两个集合里是唯一匹配的（比如主键），那$unwind阶段不会有任何问题；如果一个tableA文档对应多个collectionB文档，$unwind会把每个匹配项拆成单独的文档，这和SQL的INNER JOIN行为完全一致。
• 要是不需要严格的内连接，只是左连接，那可以直接去掉第三步的$match阶段。

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