15

我正在使用 express 3.x 和 mongoose 3.6.4。

到目前为止,我一直在我的 express apps.js 文件中创建一个猫鼬连接,如下所示:

var mongoose = require('mongoose');
mongoose.connect('mongodb://127.0.0.1:27017/mytest');

然后我将我的模型分成单独的文件,如模型/用户,如下所示:

var mongoose = require("mongoose");
var Schema = mongoose.Schema;
var ObjectId = Schema.ObjectId;

var userSchema = new Schema({
userId: ObjectId,
givenName:String ...
});

exports.User = mongoose.model('User', userSchema);

然后在多个路由文件中,我使用了 User 模型,如下所示:

var User = require('./models/user').User;
User.findById(id, function(err, user){ ...

这对当地的发展起到了很好的作用。所有模型共享相同的连接。

但现在我想使用 mongoose.createConnection() 并创建一个可以以类似方式使用的连接池。我想在应用程序启动时建立一个连接池并将该池用于所有模型。所以,我试过这个:

var conn = mongoose.createConnection("localhost","dpatest", 27017,{user:"???",pass:"???"});

但模型不会自动共享连接。因此,我尝试了各种方法,例如导出连接并尝试在模型中使用它。但是,除了为每个模型设置单独的连接之外,没有任何效果。

有人可以解释如何使用 mongoose.createConnection() 创建单个连接池吗?

这是有关我的问题的更多信息:

/************ app.js *****************/
var http = require('http');
var path = require('path');
var express = require('express');
//these are my routing files
var auth = require('./src/auth');
var profile = require('./src/profile');
var admin = require('./src/admin');
var tx = require('./src/tx');
var system = require('./src/system');
var servicing = require('./src/servicing');

var dbUri;
var dbUser = "?????";
var dbPass = "?????";

//here are my configurations for development and production
app.configure('development', function(){
    app.set('port', 3460);
    app.use(express.errorHandler());
    dbUri = "mongodb://mongodb://127.0.0.1:27017/dpatest";
});

app.configure('production', function(){
    app.set('port', 3461);
    dbName = 'dpa';
    dbUri = "mongodb://"+dbUser+":"+dbPass+"@ds052525.mongolab.com:51437/dpa";
});

/*
this is what I was originally using for development
and want to change for deployment
*/
mongoose.connect(dbUri);

这就是我打算搬到的地方:

var conn = mongoose.createConnection(dbUri);

我的模型(5 个不同的模型)位于应用程序根目录下名为 src/models 的目录中。例如用户模型:

/************ user.js *************/
var mongoose = require("mongoose");
var Schema = mongoose.Schema;
var ObjectId = Schema.ObjectId;
var userSchema = new Schema({
    userId: ObjectId,
    givenName: String, ...
});

导出如下:

export.User = mongoose.model('User', userSchema);

然后,模型在各种路由文件中使用,如下所示:

/****************auth.js**************/
var User = require('./models/user').User;

exports.createAccount = function(req, res){
    var user = new User({});
    . . . 
    user.save(function(err, usr){

    });
};

我正在寻找一个如何用 mongoose.createConnection 替换 mongoose.connect() 并让它跨多个模块工作的具体示例。Sergey 的回答看起来很有希望,但我不明白如何在路由文件中引用模型。我试过了:

var User = require(../models).User

但无法让它工作。它不断抛出参考错误。

谢谢!

4

4 回答 4

4

在您的模型文件夹中创建 index.js

例如

    module.exports = function (mongoose,  dbconn) {
        return {

            modelname:  require("./file" )(mongoose, dbconn),
            modelname2:  require("./file2" )(mongoose,  dbconn),
   };
};

然后将其加载到您的主启动文件文件中,您可以在其中通过以下方式创建数据库连接

var models    = require("./models")(mongoose,dbconn);

模型文件夹中的示例模型文件应如下所示:

module.exports = function (mongoose,  dbconn) {
    /*
     * 
     */
    var schema = new mongoose.Schema({
        /**
         * field
         * @type String
         */
        field: String......
      });

  return dbconn.model("modelname", schema, "collectioname");
};

等等....

于 2013-04-11T20:07:36.170 回答
4

我知道已经有一段时间了,但我找到了这篇文章,我想知道你们对此有何看法,它看起来很优雅。 https://productbuilder.wordpress.com/2013/09/06/using-a-single-global-db-connection-in-node-js/

它基本上是说使用 Node.js 的 global.varName 机制来全局共享连接。

顺便说一句,我自己试过了,它可以无缝运行。

于 2015-11-15T10:20:32.207 回答
2

GitHub 上的这个示例项目是实现目标的一种非常简单的方法。它优雅而有效: https ://github.com/fbeshears/register_models 。主要代码是:

(function(){
  module.exports = function(){
    var mongoose = require('mongoose');
    var Schema = mongoose.Schema; 
    var files = ['kitten.js', 'comments.js'];
    var fn = 0;
            for(fn in files) {
            var path_fn = "./" + files[fn];
            var exported_model = require(path_fn);
            exported_model(mongoose, Schema);
        }

    };
})();

我在我的主应用程序目录下创建了一个名为“models”的目录,并将其放在文件夹中并要求它,然后调用 register_models();

于 2013-06-13T22:48:31.227 回答
-1

我希望现在可以解决这个问题,但以防万一有人发现它有帮助。简而言之,改为

var conn = mongoose.createConnection(..)

要求为此连接注册所有模式。意思是,而不是User = mongoose.model(...)你需要User = db.model(...)

此处链接的更多详细信息:.createConnection 与 .connect 之间的差异

于 2015-02-10T19:12:59.150 回答