主頁 > 企業開發 > Node.js 蠶食計劃(六)—— MongoDB + Koa 入門

Node.js 蠶食計劃(六)—— MongoDB + Koa 入門

2020-09-14 16:38:24 企業開發

一、安裝 MongoDB

1. 在 Windows 環境下安裝:

// Windows 7 / Server 2008 R2 以上的版本

打開官網鏈接 https://www.mongodb.com/try/download/community

在頁面中依次選擇 On-Premises => MongoDB Communtiy Server,然后選擇 Platform 為 Windows,最后下載并執行安裝包

 

1. 在 MacOS 安裝: 

也可以按照上面的方法下載安裝包,或者選擇 Download 按鈕旁的 Copy Link,通過 curl 命令安裝

不過還有另一種不需要打開 MongoDB 官網的辦法:直接使用 brew 安裝(參考鏈接)

首先 tab 倉庫

brew tap mongodb/brew

然后安裝社區版本

brew install mongodb-community

安裝的時候會自動創建組態檔:

  • 組態檔: /usr/local/etc/mongod.conf
  • 日志目錄: /usr/local/var/log/mongodb
  • 資料目錄: /usr/local/var/mongodb

可以用 mongod --version 命令來檢查是否安裝成功

如果能正常顯示當前版本,就說明安裝成功,可以直接進入下一節

 

如果提示 "command not found: mongod" ,就得手動配置環境變數

需要先找到 mongod 的安裝位置,由于安裝的版本不同,路徑不會完全一致,可以一步一步的來找:

先進入 Cellar 目錄:

cd /usr/local/Cellar

然后通過 ls 命令查看當前目錄下的檔案,然后進入帶有 mongodb 的檔案夾,然后逐步深入,直到進入 bin 檔案夾,使用 pwd 命令查看完整路徑

記下這個路徑備用,打開環境變陣列態檔

vim ~/.bash_profile

添加一行變數(把路徑改成自己的路徑)

export PATH=/usr/local/Cellar/mongodb-community/4.2.8/bin:${PATH}}

保存檔案,執行以下命令

source ~/.bash_profile

然后就可以使用 mongod 命令了

 

 

二、啟動 MongoDB

如果直接啟動

mongod

會直接報錯 Data directory /data/db not found

這是因為使用不帶引數的 mongod 命令會使用默認的資料目錄 /data/db

如果使用之前創建的組態檔啟動就不會有問題:

mongod --config /usr/local/etc/mongod.conf

如果覺得這樣的啟動命令很累贅,就創建一個 /data/db 目錄

sudo mkdir -p /data/db

然后就能使用 mongod 命令啟動了,

// 如果遇到 Address already in use 這個錯誤,是因為埠號占用,清理對應埠的 pid 即可

可以在瀏覽器訪問 localhost:27017 確認是否成功啟動

如果需要關閉服務器,可以使用 Crtl + C 組合鍵

 

這個啟動 mongod 的終端可以放在一邊了,新起一個終端,打開 MongoDB shell

mongo

注意這個命令不是 mongod

在啟動的 shell 里面輸入 help,查看可用的命令

如果不想使用命令列來操作 MongoDB,可以使用可視化工具,比如 Robomongo、Nosqlclient、Navicat

 

 

三、MongoDB 創建資料

接下來在 MongoDB 中插入資料,首先創建一個資料庫

use Movie

這里創建了一個名為 Movie 的資料庫,但這時的 Movie 資料庫還沒有資料,所以 show dbs 不會列出剛才創建的資料庫

 在當前資料庫中創建一個集合,并插入一條資料

db.createCollection("movies")
db.movies.insert({"name":"讓子彈飛","years":"2010","director": ["姜文"]})

注意: 和創建資料庫類似,在 MongoDB 中,創建集合后要再插入一個檔案,集合才會真正創建

當插入了具體的資料之后,資料庫才算創建完成,接下來了解一下基本的增刪改查

 

1. 新增資料

在 MongoDB 中可以使用 insert 向集合插入資料,每條新建的資料都會自動生成一個主鍵 _id

使用 insert 插入資料時,如果沒有攜帶主鍵 _id,則新增資料;

如果攜帶了 _id 且 _id 沒有重復,則新增一條自帶 _id 的資料(不會自動生成 _id);

如果攜帶了 _id 且 _id 沖突,則拋出“主鍵重復”的錯誤,保存失敗,

 

2. 查詢資料

在 MongoDB 中查詢資料一般使用 find 方法

db.movies.find().pretty()

這里的 pretty() 用來格式化查詢結果

在查詢條件中,還可以加入條件判斷

 

3. 更新資料

在 MongoDB 中使用 update 和 replaceOne 來更新集合中的檔案

其中 update() 可以接收三個引數

第一個引數為查詢條件,和上面的 find 類似;

第二個引數為運算子,比如 $set 用來設定新屬性;

第三個引數為配置項,暫時不提,

這里我先新增了一條資料,然后通過 update 修改了這條資料的 name

可以看到,只有 name 被修改了,years 并沒有發生變化,也就是說 update()$set 只會合并相應的欄位

如果需要替換整條資料,可以用 replaceOne()

  

4. 洗掉資料

可以使用 remove 來洗掉集合中的資料

該方法和 find 類似,都是接受一個查詢條件,然后從集合中洗掉查詢到的檔案

remove 的 query 引數是必填的,如果往 remove 方法中傳入的查詢條件為空物件 {},會洗掉整個集合的資料

另外, 可以使用 drop 來洗掉集合,dropDatabase 來洗掉資料庫

db.collection.drop()
db.dropDatabase()

關于 MongoDB 的介紹就到這里,深入了解可以參考 MongoDB 中文網 

 

 

四、在 Koa 中連接 MongoDB

先創建一個 Koa 專案,可以參考之前的文章《Node.js 蠶食計劃(五)—— Koa 基礎專案搭建》

在專案的根目錄創建一個 mongodb 目錄,然后在該目錄下新建  config.js,用來保存一些資料庫常量配置

// /mongodb/config.js

const dbUrl = 'mongodb://127.0.0.1:27017'; // 資料庫地址
const dbName = 'Movie'; //資料庫名稱

module.exports = {
  dbUrl,
  dbName
}

然后安裝 mongodb 中間件

yarn add mongodb

在 mongodb 目錄下創建一個 index.js,使用中間件連接 MongoDB 資料庫

// /mongodb/index.js

const { MongoClient, ObjectID}  = require('mongodb');
const { dbUrl, dbName } = require('./config');

// 連接資料庫
MongoClient.connect(dbUrl, (err, client) => {
    console.log("Connected successfully to server");
    const db = client.db(dbName);
    // db.close(); // 關閉連接
});

我的專案結構是這樣的,其中 app.js 是入口檔案

可以在 app.js 中 require('./mongodb') 直接引入剛才的 index.js,檢查一下是否能夠正常連接資料庫

啟動專案,如果在 MongoDB 的終端看到連接的提示,則表示成功連接資料庫

 

 

五、封裝 MongoDB 類

實際場景中肯定不會每次查詢都呼叫一次資料庫,所以需要封裝一個類,通過類的實體來操作資料庫 

// /mongodb/index.js

const { MongoClient, ObjectID } = require("mongodb");
const Config = require("./config");

class Db {
  static getInstance() {
    // 單例模式 解決多次實體化 實體不共享的問題
    if (!Db.instance) {
      Db.instance = new Db();
    }

    return Db.instance;
  }

  constructor() {
    this.dbClient = ""; //db物件
    this.connect(); // 實體化的時候就連接資料庫
  }

  connect() {
    // 連接資料庫
    return new Promise((resolve, reject) => {
      if (!this.dbClient) {
        //解決資料庫多次連接的問題
        MongoClient.connect(Config.dbUrl, { useUnifiedTopology: true }, (err, client) => {
          if (err) {
            reject(err);
            return;
          }
          this.dbClient = client.db(Config.dbName);
          resolve(this.dbClient);
        });
      } else {
        resolve(this.dbClient);
      }
    });
  }

  //查找操作 collection:表名 json:查找條件
  find(collection, json) {
    return new Promise((resolve, reject) => {
      this.connect().then((db) => {
        let result = db.collection(collection).find(json);
        result.toArray((err, docs) => {
          if (!err) {
            resolve(docs);
          } else {
            reject(err);
          }
        });
      });
    });
  }

  //新增操作
  insert(collection, json) {
    return new Promise((resolve, reject) => {
      this.connect().then((db) => {
        db.collection(collection).insertOne(json, (err, result) => {
          if (!err) {
            resolve(result);
          } else {
            reject(err);
          }
        });
      });
    });
  }

  //修改操作
  update(collection, json1, json2) {
    return new Promise((resolve, reject) => {
      this.connect().then((db) => {
        db.collection(collection).updateOne(
          json1,
          {
            $set: json2,
          },
          (err, result) => {
            if (!err) {
              resolve(result);
            } else {
              reject(err);
            }
          }
        );
      });
    });
  }

  //洗掉操作
  delete(collection, json) {
    return new Promise((resolve, reject) => {
      this.connect().then((db) => {
        db.collection(collection).removeOne(json, (err, result) => {
          if (!err) {
            resolve(result);
          } else {
            reject(err);
          }
        });
      });
    });
  }

  //在進行查詢或者洗掉操作的時候,我們一般都會通過id去進行操作,但是我們直接使用傳遞過來的id是不起作用的,需要使用mongodb提供的ObjectID方法,生成一個新的id去查詢,
  getObjectID(id) {
    return new ObjectID(id);
  }
}

module.exports = Db.getInstance();

// 代碼摘自 https://juejin.im/post/5e4765626fb9a07cad3b93dc#heading-24

封裝好了,在 app.js 試試

//...
const bodyParser = require('koa-bodyparser');
const DB = require('./mongodb');
//... app.use(bodyParser()); router.post('/save', async(ctx, next) => { const form = ctx.request.body; console.log('form------>', form); const result = await DB.insert('movies', form); // 新增 ctx.body = result; }); router.get('/list', async(ctx, next) => { const result = await DB.find('movies', {}); // 查詢 ctx.body = result; }); //...

上面引入了 koa-bodyparser 來處理 POST 請求的引數

然后寫了一個新增資料的 post 介面 /save,和查詢資料的 get 介面 /list

接下來先用 PostMan 測驗一下 /save 介面

這里傳的引數是 JSON 格式,需要在 Headers 中設定 Content-Type 為 application/json

如果設定為 application/x-www-form-urlencoded,就需要用 querystring 轉碼

 

保存成功之后,再試試 /list 介面

到這里一個簡單的后端服務就搭好了

但這里我們直接使用了 mongodb 中間件來連接資料庫,對資料庫的操作比較原始

一個工程化的后端專案,通常會設計 Controller 來管理 API,還會通過 Schema 來規范集合

這些都可以通過 使用 mongoose 來實作,在后面的文章中會介紹

 

參考資料:

《MongoDB 中文手冊》

《koa2 + jwt + mongodb入門實戰》

轉載請註明出處,本文鏈接:https://www.uj5u.com/qiye/36858.html

標籤:JavaScript

上一篇:JavaScript影片實體:旋轉的正三角形

下一篇:詳解JS中定時器setInterval和setTImeout的this指向問題

標籤雲
其他(157675) Python(38076) JavaScript(25376) Java(17977) C(15215) 區塊鏈(8255) C#(7972) AI(7469) 爪哇(7425) MySQL(7132) html(6777) 基礎類(6313) sql(6102) 熊猫(6058) PHP(5869) 数组(5741) R(5409) Linux(5327) 反应(5209) 腳本語言(PerlPython)(5129) 非技術區(4971) Android(4554) 数据框(4311) css(4259) 节点.js(4032) C語言(3288) json(3245) 列表(3129) 扑(3119) C++語言(3117) 安卓(2998) 打字稿(2995) VBA(2789) Java相關(2746) 疑難問題(2699) 细绳(2522) 單片機工控(2479) iOS(2429) ASP.NET(2402) MongoDB(2323) 麻木的(2285) 正则表达式(2254) 字典(2211) 循环(2198) 迅速(2185) 擅长(2169) 镖(2155) 功能(1967) .NET技术(1958) Web開發(1951) python-3.x(1918) HtmlCss(1915) 弹簧靴(1913) C++(1909) xml(1889) PostgreSQL(1872) .NETCore(1853) 谷歌表格(1846) Unity3D(1843) for循环(1842)

熱門瀏覽
  • IEEE1588PTP在數字化變電站時鐘同步方面的應用

    IEEE1588ptp在數字化變電站時鐘同步方面的應用 京準電子科技官微——ahjzsz 一、電力系統時間同步基本概況 隨著對IEC 61850標準研究的不斷深入,國內外學者提出基于IEC61850通信標準體系建設數字化變電站的發展思路。數字化變電站與常規變電站的顯著區別在于程序層傳統的電流/電壓互 ......

    uj5u.com 2020-09-10 03:51:52 more
  • HTTP request smuggling CL.TE

    CL.TE 簡介 前端通過Content-Length處理請求,通過反向代理或者負載均衡將請求轉發到后端,后端Transfer-Encoding優先級較高,以TE處理請求造成安全問題。 檢測 發送如下資料包 POST / HTTP/1.1 Host: ac391f7e1e9af821806e890 ......

    uj5u.com 2020-09-10 03:52:11 more
  • 網路滲透資料大全單——漏洞庫篇

    網路滲透資料大全單——漏洞庫篇漏洞庫 NVD ——美國國家漏洞庫 →http://nvd.nist.gov/。 CERT ——美國國家應急回應中心 →https://www.us-cert.gov/ OSVDB ——開源漏洞庫 →http://osvdb.org Bugtraq ——賽門鐵克 →ht ......

    uj5u.com 2020-09-10 03:52:15 more
  • 京準講述NTP時鐘服務器應用及原理

    京準講述NTP時鐘服務器應用及原理京準講述NTP時鐘服務器應用及原理 安徽京準電子科技官微——ahjzsz 北斗授時原理 授時是指接識訓通過某種方式獲得本地時間與北斗標準時間的鐘差,然后調整本地時鐘使時差控制在一定的精度范圍內。 衛星導航系統通常由三部分組成:導航授時衛星、地面檢測校正維護系統和用戶 ......

    uj5u.com 2020-09-10 03:52:25 more
  • 利用北斗衛星系統設計NTP網路時間服務器

    利用北斗衛星系統設計NTP網路時間服務器 利用北斗衛星系統設計NTP網路時間服務器 安徽京準電子科技官微——ahjzsz 概述 NTP網路時間服務器是一款支持NTP和SNTP網路時間同步協議,高精度、大容量、高品質的高科技時鐘產品。 NTP網路時間服務器設備采用冗余架構設計,高精度時鐘直接來源于北斗 ......

    uj5u.com 2020-09-10 03:52:35 more
  • 詳細解讀電力系統各種對時方式

    詳細解讀電力系統各種對時方式 詳細解讀電力系統各種對時方式 安徽京準電子科技官微——ahjzsz,更多資料請添加VX 衛星同步時鐘是我京準公司開發研制的應用衛星授時時技術的標準時間顯示和發送的裝置,該裝置以M國全球定位系統(GLOBAL POSITIONING SYSTEM,縮寫為GPS)或者我國北 ......

    uj5u.com 2020-09-10 03:52:45 more
  • 如何保證外包團隊接入企業內網安全

    不管企業規模的大小,只要企業想省錢,那么企業的某些服務就一定會采用外包的形式,然而看似美好又經濟的策略,其實也有不好的一面。下面我通過安全的角度來聊聊使用外包團的安全隱患問題。 先看看什么服務會使用外包的,最常見的就是話務/客服這種需要大量重復性、無技術性的服務,或者是一些銷售外包、特殊的職能外包等 ......

    uj5u.com 2020-09-10 03:52:57 more
  • PHP漏洞之【整型數字型SQL注入】

    0x01 什么是SQL注入 SQL是一種注入攻擊,通過前端帶入后端資料庫進行惡意的SQL陳述句查詢。 0x02 SQL整型注入原理 SQL注入一般發生在動態網站URL地址里,當然也會發生在其它地發,如登錄框等等也會存在注入,只要是和資料庫打交道的地方都有可能存在。 如這里http://192.168. ......

    uj5u.com 2020-09-10 03:55:40 more
  • [GXYCTF2019]禁止套娃

    git泄露獲取原始碼 使用GET傳參,引數為exp 經過三層過濾執行 第一層過濾偽協議,第二層過濾帶引數的函式,第三層過濾一些函式 preg_replace('/[a-z,_]+\((?R)?\)/', NULL, $_GET['exp'] (?R)參考當前正則運算式,相當于匹配函式里的引數 因此傳遞 ......

    uj5u.com 2020-09-10 03:56:07 more
  • 等保2.0實施流程

    流程 結論 ......

    uj5u.com 2020-09-10 03:56:16 more
最新发布
  • 使用Django Rest framework搭建Blog

    在前面的Blog例子中我們使用的是GraphQL, 雖然GraphQL的使用處于上升趨勢,但是Rest API還是使用的更廣泛一些. 所以還是決定回到傳統的rest api framework上來, Django rest framework的官網上給了一個很好用的QuickStart, 我參考Qu ......

    uj5u.com 2023-04-20 08:17:54 more
  • 記錄-new Date() 我忍你很久了!

    這里給大家分享我在網上總結出來的一些知識,希望對大家有所幫助 大家平時在開發的時候有沒被new Date()折磨過?就是它的諸多怪異的設定讓你每每用的時候,都可能不小心踩坑。造成程式意外出錯,卻一下子找不到問題出處,那叫一個煩透了…… 下面,我就列舉它的“四宗罪”及應用思考 可惡的四宗罪 1. Sa ......

    uj5u.com 2023-04-20 08:17:47 more
  • 使用Vue.js實作文字跑馬燈效果

    實作文字跑馬燈效果,首先用到 substring()截取 和 setInterval計時器 clearInterval()清除計時器 效果如下: 實作代碼如下: <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta ......

    uj5u.com 2023-04-20 08:12:31 more
  • JavaScript 運算子

    JavaScript 運算子/運算子 在 JavaScript 中,有一些運算子可以使代碼更簡潔、易讀和高效。以下是一些常見的運算子: 1、可選鏈運算子(optional chaining operator) ?.是可選鏈運算子(optional chaining operator)。?. 可選鏈操 ......

    uj5u.com 2023-04-20 08:02:25 more
  • CSS—相對單位rem

    一、概述 rem是一個相對長度單位,它的單位長度取決于根標簽html的字體尺寸。rem即root em的意思,中文翻譯為根em。瀏覽器的文本尺寸一般默認為16px,即默認情況下: 1rem = 16px rem布局原理:根據CSS媒體查詢功能,更改根標簽的字體尺寸,實作rem單位隨螢屏尺寸的變化,如 ......

    uj5u.com 2023-04-20 08:02:21 more
  • 我的第一個NPM包:panghu-planebattle-esm(胖虎飛機大戰)使用說明

    好家伙,我的包終于開發完啦 歡迎使用胖虎的飛機大戰包!! 為你的主頁添加色彩 這是一個有趣的網頁小游戲包,使用canvas和js開發 使用ES6模塊化開發 效果圖如下: (覺得圖片太sb的可以自己改) 代碼已開源!! Git: https://gitee.com/tang-and-han-dynas ......

    uj5u.com 2023-04-20 08:01:50 more
  • 如何在 vue3 中使用 jsx/tsx?

    我們都知道,通常情況下我們使用 vue 大多都是用的 SFC(Signle File Component)單檔案組件模式,即一個組件就是一個檔案,但其實 Vue 也是支持使用 JSX 來撰寫組件的。這里不討論 SFC 和 JSX 的好壞,這個仁者見仁智者見智。本篇文章旨在帶領大家快速了解和使用 Vu ......

    uj5u.com 2023-04-20 08:01:37 more
  • 【Vue2.x原始碼系列06】計算屬性computed原理

    本章目標:計算屬性是如何實作的?計算屬性快取原理以及洋蔥模型的應用?在初始化Vue實體時,我們會給每個計算屬性都創建一個對應watcher,我們稱之為計算屬性watcher ......

    uj5u.com 2023-04-20 08:01:31 more
  • http1.1與http2.0

    一、http是什么 通俗來講,http就是計算機通過網路進行通信的規則,是一個基于請求與回應,無狀態的,應用層協議。常用于TCP/IP協議傳輸資料。目前任何終端之間任何一種通信方式都必須按Http協議進行,否則無法連接。tcp(三次握手,四次揮手)。 請求與回應:客戶端請求、服務端回應資料。 無狀態 ......

    uj5u.com 2023-04-20 08:01:10 more
  • http1.1與http2.0

    一、http是什么 通俗來講,http就是計算機通過網路進行通信的規則,是一個基于請求與回應,無狀態的,應用層協議。常用于TCP/IP協議傳輸資料。目前任何終端之間任何一種通信方式都必須按Http協議進行,否則無法連接。tcp(三次握手,四次揮手)。 請求與回應:客戶端請求、服務端回應資料。 無狀態 ......

    uj5u.com 2023-04-20 08:00:32 more