-
Notifications
You must be signed in to change notification settings - Fork 7
/
db.js
118 lines (101 loc) · 2.49 KB
/
db.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
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
var MongoClient = require('mongodb').MongoClient;
var url = require('./property').property['db_url'];
var documentName = "msg";
function save(data, callback) {
MongoClient.connect(url, function(err, db) {
if (err) {
console.log(err);
} else {
var collection = db.collection(documentName);
collection.insert(data, function(err, result) {
if (err) {
console.log(err);
} else {
console.log("insert success!!");
callback && callback(result);
db.close();
}
});
}
})
}
function list(page, callback) {
var pageNum = 15;
MongoClient.connect(url, function(err, db) {
if (err) {
console.log(err);
} else {
var collection = db.collection(documentName);
collection.find({},{limit: pageNum, skip: (page - 1) * pageNum}).sort({dtime:-1}).toArray(function(err, result) {
if (err) {
console.log(err);
} else {
callback && callback(result);
db.close();
}
})
}
})
}
exports.save = save;
exports.list = list;
// MongoClient.connect(url, function(err, db) {
// console.log("Connected correctly to server");
// insertDoc(db, function(result) {
// console.log(result);
// updateDoc(db, function(result) {
// console.log(result);
// removeDoc(db, function(result) {
// console.log(result);
// findDoc(db, function(result) {
// console.log(result);
// db.close();
// })
// })
// })
// })
// });
// var insertDoc = function(db, callback) {
// var collection = db.collection('doc2');
// collection.insert([{a:1},{a:2},{a:3}], function(err, result) {
// if (err) {
// console.log(err)
// } else {
// console.log('inserted 3 doc');
// callback(result);
// }
// })
// };
// var updateDoc = function(db, callback) {
// var collection = db.collection('doc2');
// collection.update({a:2}, {$set:{b:1}}, function(err, result) {
// if (err) {
// console.log(err);
// } else {
// console.log("update the doc");
// callback(result);
// }
// })
// };
// var removeDoc = function(db, callback) {
// var collection = db.collection('doc2');
// collection.remove({a:3}, function(err, result) {
// if (err) {
// console.log(err);
// } else {
// console.log("remove");
// callback(result);
// }
// })
// };
// var findDoc = function(db, callback) {
// var collection = db.collection('doc2');
// collection.find({}).toArray(function(err, docs) {
// if (err) {
// console.log(err);
// } else {
// console.log("find");
// callback(docs);
// }
// })
// }