释放双眼，带上耳机，听听看~！
查看更多资源
1. 简介：
在Node.js中使用MongoDb数据库，实现增删改查。
2. 安装：
2
2
3. 使用：
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
2var url=require('url'); //引入url模块
3var app=require('./model/express-route.js'); //引入路由
4var ejs=require('ejs');
5
6var MongoClient = require('mongodb').MongoClient; /*引入数据库 MongoClient*/
7
8var DBurl = 'mongodb://localhost:27017/student'; // 连接数据库的地址 student表示数据库的名称
9
10http.createServer(app).listen(3000); // 创建服务
11
12// 1. 增加数据
13app.get('/add', function (req, res) {
14 MongoClient.connect(DBurl, function (err, db) { /*连接数据库*/
15 if (err) {
16 console.log(err);
17 console.log('数据库连接失败');
18 return;
19 }
20 db.collection('user').insertOne({
21 "name": "xiaoyang",
22 "age": 10
23 }, function (error, result) {
24 if (error) {
25 console.log('增加数据失败');
26 return;
27 }
28 res.send('增加数据成功');
29 db.close();/*关闭数据库*/
30 })
31 })
32})
33
34// 2. 修改数据
35app.get('/edit', function (req, res) {
36 MongoClient.connect(DBurl, function (err, db) {
37 if (err) {
38 console.log(err);
39 console.log('数据库连接失败');
40 return;
41 }
42 db.collection('user').updateOne({ "name": "lisi" }, {
43 $set: {
44 "age": 666
45 }
46 }, function (error, data) {
47 if (error) {
48 console.log('修改数据失败');
49 return;
50 }
51 res.send('修改数据成功');
52 db.close();/*关闭数据库*/
53 })
54 })
55})
56
57// 3. 删除数据
58app.get('/delete', function (req, res) {
59 var query = url.parse(req.url, true).query;
60 var name = query.name;
61 MongoClient.connect(DBurl, function (err, db) {
62 if (err) {
63 console.log(err);
64 console.log('数据库连接失败');
65 return;
66 }
67 db.collection('user').deleteOne({ "name": name }, function (error, data) {
68 if (error) {
69 console.log('删除失败');
70 return;
71 }
72 console.log(data);
73 res.send('删除数据成功');
74 db.close();
75 })
76 })
77})
78
79 // 4. 查询数据
80app.get('/', function (req, res) {
81 MongoClient.connect(DBurl, function (err, db) {
82 if (err) {
83 console.log('连接数据库失败');
84 return;
85 }
86 var list = []; /*放数据库里面查询的所有数据*/
87 var result = db.collection('user').find({});
88 result.each(function (error, doc) {
89 //console.log(doc);
90 if (error) {
91 console.log(error);
92 } else {
93 if (doc != null) {
94 list.push(doc);
95 } else { /*doc==null表示数据循环完成*/
96 /*获取数据以后*/
97 //console.log(list);
98 db.close();
99 ejs.renderFile('views/index.ejs', { list: list }, function (err, data) {
100 res.send(data);
101 })
102 }
103 }
104 })
105 //console.log(result);
106 })
107})
108
