ログインしているユーザに基づいて、別のインスタンスMongoDBにコールを誘導するにはどうすればよいですか？

Question

私はマルチテナントのSaasアプリケーションになるプロジェクトに取り組んでいます。ユーザーのログイン情報に応じてさまざまなデータベースにログインする方法を実装するのが難しいです。現在のところ、Sandboxデータベース（デモ用、定期的にワイプされる）とAlphaデータベース（現在のクライアントのテストと開発用）の間でトラフィックを分割したいだけです。私はログイン時にユーザIDを検出し、mongoose.createConnection()を使ってデータベースオブジェクトを割り当てる、以下のミドルウェアconfig.jsを作成しました。このキーと値のペアは、memory-cacheを使用してストアに追加されます。 config.jsコードは次のとおりです。

var mcache = require('memory-cache'), 
    Promise = require("bluebird"), 
    mongoose = require('mongoose'); 

Promise.promisifyAll(require("mongoose")); 
(function() { 

    'use strict'; 

    var dbSand = mongoose.createConnection(process.env.DB_SAND); 
    var dbAlpha = mongoose.createConnection(process.env.DB_ALPHA); 

    function dbPathConfigMiddlewareWrapper(){ 
     return function setDbPath(req, res, next){ 
      if (req){ 
       if (!mcache.get(req.session.id) && req.body.email){ 
        var login = req.body.email; 
        if (login === 'demo@mysite.com'){ 
         mcache.put(req.session.id, dbSand); 
        } else { 
         mcache.put(req.session.id, dbAlpha); 
        } 
       } 
       req.dbPath = mcache.get(req.session.id); 

       next(); 
      } 

     }; 

    } 

module.exports = dbPathConfigMiddlewareWrapper; 

}()); 

これまでのところとても良いです。しかし私は私のルートで正しいデータベースを呼び出すことに失敗しました。私は、単一のデータベースを使用していたとき、私は簡単にこれを使用することができます。

var connStr = process.env.DBPATH; 

    if(mongoose.connection.readyState === 0){ 
     mongoose.connect(connStr, function(err) { 
      if (err) throw err; 
      console.log('Successfully connected to MongoDB'); 
     }); 
    } 

を今、私は無駄にこれをしようとしている：

var connStr = req.dbPath; //where req.dbPath is assigned in the config middleware above. 

    if(connStr.connection.readyState === 0){ 
     mongoose.connect(req.dbPath, function(err) { 
      if (err) throw err; 
      console.log('Successfully connected to MongoDB'); 
     }); 
    } 

ここで任意の指導をいただければ幸いです。これははるかに簡単であるはずだと思われるドキュメントのように見えますが、ドキュメントはそれを暗に示していますが、詳しく説明していません。

Answer 1

ここでは、データベースオブジェクトをキー値ストレージに保存していることが問題だと思います。 mcache.put(req.session.id, dbSand);。 if(connStr.connection.readyState === 0)にエラーが発生しました。

オブジェクトをストリング化することができます。 mcache.put(req.session.id, JSON.stringify(dbSand));。オブジェクトの文字列を取得し、var connStr = JSON.parse(req.dbPath);のようにJSONに解析します。

Answer 2

接続を手動で作成している場合は、mongoose.connect()に電話をかけないでください。

代わりに、接続ごとにモデルを登録する必要がありますが、これはPITAのビットですが、私が知る限り、回避する方法はありません。コードの再構築が必要になることがあります。

ここでは、そのようなものを設定する方法について、いくつかのテストされていないコードがあります。

あなたのミドルウェアファイル：

// Create connections 
const registerModels = require('./register-models'); 
let dbSand = mongoose.createConnection(process.env.DB_SAND); 
let dbAlpha = mongoose.createConnection(process.env.DB_ALPHA); 

// Register your models for each connection. 
registerModels(dbSand); 
registerModels(dbAlpha); 

function dbPathConfigMiddlewareWrapper() { ... } 

レジスタ-models.js：

const mongoose = require('mongoose'); 
const Schema = mongoose.Schema; 

let UserSchema = new mongoose.Schema(...); 

module.exports = function(conn) { 
    conn.model('User', UserSchema); 
}; 

これはのみ動作するため、あなたが、あなたのルートでUser.find(...)を使用できないことを意味してい（あなたが使用していないmongoose.connect()で作成されるデフォルトの接続）を使用しているとき

代わりに、あなたはあなたのルートにこのようなものを使用する必要があります：あなたが読むべき

req.dbPath.model('User').find(...);