修改猫鼬响应数据答案

【问题标题】：Modify mongoose response data修改猫鼬响应数据
【发布时间】：2016-05-05 12:38:25
【问题描述】：

我有一个 API 调用，它以 JSON 形式返回用户收到的所有消息。

模型数据如下所示：

{
    sender: ObjectId,
    reciever: ObjectId,
    message: String
}

修改 API 响应的 JSON 的正确方法是什么？

我想最终得到这样分组的数据：

{
    <senderid>:[ all of the messages from this sender],
    <other_sender>:[ all of the messages from this sender]
}

我是否必须在 javascript 中手动执行此操作，或者是否有更快的方法可以利用 mongoose 来执行此操作？

【问题讨论】：

你应该使用 mongodb 聚合
我已经研究过聚合，但我似乎无法弄清楚如何在保持原始字段不变的同时聚合数据。
如果可以，您应该添加您的 API 代码，在 API 级别您可以进行更改并按照您想要的方式调整返回的数据。

标签： node.js mongodb mongoose

【解决方案1】：

使用聚合框架将是此任务的理想选择。您可以运行以下聚合管道，该管道利用 $group 运算符步骤对数据进行分组以处理它们。组管道运算符类似于 SQL 的 GROUP BY 子句。在 SQL 中，除非您使用任何聚合函数，否则您不能使用 GROUP BY。同样，您也必须在 MongoDB 中使用聚合函数。在这种情况下，使用 $push 累加器运算符来创建消息数组。

由于 Model.aggregate() 返回普通对象，因此您可以使用 lodash 库的 _.indexBy() 方法将结果数组转换为所需的哈希键：

var pipeline = [
    {
        "$group": {
            "_id": "$sender",
            "messages": { "$push": "$message" }
        }
    }
];

Model.aggregate(pipeline,
    function(err, res) {
        if (err) return handleError(err);
        var hashmap = _.chain(res)
               .indexBy('_id')                 
               .mapValues('messages')                  
               .value();
        console.log(JSON.stringify(hashmap, undefined, 4));
    }
);

// Or use the aggregation pipeline builder.
Model.aggregate()
     .group({ "_id": "$sender", "messages": { "$push": "$message" } })
     .exec(function (err, res) {
        if (err) return handleError(err);
        var hashmap = _.chain(res)
               .indexBy('_id')                 
               .mapValues('messages')                  
               .value();
        console.log(JSON.stringify(hashmap, undefined, 4));
});

查看下面的演示。

var data = [
	{ _id: 'user1', messages: ['msg1', 'msg2'] }, 
	{ _id: 'user2', messages: ['msg3', 'msg1'] }, 
	{ _id: 'user3', messages: ['msg6', 'msg3'] },
	{ _id: 'user4', messages: ['msg4', 'msg8'] }
];

var hashmap = _.chain(data)
			   .indexBy('_id')				   
			   .mapValues('messages')
			   .tap(log)
			   .value();

function log(value) {
	pre.innerHTML += JSON.stringify(value, null, 4) + "\n"
}

<script src="//cdnjs.cloudflare.com/ajax/libs/lodash.js/3.10.1/lodash.min.js"></script>
<pre id="pre"></pre>

【讨论】：