Nodejs使用Mongodb存儲(chǔ)與提供后端CRD服務(wù)詳解

更新時(shí)間：2018年09月04日 10:16:16 作者：RecoReco

這篇文章主要給大家介紹了關(guān)于Nodejs使用Mongodb存儲(chǔ)與提供后端CRD服務(wù)的相關(guān)資料，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

前言

眾所周知JS是腳本語(yǔ)言，腳本語(yǔ)言都需要一個(gè)解析器才能運(yùn)行。對(duì)于寫在HTML頁(yè)面里的JS，瀏覽器充當(dāng)了解析器的角色。而對(duì)于需要獨(dú)立運(yùn)行的JS，NodeJS就是一個(gè)解析器。

每一種解析器都是一個(gè)運(yùn)行環(huán)境，不但允許JS定義各種數(shù)據(jù)結(jié)構(gòu)，進(jìn)行各種計(jì)算，還允許JS使用運(yùn)行環(huán)境提供的內(nèi)置對(duì)象和方法做一些事情。例如運(yùn)行在瀏覽器中的JS的用途是操作DOM，瀏覽器就提供了document之類的內(nèi)置對(duì)象。而運(yùn)行在NodeJS中的JS的用途是操作磁盤文件或搭建HTTP服務(wù)器，NodeJS就相應(yīng)提供了fs、http等內(nèi)置對(duì)象。

本文會(huì)把一個(gè)對(duì)象todo對(duì)象（有屬性{id，name})存儲(chǔ)到Mongodb，做查詢刪除的測(cè)試（Create Remove Delete = CRD）。這個(gè)測(cè)試包括使用Mongodb Shell，使用CallBack古典風(fēng)格的訪問(wèn)代碼，以及使用Await/Async的現(xiàn)代風(fēng)格的代碼。完成這個(gè)這個(gè)驗(yàn)證后，就可以掌握最初步的Mongodb了。

我使用的Nodejs是10.7 。操作系統(tǒng)環(huán)境為Mac OS X High Sierra。

準(zhǔn)備環(huán)境

安裝和運(yùn)行Mongodb Daemon

brew install mongodb
mongodb

訪問(wèn)驗(yàn)證

首先執(zhí)行Mongodb Shell:

mongo

輸入命令，查詢數(shù)據(jù)庫(kù)清單：

> show dbs
local  0.000GB

創(chuàng)建一個(gè)數(shù)據(jù)庫(kù)

use todos

(若database不存在，則會(huì)創(chuàng)建一個(gè)，此時(shí)若不做任何操作直接退出，則MongoDB會(huì)刪除該數(shù)據(jù)庫(kù))

db.todos.insert({id:1,name:"reco"})
db.todos.insert({id:2,name:"rita"})

查詢：

db.todos.find()

{ "_id" : ObjectId("5b727c0846b6c71a98d3af52"), "id" : 1, "name" : "reco" }
{ "_id" : ObjectId("5b727c7046b6c71a98d3af53"), "id" : 2, "name" : "reta" }

刪除記錄：

db.todo.remove({id:1})

刪除數(shù)據(jù)庫(kù)

db.todo.drop()

使用nodejs方式訪問(wèn)Mongodb

使用nodejs執(zhí)行類似Shell對(duì)對(duì)象的CRD,代碼如下：

var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/todos";
MongoClient.connect(url, function(err, db) {
 if (err) throw err;
 console.log("Database created!");
 var dbo = db.db("todos");
 // var myobj = { id: 1, name: "reco" };
 // dbo.collection("todo").insertOne(myobj, function(err, res) {
 // if (err) throw err;
 // console.log("1 document inserted");
 // db.close();
 // });
 var myobj = [
 { id: 1, name: 'reco'},
 { id: 2, name: 'rita'},
 ];
 dbo.collection("todo").insertMany(myobj, function(err, res) {
 if (err) throw err;
 console.log("Number of documents inserted: " + res.insertedCount);
 dbo.collection("todo").find({}).toArray(function(err, result) {
 if (err) throw err;
 console.log(result);
 var myquery = { id: 1 };
 dbo.collection("todo").deleteMany(myquery, function(err, obj) {
 if (err) throw err;
 console.log("document deleted");
 db.close();
 });
 }); 
 });
})

代碼非常簡(jiǎn)單，無(wú)需更多解釋。此代碼使用了mongodb模塊，需要首先安裝：

npm init -y
npm i mongodb --save

然后使用node index.js運(yùn)行即可看到效果:

Database created!
Number of documents inserted: 2
[ { _id: 5b72ab9e3245f169ef5f43d2, id: 1, name: 'reco' },
 { _id: 5b72ab9e3245f169ef5f43d3, id: 2, name: 'rita' } ]
document deleted

利用高級(jí)異步特性

使用Await/Async特性，可以有效的減少代碼中的回調(diào)地獄現(xiàn)象。同樣的功能，可以使用這樣的代碼:

const MongoClient = require('mongodb').MongoClient;
const connectionString = 'mongodb://localhost:27017';
(async () => {
 const client = await MongoClient.connect(connectionString,
  { useNewUrlParser: true });
 const dbo = client.db('todos');
 try {
  var res = await dbo.collection('todo').insertMany(
  [{id:1,name:"reco"}, {id:2,name:"rita"}]);
  console.log("Number of documents inserted: " + res.insertedCount);
  var r = await dbo.collection("todo").find().toArray()
  console.log(r);
  var myquery = { id: 1 };
 var r = await dbo.collection("todo").deleteMany(myquery)
 console.log("document deleted");
 }
 finally {
  client.close();
 }
})().catch(err => console.error(err));

執(zhí)行此代碼，輸出如下：

Number of documents inserted: 2
[ { _id: 5b72ae8a1c674a6ac1c5aa6e, id: 1, name: 'reco' },
{ _id: 5b72ae8a1c674a6ac1c5aa6f, id: 2, name: 'rita' } ]
document deleted

總結(jié)：

以上就是這篇文章的全部?jī)?nèi)容了，希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，如果有疑問(wèn)大家可以留言交流，謝謝大家對(duì)腳本之家的支持。

您可能感興趣的文章: