SQL到聚合的映射图_MonogDB 中文网

MongoDB 中文手册

在本页面

例子

该聚合管道允许的MongoDB提供原生的聚集功能，对应于许多常见的数据在SQL聚合操作。

下表概述了常见的SQL聚合术语，函数和概念以及相应的MongoDB 聚合运算符：

SQL术语，函数和概念	MongoDB聚合运算符
哪里	`$match`
通过...分组	`$group`
拥有	`$match`
选择	`$project`
订购	`$sort`
限制	`$limit`
和（）	`$sum`
计数（）	`$sum` `$sortByCount`
加入	`$lookup`
选择进入NEW_TABLE	`$out`
合并到表中	`$merge` （从MongoDB 4.2开始可用）

有关所有聚合管道和表达式运算符的列表，请参见《聚合管道快速参考》。

也可以看看

SQL到MongoDB的映射图

例子¶

下表提供了SQL聚合语句和相应的MongoDB语句的快速参考。表格中的示例假定以下条件：

SQL示例假设有两个表，orders并 order_lineitem通过order_lineitem.order_id和orders.id列进行连接。

MongoDB示例假定一个集合orders包含以下原型的文档：

复制

{
  cust_id: "abc123",
  ord_date: ISODate("2012-11-02T17:04:11.102Z"),
  status: 'A',
  price: 50,
  items: [ { sku: "xxx", qty: 25, price: 1 },
           { sku: "yyy", qty: 25, price: 1 } ]
}

SQL范例	MongoDB示例	描述
SELECT COUNT(*) AS count FROM orders	db.orders.aggregate( [ { $group: { _id: null, count: { $sum: 1 } } } ] )	计算来自的所有记录 `orders`
SELECT SUM(price) AS total FROM orders	db.orders.aggregate( [ { $group: { _id: null, total: { $sum: "$price" } } } ] )	对`price`字段求和`orders`
SELECT cust_id, SUM(price) AS total FROM orders GROUP BY cust_id	db.orders.aggregate( [ { $group: { _id: "$cust_id", total: { $sum: "$price" } } } ] )	对于每个唯一性`cust_id`，对`price`字段求和。
SELECT cust_id, SUM(price) AS total FROM orders GROUP BY cust_id ORDER BY total	db.orders.aggregate( [ { $group: { _id: "$cust_id", total: { $sum: "$price" } } }, { $sort: { total: 1 } } ] )	对于每个唯一字段，`cust_id`对`price`字段求和，结果按和排序。
SELECT cust_id, ord_date, SUM(price) AS total FROM orders GROUP BY cust_id, ord_date	db.orders.aggregate( [ { $group: { _id: { cust_id: "$cust_id", ord_date: { $dateToString: { format: "%Y-%m-%d", date: "$ord_date" }} }, total: { $sum: "$price" } } } ] )	对于每一个独特的 `cust_id`，`ord_date`分组，总结了`price`场。排除日期的时间部分。
SELECT cust_id, count() FROM orders GROUP BY cust_id HAVING count() > 1	db.orders.aggregate( [ { $group: { _id: "$cust_id", count: { $sum: 1 } } }, { $match: { count: { $gt: 1 } } } ] )	对于`cust_id`具有多个记录的记录，返回`cust_id`和对应的记录计数。
SELECT cust_id, ord_date, SUM(price) AS total FROM orders GROUP BY cust_id, ord_date HAVING total > 250	db.orders.aggregate( [ { $group: { _id: { cust_id: "$cust_id", ord_date: { $dateToString: { format: "%Y-%m-%d", date: "$ord_date" }} }, total: { $sum: "$price" } } }, { $match: { total: { $gt: 250 } } } ] )	对于每个唯一的`cust_id`，`ord_date` 分组，求和`price`场和仅返回其中总和大于250不包括的日期的时间部分。
SELECT cust_id, SUM(price) as total FROM orders WHERE status = 'A' GROUP BY cust_id	db.orders.aggregate( [ { $match: { status: 'A' } }, { $group: { _id: "$cust_id", total: { $sum: "$price" } } } ] )	对于每个`cust_id` 具有状态的唯一性`A`，对`price`字段求和。
SELECT cust_id, SUM(price) as total FROM orders WHERE status = 'A' GROUP BY cust_id HAVING total > 250	db.orders.aggregate( [ { $match: { status: 'A' } }, { $group: { _id: "$cust_id", total: { $sum: "$price" } } }, { $match: { total: { $gt: 250 } } } ] )	对于每个`cust_id` 具有status的唯一性`A`，对`price`字段求和并仅在总和大于250时返回。
SELECT cust_id, SUM(li.qty) as qty FROM orders o, order_lineitem li WHERE li.order_id = o.id GROUP BY cust_id	db.orders.aggregate( [ { $unwind: "$items" }, { $group: { _id: "$cust_id", qty: { $sum: "$items.qty" } } } ] )	对于每个唯一性`cust_id`，求和`qty`与订单关联的相应订单项字段。
SELECT COUNT(*) FROM (SELECT cust_id, ord_date FROM orders GROUP BY cust_id, ord_date) as DerivedTable	db.orders.aggregate( [ { $group: { _id: { cust_id: "$cust_id", ord_date: { $dateToString: { format: "%Y-%m-%d", date: "$ord_date" }} } } }, { $group: { _id: null, count: { $sum: 1 } } } ] )	计数不同的数目 `cust_id`，`ord_date`分组。排除日期的时间部分。

也可以看看