针对Mongoose自定义分页查询通用方法

直接上代码：

代码语言：javascript复制

var mongoose = require('mongoose');
var Schema = mongoose.Schema;
var async = require('async');

var pageQuery = function (page, pageSize, Model, populate, queryParams, sortParams, callback) {
    var start = (page - 1) * pageSize;
    var $page = {
        pageNumber: page
    };
    async.parallel({
        count: function (done) {  // 查询数量
            Model.count(queryParams).exec(function (err, count) {
                done(err, count);
            });
        },
        records: function (done) {   // 查询一页的记录
            Model.find(queryParams).skip(start).limit(pageSize).populate(populate).sort(sortParams).exec(function (err, doc) {
                done(err, doc);
            });
        }
    }, function (err, results) {
        var count = results.count;
        $page.pageCount = (count - 1) / pageSize   1;
        $page.results = results.records;
        callback(err, $page);
    });
};

module.exports = {
    pageQuery: pageQuery
};

使用方法：

代码语言：javascript复制

var dbHelper = require('../db/dbHelper');

router.get('/', function(req, res, next){
    var page = req.query.page || 1;
    var Article = mongoose.model('Article', {xxx:xxx});
    dbHelper.pageQuery(page, 10, Article, '', {}, {
        created_time: 'desc'
    }, function(error, $page){
        if(error){
            next(error);
        }else{
            res.render('index'{
                records: $page.results,
                pageCount: $page.pageCount
            })
        }
    });
})

说明： 回调函数两个参数：error和$page，$page对象包含的属性：

• pageNumber: 当前第几页（从1 开始算）
• pageCount: 共多少页
• results: 当前页的记录

error 对象 函数

0 人点赞