mongodb 实现join

浏览数：45 / 时间：2015年06月12日

mongodb提供ref和populate的方法，支持类似join的SQL操作。本文给出一个实际的例子：

1. 数据1：

var daob = new Schema({

    user: {
        type: String
    },
    title: {
        type: String
    },
    tag: [{
        type: String
    }],
    content: {
        type: String
    },
    count: {
        type: Number,
        ‘default‘:0
    }
});

2. 数据2：

var daoa = new Schema({

    name: {
        type: String
    },
    time: {
        type: Date
    },
    conments: [{
        type: mongoose.Schema.ObjectId, //这里保存daob的id，mongo中只能使用collection的_id
        ref: ‘daob‘
    }]
});

3. 插入操作：

var b = new daobmodel({
        user: ‘fredric‘,
        title: ‘title1‘,
        tag: [‘tag1‘, ‘tag2‘, ‘tag3‘],
        content: ‘nothing to say, just test‘,
    });

    b.save(function(err) {
        var a = new daoamodel({
            name: ‘sinny‘,
            time: new Date(),
            conments: [b._id]
        });

        a.save(function(err) {
            return callback(err);
        })
    });

4. 查找操作：

mongo不支持真正意义上的join操作，因此本例中的需求只能分拆成两步

//这里可以采用聚合来实现比较复杂的查询
    daobmodel.find({
        ‘tag‘: {
            $in: [‘tag1‘]
        }
    }, {
        _id: 1
    }, function(err, ids) {
        daoamodel.find({
            conments: {
                $in: ids
            }
        }).populate(‘conments‘).exec(function(err, docs) {
            return callback(err, docs);
        });
    });