Node.js學(xué)習(xí)之路23——Node.js利用mongoose連接mongodb數(shù)據(jù)庫

jsummer 發(fā)布于2019-08-22 14:59 / 1810人閱讀

摘要：類比一下你有一個巨型停車場，里邊分了不同的停車區(qū)集合，這里的，每個停車區(qū)可以停很多車下文提到的，相當于每個數(shù)據(jù)集合里邊可以有很多張數(shù)據(jù)表。

Node.js利用mongoose連接mongodb數(shù)據(jù)庫

Node.js連接mongodb數(shù)據(jù)庫有很多種方法，通過mongoose模塊引入是其中的一個方法

代碼組織結(jié)構(gòu)

|---|根目錄
|---|---|connect.js(mongoose測試連接)
|---|---|user.js(定義user數(shù)據(jù)表)
|---|---|operate.js(定義mongodb的增刪改查功能)
|---|---|login.js(Node后臺調(diào)用operate.js文件的方法處理數(shù)據(jù))

1. 引入mongoose測試連接

當前使用的mongoose版本為4.13.7

該文件為connect.js

1.1 代碼部分

const mongoose = require("mongoose");
const DB_URL = "mongodb://127.0.0.1:27017/infos";
mongoose.Promise = global.Promise;
mongoose.connect(DB_URL, { useMongoClient: true });
mongoose.connection.on("connected", () => {
    console.log("mongodb數(shù)據(jù)庫連接成功")
});
mongoose.connection.on("error", (error) => {
    console.log("mongodb數(shù)據(jù)庫連接失敗", error)
});
module.exports = mongoose;

1.2 代碼分析 1.2.1 引入mongoose模塊

const mongoose = require("mongoose");

1.2.2 獲取mongodb的本機地址

const DB_URL = "mongodb://127.0.0.1:27017/infos";

127.0.0.1是本地IP地址

27017是mongodb的服務(wù)啟動端口

infos是mongodb的一個數(shù)據(jù)集合名字

mongodb可以有很多數(shù)據(jù)集合，每個集合中可以有很多數(shù)據(jù)表。

類比一下：你有一個巨型停車場(mongodb)，里邊分了不同的停車區(qū)(集合，這里的infos)，每個停車區(qū)可以停很多車((下文提到的user)，相當于每個數(shù)據(jù)集合里邊可以有很多張數(shù)據(jù)表)。

如果需要給mongodb加上用戶及密碼，可以這樣

const DB_URL = "mongodb://username:[email protected]:27017/infos";

其中username為用戶名，中間英文:，password為密碼，其余不變

1.2.3 連接數(shù)據(jù)庫成功

mongoose.connection.on("connected", callback())

數(shù)據(jù)庫連接成功后，會在控制臺輸出mongodb數(shù)據(jù)庫連接成功

1.2.4 連接數(shù)據(jù)庫失敗

mongoose.connection.on("error", callback())

數(shù)據(jù)庫連接成功后，會在控制臺輸出mongodb數(shù)據(jù)庫連接失敗和錯誤信息

1.2.5 導(dǎo)出mongoose模塊

module.exports = mongoose;

2. 定義每張數(shù)據(jù)表的字段

該文件為user.js

2.1 代碼介紹

const mongoose = require("mongoose");
const db = require("./connect.js");
const userSchema = new mongoose.Schema({
    number: { type: Number},
    email: { type: String },
    password: { type: String },
    rePassword: { type: String },
    mobile: { type: String },
    question: { type: String },
    answer: { type: String },
});
let userModel = db.model("user", userSchema);
module.exports = userModel;

2.2 代碼分析 2.2.1 引入mongoose模塊

const mongoose = require("mongoose");

2.2.1 引入連接mongodb數(shù)據(jù)庫的模塊

const db = require("./connect.js");

2.2.2 定義Schema

const userSchema = new mongoose.Schema({})

通過mongoose對象的Schema屬性創(chuàng)建一個Schema對象

Schema原意為架構(gòu)
在mongodb中，每一個數(shù)據(jù)字段都要有固定的數(shù)據(jù)類型，所以Schema在mongoose中的意思為，每一張數(shù)據(jù)表對應(yīng)的字段的數(shù)據(jù)類型

Schema所能夠擁有的數(shù)據(jù)類型有以下幾個

String

Number

Date

Buffer

Boolean

Mixed

ObjectId

Array

字段介紹，以number字段為例

type是該字段的數(shù)據(jù)類型

default是該字段的默認值

還有很多其他的屬性，以及可以自定義屬性

2.2.3 確認數(shù)據(jù)表和該數(shù)據(jù)表的字段

let userModel = db.model("user", userSchema);

定義一個數(shù)據(jù)表userModel

使用db.model方法，第一個參數(shù)是數(shù)據(jù)表的名字，第二個參數(shù)是該數(shù)據(jù)表使用的Schema

2.2.4 最終導(dǎo)出定義的數(shù)據(jù)表

module.exports = userModel;

導(dǎo)出之后，在operate.js中使用這個對象的mongodb的增刪改查方法

3. 定義mongodb的增刪改查功能 3.1 代碼部分

該文件為operate.js

let userModel = require("./user.js");
module.exports = {
    save(data) {
        return new Promise((resolve, reject) => {
            userModel.create(data, (err, docs) => {
                if (err) {
                    rejct(err);
                } else {
                    resolve(docs);
                }
            })
        })
    },
    find(data = {}, fields = null, options = {}) {
        return new Promise((resolve, reject) => {
            //model.find(需要查找的對象(如果為空，則查找到所有數(shù)據(jù)), 屬性過濾對象[可選參數(shù)], options[可選參數(shù)], callback)
            userModel.find(data, fields, options, (error, doc) => {
                if (error) {
                    reject(error)
                } else {
                    resolve(doc)
                }
            })
        })
    },
    findOne(data) {
        return new Promise((resolve, reject) => {
            //model.findOne(需要查找的對象,callback)
            userModel.findOne(data, (error, doc) => {
                if (error) {
                    reject(error)
                } else {
                    resolve(doc)
                }
            })
        })
    },
    findById(data) {
        return new Promise((resolve, reject) => {
            //model.findById(需要查找的id對象 ,callback)
            userModel.findById(data, (error, doc) => {
                if (error) {
                    reject(error)
                } else {
                    resolve(doc)
                }
            })
        })
    },
    update(conditions, update) {
        return new Promise((resolve, reject) => {
            //model.update(查詢條件,更新對象,callback)
            userModel.update(conditions, update, (error, doc) => {
                if (error) {
                    reject(error)
                } else {
                    resolve(doc)
                }
            })
        })
    },
    remove(conditions) {
        return new Promise((resolve, reject) => {
            //model.update(查詢條件,callback)
            userModel.remove(conditions, (error, doc) => {
                if (error) {
                    reject(error)
                } else {
                    resolve(doc)
                }
            })
        })
    }
};

3.2 代碼分析

引入user模塊

let userModel = require("../models/users");

引入該文件的目的是，讓userModel這個數(shù)據(jù)表直接的調(diào)用mongodb的各種方法

4. 后臺直接使用operate處理數(shù)據(jù)

該文件為login.js

4.1 代碼部分

const express = require("express");
const router = express.Router();
let operate = require("./operate");
router.post("/", function (req, res, next) {
    let param = {};
    param.email = req.body.email;
    param.password = req.body.password;
    console.log(param);
    operate.save(param).then(result => {
        if (result) {
            res.json({
                data: result,
                success: true
            })
        } else {
            res.json({
                data: result,
                success: false
            })
        }
    });
});
module.exports = router;

4.2 代碼分析

需要熟練使用Express的router方法

引入Express，定義一個post方法

post方法傳遞的對象數(shù)據(jù)掛在在req.body上

直接調(diào)用operate.save()方法，傳遞param對象參數(shù)

獲取到返回結(jié)果result，對獲取到的結(jié)果進行進一步處理