Node.js 連線 MongoDB
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/itread01";
MongoClient.connect(url, function(err, db) {
if (err) throw err;
console.log("資料庫已建立!");
db.close();
});
建立集合
我們可以使用 createCollection() 方法來建立集合：
建立集合
var MongoClient = require('mongodb').MongoClient;
var url = 'mongodb://localhost:27017/itread01';
MongoClient.connect(url, function (err, db) {
if (err) throw err;
console.log('資料庫已建立');
var dbase = db.db("itread01");
dbase.createCollection('site', function (err, res) {
if (err) throw err;
console.log("建立集合!");
db.close();
});
});
資料庫操作( CURD )
與 MySQL 不同的是 MongoDB 會自動建立資料庫和集合，所以使用前我們不需要手動去建立。
插入資料
以下例項我們連線資料庫 itread01 的 site 表，並插入一條資料條資料，使用 insertOne()：
插入一條資料
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, function(err, db) {
if (err) throw err;
var dbo = db.db("itread01");
var myobj = { name: "入門教學", url: "www.itread01" };
dbo.collection("site").insertOne(myobj, function(err, res) {
if (err) throw err;
console.log("文件插入成功");
db.close();
});
});
執行以下命令輸出就結果為：
$ node test.js 文件插入成功
從輸出結果來看，資料已插入成功。
我們也可以開啟 MongoDB 的客戶端檢視資料，如：
> show dbs
itread01 0.000GB # 自動建立了 itread01 資料庫
> show tables
site # 自動建立了 site 集合（資料表）
> db.site.find()
{ "_id" : ObjectId("5a794e36763eb821b24db854"), "name" : "入門教學", "url" : "www.itread01" }
>
如果要插入多條資料可以使用 insertMany()：
插入多條資料
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, function(err, db) {
if (err) throw err;
var dbo = db.db("itread01");
var myobj = [
{ name: '菜鳥工具', url: 'https://c.itread01.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, function(err, db) {
if (err) throw err;
var dbo = db.db("itread01");
dbo.collection("site"). find({}).toArray(function(err, result) { // 返回集合中所有資料
if (err) throw err;
console.log(result);
db.close();
});
});
以下例項檢索 name 為 "入門教學" 的例項：
查詢指定條件的資料
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, function(err, db) {
if (err) throw err;
var dbo = db.db("itread01");
var whereStr = {"name":'入門教學'}; // 查詢條件
dbo.collection("site").find(whereStr).toArray(function(err, result) {
if (err) throw err;
console.log(result);
db.close();
});
});
執行以下命令輸出就結果為：
[ { _id: 5a794e36763eb821b24db854,
name: '入門教學',
url: 'www.itread01' } ]
更新資料
我們也可以對資料庫的資料進行修改，以下例項將 name 為 "入門教學" 的 url 改為 https://www.itread01.com：
更新一條資料
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, function(err, db) {
if (err) throw err;
var dbo = db.db("itread01");
var whereStr = {"name":'入門教學'}; // 查詢條件
var updateStr = {$set: { "url" : "https://www.itread01.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" : "入門教學",
"url" : "https://www.itread01.com" // 已修改為 https
}
如果要更新所有符合條的文件資料可以使用 updateMany()：
更新多條資料
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, function(err, db) {
if (err) throw err;
var dbo = db.db("itread01");
var whereStr = {"type":'en'}; // 查詢條件
var updateStr = {$set: { "url" : "https://www.itread01.com" }};
dbo.collection("site").updateMany(whereStr, updateStr, function(err, res) {
if (err) throw err;
console.log(res.result.nModified + " 條文件被更新");
db.close();
});
});
result.nModified 為更新的條數。
刪除資料
以下例項將 name 為 "入門教學" 的資料刪除 :
刪除一條資料
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, function(err, db) {
if (err) throw err;
var dbo = db.db("itread01");
var whereStr = {"name":'入門教學'}; // 查詢條件
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, function(err, db) {
if (err) throw err;
var dbo = db.db("itread01");
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, function(err, db) {
if (err) throw err;
var dbo = db.db("itread01");
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, function(err, db) {
if (err) throw err;
var dbo = db.db("itread01");
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, function(err, db) {
if (err) throw err;
var dbo = db.db("itread01");
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, function(err, db) {
if (err) throw err;
var dbo = db.db("itread01");
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, function(err, db) {
if (err) throw err;
var dbo = db.db("itread01");
// 刪除 test 集合
dbo.collection("test").drop(function(err, delOK) { // 執行成功 delOK 返回 true，否則返回 false
if (err) throw err;
if (delOK) console.log("集合已刪除");
db.close();
});
});
使用 Promise
Promise 是一個 ECMAScript 6 提供的類，目的是更加優雅地書寫複雜的非同步任務。
如果你還不瞭解 Promise，可以參考 JavaScript Promise。
以下例項使用 Promise 建立集合：
例項
const MongoClient = require("mongodb").MongoClient;
const url = "mongodb://localhost/itread01";
MongoClient.connect(url).then((conn) => {
console.log("資料庫已連線");
var dbase = conn.db("itread01");
dbase.createCollection("site").then((res) => {
console.log("已建立集合");
}).catch((err) => {
console.log("資料庫操作錯誤");
}).finally(() => {
conn.close();
});
}).catch((err) => {
console.log("資料庫連線失敗");
});
Promise 資料操作
現在我們在一個程式中實現四個連續操作：增加 、查詢 、更改 、刪除。
例項
const MongoClient = require("mongodb").MongoClient;
const url = "mongodb://localhost/";
MongoClient.connect(url).then((conn) => {
console.log("資料庫已連線");
const test = conn.db("testdb").collection("test");
// 增加
test.insertOne({ "site": "itread01.com" }).then((res) => {
// 查詢
return test.find().toArray().then((arr) => {
console.log(arr);
});
}).then(() => {
// 更改
return test.updateMany({ "site": "itread01.com" },
{ $set: { "site": "example.com" } });
}).then((res) => {
// 查詢
return test.find().toArray().then((arr) => {
console.log(arr);
});
}).then(() => {
// 刪除
return test.deleteMany({ "site": "example.com" });
}).then((res) => {
// 查詢
return test.find().toArray().then((arr) => {
console.log(arr);
});
}).catch((err) => {
console.log("資料操作失敗" + err.message);
}).finally(() => {
conn.close();
});
}).catch((err) => {
console.log("資料庫連線失敗");
});
執行結果：
資料庫已連線
[ { _id: 5f1664966833e531d83d3ac6, site: 'itread01.com' } ]
[ { _id: 5f1664966833e531d83d3ac6, site: 'example.com' } ]
[]
用非同步函式實現相同的資料操作
例項
const MongoClient = require("mongodb").MongoClient;
const url = "mongodb://localhost/";
async function dataOperate() {
var conn = null;
try {
conn = await MongoClient.connect(url);
console.log("資料庫已連線");
const test = conn.db("testdb").collection("test");
// 增加
await test.insertOne({ "site": "itread01.com" });
// 查詢
var arr = await test.find().toArray();
console.log(arr);
// 更改
await test.updateMany({ "site": "itread01.com" },
{ $set: { "site": "example.com" } });
// 查詢
arr = await test.find().toArray();
console.log(arr);
// 刪除
await test.deleteMany({ "site": "example.com" });
// 查詢
arr = await test.find().toArray();
console.log(arr);
} catch (err) {
console.log("錯誤：" + err.message);
} finally {
if (conn != null) conn.close();
}
}
dataOperate();
執行結果：
資料庫已連線
[ { _id: 5f169006a2780f0cd4ea640b, site: 'itread01.com' } ]
[ { _id: 5f169006a2780f0cd4ea640b, site: 'example.com' } ]
[]執行結果完全一樣。
很顯然，非同步函式是一種非常良好的程式設計風格，在多次使用非同步操作的時候非常實用。
但是請勿在低於 7.6.0 版本的 node.js 上使用非同步函式。