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); }); });