mongodb之多表关联查询并分页

Model

多表查询分页可以使用mongoose-aggregate-paginate-v2

interface表Model

const aggregatePaginate = require('mongoose-aggregate-paginate-v2');
module.exports = app => {
  const mongoose = app.mongoose;
  const schema = new mongoose.Schema({
    // 自增ID
    id: { type: Number, unique: true },
    // ...省略
    // 创建人
    createBy: { type: String },
    // 更新时间
    updateTime: { type: String },
    // 更新人
    updateBy: { type: String },
  });
  schema.plugin(aggregatePaginate);
  // mongoose.model(名称,数据,表名)
  return mongoose.model('system Interface', schema, 'interface');
};

user表Model

const aggregatePaginate = require('mongoose-aggregate-paginate-v2');
module.exports = app => {
  const mongoose = app.mongoose;
  const schema = new mongoose.Schema({
    // 自增ID
    id: { type: Number, unique: true },
    // 用户唯一ID
    uuid: { type: String, unique: true },
    // 用户角色
    roleId: { type: Number },
    // 用户名-用于登录，找回密码
    userName: { type: String, unique: true },
    // ...省略
  });
  schema.plugin(aggregatePaginate);
  // mongoose.model(名称,数据,表名)
  return mongoose.model('user-list', schema, 'user');
};

Service

这里就是使用$lookup进行多表关联查询，$lookup可以设置多个，通过不同的字段，关联不同的表

async list(page, pageSize, query, select) {
    const { ctx } = this;
    // 关联查询user表
    const aggregateQuery = ctx.model.System.Interface.aggregate([
      {
        $lookup: {
          // 关联的表
          from: 'user',
          // 当前表关联的字段（如现在的Interface表）
          localField: 'createBy',
          // 关联的表的字段(user表的userName字段)
          foreignField: 'userName',
          // 查询出来的关联数据，存放在'createUser'字段中
          as: 'createUser',
        },
      },
      {
        $lookup: {
          from: 'user',
          localField: 'updateBy',
          foreignField: 'userName',
          as: 'updateUser',
        },
      },
      {
        // $project：设置0隐藏某些字段 ，让其不返回
        $project: {
          createUser: {
            _id: 0,
            __v: 0,
            uuid: 0,
            password: 0,
            updateBy: 0,
            updateTime: 0,
            createTime: 0,
            createBy: 0,
            registerTime: 0,
          },
          updateUser: {
            _id: 0,
            __v: 0,
            uuid: 0,
            password: 0,
            updateBy: 0,
            updateTime: 0,
            createTime: 0,
            createBy: 0,
            registerTime: 0,
          },
          __v: 0,
          ...select,
        },
      },
    ]);
    const list = await ctx.model.System.Interface.aggregatePaginate(
      aggregateQuery,
      {
        page: Number(page) || 1,
        // 每页数
        limit: Number(pageSize) || 10,
        sort: { menuId: 1 },
      },
    );
    return list;
  }