这是一个关于在数组中添加一系列数据的最佳方法的问题,在该数组中,我必须匹配另一个元素。我正在尝试使用2.2聚合框架,我可以用一个简单的组来做到这一点。
因此,对于给定的一组文档,我尝试得到如下输出;
{
"result" : [
{
"_id" : null,
"numberOf": 2,
"Sales" : 468000,
"profit" : 246246,
}
],
"ok" : 1
}
现在,我最初有一个文档列表,其中包含分配给命名属性的值,例如;
[
{
_id : 1,
finance: {
sales: 234000,
profit: 123123,
}
}
,
{
_id : 2,
finance: {
sales: 234000,
profit: 123123,
}
}
]
这很容易加起来,但是由于其他原因,这个结构不能工作。例如,可能还有像"finance“这样的其他列,我希望能够在不创建数千个索引的情况下对它们进行索引,因此我需要转换为这样的结构;
[
{
_id : 1,
finance: [
{
"k": "sales",
"v": {
"description":"sales over the year",
v: 234000,
}
},
{
"k": "profit",
"v": {
"description":"money made from sales",
v: 123123,
}
}
]
}
,
{
_id : 2,
finance: [
{
"k": "sales",
"v": {
"description":"sales over the year",
v: 234000,
}
},
{
"k": "profit",
"v": {
"description": "money made from sales",
v: 123123,
}
}
]
}
]
如果需要,我可以对finance.k进行索引,但是我很难构建一个聚合查询来将匹配特定键的所有数字相加。这就是我最初选择命名属性的原因,但这确实需要在有数千个"k“标签的情况下工作。
有人知道如何使用新框架为此构建聚合查询吗?我已经试过了;
db.projects.aggregate([
{
$match: {
// QUERY
$and: [
// main query
{},
]
}
},
{
$group: {
_id: null,
"numberOf": { $sum: 1 },
"sales": { $sum: "$finance.v.v" },
"profit": { $sum: "$finance.v.v" },
}
},
])
但是我得到了;
{
"errmsg" : "exception: can't convert from BSON type Array to double",
"code" : 16005,
"ok" : 0
}
**为了获得额外的荣誉,我还需要能够在MapReduce查询中做到这一点。
发布于 2012-08-29 01:12:58
您必须使用‘$unwind’来分解数组中的值,这意味着您不能在单个聚合命令中获得销售额和利润的总和。
var pipeline = [
{"$unwind": "$finance" } ,
{"$match": {"finance.k": "sales"} },
{ $group:
{ _id: null,
numberOf: { "$sum": 1 },
sales: {"$sum": "$finance.v.v" }
}
}
];
R = db.tb.aggregate( pipeline );
printjson(R);
{
"result" : [
{
"_id" : null,
"numberOf" : 2,
"sales" : 236340
}
],
"ok" : 1
}
您可以对利润运行类似的查询,只需在"$match“运算符中用”利润“替换”销售“即可。
哦,下面是map/reduce示例:
map = function() {
var ret = { sales: 0.0 , profit: 0.0, count: 1 };
// iterate over 'finance[]' array
this.finance.forEach( function (i) {
if ( i.k == "sales" ) ret.sales = i.v.v ;
if ( i.k == "profit" ) ret.profit = i.v.v ;
} );
emit( 1, ret );
}
reduce = function(key, values) {
var ret = { sales: 0.0 , profit: 0.0, count: 0 };
values.forEach(function(v) {
ret.sales += v.sales;
ret.profit += v.profit;
ret.count += v.count;
});
return ret;
};
//
// run map/reduce
//
res = SOURCE.mapReduce( map, reduce );
https://stackoverflow.com/questions/12162681
复制相似问题