如何在NodeJS应用程序和模块之间正确重用到MongoDB的连接

Question

如何在NodeJS应用程序和模块之间正确重用到MongoDB的连接我一直在阅读，但仍然困惑于如何在整个NodeJS应用程序之间共享相同的数据库(MongoDB)连接。据我所知，当应用程序在模块之间启动和重用时，连接应该是打开的。我目前认为最好的方法是server.js(启动时的主文件)连接到数据库，并创建传递给模块的对象变量。连接后，模块将根据需要使用此变量，此连接将保持打开状态。例如：    var MongoClient = require('mongodb').MongoClient;     var mongo = {}; // this is passed to modules and code     MongoClient.connect("mongodb://localhost:27017/marankings", function(err, db) {         if (!err) {             console.log("We are connected");             // these tables will be passed to modules as part of mongo object             mongo.dbUsers = db.collection("users");             mongo.dbDisciplines = db.collection("disciplines");             console.log("aaa " + users.getAll()); // displays object and this can be used from inside modules         } else             console.log(err);     });     var users = new(require("./models/user"))(app, mongo);     console.log("bbb " + users.getAll()); // not connected at the very first time so displays undefined然后是另一个模块models/user看起来是这样的：Users = function(app, mongo) {Users.prototype.addUser = function() {     console.log("add user");}Users.prototype.getAll = function() {     return "all users " + mongo.dbUsers;     }}module.exports = Users;现在我有可怕的感觉，这是错误的，所以这种方法是否有明显的问题，如果是的话，如何使它更好？

Answer 1

我一直在阅读，但仍然困惑于如何在整个NodeJS应用程序之间共享相同的数据库(MongoDB)连接。据我所知，当应用程序在模块之间启动和重用时，连接应该是打开的。我目前认为最好的方法是server.js(启动时的主文件)连接到数据库，并创建传递给模块的对象变量。连接后，模块将根据需要使用此变量，此连接将保持打开状态。例如：

    var MongoClient = require('mongodb').MongoClient;
    var mongo = {}; // this is passed to modules and code

    MongoClient.connect("mongodb://localhost:27017/marankings", function(err, db) {
        if (!err) {
            console.log("We are connected");

            // these tables will be passed to modules as part of mongo object
            mongo.dbUsers = db.collection("users");
            mongo.dbDisciplines = db.collection("disciplines");

            console.log("aaa " + users.getAll()); // displays object and this can be used from inside modules

        } else
            console.log(err);
    });

    var users = new(require("./models/user"))(app, mongo);
    console.log("bbb " + users.getAll()); // not connected at the very first time so displays undefined

然后是另一个模块models/user看起来是这样的：

Users = function(app, mongo) {Users.prototype.addUser = function() {
    console.log("add user");}Users.prototype.getAll = function() {

    return "all users " + mongo.dbUsers;

    }}module.exports = Users;

现在我有可怕的感觉，这是错误的，所以这种方法是否有明显的问题，如果是的话，如何使它更好？

Answer 2

您可以创建一个mongoUtil.js模块，该模块具有连接到mongo和返回mongo db实例的功能：

const MongoClient = require( 'mongodb' ).MongoClient;const url = "mongodb://localhost:27017";var _db;module.exports = {

  connectToServer: function( callback ) {
    MongoClient.connect( url,  { useNewUrlParser: true }, function( err, client ) {
      _db  = client.db('test_db');
      return callback( err );
    } );
  },

  getDb: function() {
    return _db;
  }};

要使用它，你可以在你的app.js:

var mongoUtil = require( 'mongoUtil' );mongoUtil.connectToServer( function( err, client ) {
  if (err) console.log(err);
  // start the rest of your app here} );

然后，当你需要访问其他地方的蒙戈时，比如在另一个地方.js文件，您可以这样做：

var mongoUtil = require( 'mongoUtil' );var db = mongoUtil.getDb();db.collection( 'users' ).find();

这是因为在节点中，当模块是require，它们只加载一次/来源一次，因此您将只得到一个_db和mongoUtil.getDb()将始终返回相同的实例。

注意，代码没有测试。

Answer 3

以下是我如何使用当代语法，基于围棋奥列格的例子。我的是测试和功能。

我在代码中添加了一些注释。

./db/monGodb.js

 const MongoClient = require('mongodb').MongoClient
 const uri = 'mongodb://user:password@localhost:27017/dbName'
 let _db const connectDB = async (callback) => {
     try {
         MongoClient.connect(uri, (err, db) => {
             _db = db             return callback(err)
         })
     } catch (e) {
         throw e     }
 }

 const getDB = () => _db const disconnectDB = () => _db.close()

 module.exports = { connectDB, getDB, disconnectDB }

./index.js

 // Load MongoDB utils
 const MongoDB = require('./db/mongodb')
 // Load queries & mutations
 const Users = require('./users')

 // Improve debugging
 process.on('unhandledRejection', (reason, p) => {
     console.log('Unhandled Rejection at:', p, 'reason:', reason)
 })

 const seedUser = {
     name: 'Bob Alice',
     email: '[e-mail]',
     bonusSetting: true
 }

 // Connect to MongoDB and put server instantiation code inside
 // because we start the connection first
 MongoDB.connectDB(async (err) => {
     if (err) throw err     // Load db & collections
     const db = MongoDB.getDB()
     const users = db.collection('users')

     try {
         // Run some sample operations
         // and pass users collection into models
         const newUser = await Users.createUser(users, seedUser)
         const listUsers = await Users.getUsers(users)
         const findUser = await Users.findUserById(users, newUser._id)

         console.log('CREATE USER')
         console.log(newUser)
         console.log('GET ALL USERS')
         console.log(listUsers)
         console.log('FIND USER')
         console.log(findUser)
     } catch (e) {
         throw e     }

     const desired = true
     if (desired) {
         // Use disconnectDB for clean driver disconnect
         MongoDB.disconnectDB()
         process.exit(0)
     }
     // Server code anywhere above here inside connectDB()
 })

./user/index.js

 const ObjectID = require('mongodb').ObjectID

 // Notice how the users collection is passed into the models
 const createUser = async (users, user) => {
     try {
         const results = await users.insertOne(user)
         return results.ops[0]
     } catch (e) {
         throw e     }
 }

 const getUsers = async (users) => {
     try {
         const results = await users.find().toArray()
         return results     } catch (e) {
         throw e     }
 }

 const findUserById = async (users, id) => {
     try {
         if (!ObjectID.isValid(id)) throw 'Invalid MongoDB ID.'
         const results = await users.findOne(ObjectID(id))
         return results     } catch (e) {
         throw e     }
 }

 // Export garbage as methods on the Users object
 module.exports = { createUser, getUsers, findUserById }