mongodb操作的模块手动封装
[注]：这些代码都是基于nodejs进行的.
在nodejs目录下创建一个模块文件*.js，以便调用，
以下是模块代码：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
|
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
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
|
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()是个难点
如有疑问请留言或者到本站社区交流讨论，感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！
原文链接：http://blog.csdn.net/xxhdcblogzh888/article/details/75389777
