Node.js：鏈接 MongoDB

時間  2019-11-10
標籤 node.js node 鏈接 mongodb 欄目 Node.js 简体版
原文   原文鏈接
ylbtech-Node.js：鏈接 MongoDB

 

1.返回頂部
一、

Node.js 鏈接 MongoDB

MongoDB是一種文檔導向數據庫管理系統，由C++撰寫而成。html

本章節咱們將爲你們介紹如何使用 Node.js 來鏈接 MongoDB，並對數據庫進行操做。node

若是你尚未 MongoDB 的基本知識，能夠參考咱們的教程：MongoDB 教程。mongodb

安裝驅動

本教程使用了淘寶定製的 cnpm 命令進行安裝：數據庫

$ cnpm install mongodb

接下來咱們來實現增刪改查功能。npm

建立數據庫

要在 MongoDB 中建立一個數據庫，首先咱們須要建立一個 MongoClient 對象，而後配置好指定的 URL 和 端口號。工具

若是數據庫不存在，MongoDB 將建立數據庫並創建鏈接。ui

建立鏈接

var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/runoob";
 
MongoClient.connect(url, function(err, db) {
  if (err) throw err;
  console.log("數據庫已建立!");
  db.close();
});

建立集合

咱們可使用 createCollection() 方法來建立集合：google

建立集合

var MongoClient = require('mongodb').MongoClient;
var url = 'mongodb://localhost:27017/runoob';
MongoClient.connect(url, function (err, db) {
    if (err) throw err;
    console.log('數據庫已建立');
    var dbase = db.db("runoob");
    dbase.createCollection('site', function (err, res) {
        if (err) throw err;
        console.log("建立集合!");
        db.close();
    });
});

數據庫操做( CURD )

與 MySQL 不一樣的是 MongoDB 會自動建立數據庫和集合，因此使用前咱們不須要手動去建立。url

插入數據

如下實例咱們鏈接數據庫 runoob 的 site 表，並插入一條數據條數據，使用 insertOne()：spa

插入一條數據

var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
 
MongoClient.connect(url, function(err, db) {
    if (err) throw err;
    var dbo = db.db("runoob");
    var myobj = { name: "菜鳥教程", url: "www.runoob" };
    dbo.collection("site").insertOne(myobj, function(err, res) {
        if (err) throw err;
        console.log("文檔插入成功");
        db.close();
    });
});

執行如下命令輸出就結果爲：

$ node test.js 文檔插入成功

從輸出結果來看，數據已插入成功。

咱們也能夠打開 MongoDB 的客戶端查看數據，如：

> show dbs runoob 0.000GB # 自動建立了 runoob 數據庫 > show tables site # 自動建立了 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) throw err;
    var dbo = db.db("runoob");
    var myobj =  [
        { name: '菜鳥工具', url: 'https://c.runoob.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("runoob");
    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("runoob");
     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.runoob' } ]

更新數據

咱們也能夠對數據庫的數據進行修改，如下實例將 name 爲 "菜鳥教程" 的 url 改成 https://www.runoob.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("runoob");
    var whereStr = {"name":'菜鳥教程'};  // 查詢條件
    var updateStr = {$set: { "url" : "https://www.runoob.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.runoob.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("runoob");
    var whereStr = {"type":'en'};  // 查詢條件
    var updateStr = {$set: { "url" : "https://www.runoob.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("runoob");
    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("runoob");
    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("runoob");
    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("runoob");
    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("runoob");
    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("runoob");
    dbo.collection('orders').aggregate([
        { $lookup:
            {
                from: 'products',           # 右集合
                localField: 'product_id',   # 左集合 join字段
                foreignField: '_id',        # 右集合 join字段
                as: 'orderdetails'          # 新生成字段（類型array）
            }
        }
    ], 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("runoob");
    // 刪除 test 集合
    dbo.collection("test").drop(function(err, delOK) {  // 執行成功 delOK 返回 true，不然返回 false
        if (err) throw err;
        if (delOK) console.log("集合已刪除");
        db.close();
    });
});
二、
2.返回頂部
 
3.返回頂部
 
4.返回頂部
 
5.返回頂部
一、
二、
 
6.返回頂部
 
warn 做者：ylbtech
出處：http://ylbtech.cnblogs.com/
本文版權歸做者和博客園共有，歡迎轉載，但未經做者贊成必須保留此段聲明，且在文章頁面明顯位置給出原文鏈接，不然保留追究法律責任的權利。
相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程