如何在MongoDB中执行联表查询？

XKCPZ • 2025-01-11 16:28 • 编程

一、MongoDB中的联表查询是什么？

在关系型数据库中，我们通常使用JOIN语句进行查询不同表之间的关联数据。但在MongoDB中，并没有像MySQL这样的SQL语法，所以联表查询的实现方式也有所不同。

MongoDB中的联表查询指的是查询两个或多个集合中的数据，并将它们整合在一起。这种查询方式可以通过使用$lookup实现。

db.orders.aggregate([
    {
        $lookup:
            {
                from: "products",
                localField: "product_id",
                foreignField: "_id",
                as: "product_info"
            }
   }
])

以上代码会在orders集合中查找product_id字段，并将查询结果与products集合中的对应_id进行匹配，并最终将它们整合在一起。$lookup语句中的参数说明如下：

from：要进行查询的集合名称
localField：当前集合中需要匹配的字段
foreignField：目标集合中需要匹配的字段
as：输出结果的字段名称

二、如何使用$lookup进行简单联表查询？

在进行联表查询时，我们需要了解两个集合之间的关联方式。在下面的例子中，我们将查询orders和products集合，并将它们按照product_id字段进行匹配:

db.orders.aggregate([
    {
        $lookup:
            {
                from: "products",
                localField: "product_id",
                foreignField: "_id",
                as: "product_info"
            }
   }
])

这个查询可以将orders集合中的每个文档的product_id和products集合的_id字段进行匹配。这意味着，在每个输出的文档中，都将包含一个名为product_info的字段，该字段将与查询结果匹配的_product表中的文档一起返回。

三、如何执行进阶的联表查询？

当需要查询三个或更多的集合时，使用$lookup可能就不太容易了。这时我们需要使用聚合管道来处理更复杂的查询。

在下面的例子中，我们将使用三个集合: orders、order_items、和products。我们通过将orders和order_items集合的order_id字段进行匹配，将两个集合进行联接，并在与这些文档匹配的product_id字段和products集合中的_id字段进行匹配。最终，我们将在输出中包含order_number、item_name和product_name:

db.orders.aggregate([
    {
        $lookup:
            {
                from: "order_items",
                localField: "order_id",
                foreignField: "order_id",
                as: "order_items"
            }
   },
   {
        $unwind: "$order_items"
   },
   {
        $lookup:
            {
                from: "products",
                localField: "order_items.product_id",
                foreignField: "_id",
                as: "product_info"
            }
   },
   {
        $project:
            {
                order_number: 1,
                item_name: "$order_items.item_name",
                product_name: "$product_info.product_name"
            }
   }
])

在这个查询中，我们使用了两个$lookup阶段来连接三个集合。在第一个$lookup阶段中，我们将orders和order_items集合连接在一起，$unwind阶段用于展开order_items数组，并使每个文档都具有单个order_item项。在第二个lookup阶段中，我们使用了order_items的product_id字段和products集合的_id字段进行匹配。

最后，我们使用project阶段来输出order_number、item_name和product_name。由于我们将product_info输出到另一个数组中，因此需要在后面添加.product_name以访问正确的属性。

四、如何对联表查询结果进行排序和过滤？

当我们需要按照order_number字段进行排序时，可以使用sort阶段。在下面的例子中，我们将通过order_number字段对orders集合中的文档进行升序排序:

db.orders.aggregate([
    {
        $lookup:
            {
                from: "order_items",
                localField: "order_id",
                foreignField: "order_id",
                as: "order_items"
            }
   },
   {
        $sort: { order_number: 1 }
   }
])

当我们需要仅输出order_number大于100的结果时，可以使用match阶段。在下面的例子中，我们将只输出order_number大于100的文档:

db.orders.aggregate([
    {
        $lookup:
            {
                from: "order_items",
                localField: "order_id",
                foreignField: "order_id",
                as: "order_items"
            }
   },
   {
        $match: { order_number: { $gt: 100 } }
   }
])

五、总结

在MongoDB中，联表查询可以通过使用$lookup实现，$lookup语句可以连接多个集合，并按照指定的字段进行匹配。使用聚合管道进行更复杂的查询时，可以使用多个$lookup阶段，并进行排序和筛选以达到更精细的结果。

原创文章，作者：XKCPZ，如若转载，请注明出处：https://www.506064.com/n/317877.html