MongoDB是一种文档导向数据库管理系统，由C++撰写而成。
本章节我们将为大家介绍如何使用 Node.js 来连接 MongoDB，并对数据库进行操作。
如果你还没有 MongoDB 的基本知识，可以参考我们的教程：MongoDB 教程

安装驱动

本教程使用了 淘宝定制的 cnpm 命令 进行安装：

  1. npm install -g cnpm --registry=https://registry.npm.taobao.org
  3. cnpm install mongodb

接下来我们来实现增删改查功能。

创建数据库

要在 MongoDB 中创建一个数据库，首先我们需要创建一个 MongoClient 对象，然后配置好指定的 URL 和 端口号。
如果数据库不存在，MongoDB 将创建数据库并建立连接。

  1. var MongoClient = require('mongodb').MongoClient
  3. var url = "mongodb://localhost:27017/ken"
  5. MongoClient.connect(url, function (err, db) {
  6.   if (err) throw err
  7.   console.log("数据库已创建!")
  8.   db.close()
  9. })

创建集合

我们可以使用 createCollection() 方法来创建集合：

  1. var MongoClient = require('mongodb').MongoClient
  3. var url = "mongodb://localhost:27017/ken"
  4. MongoClient.connect(url, function (err, db) {
  5.   if (err) throw err;
  6.   console.log('数据库已创建')
  7.   var dbase = db.db("runoob")
  8.   dbase.createCollection('site', function (err, res) {
  9.     if (err) throw err
  10.     console.log("创建集合!")
  11.     db.close()
  12.   })
  13. })

数据库操作( CURD )

与 MySQL 不同的是 MongoDB 会自动创建数据库和集合，所以使用前我们不需要手动去创建。

插入数据

以下实例我们连接数据库 runoob 的 site 表，并插入一条数据条数据，使用 insertOne()：

  1. var MongoClient = require('mongodb').MongoClient;
  2. var url = "mongodb://localhost:27017/";
  4. MongoClient.connect(url, function(err, db) {
  5.     if (err) throw err;
  6.     var dbo = db.db("runoob");
  7.     var myobj = { name: "菜鸟教程", url: "www.runoob" };
  8.     dbo.collection("site").insertOne(myobj, function(err, res) {
  9.         if (err) throw err;
  10.         console.log("文档插入成功");
  11.         db.close();
  12.     });
  13. });

从输出结果来看，数据已插入成功。
我们也可以打开 MongoDB 的客户端查看数据，如：

  1. > show dbs
  2. runoob  0.000GB          # 自动创建了 runoob 数据库
  3. > show tables
  4. site                     # 自动创建了 site 集合（数据表）
  5. > db.site.find()
  6. { "_id" : ObjectId("5a794e36763eb821b24db854"), "name" : "菜鸟教程", "url" : "www.runoob" }
  7. >

如果要插入多条数据可以使用 insertMany()：

  1. var MongoClient = require('mongodb').MongoClient
  2. var url = "mongodb://localhost:27017/"
  4. MongoClient.connect(url, function (err, db) {
  5.   if (err) throw err
  6.   var dbo = db.db("runoob")
  7.   var myobj = [
  8.     { name: '菜鸟工具', url: 'https://c.runoob.com', type: 'cn' },
  9.     { name: 'Google', url: 'https://www.google.com', type: 'en' },
  10.     { name: 'Facebook', url: 'https://www.google.com', type: 'en' }
  11.   ]
  12.   dbo.collection("site").insertMany(myobj, function (err, res) {
  13.     if (err) throw err
  14.     console.log("插入的文档数量为: " + res.insertedCount)
  15.     db.close()
  16.   })
  17. })

res.insertedCount 为插入的条数。

查询数据

可以使用 find() 来查找数据, find() 可以返回匹配条件的所有数据。 如果未指定条件，find() 返回集合中的所有数据。

  1. var MongoClient = require('mongodb').MongoClient
  2. var url = "mongodb://localhost:27017/"
  4. MongoClient.connect(url, function (err, db) {
  5.   if (err) throw err
  6.   var dbo = db.db("runoob")
  7.   dbo.collection("site").find({}).toArray(function (err, result) { // 返回集合中所有数据
  8.     if (err) throw err
  9.     console.log(result)
  10.     db.close()
  11.   })
  12. })

以下实例检索 name 为 “菜鸟教程” 的实例：

  1. var MongoClient = require('mongodb').MongoClient
  2. var url = "mongodb://localhost:27017/"
  4. MongoClient.connect(url, function (err, db) {
  5.   if (err) throw err
  6.   var dbo = db.db("runoob")
  7.   var whereStr = { "name": '菜鸟教程' }  // 查询条件
  8.   dbo.collection("site").find(whereStr).toArray(function (err, result) {
  9.     if (err) throw err
  10.     console.log(result)
  11.     db.close()
  12.   })
  13. })

执行以下命令输出就结果为：

  1. [ { _id: 5a794e36763eb821b24db854,
  2.     name: '菜鸟教程',
  3.     url: 'www.runoob' } ]

更新数据

我们也可以对数据库的数据进行修改，以下实例将 name 为 “菜鸟教程” 的 url 改为 https://www.runoob.com：

  1. var MongoClient = require('mongodb').MongoClient
  2. var url = "mongodb://localhost:27017/"
  4. MongoClient.connect(url, function (err, db) {
  5.   if (err) throw err
  6.   var dbo = db.db("runoob")
  7.   var whereStr = { "name": '菜鸟教程' }  // 查询条件
  8.   var updateStr = { $set: { "url": "https://www.runoob.com" } }
  9.   dbo.collection("site").updateOne(whereStr, updateStr, function (err, res) {
  10.     if (err) throw err
  11.     console.log("文档更新成功")
  12.     db.close()
  13.   })
  14. })

执行成功后，进入 mongo 管理工具查看数据已修改：

  1. > db.site.find().pretty()
  2. {
  3.     "_id" : ObjectId("5a794e36763eb821b24db854"),
  4.     "name" : "菜鸟教程",
  5.     "url" : "https://www.runoob.com"     // 已修改为 https
  6. }

如果要更新所有符合条的文档数据可以使用 updateMany()：

  1. var MongoClient = require('mongodb').MongoClient
  2. var url = "mongodb://localhost:27017/"
  4. MongoClient.connect(url, function (err, db) {
  5.   if (err) throw err
  6.   var dbo = db.db("runoob")
  7.   var whereStr = { "type": 'en' }  // 查询条件
  8.   var updateStr = { $set: { "url": "https://www.runoob.com" } }
  9.   dbo.collection("site").updateMany(whereStr, updateStr, function (err, res) {
  10.     if (err) throw err
  11.     console.log(res.result.nModified + " 条文档被更新")
  12.     db.close()
  13.   })
  14. })

result.nModified 为更新的条数。

删除数据

以下实例将 name 为 “菜鸟教程” 的数据删除 :

  1. var MongoClient = require('mongodb').MongoClient
  2. var url = "mongodb://localhost:27017/"
  4. MongoClient.connect(url, function (err, db) {
  5.   if (err) throw err
  6.   var dbo = db.db("runoob")
  7.   var whereStr = { "name": '菜鸟教程' }  // 查询条件
  8.   dbo.collection("site").deleteOne(whereStr, function (err, obj) {
  9.     if (err) throw err
  10.     console.log("文档删除成功")
  11.     db.close()
  12.   })
  13. })

执行成功后，进入 mongo 管理工具查看数据已删除：

  1. > db.site.find()
  2. >

如果要删除多条语句可以使用 deleteMany() 方法
以下实例将 type 为 en 的所有数据删除 :

  1. var MongoClient = require('mongodb').MongoClient
  2. var url = "mongodb://localhost:27017/"
  4. MongoClient.connect(url, function (err, db) {
  5.   if (err) throw err
  6.   var dbo = db.db("runoob")
  7.   var whereStr = { type: "en" }  // 查询条件
  8.   dbo.collection("site").deleteMany(whereStr, function (err, obj) {
  9.     if (err) throw err
  10.     console.log(obj.result.n + " 条文档被删除")
  11.     db.close()
  12.   })
  13. })

obj.result.n 删除的条数。

排序

排序 使用 sort() 方法，该方法接受一个参数，规定是升序(1)还是降序(-1)。
例如：

  1. { type: 1 }  // 按 type 字段升序
  2. { type: -1 } // 按 type 字段降序

按 type 升序排列:

  1. var MongoClient = require('mongodb').MongoClient
  2. var url = "mongodb://localhost:27017/"
  4. MongoClient.connect(url, function (err, db) {
  5.   if (err) throw err
  6.   var dbo = db.db("runoob")
  7.   var mysort = { type: 1 }
  8.   dbo.collection("site").find().sort(mysort).toArray(function (err, result) {
  9.     if (err) throw err
  10.     console.log(result)
  11.     db.close()
  12.   })
  13. })

查询分页

如果要设置指定的返回条数可以使用 limit() 方法，该方法只接受一个参数，指定了返回的条数。

  1. var MongoClient = require('mongodb').MongoClient
  2. var url = "mongodb://localhost:27017/"
  4. MongoClient.connect(url, function (err, db) {
  5.   if (err) throw err
  6.   var dbo = db.db("runoob")
  7.   dbo.collection("site").find().limit(2).toArray(function (err, result) {
  8.     if (err) throw err
  9.     console.log(result)
  10.     db.close()
  11.   })
  12. })

如果要指定跳过的条数，可以使用 skip() 方法。

  1. var MongoClient = require('mongodb').MongoClient
  2. var url = "mongodb://localhost:27017/"
  4. MongoClient.connect(url, function (err, db) {
  5.   if (err) throw err
  6.   var dbo = db.db("runoob")
  7.   dbo.collection("site").find().skip(2).limit(2).toArray(function (err, result) {
  8.     if (err) throw err
  9.     console.log(result)
  10.     db.close()
  11.   })
  12. })

连接操作

mongoDB 不是一个关系型数据库，但我们可以使用 $lookup 来实现左连接。
例如我们有两个集合数据分别为：
集合1：orders

  1. [
  2.   { _id: 1, product_id: 154, status: 1 }
  3. ]

集合2：products

  1. [
  2.   { _id: 154, name: '笔记本电脑' },
  3.   { _id: 155, name: '耳机' },
  4.   { _id: 156, name: '台式电脑' }
  5. ]

$lookup 实现左连接

  1. var MongoClient = require('mongodb').MongoClient;
  2. var url = "mongodb://127.0.0.1:27017/";
  4. MongoClient.connect(url, function(err, db) {
  5.   if (err) throw err;
  6.   var dbo = db.db("runoob");
  7.   dbo.collection('orders').aggregate([
  8.     { $lookup:
  9.        {
  10.          from: 'products',            // 右集合
  11.          localField: 'product_id',    // 左集合 join 字段
  12.          foreignField: '_id',         // 右集合 join 字段
  13.          as: 'orderdetails'           // 新生成字段（类型array）
  14.        }
  15.      }
  16.     ]).toArray(function(err, res) {
  17.     if (err) throw err;
  18.     console.log(JSON.stringify(res));
  19.     db.close();
  20.   });
  21. });

删除集合

我们可以使用 drop() 方法来删除集合：

  1. var MongoClient = require('mongodb').MongoClient
  2. var url = "mongodb://localhost:27017/"
  4. MongoClient.connect(url, function (err, db) {
  5.   if (err) throw err
  6.   var dbo = db.db("runoob")
  7.   // 删除 test 集合
  8.   dbo.collection("test").drop(function (err, delOK) {  // 执行成功 delOK 返回 true，否则返回 false
  9.     if (err) throw err
  10.     if (delOK) console.log("集合已删除")
  11.     db.close()
  12.   })
  13. })

使用 Promise

Promise 是一个 ECMAScript 6 提供的类，目的是更加优雅地书写复杂的异步任务。
如果你还不了解 Promise，可以参考 JavaScript Promise。
以下实例使用 Promise 创建集合：

  1. const MongoClient = require("mongodb").MongoClient
  3. const url = "mongodb://localhost/runoob"
  4. MongoClient.connect(url).then((conn) => {
  5.   console.log("数据库已连接")
  6.   var dbase = conn.db("runoob")
  7.   dbase.createCollection("site").then((res) => {
  8.     console.log("已创建集合")
  9.   }).catch((err) => {
  10.     console.log("数据库操作错误")
  11.   }).finally(() => {
  12.     conn.close()
  13.   })
  14. }).catch((err) => {
  15.   console.log("数据库连接失败")
  16. })

Promise 数据操作

现在我们在一个程序中实现四个连续操作：增加 、查询 、更改 、删除。

  1. const MongoClient = require("mongodb").MongoClient
  3. const url = "mongodb://localhost/"
  4. MongoClient.connect(url).then((conn) => {
  5.   console.log("数据库已连接")
  6.   const test = conn.db("testdb").collection("test")
  7.   // 增加
  8.   test.insertOne({ "site": "runoob.com" }).then((res) => {
  9.     // 查询
  10.     return test.find().toArray().then((arr) => {
  11.       console.log(arr)
  12.     })
  13.   }).then(() => {
  14.     // 更改
  15.     return test.updateMany({ "site": "runoob.com" },
  16.       { $set: { "site": "example.com" } })
  17.   }).then((res) => {
  18.     // 查询
  19.     return test.find().toArray().then((arr) => {
  20.       console.log(arr)
  21.     })
  22.   }).then(() => {
  23.     // 删除
  24.     return test.deleteMany({ "site": "example.com" })
  25.   }).then((res) => {
  26.     // 查询
  27.     return test.find().toArray().then((arr) => {
  28.       console.log(arr)
  29.     })
  30.   }).catch((err) => {
  31.     console.log("数据操作失败" + err.message)
  32.   }).finally(() => {
  33.     conn.close()
  34.   })
  35. }).catch((err) => {
  36.   console.log("数据库连接失败")
  37. })

用异步函数实现相同的数据操作

  1. const MongoClient = require("mongodb").MongoClient
  3. const url = "mongodb://localhost/"
  4. async function dataOperate() {
  5.   var conn = null
  6.   try {
  7.     conn = await MongoClient.connect(url)
  8.     console.log("数据库已连接")
  9.     const test = conn.db("testdb").collection("test")
  10.     // 增加
  11.     await test.insertOne({ "site": "runoob.com" })
  12.     // 查询
  13.     var arr = await test.find().toArray()
  14.     console.log(arr)
  15.     // 更改
  16.     await test.updateMany({ "site": "runoob.com" },
  17.       { $set: { "site": "example.com" } })
  18.     // 查询
  19.     arr = await test.find().toArray()
  20.     console.log(arr)
  21.     // 删除
  22.     await test.deleteMany({ "site": "example.com" })
  23.     // 查询
  24.     arr = await test.find().toArray()
  25.     console.log(arr)
  26.   } catch (err) {
  27.     console.log("错误：" + err.message)
  28.   } finally {
  29.     if (conn != null) conn.close()
  30.   }
  31. }
  33. dataOperate()

运行结果完全一样。
很显然，异步函数是一种非常良好的编程风格，在多次使用异步操作的时候非常实用。
但是请勿在低于 7.6.0 版本的 node.js 上使用异步函数。