Nodejs：使用Mongodb存储和提供后端CRD服务-白红宇

本文会把一个对象todo对象（有属性{id，name})存储到Mongodb，做查询删除的测试（Create Remove Delete = CRD）。这个测试包括使用Mongodb Shell，使用CallBack古典风格的访问代码，以及使用Await/Async的现代风格的代码。完成这个这个验证后，就可以掌握最初步的Mongodb了。

我使用的Nodejs是10.7 。操作系统环境为Mac OS X High Sierra。

准备环境

安装和运行Mongodb Daemon

brew install mongodbmongodb复制代码

访问验证

首先执行Mongodb Shell:

mongo复制代码

输入命令，查询数据库清单：

> show dbslocal           0.000GB复制代码

创建一个数据库

use todos复制代码

(若database不存在，则会创建一个，此时若不做任何操作直接退出，则MongoDB会删除该数据库)

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})复制代码

删除数据库

db.todo.drop()复制代码

使用nodejs方式访问Mongodb

使用nodejs执行类似Shell对对象的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();		  });	  });      });})复制代码

代码非常简单，无需更多解释。此代码使用了mongodb模块，需要首先安装：

npm init -ynpm i mongodb --save复制代码

然后使用node index.js运行即可看到效果:

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

利用高级异步特性

使用Await/Async特性，可以有效的减少代码中的回调地狱现象。同样的功能，可以使用这样的代码:

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));复制代码

执行此代码，输出如下：

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