1

我正在开发一个节点模块。我需要将猫鼬传递给我的模块以从中获取三件事（mongoose.connection、mongoose.connection.db、mongoose.mongo）。

index.js (myModule - 我开发的模块)

function myModule(mongoose) {
    var db = mongoose.connection;
    var gfs = gridfsLockingStream(mongoose.connection.db, mongoose.mongo);
    this.someFunction = function() {//some code here}
}
module.exports = myModule;

db.js（用户必须像这样使用 myModule）

var mongoose = require('mongoose');
var myModule = require('myModule');

var dbUrl = 'mongodb://localhost:27017/gfsTestDB';
mongoose.connect(dbUrl);

var readyObj = new myModule(mongoose);
module.exports = readyObj; // so that the user can use this everywhere

然后用户可以使用readyObj来完成他/她的工作。我的问题是myModule函数中只有mongoose.connection可用，我收到此错误（gridfsLockingStreamn 导致错误）：

错误：缺少 db 参数

新网格（db，mongo）

我在用着 ：

"mongodb": "3.0.4",

"mongoose": "4.11.6",

"gridfs-locking-stream": "1.1.1",

"gridfs-stream": "1.1.1",

一种解决方案（来自@GrégoryNEUT 的想法）（但我认为这不是正确的方法）：

index.js 没有变化

db.js使用promise和mongoose事件处理程序

var mongoose = require('mongoose');
var myModule = require('myModule');

var dbUrl = 'mongodb://localhost:27017/gfsTestDB';
mongoose.connect(dbUrl);


module.exports = new Promise(function (resolve, reject) {

    mongoose.connection.on('connected', function () {
        var readyObj = new myModule(mongoose);
        resolve(readyObj);
    });
});

photoRouter.js（用户的文件之一 - 用户想要使用readyObj）

var readyObj = require('./db').then(function (readyObj) {
    // then the user uses readyObj
}

代码可以改进吗？

4

1 回答 1

1

查看mongoose connect的文档

你可以使用 Promise。

    var mongoose = require('mongoose');
    var myModule = require('myModule');

    var dbUrl = 'mongodb://localhost:27017/gfsTestDB';

    mongoose.connect(dbUrl)
      .then(
        // The connection is ready to use!
        () => {
          var readyObj = new myModule(mongoose);

          // ...
        },

        // Handle the connection error
        (err) => {
          // ...
        },
      );

您可以使用回调

    var mongoose = require('mongoose');
    var myModule = require('myModule');

    var dbUrl = 'mongodb://localhost:27017/gfsTestDB';

    mongoose.connect(dbUrl, (err) => {
      if (err) {
        // Handle the error

        // ...

        return;
      }

      // We get successfully connected to the database

      var readyObj = new myModule(mongoose);

      // ...
    });
于 2018-03-22T17:57:35.053 回答