Как правильно организовать запрос к базе данных MySQL из Node.JS приложения?

Question

[nurzhannogerbek]

Здравствуйте, товарищи! Помогите пожалуйста разобраться. Пытаюсь правильно организовать запрос к MySQL базе данных из Node.JS приложения.

В проекте Node.JS при первом запуске сервера вызываю модуль, который создает пул для базы данных MySQL. Выглядит этот модуль следующим образом:

const mysql = require('mysql');
const configuration = require('../config/mysql_database');

async function initialization() {
    await mysql.createPool(configuration);
}

module.exports.initialization = initialization;

Далее в проекте при обращении к определенному url адресу запускаю контроллер, который вызывает функцию для выполнения нативного SQL запроса. Выглядит она следующим образом:

mysql_database.js:

function executeSQLStatement(query, binds = []) {
    return new Promise(async (resolve, reject) => {
        let connection;
        try {
            const  result = await mysql.query(query, binds, function (error, results, fields) {
                if (error) throw error;
            });
            resolve(result);
        } catch (error) {
            reject(error);
        } finally {
            if (connection) {
                try {
                    await connection.close();
                } catch (error) {
                    console.log(error);
                }
            }
        }
    });
}

module.exports.executeSQLStatement = executeSQLStatement;

Ошибка в терминале:

TypeError: mysql.query is not a function
at new Promise (<anonymous>)
500     at Object.executeSQLStatement

Из официальной документации (ссылка) видно, что при выполнении запроса, каждый раз создают пул. Насколько это правильно?

Answer 1

[Евгений]

Это можно в отдельный файл вынести.

var mysql = require('mysql');
var pool  = mysql.createPool({
  connectionLimit : 10,
  host            : 'example.org',
  user            : 'bob',
  password        : 'secret',
  database        : 'my_db'
});

module.exports = pool;

А потом подключать этот модуль и пользоваться

const pool   = require('./file');
const query = 'SELECT 1 + 1 AS solution';
const result = await pool.query(query);

Comments

[nurzhannogerbek]

Евгений, здравствуйте! Я изначально также сделал, но потом подумал, что это не best practice. Я правильно понимаю, что в этом варианте мы все равно создаем новый пул для каждого нового запроса?! Поправьте меня, если я что-то путаю.

[Евгений]

NogerbekNurzhan, Когда вы создаете пул соединений то они уже открыты и ждут пока к ним подключатся. И для каждого запроса не создается новый пул они уже созданы на момент обращения.

Answer 2

[Михаил]

Из официальной документации видно, что при выполнении запроса, каждый раз создают пул.

Нет! Пул создаётся единожды, из которого потом при каждом запросе берётся соединение (на то он и пул).
Функция executeSQLStatement тоже не нужна, ито это то же самое, что и connection.query('', () => {}).
Делайте всё как в ответе Евгения, и всё будет хорошо