在 Node.js 项目中连接多个 Mongo DB答案

【问题标题】：Connecting Multiple Mongo DBs in a Node.js Project在 Node.js 项目中连接多个 Mongo DB
【发布时间】：2018-01-05 04:57:29
【问题描述】：

我正在尝试将多个 MongoDB 数据库连接到一个 Node.js 项目中。这是我目前的结构和手头的问题。

节点版本：v6.12.1

Express.js 版本：4.16.2

猫鼬版本：4.13.6

当前结构：

primaryDB.js

var mongoose = require('mongoose');
var configDB = require('./database.js');


//Connect to MongoDB via Mongoose
mongoose.Promise = require('bluebird');

//mongoose.Promise = global.Promise;
mongoose.connect(configDB.url, { useMongoClient: true });


//Check for successful DB connection
var db = mongoose.connection;
db.on('error', console.error.bind(console, 'connection error:'));
db.once('open', function() {
  console.log("Primary DB Successfully Connected..");
});

module.exports = mongoose;

secondaryDB.js

var mongoose = require('mongoose');

mongoose.connect('mongodb://mongodb_address_goes_here:27017/db_name', { useMongoClient: true });

var db = mongoose.connection;
db.on('error', console.error.bind(console, 'connection error:'));
db.once('open', function() {
  console.log("Secondary DB Successfully Connected..");
});


module.exports = mongoose;

然后每个数据库连接被分别导入到它们的架构文件中，架构文件从中导出模块。

手头的问题

当我运行我的应用程序时，它可以正常启动并成功连接到两个数据库，但是我相信 mongoose 要么被覆盖，要么因为我可以在主服务器上执行 findOne() 命令，但辅助服务器失败，反之亦然。

示例：

var async = require('async');
var primaryModel = require('../../../models/general/primary');
var SecondaryModel = require('../../../models/general/secondary');


function getInfo() {

  async.waterfall([
    getPrimaryName,
    getSecondaryName
  ], function (err, info) {
  });
};

function getPrimaryName(callback){
  Primary.findOne({}, function (err, primaryInfo){
    if (err) {
      console.log("Error" + err);
    }
      console.log('Primary info is : ' + primaryInfo);
     callback(null,primaryInfo);
  });
}



function getSecondaryName(primaryInfo, callback) {
  
  console.log(primaryInfo); //Make sure its being passed

  Secondary.findOne({}, function (err, secondaryInfo) {
    if (err) {
      console.log("Error" + err);
    }
    console.log('Secondary Info is  : ' + secondaryInfo);
    callback(null, secondaryInfo);
  });
}

上面的问题是我可能会从对 Primary 而不是 Secondary 的调用中获取数据。我再次相信这是被覆盖的东西。

任何帮助表示赞赏。对冗长感到抱歉。

【问题讨论】：

标签： javascript node.js mongodb express mongoose

【解决方案1】：

使用mongoose.createConnection 创建您的连接

所以

const conn1 = mongoose.createConnection('first server options')
const conn2 = mongoose.createConnection('second server options')

【讨论】：