nodejs操作mongodb的增删改查功能实例
本文实例讲述了nodejs操作mongodb的增删改查功能。分享给大家供大家参考，具体如下：
安装相关模块
如果使用这个的话，你需要先自己安装一下他需要的模块，在根目录输入
npminstallmongodb--save
进行模块安装，安装成功以后就可以进行以下的步骤。
文件的引入
以下是我书写的相关代码，放到你可以引用的相关目录，本人放到了express的根目录
functionMongo(options){
this.settings={
url:'mongodb://localhost:27017/jk',
MongoClient:require('mongodb').MongoClient,
assert:require('assert')
};
for(letiinoptions){
this.settings[i]=options[i];
}
this._run=function(fun){
letthat=this;
letsettings=this.settings;
this.settings.MongoClient.connect(this.settings.url,function(err,db){
settings.assert.equal(null,err);
console.log("Connectedcorrectlytoserver");
fun(db,function(){
db.close();
});
});
};
this.insert=function(collectionName,data,func){
//增加数据
letinsertDocuments=function(db,callback){
letcollection=db.collection(collectionName);
collection.insertMany([
data
],function(err,result){
if(!err){
func(true);
}else{
func(false);
}
callback(result);
});
};
this._run(insertDocuments);
};
this.update=function(collectionName,updateData,data,func){
//更新数据
letupdateDocument=function(db,callback){
letcollection=db.collection(collectionName);
collection.updateOne(updateData
,{$set:data},function(err,result){
if(!err){
func(true);
}else{
func(false);
}
callback(result);
});
};
this._run(updateDocument);
};
this.delete=function(collectionName,data,func){
//删除数据
letdeleteDocument=function(db,callback){
letcollection=db.collection(collectionName);
collection.deleteOne(data,function(err,result){
if(!err){
func(true);
}else{
func(false);
}
callback(result);
});
};
this._run(deleteDocument);
};
this.find=function(collectionName,data,func){
//查找数据
letfindDocuments=function(db,callback){
//Getthedocumentscollection
letcollection=db.collection(collectionName);
//Findsomedocuments
collection.find(data).toArray(function(err,docs){
if(!err){
func(true,docs);
}
else{
func(false,err);
}
callback(docs);
});
};
this._run(findDocuments);
};
}
module.exports=Mongo;
我存入到了一个名字叫server.js的文件名内
使用
我们在需要使用页面先将模块引入，比如我在路由文件index.js里面引入：
constServer=require("../server.js");
然后需要实例化对象，如下：
letserver=newServer();
如果需要配置相关信息，可以在实例化的时候传入一个对象配置，可以配置数据库的地址：
letserver=newServer({url:"mongodb://localhost:27017/mydb"});
里面封装了四个方法，添删改查，分别是
添加方法
server.insert(数据表名,需要插入的数据（键值对的对象）,回调函数);
更新方法
server.update(数据表名,查询的数据（对象）,更新的数据（对象）,回调函数);
删除方法
server.delete(数据表名,查询的数据（对象）,回调函数);
查找方法
server.find(数据表名,查询的数据（对象）,回调函数);
回调函数都会返回两个值，第一个布尔类型，是否处理成功，第二个值，查找返回查找到的个数，别的都返回处理成功的个数（现在一次只处理一条）
使用案例
比如我需要在一个路由里面查找数据，我就需要这样：
server.find("users",{username:"username"},function(bool,data){
if(bool){
console.log("查询到数据为"+data.length+"条");
}
else{
console.log(data);
}
});
});
上面的代码是查询了users表里面username为username的字段的数据，如果成功，后面data就会返回一个数组，如果出现错误，就直接返回data错误。
希望本文所述对大家nodejs程序设计有所帮助。