Docs 菜单
Docs 主页
/
语言
/
C++
/
C++ 驱动程序

通过聚合转换数据

在此页面上

  • Overview
  • 聚合与查找操作
  • 限制
  • 聚合示例
  • 解释聚合
  • 更多信息
  • MongoDB Server 手册
  • API 文档

Overview

在本指南中，您可以学习；了解如何使用C++驾驶员执行聚合操作。

聚合操作处理 MongoDB 集合中的数据并返回计算结果。 MongoDB 聚合框架是 Query API 的一部分，以数据处理管道的概念为模型。 文档进入包含一个或多个阶段的管道，该管道将文档转换为聚合结果。

聚合操作类似于汽车工厂。汽车工厂有一条装配线，其中包含配备专用工具的装配站，用于完成特定的工作，例如钻机和焊机。毛坯零件会进入工厂，然后装配线将其转换并组装为成品。

聚合管道是装配线，聚合阶段是装配站，操作符表达式则是专用工具。

聚合与查找操作

您可以使用查找操作执行以下动作：

  • 选择要返回的文档

  • 选择要返回的字段

  • 对结果进行排序

您可以使用聚合操作执行以下动作：

  • 运行查找操作

  • 重命名字段

  • 计算字段

  • 汇总数据

  • 对值进行分组

限制

使用聚合操作时，请记住以下限制：

  • 返回的文档不能违反16 MB 的 BSON文档大小限制。

  • 默认，管道阶段的内存限制为100 MB。 您可以通过将 实例的allow_disk_use 字段设置为 来超过此限制。mongocxx::options::aggregatetrue

重要

$graphLookup 异常

$graphLookup阶段有100 MB 的严格内存限制，并忽略allow_disk_use字段。

聚合示例

注意

本指南中的示例使用Atlas示例数据集的sample_restaurants数据库中的restaurants集合。 要学习；了解如何创建免费的MongoDB Atlas 群集并加载示例数据集，请参阅Atlas入门指南。

要执行聚合，请将包含聚合阶段的mongocxx::pipeline实例传递给collection.aggregate()方法。

以下代码示例计算纽约每个区的面包店数量。 为此，它使用包含以下阶段的聚合管道：

  • $match阶段，用于过滤cuisine字段包含值"Bakery"的文档

  • $ 群组阶段按borough字段对匹配文档进行群组，并累积每个不同值的文档计数

mongocxx::pipeline stages;
stages.match(make_document(kvp("cuisine", "Bakery")))
      .group(make_document(kvp("_id", "$borough"), kvp("count", make_document(kvp("$sum", 1)))));
auto cursor = collection.aggregate(stages);
for (auto&& doc : cursor) {
    std::cout << bsoncxx::to_json(doc) << std::endl;
}
{ "_id" : "Brooklyn", "count" : 173 }
{ "_id" : "Queens", "count" : 204 }
{ "_id" : "Bronx", "count" : 71 }
{ "_id" : "Staten Island", "count" : 20 }
{ "_id" : "Missing", "count" : 2 }
{ "_id" : "Manhattan", "count" : 221 }

解释聚合

要查看有关MongoDB如何执行您的操作的信息，您可以指示MongoDB查询规划器对其进行解释。 MongoDB解释操作时，会返回执行计划和性能统计信息。 执行计划是MongoDB完成操作的一种潜在方式。 当您指示MongoDB解释一个操作时，它会返回MongoDB执行的计划和任何被拒绝的执行计划。

要解释聚合操作，请运行explain数据库命令，具体方法是在BSON文档中指定该命令并将其作为参数传递给run_command()方法。

以下示例指示MongoDB解释前面聚合示例中的聚合操作：

mongocxx::pipeline stages;
stages.match(make_document(kvp("cuisine", "Bakery")))
      .group(make_document(kvp("_id", "$borough"), kvp("count", make_document(kvp("$sum", 1)))));
auto command = make_document(
    kvp("explain", make_document(
                        kvp("aggregate", "restaurants"),
                        kvp("pipeline", stages.view_array()),
                        kvp("cursor", make_document()))));
auto result = db.run_command(command.view());
std::cout << bsoncxx::to_json(result) << std::endl;
{ "explainVersion" : "2", "queryPlanner" : { "namespace" : "sample_restaurants.restaurants",
"indexFilterSet" : false, "parsedQuery" : { "cuisine" : { "$eq" : "Bakery" } }, "queryHash":
"...", "planCacheKey" : "...", "optimizedPipeline" : true, "maxIndexedOrSolutionsReached":
false, "maxIndexedAndSolutionsReached" : false, "maxScansToExplodeReached" : false,
"winningPlan" : { ... }
... }

更多信息

MongoDB Server 手册

要查看表达式操作符的完整列表，请参阅聚合操作符。

要了解如何组装聚合管道并查看示例，请参阅聚合管道。

要了解有关创建管道阶段的更多信息，请参阅聚合阶段。

要了解有关解释 MongoDB 操作的更多信息，请参阅解释输出和查询计划。

API 文档

有关使用C++驾驶员执行聚合操作的更多信息，请参阅以下API文档：

后退

使用索引