直接上代碼：
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) { // 查詢數(shù)量
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
};
使用方法：
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
})
}
});
})
說明：
回調(diào)函數(shù)兩個(gè)參數(shù)：error和$page玛瘸，$page對象包含的屬性：
- pageNumber: 當(dāng)前第幾頁（從1 開始算）
- pageCount: 共多少頁
- results: 當(dāng)前頁的記錄
