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

喜歡這篇文章嗎？立刻分享出去讓更多人知道吧！