如何在MongoDB 4.4中使用unionWith联表查询

在 MongoDB 4.4 版本中，$unionWith 确实可以使用，但与 5.0 及更高版本存在本质差异。许多关键细节若不留意，开发过程中容易遇到问题。特别是 pipeline 参数的支持、字段对齐以及合并后的顺序，都需要额外处理。以下结合实际开发经验，详细说明几个核心要点。

4.4 版本支持 $unionWith，但不支持 pipeline 参数

MongoDB 4.4 确实引入了 $unionWith，但该阶段仅接受字符串形式的集合名，例如 {$unionWith: "admins"}，不支持 pipeline 字段。这是与 5.0+ 最关键的区别——4.4 的 $unionWith 没有 pipeline 选项，因此无法在联合时对目标集合进行 $match、$project 等预处理。

实际开发中，许多人会直接照搬 5.0+ 的写法，比如：

{$unionWith: { coll: "admins", pipeline: [{$match: {active: true}}] }}

这在 4.4 中会报错：unrecognized field 'pipeline'。请记住，4.4 只允许简写形式：{$unionWith: "targetCollection"}。

• 若需要过滤或字段对齐，必须提前在源集合或目标集合上单独添加 $match 或 $project 阶段（不能嵌套在 $unionWith 内部）
• 两个集合字段不一致时，缺失字段不会自动补 null，而是直接不出现——容易导致后续的 $group 或 $sum 出错

如何让 4.4 的 $unionWith 输出结构一致？

如果 orders 和 returns 集合的字段不同（例如前者有 amount，后者是 refund），直接使用 $unionWith 后字段会错乱。必须通过 $project 统一输出结构。

正确的做法是：在每个集合的数据流中先进行字段映射，再进行 union。具体来说：

• 先对主集合执行 $project，将字段重命名为统一别名，例如 {value: "$amount"}
• 再使用 $unionWith: "returns"，但需注意：4.4 不允许为 returns 单独添加 pipeline，因此需要提前创建视图或改写查询逻辑
• 更稳妥的方式是创建一个中间视图：db.createView("unified_events", "orders", [{$project: {type: "order", value: "$amount", ts: "$createdAt"}}])，再对 returns 做同样的视图，最后查询视图并进行 union

4.4 中实现 UNION ALL 语义的实际限制

$unionWith 在 4.4 中默认不去重，这一点与 SQL 的 UNION ALL 行为一致，但顺序完全不可控——即使两个集合各自有序，合并后文档的排列顺序也是随机的。

• 不能依赖自然插入顺序，也不能依靠 _id 排序进行隐含保证
• 如果需要按时间归并（例如日志表 logs_202401 和 logs_202402），必须在 $unionWith 后显式添加 $sort，例如 {$sort: {timestamp: 1}}
• 但需注意：4.4 对内存排序有限制，当结果集较大且缺少索引支持时容易触发 Sort exceeded memory limit 错误
• 如果仅需求取前 20 条，分别查询两个集合并在应用层进行归并（按时间字段执行 merge sort），通常比全量 union 后再使用 $skip/$limit 更快速、更稳定

Java 中用 MongoTemplate 调用 $unionWith 的写法

MongoTemplate 4.x（对应 MongoDB 4.4）没有封装 $unionWith 的 Criteria 方法，必须使用原生 BSON 构造。具体来说：

• 不能使用 Aggregation.newAggregation(...) 直接链式调用 $unionWith
• 需要手动编写 Document：new Document("$unionWith", "admins")
• 整个聚合管道必须通过 Aggregation.aggregate(..., new Document(...)) 方式传入
• 当字段不一致时，Java 层获取的 Map 可能缺少某些 key，建议使用 @Document 类定义统一的 DTO，并结合 $project 显式映射字段

真正棘手的并非语法本身——字段对齐和顺序控制才是 MongoDB 4.4 版本中 $unionWith 最令人头疼的地方。若想像 5.0+ 那样通过 pipeline: [] 一键实现，在 4.4 上只能依靠组合各个阶段来硬性应对。