28

假设我有一个名为“posts”的集合（实际上它是一个更复杂的集合，posts 太简单了），其结构如下：

> db.posts.find()

{ "_id" : ObjectId("50ad8d451d41c8fc58000003"), "title" : "Lorem ipsum", "author" : 
"John Doe", "content" : "This is the content", "tags" : [ "SOME", "RANDOM", "TAGS" ] }

我希望这个集合跨越数十万甚至数百万，我需要按标签查询帖子并按标签对结果进行分组并显示分页的结果。这就是聚合框架的用武之地。我打算使用 aggregate() 方法来查询集合：

db.posts.aggregate([
  { "$unwind" : "$tags" },
  { "$group" : {
      _id: { tag: "$tags" },
      count: { $sum: 1 }
  } }
]);

关键是要创建分页器，我需要知道输出数组的长度。我知道要做到这一点，你可以这样做：

db.posts.aggregate([
  { "$unwind" : "$tags" },
  { "$group" : {
      _id: { tag: "$tags" },
      count: { $sum: 1 }
  } }
  { "$group" : {
      _id: null,
      total: { $sum: 1 }
  } }
]);

但这会丢弃前一个管道（第一组）的输出。有没有办法在保留每个管道的输出的同时组合这两个操作？我知道整个聚合操作的输出可以转换为某种语言的数组并计算内容，但管道输出可能超过 16Mb 限制。此外，执行相同的查询只是为了获得计数似乎是一种浪费。

那么是否可以同时获取文档结果和计数呢？任何帮助表示赞赏。

4

2 回答 2

34
  1. 用于$project保存tag和count进入tmp
  2. 使用$push或addToSet存储tmp到您的data列表中。

代码：

db.test.aggregate(
    {$unwind: '$tags'}, 
    {$group:{_id: '$tags', count:{$sum:1}}},
    {$project:{tmp:{tag:'$_id', count:'$count'}}}, 
    {$group:{_id:null, total:{$sum:1}, data:{$addToSet:'$tmp'}}}
)

输出：

{
    "result" : [
            {
                    "_id" : null,
                    "total" : 5,
                    "data" : [
                            {
                                    "tag" : "SOME",
                                    "count" : 1
                            },
                            {
                                    "tag" : "RANDOM",
                                    "count" : 2
                            },
                            {
                                    "tag" : "TAGS1",
                                    "count" : 1
                            },
                            {
                                    "tag" : "TAGS",
                                    "count" : 1
                            },
                            {
                                    "tag" : "SOME1",
                                    "count" : 1
                            }
                      ]
              }
      ],
      "ok" : 1
}
于 2012-11-24T02:55:20.640 回答
3

除了计算所有标签之外，我不确定您是否需要聚合框架，例如：

db.posts.aggregate(
  { "unwind" : "$tags" },
  { "group" : {
      _id: { tag: "$tags" },
      count: { $sum: 1 }
  } }
);

对于每个标签的分页，您可以使用普通的查询语法 - 如下所示：

db.posts.find({tags: "RANDOM"}).skip(10).limit(10)
于 2012-11-23T13:59:49.160 回答