Как заставить Node.Js дождаться выполнения MySQL?

Question

[ebanytiu_lis]

Т.к. Node.js, в отличии от PHP - штука асинхронная, то возникают некоторые трудности...

function sql_get(){
  var mysql      = require('mysql');
  var connection = mysql.createConnection({
    host     : 'localhost',
    user     : 'root',
    password : '',
    database : '1047750'
  });
  connection.query(
    'SELECT * FROM test',
    function(err, result, fields){
      return(result[0]);
    }
  );
  
  connection.end();
}
console.log(sql_get());

Код выводит в консоль "undefined"...
ВНИМАНИЕ, ВОПРОС! Как заставить Node дождаться ответа от MySQL, а потом уж вывести значение в консоль?
В гугл не слать! Кроме головной боли он пока ничего не дал...

Answer 1

[Сережа Ахен]

А если так:

var mysql      = require('mysql');
  var connection = mysql.createConnection({
    host     : 'localhost',
    user     : 'root',
    password : '',
    database : '1047750'
  });
  connection.query(
    'SELECT * FROM test',
    function(err, result, fields){
      console.log(err);
      console.log(result);
    }
  );
  
  connection.end();

У вас тут итак колбек, функция, которая будет вызвана после совершения запроса и примет в себя данные (результат либо ошибка).

Comments

[ebanytiu_lis]

Я так и хотел сначала, но так кода будет в несколько раз больше...

[Kovalsky]

ebanytiu_lis: не-не-не, Девид Блейн, смысл как раз в том, что в вашем коде уже и так реализован колбэк, который прекрасно справляется с задачей "заставить Node.Js дождаться выполнения MySQL". Вопрос только в том, почему вам не нравится такая организация, и что значит "кода будет в несколько раз больше" - кода в любом случае будет одинаковое количество, просто он будет по-разному распределён. Почти каждое node приложение имеет такую функцию init, в которой выполняются какие-то начальные/проверочные запросы к БД и другие процедуры.

[Сережа Ахен]

ebanytiu_lis: по уму вам нужен connection pool. Суть: при инициализации ваш скрипт поднимает энное количество коннектов к базе, а далее при запросах берет свободный коннект, блокирует его, а после использования возвращает на место.

Реализация на промисах (ну тип модно и лучше колбеков):
Для удобства выносим настройку бд в отдельный файл, чтобы оно нам глаза не мозолило:

var pool = require('mysql').createPool({
    host: 'localhost',
    user: 'user',
    password: 'pass',
    database: 'dbname',
    connectionLimit: 100
});
exports.query = function (sql, props) {
    return new Promise(function (resolve, reject) {
        pool.getConnection(function (err, connection) {
            connection.query(
                sql, props,
                function (err, res) {
                    if (err) reject(err);
                    else resolve(res);
                }
            );
            connection.release();
        });
    });
};

Непосредственно в вашей программе подключаем этот файл и мы уже можем использовать функцию query. Грубо говоря - в .then возвращается результат, в .catch возвращается ошибка.
Но вам, опять-же, стоит почитать на тему промисы vs колбеки vs async и избрать какой-то один путь, чтобы не получилось что половина программы на устаревших и глаза ломающих колбеках, а половина на промисах неверно используемых.

var query = require('./mysql').query;

query('SELECT * FROM cms_users WHERE id = ?', [5]).then(function (res) {
    // здесь код будет выполнятся после запроса
    console.log('Result');
    console.log(res);
}).catch(function (err) {
    // здесь будет сообщение об ошибке
    console.log('Error');
    console.log(err);
});

P.S. Данный пример не является единственно верным/красивым/надежным.

[ebanytiu_lis]

Сережа Ахен: Совсем не в ту сторону...
Вот смотрите:
Я только что с PHP пришёл, поэтому всё понимать немножко трудно.
Алгоритм такой (назову его блоком):
1. Отправляем запрос
2. Получаем ответ
3. Выводим его

Я хотел выделить отправление и получение в функцию, чтобы это занимало меньше места (изначально в функции должен быть аргумент - столбец, значение которого нам нужно)... На PHP это бы прекрасно работало, но здесь либо я тупой (а это именно так), либо я тупой (и это точно).

Ваш вариант подходит. Но он подходит если блоков мало. А если у меня будет их десять?
Работать-то оно конечно будет, но код получится громоздкий...
Отсюда и мои тщетные попытки заставить node сначала дождаться ответа, а потом вывести его...

[ebanytiu_lis]

Сережа Ахен: вот, например, как я вижу код на PHP:

//Создаём функцию
function sql_get($get){
  $link = mysqli_connect('localhost', 'root', '', '1047750');
  $query = "SELECT * FROM test";
  $row = mysqli_fetch_array(mysqli_query($link, $query), MYSQLI_ASSOC);
  if ($row){
    return($row[$get]);
  }
switch($var){
  case 0:
    echo (sql_get("a"));
    break;
  case 1:
    echo (sql_get("jdsl"));
    break;
  case 56:
    echo (sql_get("hzhz"));
    break;
}
}

Представить страшно, какой большой получится код, если 1 сточку (sql_get()) заменить на 9 Ваших...
Но если другого решения нет...

[Сережа Ахен]

ebanytiu_lis: подождите, каких 9?) То, что мы отнесли в другой файл - пулл коннектов, нам его менять не нужно (кроме данных от БД). Далее же мы выполняем простейшим образом запрос

query('SELECT * FROM cms_users WHERE id = ?', [5]).then(function (res) {
//Замечательно! Работаем с полученными данными.
//Вы выводите данные по ключу, не вопрос! 

console.log(res[0].a);
console.log(res[0].jdsl);
console.log(res[0].hzhz);

}).catch(function (err) {
//Досадно, но нужно обработать ошибку, они случаются, увы

});

[Сережа Ахен]

ebanytiu_lis: ну или вот вам подобие свитча, только зачем нам какой-то свитч? Мне ваш кейс работы с бд не понятен от слова совсем. Здесь мы кидаем в переменную myParam значение, которе Вы бы использовали при свитче в пхп. Допустим "a".
И Вы не поверите, оно дождется выполнения запроса, прежде чем попытаться вывести результат в консоль (произвести необходимые вам действия). Вот и все.
Если Вы настолько пхп, можете в лс вк черкануть, скину пример (далеко не лучший) реализации сессий в боте для вк на node + mysql.

function dbrequest (param) {
  return new Promise(function (resolve, reject) {
    query('SELECT * FROM test', [5]).then(function (res) {
        resolve(res[0][param])
    }).catch(function (err) {
      reject(err)
    })
  })
}
var myParam = 'a'
dbrequest (myParam).then(function (res){
  console.log(res)
})

[ebanytiu_lis]

Сережа Ахен: тэкс...
Извините, если сильно напрягаю)))
Получается должно быть так:
best_function_from_serega.js

var pool = require('mysql').createPool({
    host: 'localhost',
    user: 'user',
    password: 'pass',
    database: 'dbname',
    connectionLimit: 100
});
exports.query = function (sql, props) {
    return new Promise(function (resolve, reject) {
        pool.getConnection(function (err, connection) {
            connection.query(
                sql, props,
                function (err, res) {
                    if (err) reject(err);
                    else resolve(res);
                }
            );
            connection.release();
        });
    });
};

my_mega_strange_and_hard_script.js

var query = require('./mysql').query; //Это же подключение и "best_function_from_serega.js", правильно?

query('SELECT * FROM test WHERE id = ?', [5]).then(function (res) { //Откуда 5?))))
//Замечательно! Работаем с полученными данными.
//Вы выводите данные по ключу, не вопрос! 

switch($var){
  case 0:
    console.log(res[0].a);
    break;
  case 1:
    console.log(res[0].jdsl);
    break;
  case 2:
    console.log(res[0].hzhz);
    break;
}

}).catch(function (err) {
  console.log('AHTUNG!!! OPASNOST!!!');
  console.log(err);
});

[Сережа Ахен]

ebanytiu_lis:

var query = require('./best_function_from_serega').query;

Ну все верно

[ebanytiu_lis]

Сережа Ахен:

Мне ваш кейс работы с бд не понятен от слова совсем.

Имеете ввиду, не понятен на PHP?
Опишу на русском:
функция получает на вход два параметра >id, >get (дааа, я только сейчас допёр, что мне нужен ещё один параметр)
1) открывается подключение
2) выполняется запрос (как раз таки, Ваш запрос тут и подойдёт)
SELECT * FROM test WHERE id = >id
3) запрос возвращает массив
4) берём из массива нужный нам столбец (>get)

а ещё я чиркнул вам в вк...

Answer 2

[Олег Гамега]

используйте async await

Answer 3

[Александр Дроздов]

Заюзай библу sync
https://github.com/ybogdanov/node-sync

Comments

[Boris Köln]

Делать асинхронный node синхронным - глупо

Answer 4

[Boris Köln]

Функция sql_get() не имеет return, поэтому "undefined".
return совсем в другой функции. Кстати, он никак не используется. Вместо него напишите вызов нужного вам действия (например, console.log(result);).

Забудьте про PHP и синхронность. Если взялись писать на node.js - учитесь асинхронности!

Comments

[ebanytiu_lis]

Я хотел написать бота для телеграмма... И думал, смогу выделить запрос к базе данных в отдельную функцию, что бы кода поменьше было...

[Boris Köln]

Да, запрос выполнить правильнее в единой функции.
А вот обработку результата надо выполнять в персональной функции.

Вариант 1: в sql_get передавать callback-функцию и вызывать ее после получения результата. Только поаккуратнее, чтобы не было callback hell

Вариант 2 (предпочтительней): sql_get возвращает promise. Дальнейшая обработка идет после его окончания.

Answer 5

[Александр N++]

await из ES6 передает вам привет

caolan.github.io/async
лучшая псевдо асинхроностьи избавление от колбасы колбеков