mongodb操作的模块手动封装
[注]：这些代码都是基于nodejs进行的.
在nodejs目录下创建一个模块文件*.js，以便调用，
以下是模块代码：
function mongodbModel(dbname,dataform) {
var MongoClient;
var DB_CONN_STR;
this.init = function() {
MongoClient = require('mongodb').MongoClient;
DB_CONN_STR = 'mongodb://localhost:27017/' + dbname;
}
/*这里是插入数据*/ this.insert = function(data,callback) {
MongoClient.connect(DB_CONN_STR, function(err, db) {
console.log('连接成功') var collection = db.collection(dataform);
collection.insert(data, function(err,result){
callback(err,result);
}
) }
) }
/*这里是删除数据*/ this.remove = function(data,callback){
MongoClient.connect(DB_CONN_STR, function(err, db) {
console.log('连接成功') var collection = db.collection(dataform);
collection.remove(data, function(err,result){
callback(err,result);
}
) }
) }
/*这里是修改*/ this.update=function(data,updata,callback){
MongoClient.connect(DB_CONN_STR, function(err, db) {
console.log('连接成功') var collection = db.collection(dataform);
collection.update(data,updata,function(err,data){
callback(err,data);
}
) }
) }
/*这里是查询*/ this.find=function(data,callback){
MongoClient.connect(DB_CONN_STR, function(err, db) {
console.log('连接成功') var collection = db.collection(dataform);
collection.find(data).toArray(function(err,data){
callback(err,data);
}
) }
) }
}
module.exports = mongodbModel;
如何使用：
在同目录下创建一个调用文件*.js
var mongodbModel = require('./mongodbModel');
var mongodbObject = new mongodbModel('seraph','singer');
mongodbObject.init();
/*这里是插入*/mongodbObject.insert({
name:'啊xx'}
,function(err,data){
if(err){
console.log(err);
}
else{
console.log(data);
}
}
)/*这是删除*/mongodbObject.remove({
name:'啊xiao'}
,function(err,data){
if(err){
console.log(err);
}
else{
console.log('成功删除指定数据');
}
}
)/*这里是修改*/mongodbObject.update({
name:'小李'}
,{
$set:{
name:'小勇'}
}
,function(err,data){
if(err){
console.log(err);
}
else{
console.log(data);
}
}
)/*这里是条件查询*/mongodbObject.find({
name:'李洛克'}
,function(err,data){
if(err){
console.log(err);
}
else{
console.log(data);
}
}
)
相关参数：
dbname:是指要操作的database；
dataform:是指要操作的数据表；
data:表示需要插入或者查询或者修改的数据；
updata:表示修改后的数据；
个人在封装的时候，callback()是个难点
如有疑问请留言或者到本站社区交流讨论，感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！
