/*
Mongodb的數(shù)據(jù)庫(kù)工具類(lèi)
*/
var client = require('mongodb').MongoClient;function MongoUtil() {
this.url="mongodb://localhost:27017/storage";//在本地新建數(shù)據(jù)庫(kù)storage，此后插入的數(shù)據(jù)都在storage中
}MongoUtil.prototype.connect=function(callback){
var that = this;
// console.log(3);
client.connect(this.url,function(err,db){
// console.log(4);
if(err){
console.dir(err);
}else{
that.db = db;
callback();
}
});
}MongoUtil.prototype.close = function(){
this.db.close();
}MongoUtil.prototype.insertDocuments = function(collectionName,docs,callback) {
var that = this;
this.connect(function(){
var collection = that.db.collection(collectionName);
collection.insertMany(docs, function(err,result){
if(err){
console.dir(err);
}else{
callback(result);
}
that.close();
});});
}MongoUtil.prototype.insertDocument = function(collectionName,doc,callback) {
var that = this;
this.connect(function(){
var collection = that.db.collection(collectionName);
collection.insertOne(doc, function(err,result){
if(err){
console.dir(err);
}else{
callback(result.insertedCount);
}
that.close();
});
});
}MongoUtil.prototype.findAllDocuments = function(collectionName, callback) {
var that = this;
this.connect(function(){
var collection = that.db.collection(collectionName); 
collection.find({}).toArray(function(err,result){
if(err){
console.dir(err);
}else{
callback(result);//返回插入的行數(shù)
}
that.close();
});
})
}MongoUtil.prototype.update = function(collectionName,filter,update,callback){
var that = this;
this.connect(function(){
var collection = that.db.collection(collectionName);
collection.updateOne(filter,update,function(err,result){
if(err){
console.dir(err);
}else{
callback(result.insertedCount);//返回插入的行數(shù)
}
});
});
}MongoUtil.prototype.findOne = function(collectionName,query,options,callback){
var that = this;
this.connect(function(){
var collection = that.db.collection(collectionName);
collection.findOne(query,options).then(function(doc){
callback(doc);
});
});
}module.exports=new MongoUtil();

?

轉(zhuǎn)載于:https://www.cnblogs.com/cy2525/p/6506420.html

總結(jié)

以上是生活随笔為你收集整理的mongoDB数据库操作工具库的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。