NodeJs操作MongoDB之分页功能与常见问题

一,方法介绍

1,聚合操作之count

count()方法可以查询统计符合条件的集合的总数

 db.User.count(<query>) // 此方法等价于 db.User.find(<query>).count()

在分布式集合中，会出现计算错误的情况，这个时候推荐使用aggregate；

2,find() 方法以非结构化的方式来显示所有文档。

 db.User.find();//相当于：select* from User;

3,exec() 方法用于检索字符串中的正则表达式的匹配。(javascript方法)

4,sort() 方法对数据进行排序，sort() 方法可以通过参数指定排序的字段，并使用 1 和 -1 来指定排序的方式，其中 1 为升序排列，而 -1 是用于降序排列。

 升序：db.User.find().sort({CreateTime: 1});

 降序：db.User.find().sort({CreateTime: -1});

5,skip()方法来跳过指定数量的数据，skip方法同样接受一个数字参数作为跳过的记录条数。

 db.User.find().skip(2)//跳过2条

6,limit()方法接受一个数字参数，该参数指定从MongoDB中读取的记录条数。一般与skip连用

 # limit()中number值为空时代表全部查出

 db.User.find().limit() #读取的条数

 # 常用在分页方法中

 # 查询User集合中，跳过前两条记录，每页一条记录

 > db.User.find().skip(2).limit(1)

二,封装与接口抛出

2.1,分页查询

1,根据查询条件获取总条数,使用count（{}，callback）方法

 /**

  * 根据条件获取有多少条数据 文档数

  * @param table_name 表名

  * @param conditions 查询条件 {a:1, b:2}

  * @param callback 回调方法

  */

 MongoDbAction.getTotal = function (table_name, conditions, callback) {

     var node_model = this.getConnection(table_name);

     if (!node_model || node_model.message) {

         if (callback) callback(1, node_model)

     } else {

         node_model.find(conditions)

             .count({})

             .exec(function (err, total) {

                 if (err) {

                     if (callback) callback(err);

                 } else {

                     if (callback) callback(null, total);

                 }

             });

     }

 };

2,实现连写查询

（1）这个可以用来做分页，表示获取从第1条（第1条记录序号为0）记录开始的10条记录.类似与Mysql的limit 0, 10，如下：

{

limit:10,//pageSize

skip:0//page:skip+1

}

（2）按某个字段升序(1)降序(-1),如下按照创建时间进行降序排列

sort: {CreateTime: -1},

（3）代码连写查询实现：

 /**

  * 连写查询 查询多条数据

  * @param table_name 表名

  * @param conditions 查询条件 {a:1, b:2}

  * @param options 选项：{fields: "a b c", sort: {time: -1}, limit: 10}

  * @param callback 回调方法

  */

 MongoDbAction.whereCondition = function (table_name, conditions, options, callback) {

     var node_model = this.getConnection(table_name);

     if (!node_model || node_model.message) {

         if (callback) callback(1, node_model)

     } else {

         node_model.find(conditions)

             .select(options.fields || '')

             .sort(options.sort || {})//排序 //按某个字段升序(1)降序(-1)

             .skip(options.skip || 0)//跳过的条数

             .limit(options.limit || {})//查询几条

             .exec(function (err, res) {

                 if (err) {

                     if (callback) callback(err);

                 } else {

                     if (callback) callback(null, res);

                 }

             });

     }

 };

3,根据所传的参数实现分页查询

抛出分页查询的接口

 //连写查询数据 包括分页 获取总条数

 router.put('/user/getSingleAndManyData', function (req, res) {

     var tableName = req.body.tableName;//'User'

     var IsEnable = req.body.IsEnable;

     var limit = req.body.pageSize;

     var sort = req.body.sort;

     var skip = req.body.page;

     let conditions = {

         IsEnable

     }

     let options = {

         sort: {CreateTime: sort},//排序

         limit,//pageSize

         skip:(limit*(skip-1))//page

     }

     // let options = {

     //     sort: {CreateTime: -1},//按某个字段升序(1)降序(-1)

     //     limit:10,

     //     skip:(limit*(skip-1))//skip=1=> skip:0

     // }

     //  这个可以用来做分页，表示获取从第1条（第1条记录序号为0）记录开始的10条记录.类似与Mysql的limit 0, 10

     let data = {

         httpCode: 200,

         message: "查询成功！",

         status: 1,

         data: null,

         page:skip,

         pageSize:limit

     }

     MongoDbAction.getTotal(tableName,conditions, function (err, total) {

         if (err) {

             data.total=0

             data.status = 0

             data.message = "未查询到数据！"

             data.data = null

             res.status(data.httpCode).json(data);

         } else {

             MongoDbAction.whereCondition(tableName,conditions,options, function (err, result) {

                 if (!err) {

                     data.total=total

                     data.data = result

                     res.status(data.httpCode).json(data);

                 } else {

                     data.total=0

                     data.status = 0

                     data.message = "未查询到数据！"

                     data.data = result

                     res.status(data.httpCode).json(data);

                 }

             });

         }

     });

 })

4,接口调用,返回的结果集如下：

三,常见问题

1,连接警告

警告：(node:204) DeprecationWarning: current URL string parser is deprecated, and will be removed in a future version. To use the new parser, pass option { useNewUrlParser: true } to MongoClient.connect.

 mongoose.connect(dbURL);// 连接数据库 存在警告

解决办法：连接配置添加： { useNewUrlParser: true }

 mongoose.connect(dbURL,{useNewUrlParser:true});//连接数据库

巴特西

NodeJs操作MongoDB之分页功能与常见问题

NodeJs操作MongoDB之分页功能与常见问题

一,方法介绍

二,封装与接口抛出

2.1,分页查询

1,根据查询条件获取总条数,使用count（{}，callback）方法

2,实现连写查询

3,根据所传的参数实现分页查询

4,接口调用,返回的结果集如下：

三,常见问题

1,连接警告

最新文章

热门文章