NodeJs操作MongoDB教程之分页功能以及常见问题

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

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

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

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

1 # limit()中number值为空时代表全部查出
2 db.User.find().limit(2) #读取的条数

1 # 常用在分页方法中
2 # 查询User集合中，跳过前两条记录，每页一条记录
3 > db.User.find().skip(2).limit(1)

/
  根据条件获取有多少条数据 文档数
  @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);
  }
  });
 }
};

{

 limit:10,//pageSize
 skip:0//page:skip+1
}

sort: {CreateTime: -1},

/
  连写查询 查询多条数据
  @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);
    }
   });
 }
};

//连写查询数据 包括分页 获取总条数
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);
    }
   });
  }
 });
 
})

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

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