nodejs连接mongodb，对数据增删改查操作（跳过坑）Windows版
第一步：安装nodejs
1.1.官网下载 版本：nodejs v6.9.2（对应npm v3.10.9）下载地址：https://nodejs.org/dist/
1.2.详细安装步骤，请参考https://www.cnblogs.com/sese/p/5182783.html
第二步：安装mongodb及驱动(注意版本兼容)
2.1.官网下载版本：mongodb v3.0.0 驱动版本：v2.2.33 下载地址：https://www.mongodb.com/download-center?jmp=nav#community
2.2.mongodb详细安装步骤，请参考https://www.cnblogs.com/wyhlightstar/p/6271251.html
2.3.驱动安装
首先打开nodejs进行全局安装mongodb驱动器 输入命令npm install mongodb -g
再在新建的项目安装中 命令 npm install mongodb --save 此步骤安装时还需要配置package.json文件(请放在项目的根目录下)
package.json 内容如下：
01
{
02
"name": "nodejs02",
03
"version": "0.0.0",
04
"private": true,
05
"scripts": {
06
"start": "node ./bin/www"
07
},
08
"dependencies": {
09
"body-parser": "~1.15.2",
10
"cookie-parser": "~1.4.3",
11
"debug": "~2.2.0",
12
"ejs": "~2.5.2",
13
"express": "^4.14.1",
14
"mongodb": "^2.2.33",
15
"morgan": "~1.7.0",
16
"serve-favicon": "~2.3.0"
17
}
18
}
第三步：nodejs操作mongodb 实现增删改查示例
nodejs和mongodb已经全部安装完毕，所需驱动模板mongodb也已安装，下面开始利用nodejs来操作mongodb吧
3.1.在项目的根目录下新建一个app.js文件实现增加
01
//引入mongodb模块，获得客户端对象
02
var MongoClient = require('mongodb').MongoClient;
03
//连接字符串
04
var DB_CONN_STR = 'mongodb://localhost:27017/gomall';
05
06
//定义函数表达式，用于操作数据库并返回结果
07
var insertData = function(db, callback) {
08
//获得指定的集合
09
var collection = db.collection('users');
10
//插入数据
11
var data = [{_id:7,"name":'rose',"age":21},{_id:8,"name":'mark',"age":22}];
12
collection.insert(data, function(err, result) {
13
//如果存在错误
14
if(err)
15
{
16
console.log('Error:'+ err);
17
return;
18
}
19
//调用传入的回调方法，将操作结果返回
20
callback(result);
21
});
22
}
23
24
//使用客户端连接数据，并指定完成时的回调方法
25
MongoClient.connect(DB_CONN_STR, function(err, db) {
26
console.log("连接成功！");
27
//执行插入数据操作，调用自定义方法
28
insertData(db, function(result) {
29
//显示结果
30
console.log(result);
31
//关闭数据库
32
db.close();
33
});
34
});
运行结果：
1
连接成功！
2
{ result: { ok: 1, n: 2 },
3
ops:
4
[ { _id: 7, name: 'rose', age: 21 },
5
{ _id: 8, name: 'mark', age: 22 } ],
6
insertedCount: 2,
7
insertedIds: [ 7, 8 ] }
3.2 修改操作示例
01
//引入mongodb模块，获得客户端对象
02
var MongoClient = require('mongodb').MongoClient;
03
//连接字符串
04
var DB_CONN_STR = 'mongodb://localhost:27017/gomall';
05
06
//定义函数表达式，用于操作数据库并返回结果
07
var updateData = function(db, callback) {
08
//获得指定的集合
09
var collection = db.collection('users');
10
//要修改数据的条件，>=10岁的用户
11
var where={age:{"$gte":10}};
12
//要修改的结果
13
var set={$set:{age:95}};
14
collection.updateMany(where,set, function(err, result) {
15
//如果存在错误
16
if(err)
17
{
18
console.log('Error:'+ err);
19
return;
20
}
21
//调用传入的回调方法，将操作结果返回
22
callback(result);
23
});
24
}
3.3 查询示例
01
//引入mongodb模块，获得客户端对象
02
var MongoClient = require('mongodb').MongoClient;
03
//连接字符串
04
var DB_CONN_STR = 'mongodb://localhost:27017/gomall';
05
06
//定义函数表达式，用于操作数据库并返回结果
07
var findData = function(db, callback) {
08
//获得指定的集合
09
var collection = db.collection('users');
10
//要查询数据的条件，<=10岁的用户
11
var where={age:{"$lte":10}};
12
//要显示的字段
13
var set={name:1,age:1};
14
collection.find(where,set).toArray(function(err, result) {
15
//如果存在错误
16
if(err)
17
{
18
console.log('Error:'+ err);
19
return;
20
}
21
//调用传入的回调方法，将操作结果返回
22
callback(result);
23
});
24
}
25
26
//使用客户端连接数据，并指定完成时的回调方法
27
MongoClient.connect(DB_CONN_STR, function(err, db) {
28
console.log("连接成功！");
29
//执行插入数据操作，调用自定义方法
30
findData(db, function(result) {
31
//显示结果
32
console.log(result);
33
//关闭数据库
34
db.close();
35
});
36
});
3.4删除示例
01
//引入mongodb模块，获得客户端对象
02
var MongoClient = require('mongodb').MongoClient;
03
//连接字符串
04
var DB_CONN_STR = 'mongodb://localhost:27017/gomall';
05
06
//定义函数表达式，用于操作数据库并返回结果
07
var findData = function(db, callback) {
08
//获得指定的集合
09
var collection = db.collection('users');
10
//要删除数据的条件，_id>2的用户删除
11
var where={_id:{"$gt":2}};
12
collection.remove(where,function(err, result) {
13
//如果存在错误
14
if(err)
15
{
16
console.log('Error:'+ err);
17
return;
18
}
19
//调用传入的回调方法，将操作结果返回
20
callback(result);
21
});
22
}
23
24
//使用客户端连接数据，并指定完成时的回调方法
25
MongoClient.connect(DB_CONN_STR, function(err, db) {
26
console.log("连接成功！");
27
//执行插入数据操作，调用自定义方法
28
findData(db, function(result) {
29
//显示结果
30
console.log(result);
31
//关闭数据库
32
db.close();
33
});
34
});
作者：bzyaocom
原文：http://www.zuidaima.com/blog/3669151412947968.htm
