MongoDB:将来自多个集合的数据合并为一个..how？

Question

MongoDB:将来自多个集合的数据合并为一个..how？

use*_*697 214 mongodb mongodb-query aggregation-framework

我如何(在MongoDB中)将来自多个集合的数据合并到一个集合中？

我可以使用map-reduce吗？如果是,那么如何？

我非常感谢一些例子,因为我是新手.

Answer 1

虽然您无法实时执行此操作,但您可以使用MongoDB 1.8+ map/reduce中的"reduce"输出选项多次运行map-reduce以将数据合并在一起(请参阅http://www.mongodb.org/ display/DOCS/MapReduce#MapReduce-Outputoptions).您需要在两个集合中都有一些密钥才能用作_id.

例如,假设您有一个users集合和一个comments集合,并且您希望拥有一个新集合,其中包含每个评论的一些用户人口统计信息.

假设该users集合包含以下字段:

_ID
名字
姓
国家
性别
年龄

然后该comments集合包含以下字段:

_ID
用户身份
评论
创建

你会做这个map/reduce:

var mapUsers, mapComments, reduce;
db.users_comments.remove();

// setup sample data - wouldn't actually use this in production
db.users.remove();
db.comments.remove();
db.users.save({firstName:"Rich",lastName:"S",gender:"M",country:"CA",age:"18"});
db.users.save({firstName:"Rob",lastName:"M",gender:"M",country:"US",age:"25"});
db.users.save({firstName:"Sarah",lastName:"T",gender:"F",country:"US",age:"13"});
var users = db.users.find();
db.comments.save({userId: users[0]._id, "comment": "Hey, what's up?", created: new ISODate()});
db.comments.save({userId: users[1]._id, "comment": "Not much", created: new ISODate()});
db.comments.save({userId: users[0]._id, "comment": "Cool", created: new ISODate()});
// end sample data setup

mapUsers = function() {
    var values = {
        country: this.country,
        gender: this.gender,
        age: this.age
    };
    emit(this._id, values);
};
mapComments = function() {
    var values = {
        commentId: this._id,
        comment: this.comment,
        created: this.created
    };
    emit(this.userId, values);
};
reduce = function(k, values) {
    var result = {}, commentFields = {
        "commentId": '', 
        "comment": '',
        "created": ''
    };
    values.forEach(function(value) {
        var field;
        if ("comment" in value) {
            if (!("comments" in result)) {
                result.comments = [];
            }
            result.comments.push(value);
        } else if ("comments" in value) {
            if (!("comments" in result)) {
                result.comments = [];
            }
            result.comments.push.apply(result.comments, value.comments);
        }
        for (field in value) {
            if (value.hasOwnProperty(field) && !(field in commentFields)) {
                result[field] = value[field];
            }
        }
    });
    return result;
};
db.users.mapReduce(mapUsers, reduce, {"out": {"reduce": "users_comments"}});
db.comments.mapReduce(mapComments, reduce, {"out": {"reduce": "users_comments"}});
db.users_comments.find().pretty(); // see the resulting collection

归档时间：	14 年，6 月前
查看次数：	255588 次
最近记录：	6 年，5 月前