node操作mongodb数据库的封装

remove: function(dataname， removelanguage， dealdata) {
var server = new mongodb.Server(dataconfig.dataurl， dataconfig.dataport， {
auto_reconnect: true
}); // 创建mongodb服务
var db = new mongodb.Db(dataconfig.dataname， server， {
safe: true
});
db.open(function(err， db) {
if (err) {
console.log('数据库打开失败');
} else {
db.createCollection(dataname， {
safe: true
}， function(err， collection) {
if (err) {
console.log('数据库连接失败');
} else {
collection.remove(removelanguage， {
safe: true
}， function(err， result) {
dealdata(result);
db.close();
});
}
})
}
})
db.on("close"， function(err， data) {
if (err) {
console.log("数据库关闭失败");
}
console.log('数据库已经关闭');
});
}，
/*
@remove  删除全部数据的方法
@dataname 数据库名称
@dealdata 回调函数处理函数有一个result参数
*/
removeall: function(dataname， dealdata) {
var server = new mongodb.Server(dataconfig.dataurl， dataconfig.dataport， {
auto_reconnect: true
}); // 创建mongodb服务
var db = new mongodb.Db(dataconfig.dataname， server， {
safe: true
});
db.open(function(err， db) {
if (err) {
console.log('数据库打开失败');
} else {
db.createCollection(dataname， {
safe: true
}， function(err， collection) {
if (err) {
console.log('数据库连接失败');
} else {
collection.remove({}， {
safe: true
}， function(err， result) {
dealdata(result);
db.close();
});
}
})
}
})
db.on("close"， function(err， data) {
if (err) {
console.log("数据库关闭失败");
}
console.log('数据库已经关闭');
});
}
};
　　数据库封装完毕，我们测试一下
//测试用例
Mainpulation.select('test'， {"title": "hello"}， function(result) {
console.log("select查询结果");
console.log(result);
})
Mainpulation.insert('test'，{"insert":"hello"}，function(result){
console.log('inserts插入结果');
console.log(result);
})
Mainpulation.remove('test'，{"insert":"hello"}，function(result){
console.log(result);
})
Mainpulation.removeall('test'，function(result){
console.log(result);
})
Mainpulation.selectall('test'， function(result) {
console.log('selectall查询结果');
console.log(result);
});
　　当然后我们封装完毕后，我们要把这个模块导出一下方便我们以后的使用
　　module.exports = Mainpulation;