Mongoose多表查询运用实例

在开发内容管理系统时，经常会用到多表关联查询场景，如文章分类、文章详情、文章作者三张表，UML图如下：

业务需求如下：查询文章信息，并显示文章的分类以及文章的作者信息。这样简单的一个需求在MySQL里要写一个很长的大SQL语句，但是在MongoDB里，凭借着Mongoose却可以轻松实现，实现步骤如下：

1. 定义文章分类的schema生成模型导出，文件名 aritcleCate.js

// 引入自定义的数据库连接文件
var mongoose = require('./db.js');

var ArticleCateSchema = new mongoose.Schema({
    title: {
        type: String,
        unique: true
    },
    descripton: String,
    addtime: {
        type: Date
    }
});
module.exports = mongoose.model('ArticleCate', ArticleCateSchema, 'articlecate');           

复制

2. 定义用户的schema生成模型导出，文件名 user.js

// 引入自定义的数据库连接文件
var mongoose = require('./db.js');

var UserSchema = new mongoose.Schema({
    username: {
        type: String,
        unique: true
    },
    password: String,
    name: String,
    age: Number,
    sex: String,
    tel: Number,
    status: {
        type: Number,
        default: 1
    }
});
module.exports = mongoose.model('User', UserSchema, 'user');           

复制

3. 定义文章的schema生成模型导出，文件名article.js

// 引入自定义的数据库连接文件
var mongoose = require('./db.js');

var ArticleSchema = new mongoose.Schema({
    title: {
        type: String,
        unique: true
    },
    // 分类 id
    cid: {
        type: Schema.Types.ObjectId
    },
    // 用户 id
    author_id: {
        type: Schema.Types.ObjectId
    },
    author_name: {
        type: String
    },
    descripton: String,
    content: String
});

module.exports = mongoose.model('Article', ArticleSchema, 'article');           

复制

4. 执行查询操作

// 引入定义的文章模型
var ArticleModel = require('./model/article.js');
// 三个表关联查询
ArticleModel.aggregate([
    {

        $lookup: {
            from: "articlecate",
            localField: "cid",
            foreignField: "_id",
            as: "cate"
        }
    },
    {

        $lookup: {
            from: "user",
            localField: "author_id",
            foreignField: "_id",
            as: "user"
        }
    }
], function (err, docs) {
    console.log(JSON.stringify(docs));
})           

复制

看到这里你可能觉得执行这样一个查询操作需要定义三个schema来完成，尽管如此，但是这三个schema 却是独立的，可以执行单独的操作，还可以在其他的地方进行复用，也便于进行维护。