node中封装MongoDB

​前言：封装方法，哪儿都能调用，岂不美哉。​

首先我们需要下载这个模块

npm install mongodb

接下来新建一个mongo.js文件，写入如下代码：

var MongoClient=require('mongodb').MongoClient
var ObjectID = require('mongodb').ObjectID;
// 地址
var url = ""
//导出查询mongo自生成的id
exports.objid=ObjectID
/**
 * 封装find()查询所有数据
 * @param {*} table 数据库名称
 * @param {*} collect  集合名
 * @returns 
 */
exports.findAll=function findAll(table, collect) {
    return new Promise((resolve, reject) => {
        MongoClient.connect(url, function (err, db) {
            if (err) throw err;
            var dbo = db.db(table);
            dbo.collection(collect).find().toArray(function (err, result) { // 返回集合中所有数据
                if (err) {
                    reject(err)
                } else {
                    resolve(result)
                    db.close()
                }
            })
        })
    })
}
/**
 * 查询某一条记录
 * @param {*} table 
 * @param {*} collect 
 * @param {*} params 
 * @returns 
 */
exports.findone= function findone(table, collect,params) {
    return new Promise((resolve, reject) => {
        MongoClient.connect(url, function (err, db) {
            if (err) throw err;
            var dbo = db.db(table);
            dbo.collection(collect).find(params).toArray(function (err, result) { // 返回集合中所有数据
                if (err) {
                    reject(err)
                } else {
                    resolve(result)
                    db.close()
                }
            })
        })
    })
}
/**
 * 封装更新方法
 * @param {*} table 
 * @param {*} collect 
 * @param {*} id 
 * @param {*} newdata 
 * @returns 
 */

exports.Update= function update(table, collect,id,newdata) {
    return new Promise((resolve, reject) => {
        MongoClient.connect(url, function (err, db) {
            if (err) throw err;
            var dbo = db.db(table);
            dbo.collection(collect).updateOne(ObjectID(id), newdata, function(err, result) {
                if (err) {
                    reject(err)
                } else {
                    resolve(result)
                    db.close()
                }
            })
        })
    })
} 

/**
 * 封装插入数据方法
 * @param {*} table 
 * @param {*} collect 
 * @param {*} data 
 * @returns 
 */
exports.Insert= function insert(table, collect,data) {
    return new Promise((resolve, reject) => {
        MongoClient.connect(url, function (err, db) {
            if (err) throw err;
            var dbo = db.db(table);
            dbo.collection(collect).insertOne(data, function(err, result) {
                if (err) {
                    reject(err)
                } else {
                    resolve(result)
                    db.close()
                }
            })
        })
    })
} 
/**
 * 封装删除的方法
 * @param {*} table 
 * @param {*} collect 
 * @param {*} params 
 * @returns 
 */
exports.Delete= function delete(table, collect,params) {
    return new Promise((resolve, reject) => {
        MongoClient.connect(url, function (err, db) {
            if (err) throw err;
            var dbo = db.db(table);
            dbo.collection(collect).deleteOne(params, function(err, result) {
                if (err) {
                    reject(err)
                } else {
                    resolve(result)
                    db.close()
                }
            })
        })
    })
}

调用：

const express = require('express')
const mongo = require('../mongo/mongodb')
const router = express.Router()

router.get('/log', (req, res) => {
    mongo.findAll('数据库名称', "集合名").then(resp => {
        res.send({
            code: 200,
            count: resp.length,
            data: resp,
            msg: 'Search All  Success'
        })
    })
})