按值和条件分组

Question

刚接触mongo，对这个问题有点困惑。我有这样的集合

{ "_id" : "PN89dNYYkBBmab3uH", "card_id" : 1, "vote" : 1, "time" : 1437700845154 }
{ "_id" : "Ldz7N5syeW2SXtQzP", "card_id" : 1, "vote" : 1, "time" : 1437700846035 }
{ "_id" : "v3XWHHvFSHwYxxk6H", "card_id" : 1, "vote" : 2, "time" : 1437700849817 }
{ "_id" : "eehcDaCyTdz6Yd2a9", "card_id" : 2, "vote" : 1, "time" : 1437700850666 }
{ "_id" : "efhcDaCyTdz6Yd2b9", "card_id" : 2, "vote" : 1, "time" : 1437700850666 }
{ "_id" : "efhcDaCyTdz7Yd2b9", "card_id" : 3, "vote" : 1, "time" : 1437700850666 }
{ "_id" : "w3XWgHvFSHwYxxk6H", "card_id" : 1, "vote" : 1, "time" : 1437700849817 }

我需要写一个查询，将分组卡基本上通过投票(1是喜欢;2是不喜欢)。所以我需要得到每张卡的喜欢减去不喜欢的总数，并能够对它们进行排名。

结果就像:

card_id 1: 3个喜欢- 1个不喜欢= 2

card_id 3: 1 like - 0 dislike = 1

card_id 2: 2个喜欢- 0个不喜欢= 0

知道如何得到所有卡的1票减去2票的计数，然后排序结果吗?

Answer 1

要用MongoDB查询做任何类型的"分组"，那么您希望能够使用聚合框架或mapReduce。聚合框架通常是首选，因为它使用本地编码的操作符而不是JavaScript翻译，因此通常更快。

聚合语句只能在服务器API端运行，这是有意义的，因为您不希望在客户端执行此操作。但它可以在那里完成，并将结果提供给客户端。

对于提供发布结果的方法的答案:

Meteor.publish("cardLikesDislikes", function(args) {
    var sub = this;
    var db = MongoInternals.defaultRemoteCollectionDriver().mongo.db;
    var pipeline = [
        { "$group": {
            "_id": "$card_id",
            "likes": {
                "$sum": {
                    "$cond": [
                        { "$eq": [ "$vote", 1 ] },
                        1,
                        0
                    ]
                }
            },
            "dislikes": {
                "$sum": {
                    "$cond": [
                        { "$eq": [ "$vote", 2 ] },
                        1,
                        0
                    ]
                }
            },
            "total": {
                "$sum": {
                    "$cond": [
                        { "$eq": [ "$vote", 1 ] },
                        1,
                        -1
                    ]
                }
            }
        }},
        { "$sort": { "total": -1 } }
    ];
    db.collection("server_collection_name").aggregate(        
        pipeline,
        // Need to wrap the callback so it gets called in a Fiber.
        Meteor.bindEnvironment(
            function(err, result) {
                // Add each of the results to the subscription.
                _.each(result, function(e) {
                    // Generate a random disposable id for aggregated documents
                    sub.added("client_collection_name", Random.id(), {
                        card: e._id,                        
                        likes: e.likes,
                        dislikes: e.dislikes,
                        total: e.total
                    });
                });
                sub.ready();
            },
            function(error) {
                Meteor._debug( "Error doing aggregation: " + error);
            }
        )
    );
});

一般聚合语句只有一个 $group 对"card_id"的单键操作。为了得到"喜欢"one_answers"不喜欢"，你使用一个"条件表达式"，它是 $cond 。

这是一个"三元"运算符，它考虑对"vote"的值进行逻辑测试，如果它与期望类型匹配，则返回正1，否则返回0。

这些值然后被发送到累加器 $sum 将它们加在一起，并通过"喜欢"或"不喜欢"产生每个"card_id"的总数。

对于"total"，最有效的方法是在进行分组的同时为"like"赋予一个"正"值，为"dislike"赋予一个负值。有一个 $add 操作符，但在这种情况下，它的使用将需要另一个管道阶段。所以我们就在一个舞台上做。

在这个结尾有一个 $sort 按"降序"排列，所以最大的积极投票计数在顶部。这是可选的，您可能只想在客户端使用动态排序。但是对于默认值来说，这是一个很好的开始，它消除了必须这样做的开销。

这是在做条件聚合并处理结果。

---

测试清单

这是我用一个新创建的流星项目测试的，没有添加，只有一个模板和javascript文件

控制台命令

meteor create cardtest
cd cardtest
meteor remove autopublish

在数据库中创建"cards"集合，其中包含问题中发布的文档。然后编辑默认文件，内容如下:

cardtest.js

Cards = new Meteor.Collection("cardStore");
if (Meteor.isClient) {
  Meteor.subscribe("cards");
  Template.body.helpers({
    cards: function() {
      return Cards.find({});
    }
  });
}
if (Meteor.isServer) {
  Meteor.publish("cards",function(args) {
    var sub = this;
    var db = MongoInternals.defaultRemoteCollectionDriver().mongo.db;
    var pipeline = [
      { "$group": {
        "_id": "$card_id",
        "likes": { "$sum": { "$cond": [{ "$eq": [ "$vote", 1 ] },1,0] } },
        "dislikes": { "$sum": { "$cond": [{ "$eq": [ "$vote", 2 ] },1,0] } },
        "total": { "$sum": { "$cond": [{ "$eq": [ "$vote", 1 ] },1,-1] } }
      }},
      { "$sort": { "total": -1, "_id": 1 } }
    ];
    db.collection("cards").aggregate(
      pipeline,
      Meteor.bindEnvironment(
        function(err,result) {
          _.each(result,function(e) {
            e.card_id = e._id;
            delete e._id;
            sub.added("cardStore",Random.id(), e);
          });
          sub.ready();
        },
        function(error) {
          Meteor._debug( "error running: " + error);
        }
      )
    );
  });
}

cardtest.html

<head>
  <title>cardtest</title>
</head>
<body>
  <h1>Card aggregation</h1>
  <table border="1">
    <tr>
      <th>Card_id</th>
      <th>Likes</th>
      <th>Dislikes</th>
      <th>Total</th>
    </tr>
    {{#each cards}}
      {{> card }}
    {{/each}}
  </table>
</body>
<template name="card">
  <tr>
    <td>{{card_id}}</td>
    <td>{{likes}}</td>
    <td>{{dislikes}}</td>
    <td>{{total}}</td>
  </tr>
</template>

最终聚合集合内容:

[
   {
     "_id":"Z9cg2p2vQExmCRLoM",
     "likes":3,
     "dislikes":1,
     "total":2,
     "card_id":1
   },
   {
     "_id":"KQWCS8pHHYEbiwzBA",
      "likes":2,
      "dislikes":0,
      "total":2,
      "card_id":2
   },
   {
      "_id":"KbGnfh3Lqcmjow3WN",
      "likes":1,
      "dislikes":0,
      "total":1,
      "card_id":3
   }
]

Answer 2

use meteorhacks:aggregate package.

Cards = new Mongo.Collection('cards');
var groupedCards = Cards.aggregate({ $group: { _id: { card_id: '$card_id' }}});
groupedCards.forEach(function(card) {
  console.log(card);
});

{ "_id" : "v3XWHHvFSHwYxxk6H", "card_id" : 1, "vote" : 2, "time" : 1437700849817 }
{ "_id" : "eehcDaCyTdz6Yd2a9", "card_id" : 2, "vote" : 1, "time" : 1437700850666 }
{ "_id" : "efhcDaCyTdz7Yd2b9", "card_id" : 3, "vote" : 1, "time" : 1437700850666 }