Подключение к Mongodb-Native-Driver в express.js

как подключиться к базе данных?

Чтобы подключиться с помощью собственного драйвера MongoDB, вам нужно сделать что-то вроде следующего:

var util = require('util');
var mongodb = require('mongodb');
var client = mongodb.MongoClient;

var auth = {
    user: 'username',
    pass: 'password',
    host: 'hostname',
    port: 1337,
    name: 'databaseName'
};

var uri = util.format('mongodb://%s:%s@%s:%d/%s',
    auth.user, auth.pass, auth.host, auth.port, auth.name);

/** Connect to the Mongo database at the URI using the client */
client.connect(uri, { auto_reconnect: true }, function (err, database) {
    if (err) throw err;
    else if (!database) console.log('Unknown error connecting to database');
    else {

        console.log('Connected to MongoDB database server at:');
        console.log('\n\t%s\n', uri);

        // Create or access collections, etc here using the database object
    }
});

Базовое соединение настраивается следующим образом. Это все, что я могу вам дать, это просто базовое описание того, что вы хотите. Опубликуйте некоторый код, который у вас есть, чтобы получить более конкретную помощь.

Должен ли я создавать соединение в каждом из этих файлов и использовать их?

No.

Как мне создать единый пул соединений и использовать его во всех файлах collections.js?

Вы можете создать один файл с кодом, подобным приведенному выше, назовем его dbmanager.js для подключения к базе данных. Экспортируйте такие функции, как createUser, deleteUser и т. д., которые работают с вашей базой данных, а затем экспортируйте функциональность следующим образом:

module.exports = {
    createUser: function () { ; },
    deleteUser: function () { ; }
};

который вы могли бы затем require из другого файла вот так:

var dbman = require('./dbmanager');

dbman.createUser(userData); // using connection established in `dbmanager.js`

EDIT: Поскольку мы имеем дело с JavaScript и одним потоком, собственный драйвер действительно автоматически обрабатывает пул соединений для вас. Вы можете найти это по ссылкам StackOverflow ниже для получения дополнительных подтверждений этого. ОП также указывает это в вопросе. Это означает, что client.connect должен вызываться только один раз экземпляром вашего сервера. После того, как объект database будет успешно получен из вызова client.connect, этот объект database следует повторно использовать во всем экземпляре вашего приложения. Это легко сделать с помощью шаблона модуля, предоставляемого Node.JS.

Мое предложение состоит в том, чтобы создать модуль или набор модулей, которые служат единой точкой контакта для взаимодействия с базой данных. В моих приложениях у меня обычно есть один модуль, который зависит от родного драйвера и вызывает require('mongodb'). Все остальные модули в моем приложении не будут напрямую обращаться к базе данных, но вместо этого все манипуляции должны координироваться этим модулем базы данных.

Это инкапсулирует весь код, связанный с собственным драйвером, в один модуль или набор модулей. ОП, кажется, думает, что есть проблема с простым примером кода, который я опубликовал, описывая проблему с «одним большим закрытием» в моем примере. Это все довольно простые вещи, поэтому я добавляю разъяснения относительно базовой архитектуры, но я все еще не чувствую необходимости менять какой-либо код.

ОП также, кажется, думает, что здесь можно установить несколько соединений. Это невозможно с этой установкой. Если вы создали модуль, как я предлагаю выше, то при первом вызове require('./dbmanager') он выполнит код в файле dbmanager.js и вернет объект module.exports. Объект экспорта кэшируется и также возвращается при каждом последующем вызове require('./dbmanager'), однако код в dbmanager.js будет выполняться только в первый require.

Если вы не хотите создавать такой модуль, другим вариантом будет экспортировать только database, переданный в обратный вызов для client.connect, и использовать его напрямую в разных местах вашего приложения. Однако я рекомендую против этого, независимо от опасений ОП.

Подобные, возможно, повторяющиеся вопросы Stackoverflow, среди прочего:

• Как управлять подключениями mongodb в веб-приложении nodejs
• Node.JS и MongoDB, повторное использование объекта БД
• Node.JS - Как правильно поступить с Подключения MongoDB

Как говорится в принятом ответе, вы должны создать только одно соединение для всех входящих запросов и повторно использовать его, но в ответе отсутствует решение, которое создаст и кэширует соединение. Для этого я написал экспресс-промежуточное ПО — express-mongo-db. На первый взгляд эта задача тривиальна, и большинство людей используют такой код:

var db;
function createConnection(req, res, next) {
    if (db) { req.db = db; next(); }
    client.connect(uri, { auto_reconnect: true }, function (err, database) {
        req.db = db = databse;
        next();
    });
}

app.use(createConnection);

Но этот код приводит к утечке соединения, когда одновременно приходит несколько запросов, а db не определено. express-mongo-db решить эту проблему путем удержания входящих клиентов и вызова connect только один раз, когда требуется модуль (а не при поступлении первого запроса).

Надеюсь, что вы найдете ее полезной.

Я просто подумал, что добавлю свой собственный метод подключения к MongoDB для других, заинтересованных или имеющих проблемы с другими методами.

Этот метод предполагает, что вам не нужна аутентификация (я использую это на локальном хосте)

Аутентификацию по-прежнему легко реализовать

var MongoClient = require('mongodb').MongoClient;
var Server      = require('mongodb').Server;

var client = new MongoClient(new Server('localhost',27017,{
                                socketOptions: {connectTimeoutMS: 500},
                                poolSize:5,
                                auto_reconnect:true
                            }, {
                                numberOfRetries:3,
                                retryMilliseconds: 500
                            }));

client.open(function(err, client) {
    if(err) {
        console.log("Connection Failed Via Client Object.");
    } else {
        var db = client.db("theDbName");
        if(db) {
            console.log("Connected Via Client Object . . .");
            db.logout(function(err,result) {
                if(!err) {
                    console.log("Logged out successfully");
                }
                client.close();
                console.log("Connection closed");
            });
        }
    }
});

Кредит принадлежит Брэду Дэвли, который описывает этот метод в своей книге (стр. 231-232)