安裝相關模組

如果使用這個的話，你需要先自己安裝一下他需要的模組，在根目錄輸入

npm install mongodb --save

進行模組安裝，安裝成功以後就可以進行以下的步驟。

檔案的引入

以下是我書寫的相關程式碼，放到你可以引用的相關目錄，本人放到了express的根目錄

function Mongo(options) {
    this.settings = {
        url: 'mongodb://localhost:27017/jk',
        MongoClient:require('mongodb').MongoClient,
        assert:require
 
('assert')
    };

    for(let i in options){
        this.settings[i] = options[i];
    }

    this._run = function (fun) {
        let that = this;
        let settings = this.settings;
        this.settings.MongoClient.connect(this.settings.url, function (err, db) {
            settings.assert.equal(null
 
, err);
            console.log("Connected correctly to server");

            fun(db, function () {
                db.close();
            });
        });
    };

    this.insert = function (collectionName, data, func) {
        //增加資料
        let insertDocuments = function (db, callback) {
            let
 
 collection = db.collection(collectionName);
            collection.insertMany([
                data
            ], function (err, result) {
                if (!err) {
                    func(true);
                } else {
                    func(false);
                }
                callback(result);
            });
        };

        this._run(insertDocuments);
    };

    this.update = function (collectionName, updateData, data, func) {
        //更新資料
        let updateDocument = function (db, callback) {
            let collection = db.collection(collectionName);
            collection.updateOne(updateData
                , {$set: data}, function (err, result) {
                    if (!err) {
                        func(true);
                    } else {
                        func(false);
                    }
                    callback(result);
                });
        };

        this._run(updateDocument);
    };

    this.delete = function (collectionName, data, func) {
        //刪除資料
        let deleteDocument = function (db, callback) {
            let collection = db.collection(collectionName);
            collection.deleteOne(data, function (err, result) {
                if (!err) {
                    func(true);
                } else {
                    func(false);
                }
                callback(result);
            });
        };

        this._run(deleteDocument);
    };

    this.find = function (collectionName, data, func) {
        //查詢資料
        let findDocuments = function (db, callback) {
            // Get the documents collection
            let collection = db.collection(collectionName);
            // Find some documents
            collection.find(data).toArray(function (err, docs) {
                if (!err) {
                    func(true,docs);
                }
                else {
                    func(false, err);
                }
                callback(docs);
            });
        };

        this._run(findDocuments);
    };
}

module.exports = Mongo;

我存入到了一個名字叫server.js的檔名內

使用

我們在需要使用頁面先將模組引入，比如我在路由檔案index.js裡面引入：

const Server = require("../server.js");

然後需要例項化物件，如下：

let server = new Server();

如果需要配置相關資訊，可以在例項化的時候傳入一個物件配置，可以配置資料庫的地址：

let server = new Server({url:"mongodb://localhost:27017/mydb"});

裡面封裝了四個方法，添刪改查，分別是
新增方法

server.insert(資料表名,需要插入的資料（鍵值對的物件）,回撥函式);

更新方法

server.update(資料表名,查詢的資料（物件）,更新的資料（物件）,回撥函式);

刪除方法

server.delete(資料表名,查詢的資料（物件）,回撥函式);

查詢方法

server.find(資料表名,查詢的資料（物件）,回撥函式);

回撥函式都會返回兩個值，第一個布林型別，是否處理成功，第二個值，查詢返回查詢到的個數，別的都返回處理成功的個數（現在一次只處理一條）

使用案例

比如我需要在一個路由裡面查詢資料，我就需要這樣：

server.find("users",{username:"username"},function (bool,data) {
        if(bool){
            console.log("查詢到資料為"+data.length+"條");
        }
        else{
            console.log(data);
        }
    });
});

上面的程式碼是查詢了users表裡面username為username的欄位的資料，如果成功，後面data就會返回一個數組，如果出現錯誤，就直接返回data錯誤。