传统的写法/**

* Created by 黄森 on 2017/7/22.

*/var express = require('express');var app = express();var MongoClient = require('mongodb').MongoClient;

app.get('/',function (req,res) {    // Connection URL

var url = 'mongodb://localhost:27017/database';

MongoClient.connect(url, function(err, db) {        if(err){            console.log("数据库连接失败")

}        console.log("数据库连接成功");        //插入数据

db.collection('student').insertOne({            "name":"hahah",            "age":"100"

},function (err,result) {            console.log(result);

res.send("插入数据成功:"+result);

db.close();

});

});

});

app.listen(3000);

这样的话，我们可以看出用户在每次操作的时候，就要连接依次数据库，这样的话效率很低，所以我们把数据库的增删改查封装成一个 模块，这个模块命名为db.js

Dao层封装：db.js

1、引入mongodbvar MongoClient = require('mongodb').MongoClient;

2、连接数据库//连接数据路function _connectDB(callback) {    // Connection URL

var url = 'mongodb://localhost:27017/database';

MongoClient.connect(url, function (err, db) {        console.log("数据库连接成功");        if(err){

callback(err,null);            return;

}

callback(err, db);

});

}

3、封装方法插入数据// 插入数据exports.insertOne = function (collectionName, json, callback) {

_connectDB(function (err, db) {

db.collection(collectionName).insertOne(json, function (err, result) {

callback(err, result);

db.close();

})

})

};查找数据// 查找数据exports.find = function (collectionName, json, callback) {    var result = [];   //返回结果的数组

if (arguments.length != 3) {

callback("find接受三个参数", null);        return;

}

_connectDB(function (err, db) {        var cursor = db.collection(collectionName).find(json);

cursor.each(function (err, doc) {            if (err) {

callback(err, null);

db.close();                return;

}            if (doc != null) {

result.push(doc);   //放入结果数组中

} else {                //没有结果

callback(null, result);

db.close();

}

})

})

};分页查询

mongo在分页查询的时候是db.student.find().skip().limit();

find()就是查找的条件，skip()就是略过的条数，limit()就是读取的条数，limit和skip配合使用就是分页查询。

数据总数两种写法：db.student.find().count()db.student.stats().count;

比如：第一页是page=0。每页10条，所以当前页的查询语句：db.student.find({}).limit(10).skip(page*10)

所以分页查询封装好的函数就是如下所示：// 查找数据,args是一个对象{"pageamount":2,"page":page}exports.find = function (collectionName, json, C,D) {    var result = [];   //返回结果的数组

if (arguments.length == 3) {        var callback = C;        var skip = 0;        var limit = 0;

}else if(arguments.length==4){        var callback = D;        var args = C;        //应该省略的条数

var skip = args.pageamount*args.page||0;        //数目限制数

var limit = args.pageamount||0;       // 排序

var sort = args.sort||{}

}else{        throw new Error("find函数的参数必须是三个或四个");        return;

}

_connectDB(function (err, db) {       var cursor = db.collection(collectionName).find(json).skip(skip).limit(limit).sort(sort);

cursor.each(function (err, doc) {            if (err) {

callback(err, null);

db.close();                return;

}            if (doc != null) {

result.push(doc);   //放入结果数组中

} else {                //没有结果

callback(null, result);

db.close();

}

})

})

};

去调用的时候就是：app.get("/find",function (req,res) {    var page =parseInt(req.query.page);

db.find("student",{},{"pageamount":2,"page":page},{"sort":{"shijian":-1}},function (err,result) {       if(err){           console.log("查找失败")

}

res.send(result);

})

});修改数据//修改exports.updateMany = function (collectionName, json1, json2, callback) {

_connectDB(function (err, db) {

db.collection(collectionName).updateMany(

json1,

json2,            function (err, results) {

callback(err, results);

db.close();

});

})

};删除数据// 删除exports.deleteMany = function (collectionName, json, callback) {

_connectDB(function (err, db) {

db.collection(collectionName).deleteMany(json, function (err, result) {

callback(result.length);

db.close();

})

})

};

作者：不要和我名字一样

链接：https://www.jianshu.com/p/61c99740561f