nodejs操作monggodb数据库封装
Posted 凌晨四点的北京
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了nodejs操作monggodb数据库封装相关的知识，希望对你有一定的参考价值。
var MongoClient=require(‘mongodb‘).MongoClient;
var DbUrl=‘mongodb://localhost:27017/productmanage‘; /*?????????*/
var ObjectID = require(‘mongodb‘).ObjectID;
function __connectDb(callback){
MongoClient.connect(DbUrl,function(err,db){
if(err){
console.log(‘????????????‘);
return;
}
//???? ??? ???
callback(db);
})
}
//??? ObjectID
exports.ObjectID=ObjectID;
//????????
/*
Db.find(‘user‘,{},function(err,data){
data????
})
*/
exports.find=function(collectionname,json,callback){
__connectDb(function(db){
var result=db.collection(collectionname).find(json);
result.toArray(function(error,data){
db.close();/*????????????*/
callback(error,data);/*?????????л??????*/
})
})
}
//????????
exports.insert=function(collectionname,json,callback){
__connectDb(function(db){
db.collection(collectionname).insertOne(json,function(error,data){
callback(error,data);
})
})
}
//????????
exports.update=function(collectionname,json1,json2,callback){
__connectDb(function(db){
db.collection(collectionname).updateOne(json1,{$set:json2},function(error,data){
callback(error,data);
})
})
}
//???????
exports.deleteOne=function(collectionname,json,callback){
__connectDb(function(db){
db.collection(collectionname).deleteOne(json,function(error,data){
callback(error,data);
})
})
}
以上是关于nodejs操作monggodb数据库封装的主要内容，如果未能解决你的问题，请参考以下文章