MongoDB是一種文檔導向數據庫管理系統，由C++撰寫而成。本章節我們將為大家介紹如何使用 Node.js 來連接 MongoDB，並對數據庫進行操作。
1、安裝驅動
本教程使用了淘寶定製的 cnpm 命令進行安裝：
$ cnpm install mongodb
接下來我們來實現增刪改查功能。
2、創建數據庫
要在 MongoDB 中創建一個數據庫，首先我們需要創建一個 MongoClient 對象，然後配置好指定的 URL 和 端口號。如果數據庫不存在，MongoDB 將創建數據庫並建立連接。
1）創建連接
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/runoob";
MongoClient.connect(url, function(err, db){
if(err)throwerr;
console.log("數據庫已創建!");
db.close();
});
2）創建集合
我們可以使用 createCollection() 方法來創建集合：
var MongoClient = require('mongodb').MongoClient;
var url = 'mongodb://localhost:27017/runoob';
MongoClient.connect(url, function(err, db){
if(err)throwerr;
console.log('數據庫已創建');
var dbase = db.db("dtinone");
dbase.createCollection('site', function(err, res){
if(err)throwerr;
console.log("創建集合!");
db.close();
});
});
3、數據庫操作( CURD )
與 MySQL 不同的是 MongoDB 會自動創建數據庫和集合，所以使用前我們不需要手動去創建。
1）插入數據
以下實例我們連接數據庫 runoob 的 site 表，並插入一條數據條數據，使用 insertOne()：
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, function(err, db){
if(err)throwerr;
var dbo = db.db("dtinone");
var myobj = {name: "加米穀大數據", url: "www.dtinone"};
dbo.collection("site").insertOne(myobj, function(err, res){
if(err)throwerr;
console.log("文檔插入成功");
db.close();
});
});
執行以下命令輸出就結果為：
$ node test.js文檔插入成功
從輸出結果來看，數據已插入成功。
我們也可以打開 MongoDB 的客戶端查看數據，如：
> show dbsrunoob 0.000GB # 自動創建了 runoob 數據庫> show tablessite # 自動創建了 site 集合（數據表）> db.site.find(){ "_id" : ObjectId("5a794e36763eb821b24db854"), "name" : "加米穀大數據", "url" : "www.runoob" }>如果要插入多條數據可以使用 insertMany()：
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, function(err, db){
if(err)throwerr;
var dbo = db.db("dtinone");
var myobj = [
{name: '加米穀工具', url: 'https://c.dtinone.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)throwerr;
console.log("插入的文檔數量為: " + res.insertedCount);
db.close();
});
});
res.insertedCount 為插入的條數。
2）查詢數據
可以使用 find() 來查找數據, find() 可以返回匹配條件的所有數據。 如果未指定條件，find() 返回集合中的所有數據。
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, function(err, db){
if(err)throwerr;
var dbo = db.db("dtinone");
dbo.collection("site"). find({}).toArray(function(err, result){// 返回集合中所有數據
if(err)throwerr;
console.log(result);
db.close();
});
});
以下實例檢索 name 為 "加米穀大數據" 的實例：
3）查詢指定條件數據
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, function(err, db){
if(err)throwerr;
var dbo = db.db("dtinone");
var whereStr = {"name":'加米穀大數據'}; // 查詢條件
dbo.collection("site").find(whereStr).toArray(function(err, result){
if(err)throwerr;
console.log(result);
db.close();
});
});
執行以下命令輸出就結果為：
[ { _id: 5a794e36763eb821b24db854, name: '加米穀大數據', url: 'www.runoob' } ]4）更新數據
我們也可以對數據庫的數據進行修改，以下實例將 name 為 "加米穀大數據" 的 url 改為 https://www.dtinone.com：
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, function(err, db){
if(err)throwerr;
var dbo = db.db("dtinone");
var whereStr = {"name":'加米穀大數據'}; // 查詢條件
var updateStr = {$set: {"url" : "https://www.dtinone.com"}};
dbo.collection("site").updateOne(whereStr, updateStr, function(err, res){
if(err)throwerr;
console.log("文檔更新成功");
db.close();
});
});
執行成功後，進入 mongo 管理工具查看數據已修改：
> db.site.find().pretty(){ "_id" : ObjectId("5a794e36763eb821b24db854"), "name" : "加米穀大數據", "url" : "https://www.dtinone.com" // 已修改為 https}如果要更新所有符合條的文檔數據可以使用 updateMany()：
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, function(err, db){
if(err)throwerr;
var dbo = db.db("dtinone");
var whereStr = {"type":'en'}; // 查詢條件
var updateStr = {$set: {"url" : "https://www.dtinone.com"}};
dbo.collection("site").updateMany(whereStr, updateStr, function(err, res){
if(err)throwerr;
console.log(res.result.nModified + " 條文檔被更新");
db.close();
});
});
result.nModified 為更新的條數。
5）刪除數據
以下實例將 name 為 "加米穀大數據" 的數據刪除 :
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, function(err, db){
if(err)throwerr;
var dbo = db.db("dtinone");
var whereStr = {"name":'加米穀大數據'}; // 查詢條件
dbo.collection("site").deleteOne(whereStr, function(err, obj){
if(err)throwerr;
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)throwerr;
var dbo = db.db("dtinone");
var whereStr = {type: "en"}; // 查詢條件
dbo.collection("site").deleteMany(whereStr, function(err, obj){
if(err)throwerr;
console.log(obj.result.n + " 條文檔被刪除");
db.close();
});
});
obj.result.n 刪除的條數。
6）排序
排序 使用 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)throwerr;
var dbo = db.db("dtinone");
var mysort = {type: 1};
dbo.collection("site").find().sort(mysort).toArray(function(err, result){
if(err)throwerr;
console.log(result);
db.close();
});
});
7）查詢分頁
如果要設置指定的返回條數可以使用 limit() 方法，該方法只接受一個參數，指定了返回的條數。
var MongoClient = require('mongodb').MongoClient;
varurl = "mongodb://localhost:27017/";
MongoClient.connect(url, function(err, db){
if(err)throwerr;
var dbo = db.db("dtinone");
dbo.collection("site").find().limit(2).toArray(function(err, result){
if(err)throwerr;
console.log(result);
db.close();
});
});
如果要指定跳過的條數，可以使用 skip() 方法。
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, function(err, db){
if(err)throwerr;
var dbo = db.db("dtinone");
dbo.collection("site").find().skip(2).limit(2).toArray(function(err, result){
if(err)throwerr;
console.log(result);
db.close();
});
});
8）連接操作
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)throwerr;
var dbo = db.db("dtinone");
dbo.collection('orders').aggregate([
{ $lookup:
{
from: 'products', # 右集合
localField: 'product_id', # 左集合 join字段
foreignField: '_id', # 右集合 join字段
as: 'orderdetails' # 新生成字段（類型array）
}
}],
function(err, res){
if(err)throwerr;
console.log(JSON.stringify(res));
db.close();
});
9）刪除集合
我們可以使用 drop() 方法來刪除集合：
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
MongoClient.connect(url, function(err, db){
if(err)throwerr;
var dbo = db.db("dtinone"); // 刪除 test 集合
dbo.collection("test").drop(function(err, delOK){// 執行成功 delOK 返回 true，否則返回 falseif(err)throwerr;
if(delOK)
console.log("集合已刪除");
db.close();
});
});
閱讀更多 加米穀大數據 的文章
