mongodb实现同库联表查询方法示例

MongoDB实现同库联表查询，可通过聚合管道或嵌入文档方式进行，示例中展示了具体的操作方法和步骤。

MongoDB同库联表查询实践：实现方法与示例解析

MongoDB 是一款流行的 NoSQL 数据库，其文档型存储结构为开发人员提供了极高的灵活性，在实际应用中，我们经常需要从多个集合（表）中查询数据，这就涉及到同库联表查询，与关系型数据库不同，MongoDB 不支持 SQL 中的 JOIN 操作，但我们可以通过其他方式实现类似的功能，本文将介绍 MongoDB 同库联表查询的实现方法，并通过示例进行详细解析。

实现方法

MongoDB 同库联表查询主要有以下几种方法：

1、嵌入式文档（Embedding）

嵌入式文档是一种将相关数据存储在同一文档中的方法，这种方式在查询时不需要进行联表操作，因为所有数据都在一个文档中，如果我们有一个订单集合和一个用户集合，可以将用户信息嵌入到订单文档中。

优点：查询速度快，不需要进行联表操作。

缺点：数据冗余，不易维护。

2、引用式文档（Referencing）

引用式文档通过在文档中存储关联文档的 ID，来实现文档之间的关联，这种方式在查询时需要先查询主文档，然后根据关联 ID 查询关联文档。

优点：数据结构清晰，易于维护。

缺点：查询时需要进行多次查询，性能相对较差。

示例：

// 订单集合
{
  "_id": ObjectId("5f1e5c3a8f3e3e8e8c3a3a3a3"),
  "userId": ObjectId("5f1e5c3a8f3e3e8e8c3a3a3a4"),
  "orderItems": [
    {
      "productId": ObjectId("5f1e5c3a8f3e3e8e8c3a3a3a5"),
      "quantity": 2
    }
  ]
}
// 用户集合
{
  "_id": ObjectId("5f1e5c3a8f3e3e8e8c3a3a3a4"),
  "username": "张三",
  "email": "zhangsan@example.com"
}
// 商品集合
{
  "_id": ObjectId("5f1e5c3a8f3e3e8e8c3a3a3a5"),
  "name": "苹果",
  "price": 5.0
}

3、聚合查询（Aggregation）

MongoDB 的聚合查询功能非常强大，可以通过多个阶段的聚合操作实现联表查询，聚合查询通常使用 $lookup 阶段来实现关联查询。

优点：查询效率较高，可以处理复杂的查询逻辑。

缺点：聚合查询语法相对复杂，学习成本较高。

示例解析

下面以一个简单的示例来说明 MongoDB 同库联表查询的方法。

需求：查询订单及其对应的用户和订单详情。

1、使用嵌入式文档实现：

// 查询订单集合，同时包含用户信息和订单详情
db.orders.aggregate([
  {
    $lookup: {
      from: "users",
      localField: "userId",
      foreignField: "_id",
      as: "user"
    }
  },
  {
    $lookup: {
      from: "products",
      localField: "orderItems.productId",
      foreignField: "_id",
      as: "orderItems.product"
    }
  },
  {
    $unwind: "$orderItems"
  },
  {
    $unwind: "$orderItems.product"
  },
  {
    $project: {
      _id: 0,
      orderNumber: 1,
      user: {
        _id: 0,
        username: 1,
        email: 1
      },
      orderItems: {
        _id: 0,
        productId: 1,
        quantity: 1,
        product: {
          _id: 0,
          name: 1,
          price: 1
        }
      }
    }
  }
]);

2、使用引用式文档实现：

// 查询订单集合，仅包含订单基本信息和用户 ID
const orders = db.orders.find().toArray();
// 遍历订单，查询用户信息和订单详情
const result = orders.map(order => {
  const user = db.users.findOne({ _id: order.userId });
  const orderItems = order.orderItems.map(item => {
    const product = db.products.findOne({ _id: item.productId });
    return {
      ...item,
      product: {
        _id: product._id,
        name: product.name,
        price: product.price
      }
    };
  });
  return {
    ...order,
    user: {
      _id: user._id,
      username: user.username,
      email: user.email
    },
    orderItems
  };
});
console.log(result);

3、使用聚合查询实现：

db.orders.aggregate([
  {
    $lookup: {
      from: "users",
      localField: "userId",
      foreignField: "_id",
      as: "user"
    }
  },
  {
    $unwind: "$user"
  },
  {
    $lookup: {
      from: "products",
      localField: "orderItems.productId",
      foreignField: "_id",
      as: "orderItems.product"
    }
  },
  {
    $unwind: "$orderItems"
  },
  {
    $unwind: "$orderItems.product"
  },
  {
    $project: {
      _id: 0,
      orderNumber: 1,
      user: {
        _id: 0,
        username: 1,
        email: 1
      },
      orderItems: {
        _id: 0,
        productId: 1,
        quantity: 1,
        product: {
          _id: 0,
          name: 1,
          price: 1
        }
      }
    }
  },
  {
    $group: {
      _id: "$orderNumber",
      user: { $first: "$user" },
      orderItems: { $push: "$orderItems" }
    }
  }
]);

以上示例分别使用了嵌入式文档、引用式文档和聚合查询实现了同库联表查询，在实际应用中，可以根据业务需求和数据结构选择合适的方法。