$first(聚合)
定义
已更改在版本5.0.
返回一个表达式的结果,该表达式用于文档组中的第一个文档。只有当文档按定义的顺序排列时才有意义。
$first
在以下阶段可用
$setWindowFields
(从 MongoDB 5.0 开始可用)
语法
$first
语法
{ $first: <expression> }
行为
定义文档顺序
要在
$first
的$setWindowFields
中定义文档顺序,设置sortBy
字段。要在其他管道阶段中为
$first
定义文档顺序,添加一个先前的
阶段。$sort
数组运算符
如果表达式解析为数组
对于一组文档,
$first
返回第一个文档中的整个数组。它不会遍历数组元素。这种情况适用于类似于
和$group
的阶段。$setWindowFields
对于单个文档,
$first
返回数组的第一个元素。这种情况适用于类似于
的阶段。$addFields
缺失值
组中的文档可能缺少字段,或者字段值可能缺失。
如果上一个流水线阶段没有文档,则
$group
阶段返回空。如果
$first
累加器处理的字段缺失,则$first
返回null
。当与
$setWindowFields
一起使用时,如果窗口为空,则$first
返回null
。例如,当您在分区的第一个文档上有一个{ documents:[ -1, -1] }
的documents
窗口时。
有关更多信息,请参阅本主题后面关于缺失数据
的示例。
示例
在 $group
阶段使用
创建 sales
集合
db.sales.insertMany( [ { "_id" : 1, "item" : "abc", "price" : 10, "quantity" : 2, "date" : ISODate("2014-01-01T08:00:00Z") }, { "_id" : 2, "item" : "jkl", "price" : 20, "quantity" : 1, "date" : ISODate("2014-02-03T09:00:00Z") }, { "_id" : 3, "item" : "xyz", "price" : 5, "quantity" : 5, "date" : ISODate("2014-02-03T09:05:00Z") }, { "_id" : 4, "item" : "abc", "price" : 10, "quantity" : 10, "date" : ISODate("2014-02-15T08:00:00Z") }, { "_id" : 5, "item" : "xyz", "price" : 5, "quantity" : 10, "date" : ISODate("2014-02-15T09:05:00Z") }, { "_id" : 6, "item" : "xyz", "price" : 5, "quantity" : 5, "date" : ISODate("2014-02-15T12:05:10Z") }, { "_id" : 7, "item" : "xyz", "price" : 5, "quantity" : 10, "date" : ISODate("2014-02-15T14:12:12Z") } ] )
按照 item
字段对文档进行分组,以下操作使用 $first
累加器返回每个项目的第一个销售日期
db.sales.aggregate( [ { $sort: { item: 1, date: 1 } }, { $group: { _id: "$item", firstSale: { $first: "$date" } } } ] )
操作返回以下结果
[ { _id: 'jkl', firstSale: ISODate("2014-02-03T09:00:00.000Z") }, { _id: 'xyz', firstSale: ISODate("2014-02-03T09:05:00.000Z") }, { _id: 'abc', firstSale: ISODate("2014-01-01T08:00:00.000Z") } ]
缺失数据
在 badData
集合中,一些文档缺少字段,其他文档缺少值。
创建 badData
集合
db.badData.insertMany( [ { "_id": 1, "price": 6, "quantity": 6 }, { "_id": 2, "item": "album", "price": 5 , "quantity": 5 }, { "_id": 7, "item": "tape", "price": 6, "quantity": 6 }, { "_id": 8, "price": 5, "quantity": 5 }, { "_id": 9, "item": "album", "price": 3, "quantity": '' }, { "_id": 10, "item": "tape", "price": 3, "quantity": 4 }, { "_id": 12, "item": "cd", "price": 7 } ] )
查询 badData
集合,按 item
字段进行分组
db.badData.aggregate( [ { $sort: { item: 1, price: 1 } }, { $group: { _id: "$item", inStock: { $first: "$quantity" } } } ] )
$sort
阶段对文档进行排序并将它们传递到 $group
阶段。
[ { _id: null, inStock: 5 }, { _id: 'album', inStock: '' }, { _id: 'cd', inStock: null }, { _id: 'tape', inStock: 4 } ]
$first
从每个输出组中选择第一个文档
包含
_id: null
组。当累加器字段(例如本例中的
$quantity
)缺失时,$first
返回null
。
在 $setWindowFields
阶段中使用
新增在版本5.0.
创建一个包含加利福尼亚州(CA
)和华盛顿州(WA
)的糕点销售的cakeSales
集合
db.cakeSales.insertMany( [ { _id: 0, type: "chocolate", orderDate: new Date("2020-05-18T14:10:30Z"), state: "CA", price: 13, quantity: 120 }, { _id: 1, type: "chocolate", orderDate: new Date("2021-03-20T11:30:05Z"), state: "WA", price: 14, quantity: 140 }, { _id: 2, type: "vanilla", orderDate: new Date("2021-01-11T06:31:15Z"), state: "CA", price: 12, quantity: 145 }, { _id: 3, type: "vanilla", orderDate: new Date("2020-02-08T13:13:23Z"), state: "WA", price: 13, quantity: 104 }, { _id: 4, type: "strawberry", orderDate: new Date("2019-05-18T16:09:01Z"), state: "CA", price: 41, quantity: 162 }, { _id: 5, type: "strawberry", orderDate: new Date("2019-01-08T06:12:03Z"), state: "WA", price: 43, quantity: 134 } ] )
此示例在$setWindowFields
阶段中使用$first
以输出每个state
的第一个糕点销售订单type
db.cakeSales.aggregate( [ { $setWindowFields: { partitionBy: "$state", sortBy: { orderDate: 1 }, output: { firstOrderTypeForState: { $first: "$type", window: { documents: [ "unbounded", "current" ] } } } } } ] )
在示例中
partitionBy: "$state"
$setWindowFields
按state
对集合中的文档进行分区。有CA
和WA
的分区。sortBy: { orderDate: 1 }
按升序(1
)对每个分区中的文档进行排序,以便最早的orderDate
排在首位。
output
将firstOrderTypeForState
字段设置为documents
窗口中的第一个订单type
该
window
包含从无界下限到输出中当前文档之间的文档。这意味着$first
返回从分区开始到当前文档之间的第一个订单type
在此输出中,CA
和WA
的第一个订单type
值显示在firstOrderTypeForState
字段中
{ "_id" : 4, "type" : "strawberry", "orderDate" : ISODate("2019-05-18T16:09:01Z"), "state" : "CA", "price" : 41, "quantity" : 162, "firstOrderTypeForState" : "strawberry" } { "_id" : 0, "type" : "chocolate", "orderDate" : ISODate("2020-05-18T14:10:30Z"), "state" : "CA", "price" : 13, "quantity" : 120, "firstOrderTypeForState" : "strawberry" } { "_id" : 2, "type" : "vanilla", "orderDate" : ISODate("2021-01-11T06:31:15Z"), "state" : "CA", "price" : 12, "quantity" : 145, "firstOrderTypeForState" : "strawberry" } { "_id" : 5, "type" : "strawberry", "orderDate" : ISODate("2019-01-08T06:12:03Z"), "state" : "WA", "price" : 43, "quantity" : 134, "firstOrderTypeForState" : "strawberry" } { "_id" : 3, "type" : "vanilla", "orderDate" : ISODate("2020-02-08T13:13:23Z"), "state" : "WA", "price" : 13, "quantity" : 104, "firstOrderTypeForState" : "strawberry" } { "_id" : 1, "type" : "chocolate", "orderDate" : ISODate("2021-03-20T11:30:05Z"), "state" : "WA", "price" : 14, "quantity" : 140, "firstOrderTypeForState" : "strawberry" }