ES6最簡(jiǎn)單的方式訪問(wèn)MongoDB

pekonchan 發(fā)布于2019-06-26 16:56 / 2618人閱讀

摘要：前言越來(lái)越流行，也越來(lái)越流行，也許你第一時(shí)間用上了框架，但是如何才能在用的方式訪問(wèn)呢其實(shí)上不少類似的方案，比如你繼續(xù)使用的方式操作數(shù)據(jù)庫(kù)，其實(shí)都沒(méi)什么不可以。我的項(xiàng)目比較簡(jiǎn)單，不想用太多復(fù)雜的框架，自己寫(xiě)個(gè)來(lái)連接數(shù)據(jù)庫(kù)好了。

前言
MongoDB越來(lái)越流行，NodeJS也越來(lái)越流行，也許你第一時(shí)間用上了KOA框架，但是如何才能在KOA用ES6的方式訪問(wèn)MongoDB呢？其實(shí)Github上不少類似的方案，比如你繼續(xù)使用mongoose的Promise方式操作數(shù)據(jù)庫(kù)，其實(shí)都沒(méi)什么不可以。我的項(xiàng)目比較簡(jiǎn)單，不想用太多復(fù)雜的框架，自己寫(xiě)個(gè)Helper來(lái)連接數(shù)據(jù)庫(kù)好了。

代碼其實(shí)很簡(jiǎn)單，我貼出來(lái)，給官方驅(qū)動(dòng)包個(gè)Promise殼兒，所有操作返回官方Promise，然后yield調(diào)用就這么簡(jiǎn)單

// helper_mongo.js文件
// 作者freewolf
// 當(dāng)然還是使用官方驅(qū)動(dòng)
var MongoClient = require("mongodb").MongoClient;
var ObjectID = require("mongodb").ObjectID;

var mongoLink = ""; 
// 這里修改成你的MongoLink字符串mongodb://user:password@yourserver

// 插入方法
var insert = function(collectionName, obj) {
    return new Promise(function(resolve, reject) {
        MongoClient.connect(mongoLink, function(err, db) {
            if (err) reject(err);
            var collection = db.collection(collectionName);

            collection.insert(obj, {w: 1}, function(err, res) {
                db.close();
                if (err) reject(err);
                else resolve(res[0]);
            });
        });
    });
}
// 更新
var update = function(collectionName, obj) {
    return new Promise(function(resolve, reject) {
        MongoClient.connect(mongoLink, function(err, db) {
            if (err) reject(err);
            var collection = db.collection(collectionName);
            collection.update({_id: new ObjectID(obj._id)}, obj, {upsert: true,w: 1}, function(err, res) {
                db.close();
                if (err) reject(err);
                else resolve(res);
            });
        });
    });
}
// 查找一個(gè)
var findOne = function (collectionName, query, option) {
    return new Promise(function(resolve, reject) {
        MongoClient.connect(mongoLink, function(err, db) {
            if (err) reject(err);

            var collection = db.collection(collectionName);

            if(option==undefined || option==null)
            {
                collection.findOne(query, function(err, res) {
                    db.close();
                    if (err) reject(err);
                    else resolve(res);
                });
            }else{
                collection.findOne(query, option, function(err, res) {
                    db.close();
                    if (err) reject(err);
                    else resolve(res);
                });
            }
        });
    });
}
// 查找多個(gè)
var find = function(collectionName, query, option) {
    return new Promise(function(resolve, reject) {
        MongoClient.connect(mongoLink, function(err, db) {
            if (err) reject(err);

            var collection = db.collection(collectionName);
            if(option==undefined || option==null)
            {
                collection.find(query).toArray(function(err, res) {
                    db.close();
                    if (err) reject(err);
                    else resolve(res);
                });
            }else{
                collection.find(query, option).toArray(function(err, res) {
                    db.close();
                    if (err) reject(err);
                    else resolve(res);
                });
            }
        });
    });
}
// 刪除
var remove = function(collectionName, query) {
    return new Promise(function(resolve, reject) {
        MongoClient.connect(mongoLink, function(err, db) {
            if (err) reject(err);
            var collection = db.collection(collectionName);

            collection.remove(query, {w: 1}, function(err, res) {
                db.close();
                if (err) reject(err);
                else resolve(res);
            });
        });
    });
}
// 計(jì)數(shù)
var count = function(collectionName, query, option) {
    return new Promise(function(resolve, reject) {
        MongoClient.connect(mongoLink, function(err, db) {
            if (err) reject(err);
            var collection = db.collection(collectionName);
            if(query==undefined || query==null)
                query = {};
            if(option==undefined || option==null)
            {
                collection.count(query, function(err, count) {
                    db.close();
                    if (err) reject(err);
                    else resolve(count);
                });
            }else{
                collection.count(query, option, function(err, count) {
                    db.close();
                    if (err) reject(err);
                    else resolve(count);
                });
            }
        });
    });
}

module.exports.insert = insert;
module.exports.update = update;
module.exports.findOne = findOne;
module.exports.find = find;
module.exports.remove = remove;
module.exports.count = count;

好了 Helper結(jié)束
怎么使用呢？
使用一個(gè)Service來(lái)裝飾一下

// service.js文件
var ObjectID = require("mongodb").ObjectID;
var helperMongo = require("./helper_mongo");

module.exports = {
    // 創(chuàng)建
    insert : function * (obj){
        var res = yield helperMongo.insert(this.collectionName, obj);
        return res;
    },

    // 更新
    update : function * (obj){
        var res = yield helperMongo.update(this.collectionName, obj);
        return res;
    },

    // 刪除
    remove : function * (id){
        var res = yield helperMongo.remove(this.collectionName, { _id : new ObjectID(id) });
        return res;
    },


    // 查詢
    find : function * (query, option){
        var res = yield helperMongo.find(this.collectionName, query, option);
        return res;
    },

    // 查詢
    findOne : function * (query, option){
        var res = yield helperMongo.findOne(this.collectionName, query, option);
        return res;
    },

    // 取全部
    getAll : function * (){
        var res = yield helperMongo.find(this.collectionName, {});
        return res;
    },

    // 按照id查詢
    getById : function * (id){
        var res = yield helperMongo.findOne(this.collectionName, { _id : new ObjectID(id) });
        return res;
    },

    // 按照很多id來(lái)查詢
    getByIds :function * (ids, option){
        ids = ids.map(function(id) { return new ObjectID(id); });
        var res = yield helperMongo.find(this.collectionName, {_id: {$in: ids}}, option);
        return res;
    },

    // 列出（帶分頁(yè)）
    getByPage : function*(query, sort, pageSize, pageNum){
        if(!query)
            query = {};
        if(!sort)
            sort = [["_id", "desc"]];
        var option = {
            sort : sort,
            limit: pageSize,
            skip : (pageNum - 1) * pageSize
        };
        var res = yield helperMongo.find(this.collectionName, query, option);
        return res;
    },

    // 計(jì)數(shù)
    count : function * (query){
        if(!query)
            query = {};
        var res = yield helperMongo.count(this.collectionName, query);
        return res;
    }
}

然后呢？
其實(shí)更簡(jiǎn)單單例的操作從service繼承

// service_user.js舉例
var service = require("./service");
var helperMongo = require("../helper_mongo");
var ObjectID = require("mongodb").ObjectID;

var Service = function(){
    this.collectionName = "users";

    // 這里擴(kuò)充你自己的方法 比如 按照邀請(qǐng)碼搜索
    this.getByInviteCode = function * (inviteCode){
        var res = yield this.findOne({ invitecode : inviteCode });
        return res;
    }

    if(Service.instance == null)
    {
        Service.instance = this;
    }
    return Service.instance;
}
Service.prototype = service;

module.exports = Service;

好了再看如何使用

var co = require("co");
var ServiceUser = require("./service_user.js");
var serviceUser = new ServiceUser();
// 其實(shí)可以直接返回單例實(shí)例在service_user.js 但是WS不能出提示 還是這樣吧

// Demo下
co(function*(){
    var user = {name:"freewolf", password:"123", invitecode:"abcd"};
    // 插入
    yield serviceUser.insert(user); 
    
    // 查找 使用service包裝的方法
    var user1 = yield serviceUser.find({name:"freewolf"});
    // 查找 使用擴(kuò)展方法
    var user2 = yield serviceUser.getByInviteCode("abcd");
    // 分頁(yè)
    var sort = [["lastedittime", "desc"]];
    var pageSize = 20;  // 每頁(yè)20條
    var pageNum = 1;    // 第一頁(yè)
    var users = yield serviceUser.getByPage({}, sort, pageSize, pageNum);
    // ......
});

就寫(xiě)這么多吧，這個(gè)玩意就是官方驅(qū)動(dòng)包個(gè)殼，很好用，滿足一般的需求。其實(shí)JS我并不太擅長(zhǎng)，有什么語(yǔ)法怪怪的地方，歡迎大家拍磚~

GPU云服務(wù)器云服務(wù)器最簡(jiǎn)單的算法最簡(jiǎn)單的爬蟲(chóng) 最簡(jiǎn)單的webrtc 最簡(jiǎn)單的rxjava

文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址：http://systransis.cn/yun/18787.html

發(fā)表評(píng)論

登陸后可評(píng)論

0條評(píng)論

pekonchan

男|高級(jí)講師

我要關(guān)注我要私信

TA的文章

tensorflow用cpu訓(xùn)練

閱讀 3375·2023-04-26 03:05
Flexbox完全指南（譯）

閱讀 1474·2019-08-30 13:09
CSS 無(wú)圖片技術(shù)總結(jié)

閱讀 1916·2019-08-30 13:05
清除Css中select的下拉箭頭樣式

閱讀 897·2019-08-29 12:42
avalon js實(shí)現(xiàn)仿google plus圖片多張拖動(dòng)排序

閱讀 1394·2019-08-28 18:18
css中應(yīng)該滾瓜爛熟的屬性

閱讀 3454·2019-08-28 18:09
初學(xué)者請(qǐng)注意手寫(xiě) css 樣式表的各屬性的順序及 CSScomb 的使用

閱讀 528·2019-08-28 18:00
Javascript 簡(jiǎn)史

閱讀 1726·2019-08-26 12:10

成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！

ES6最簡(jiǎn)單的方式訪問(wèn)MongoDB

相關(guān)文章

用agenda和agendash管理定時(shí)任務(wù)

用agenda和agendash管理定時(shí)任務(wù)

**【實(shí)戰(zhàn)】用 express+MongoDB 搭建一個(gè)完整的前端項(xiàng)目**

JS筆記

ES6之Promise

發(fā)表評(píng)論

0條評(píng)論

pekonchan

男|高級(jí)講師

TA的文章

tensorflow用cpu訓(xùn)練

Flexbox完全指南（譯）

CSS 無(wú)圖片技術(shù)總結(jié)

清除Css中select的下拉箭頭樣式

avalon js實(shí)現(xiàn)仿google plus圖片多張拖動(dòng)排序

css中應(yīng)該滾瓜爛熟的屬性

初學(xué)者請(qǐng)注意手寫(xiě) css 樣式表的各屬性的順序及 CSScomb 的使用

Javascript 簡(jiǎn)史

最新活動(dòng)

資訊專欄INFORMATION COLUMN

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！

ES6最簡(jiǎn)單的方式訪問(wèn)MongoDB

相關(guān)文章

發(fā)表評(píng)論

0條評(píng)論

男|高級(jí)講師

TA的文章

最新活動(dòng)

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！