sql >> データベース >  >> NoSQL >> MongoDB

nodejsからmongodbまたはmongooseへの動的データベース接続

    これは、私と同じような状況に陥る可能性のある他の人を助けるためです。標準化できればと思います。誰かがマルチテナントアプリケーションを作成する必要があるたびに、車輪の再発明を行う必要があるとは思いません。

    この例では、各クライアントが独自のデータベースを持っているマルチテナント構造について説明します。これを行うにはもっと良い方法があるかもしれないと言ったように、自分で助けが得られなかったので、これが私の解決策でした。

    したがって、このソリューションが目標とする目標は次のとおりです。

    • 各クライアントは、client1.application.comなどのサブドメインによって識別されます。
    • アプリケーションはサブドメインが有効かどうかを確認します
    • アプリケーションは、マスターデータベースから接続情報(データベースのURL、資格情報など)を検索して取得します。
    • アプリケーションはクライアントデータベースに接続します(ほとんどの場合、クライアントに渡されます)。
    • アプリケーションは、整合性とリソース管理を確保するための対策を講じます(たとえば、新しい接続を確立するのではなく、同じクライアントのメンバーに同じデータベース接続を使用します)。

    ここにコードがあります

    app.jsで ファイル

    app.use(clientListener()); // checks and identify valid clients
    app.use(setclientdb());// sets db for valid clients
    

    2つのミドルウェアを作成しました:

    • clientListener -接続しているクライアントを識別するために
    • setclientdb -クライアントが識別された後、マスターデータベースからクライアントの詳細を取得し、クライアントデータベースへの接続を確立します。

    clientListenerミドルウェア

    リクエストオブジェクトからサブドメインをチェックすることで、クライアントが誰であるかをチェックします。私はクライアントが有効であることを確認するためにたくさんのチェックを行います(コードが乱雑で、よりクリーンにすることができることを私は知っています)。クライアントが有効であることを確認した後、クライアント情報をセッションに保存します。また、クライアント情報がすでにセッションに保存されている場合は、データベースを再度照会する必要がないことも確認します。リクエストのサブドメインが、すでにセッションに保存されているものと一致していることを確認する必要があります。

    var Clients = require('../models/clients');
    var basedomain = dbConfig.baseDomain;
    var allowedSubs = {'admin':true, 'www':true };
    allowedSubs[basedomain] = true;
    function clientlistener() {
    return function(req, res, next) {
        //console.dir('look at my sub domain  ' + req.subdomains[0]);
        // console.log(req.session.Client.name);
    
        if( req.subdomains[0] in allowedSubs ||  typeof req.subdomains[0] === 'undefined' || req.session.Client && req.session.Client.name === req.subdomains[0] ){
            //console.dir('look at the sub domain  ' + req.subdomains[0]);
            //console.dir('testing Session ' + req.session.Client);
            console.log('did not search database for '+ req.subdomains[0]);
            //console.log(JSON.stringify(req.session.Client, null, 4));
            next();
        }
        else{
    
            Clients.findOne({subdomain: req.subdomains[0]}, function (err, client) {
                if(!err){
                    if(!client){
                        //res.send(client);
                        res.send(403, 'Sorry! you cant see that.');
                    }
                    else{
                        console.log('searched database for '+ req.subdomains[0]);
                        //console.log(JSON.stringify(client, null, 4));
                        //console.log(client);
                       // req.session.tester = "moyo cow";
                        req.session.Client = client;
                        return next();
    
                    }
                }
                else{
                    console.log(err);
                    return next(err)
                }
    
            });
        }
    
       }
     }
    
    module.exports = clientlistener;
    

    setclientdbミドルウェア:

    クライアントが有効であることを確認するために、すべてをもう一度チェックします。次に、セッションから取得した情報を使用したクライアントのデータベースへの接続が開きます。

    また、リクエストごとにデータベースへの新しい接続を防ぐために、すべてのアクティブな接続をグローバルオブジェクトに格納するようにします(接続で各クライアントのmongodbサーバーに過負荷をかけたくない)。

    var mongoose = require('mongoose');
    //var dynamicConnection = require('../models/dynamicMongoose');
    function setclientdb() {
        return function(req, res, next){
            //check if client has an existing db connection                                                               /*** Check if client db is connected and pooled *****/
        if(/*typeof global.App.clientdbconn === 'undefined' && */ typeof(req.session.Client) !== 'undefined' && global.App.clients[req.session.Client.name] !== req.subdomains[0])
        {
            //check if client session, matches current client if it matches, establish new connection for client
            if(req.session.Client && req.session.Client.name === req.subdomains[0] )
            {
                console.log('setting db for client ' + req.subdomains[0]+ ' and '+ req.session.Client.dbUrl);
                client = mongoose.createConnection(req.session.Client.dbUrl /*, dbconfigoptions*/);
    
    
                client.on('connected', function () {
                    console.log('Mongoose default connection open to  ' + req.session.Client.name);
                });
                // When the connection is disconnected
                client.on('disconnected', function () {
                    console.log('Mongoose '+ req.session.Client.name +' connection disconnected');
                });
    
                // If the Node process ends, close the Mongoose connection
                process.on('SIGINT', function() {
                    client.close(function () {
                        console.log(req.session.Client.name +' connection disconnected through app termination');
                        process.exit(0);
                    });
                });
    
                //If pool has not been created, create it and Add new connection to the pool and set it as active connection
    
                if(typeof(global.App.clients) === 'undefined' || typeof(global.App.clients[req.session.Client.name]) === 'undefined' && typeof(global.App.clientdbconn[req.session.Client.name]) === 'undefined')
                {
                    clientname = req.session.Client.name;
                    global.App.clients[clientname] = req.session.Client.name;// Store name of client in the global clients array
                    activedb = global.App.clientdbconn[clientname] = client; //Store connection in the global connection array
                    console.log('I am now in the list of active clients  ' + global.App.clients[clientname]);
                }
                global.App.activdb = activedb;
                console.log('client connection established, and saved ' + req.session.Client.name);
                next();
            }
            //if current client, does not match session client, then do not establish connection
            else
            {
                delete req.session.Client;
                client = false;
                next();
            }
        }
        else
        {
            if(typeof(req.session.Client) === 'undefined')
            {
               next();
            }
            //if client already has a connection make it active
            else{
                global.App.activdb = global.App.clientdbconn[req.session.Client.name];
                console.log('did not make new connection for ' + req.session.Client.name);
                return next();
            }
    
        }
        }
    }
    
    module.exports = setclientdb;
    

    最後になりましたが、少なくとも

    マングースとネイティブモンゴを組み合わせて使用​​しているため、実行時にモデルをコンパイルする必要があります。以下をご覧ください

    これをapp.jsに追加します

    // require your models directory
    var models = require('./models');
    
    // Create models using mongoose connection for use in controllers
    app.use(function db(req, res, next) {
        req.db = {
            User: global.App.activdb.model('User', models.agency_user, 'users')
            //Post: global.App.activdb.model('Post', models.Post, 'posts')
        };
        return next();
    });
    

    説明:

    前に述べたように、アクティブなデータベース接続オブジェクトを格納するグローバルオブジェクトを作成しました:global.App.activdb

    次に、この接続オブジェクトを使用して、マングースモデルを作成(コンパイル)します。これをreqオブジェクトのdbプロパティに格納した後、req.db 。これは、たとえば、このようにコントローラーのモデルにアクセスできるようにするためです。

    ユーザーコントローラーの例:

    exports.list = function (req, res) {
        req.db.User.find(function (err, users) {
    
            res.send("respond with a resource" + users + 'and connections  ' + JSON.stringify(global.App.clients, null, 4));
            console.log('Worker ' + cluster.worker.id + ' running!');
        });
    
    };
    

    私は戻ってきて、これを最終的に片付けます。誰かが私を助けたいのなら、それは素晴らしいことです。



    1. Django-セロリとredisで非同期タスクキューを使用する方法

    2. そのjavaドライバーでのMongoDbの$set相当

    3. redisでキーを複製します

    4. $lookupmongodbの$project