要对 MongoDB 查询进行任何类型的“分组”,那么您希望能够使用 aggregation framework 或 mapReduce。聚合框架通常是首选,因为它使用本机编码运算符而不是 JavaScript 翻译,因此通常更快。
聚合语句只能在服务器 API 端运行,这很有意义,因为您不想在客户端执行此操作。但它可以在那里完成并将结果提供给客户。
感谢this answer 提供发布结果的方法:
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);
}
)
);
});
一般的聚合语句只是对“card_id”的单个键进行$group 操作。为了获得“喜欢”和“不喜欢”,您使用“条件表达式”,即$cond。
这是一个“三元”运算符,它考虑对“投票”的值进行逻辑测试,如果它与期望类型匹配,则返回正数 1,否则返回 0。
然后将这些值发送到累加器 $sum 以将它们加在一起,并通过“喜欢”或“不喜欢”产生每个“card_id”的总计数。
对于“总数”,最有效的方法是在分组的同时为“喜欢”赋予“正”值,为“不喜欢”赋予负值。有一个 $add 运算符,但在这种情况下,它的使用将需要另一个管道阶段。所以我们只是在一个阶段完成。
最后,$sort 按“降序”排列,因此最大的正票数排在首位。这是可选的,您可能只想使用动态排序客户端。但对于消除必须这样做的开销的默认设置来说,这是一个好的开始。
这就是进行条件聚合并处理结果。
测试清单
这是我用新创建的流星项目测试的,没有插件,只有一个模板和 javascript 文件
控制台命令
meteor create cardtest
cd cardtest
meteor remove autopublish
使用问题中发布的文档在数据库中创建了“卡片”集合。然后编辑默认文件,内容如下:
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
}
]