一、node.js对于mongodb的基本操作
1、数据库的开机
首先我们要先对数据库进行开机的操作，建立一个文件夹用于存放数据库文档。如D:\mongo，接下去在cmd当中键入命令-> mongod --dbpath D:\mongo来实现数据库的开机。如下图所示：
接下去就保持这个cmd控制面板处于这种状态，以确保数据库处于开机状态。
2、连接数据库
在node.js当中操作mongodb数据库需要引入第三方模块包mongodb。所以我们先在项目文件夹下键入命令-> npm install mongodb来完成下载包。接下去再用const MongoClient = require('mongodb').MongoClient;来完成引包。示例代码如下所示：
const MongoClient = require('mongodb').MongoClient;
var dburl = "mongodb://127.0.0.1:27017/test";
MongoClient.connect(dburl,(err,db)=>{
if(err){
console.log('数据库连接失败！');
return;
};
console.log(db);
});
我们先定义一个dburl变量用于指定本机上27017端口号（mongodb的默认端口号）上的数据库地址。test为自定义的数据库的名字。若该数据库不存在则会自动完成该数据库的新建。接下去完成与本机上test数据库的连接，这是一个异步函数，当连接完成之后，触发执行其回调函数，参数db指代这个数据库本身。接下去对数据库的增删改查操作都写在连接的回调函数当中。
3、插入数据
数据插入操作，指的是对数据库的某个指定集合进行文档对象的插入。同样是在完成数据库连接的回调函数当中对db这个对象进行操作。示例代码如下所示：
const MongoClient = require('mongodb').MongoClient;
var dburl = "mongodb://127.0.0.1:27017/test";
MongoClient.connect(dburl,(err,db)=>{
if(err){
console.log('数据库连接失败！');
return;
};
db.collection('student').insertOne({"name":"qianqian"},(err,result)=>{
if(err){
console.log('数据插入失败！');
db.close();
return;
};
console.log(result);
db.close();
});
});
在用node命令运行该文件之后，这时候我们可以在控制台或在可视化工具当中查看插入结果。
在db对象的collection方法当中写入集合的名字，若该集合不存在则自动完成新建，使用方法insertOne()来完成一条文档的插入，第一个参数为一个json对象，即插入的那一条文档数据。当完成插入操作之后触发执行其回调函数，result表示对插入结果的反馈。由于数据库不能进行长连接，我们一般都在完成数据库操作的回调函数的最后加上db.close();来关闭数据库。下一次数据库操作时需要重新连接数据库。
4、删除数据
数据删除操作，指的是对数据库的某个指定集合当中匹配上筛选条件的文档进行删除。同样是在完成数据库连接的回调函数当中对db这个对象进行操作。示例代码如下所示：
const MongoClient = require('mongodb').MongoClient;
var dburl = "mongodb://127.0.0.1:27017/test";
MongoClient.connect(dburl,(err,db)=>{
if(err){
console.log('数据库连接失败！');
return;
};
db.collection('student').deleteMany({"name":"qianqian"},(err,result)=>{
if(err){
console.log('数据删除失败！');
db.close();
return;
};
console.log(result);
db.close();
});
});
使用方法deleteMany()来对该集合当中所有符合筛选条件的文档全部进行删除，第一个参数为一个json对象，即筛选条件。当完成删除操作之后触发执行其回调函数，result表示对删除结果的反馈。
5、修改数据
数据修改操作，指的是对数据库的某个指定集合当中匹配上筛选条件的所有文档进行修改。同样是在完成数据库连接的回调函数当中对db这个对象进行操作。示例代码如下所示：
const MongoClient = require('mongodb').MongoClient;
var dburl = "mongodb://127.0.0.1:27017/test";
MongoClient.connect(dburl,(err,db)=>{
if(err){
console.log('数据库连接失败！');
return;
};
db.collection('student').updateMany({"name":"qianqian"},{$set:{"age":18}},(err,result)=>{
if(err){
console.log('数据修改失败！');
db.close();
return;
};
console.log(result);
db.close();
});
});
使用方法updateMany()来对该集合当中所有符合筛选条件的文档全部进行修改，第一个参数为一个json对象，即筛选条件。第二个参数为一个json对象，即修改条件，语法如上所示。当没有写$set这个关键字，即{"age":18}代表把匹配上的文档进行替换。当完成修改操作之后触发执行其回调函数，result表示对修改结果的反馈。
6、查找数据
数据查找操作，指的是对数据库的某个指定集合当中匹配上筛选条件的所有文档进行查找。同样是在完成数据库连接的回调函数当中对db这个对象进行操作。示例代码如下所示：
const MongoClient = require('mongodb').MongoClient;
var dburl = "mongodb://127.0.0.1:27017/test";
MongoClient.connect(dburl,(err,db)=>{
if(err){
console.log('数据库连接失败！');
return;
};
var cursor = db.collection("student").find({"name":"qianqian"});
var result = [];
cursor.each((err,doc)=>{
if(err){
console.log('数据查找失败！');
db.close();
return;
};
if(doc!=null){
result.push(doc);
}else{
console.log(result);
db.close();
};
});
});
使用方法find
()来对该集合当中所有符合筛选条件的文档全部进行查找，第一个参数为一个json对象，即筛选条件。先定义一个空数组，用于存放符合条件的文档对象，当完成查找操作之后触发执行其回调函数，这里的result表示符合条件的文档对象的数组。
我们在find()方法后面继续加上sort()方法可以实现对查找的文档对象的排序操作，参数同样是一个json对象。此外mongodb模块还提供了两个函数limit()表示限制读取的条数，skip()表示略过的条数。其参数均为number类型。如把上述代码修改为： var cursor = db.collection("student").find({"name":"qianqian"}).sort({"age":-1}).skip(0).limit(2);查找结果为：
7、获取该集合当中文档对象的总数
同样是在完成数据库连接的回调函数当中对db这个对象进行操作。示例代码如下所示：
const MongoClient = require('mongodb').MongoClient;
var dburl = "mongodb://127.0.0.1:27017/test";
MongoClient.connect(dburl,(err,db)=>{
if(err){
console.log('数据库连接失败！');
return;
};
db.collection("student").count({}).then(function(count){
console.log(count);
db.close();
});
});
在回调函数当中的count即代表数据库的student这个集合当中数据文档的数目。
二、node.js操作mongodb的常用函数的封装
我们写一个db.js模块，在该模块当中封装对数据库的一些基本操作函数。其中db.js的示例代码如下所示：
const MongoClient = require('mongodb').MongoClient;
var dburl = "mongodb://127.0.0.1:27017/test";
//连接数据库操作
function _connectDB(callback){
MongoClient.connect(dburl,(err,db)=>{
callback(err,db);
});
};
//插入函数的封装
module.exports.insertOne = function(collection,json,callback){
_connectDB(function(err,db){
if(err){
console.log('数据库连接失败！');
return;
};
db.collection(collection).insertOne(json,(err,result)=>{
callback(err,result);
db.close();
})
})
};
//删除函数的封装
module.exports.deleteMany = function(collection,json,callback){
_connectDB(function(err,db){
if(err){
console.log('数据库连接失败！');
return;
};
db.collection(collection).deleteMany(json,(err,result)=>{
callback(err,result);
db.close();
});
});
};
//修改函数的封装
module.exports.updateMany = function(collection,json1,json2,callback){
_connectDB(function(err,db){
if(err){
console.log('数据库连接失败！');
return;
};
db.collection(collection).updateMany(json1,json2,(err,result)=>{
callback(err,result);
db.close();
});
});
};
//获取集合当中文档的总条数
module.exports.getAllCount = function(collection,callback){
_connectDB(function(err,db){
if(err){
console.log('数据库连接失败！');
return;
};
db.collection(collection).count({}).then(function(count){
callback(count);
db.close();
});
});
};
//查找函数的封装
module.exports.find = function(collection,json,C,D){
if(arguments.length == 3){
var callback = C;
var skipnumber = 0;
var limit = 0;
var sort = {};
}else if(arguments.length == 4){
var callback = D;
var args = C;
var skipnumber = args.pageamount * args.page;
var limit = args.pageamount;
var sort = args.sort;
}else{
throw new Error('find函数参数个数不正确！');
return;
}
var result = [];
_connectDB(function(err,db){
if(err){
console.log('数据库连接失败！');
return;
};
var cursor = db.collection(collection).find(json).sort(sort).limit(limit)
.skip(skipnumber);
cursor.each((err,doc)=>{
if(err){
callback(err,null);
db.close();
return;
};
if(doc!=null){
result.push(doc);
}else{
callback(null,result);
db.close();
}
})
});
};
我们每次在使用该模块之前，先对本机上的mongodb数据库进行开机操作，然后在项目文件夹下下载mongodb这个第三方模块包，然后修改db.js当中的dburl的值，接下去只要在我们自己的主文件用require的方式进行引入即可。如主文件1.js与db.js处于同一目录下，则在1.js当中使用const db = require('./db.js');对该模块进行引入即可。下面给出主文件的示例代码，作为该模块的使用示范：
const db = require('./db.js');
db.insertOne('student',{'name':'qianqiang'},(err,result)=>{
if(err){
console.log('数据插入失败！');
db.close();
return;
};
console.log(result);
});
db.deleteMany('student',{'age':11},(err,result)=>{
if(err){
console.log('数据删除失败！');
db.close();
return;
};
console.log(result);
});
db.updateMany('student',{'age':18},{$set:{'age':25}},(err,result)=>{
if(err){
console.log('数据修改失败！');
db.close();
return;
};
console.log(result);
});
db.find('student',{},{'pageamount':2,'page':4,'sort':{}},(err,result)=>{
if(err){
console.log('数据查找失败！');
db.close();
return;
};
console.log(result);
});
db.getAllCount('student',function(count){
console.log(count);
});
其中find函数当中的pageamount表示每页显示的文档对象的条数，page表示显示第几页的内容（从第0页开始计数）。以此来实现对查找数据分页显示的功能。