Как реализовать асинхронность запросов в базу данных на Express.js ( MySql )?

Question

[hatealleverything]

Добрый день. Столкнулся с такой проблемой. Есть условие, если в базе данных уже существует такой идентификатор, то мы обновим имя в этой строке. Если такого идентификатора нет, то мы добавим идентификатор и имя. Я смог это реализовать, но когда я начал тестировать и заходить и выходить из аккаунта у меня постоянно выскакивала ошибка ( Подключение к базе данных закрыто ). Я понял, что тут не обойтись без асинхронности запросов, начал разбираться в Promise, но проблема осталась. Не могу найти хорошую документацию по Промисам или какое-либо видео. Могли бы вы подсказать как это можно реализовать и где ошибки или подсказать хороший источник по промисам для Express.js. За исключением Metanit, я прочитал статью про pool, но на свой вопрос так и не смог найти ответ.

Вот, что получилось у меня набросать для того, чтобы вообще это сделать.

// pool.query('SELECT * FROM users WHERE vkontakteid = ?', [req.user.id])
// console.log('Подключение к бд успешно, условие выполнено')

// results.length === 0

// const data = [req.user.id, req.user.displayName]
// pool.execute('INSERT INTO users (vkontakteid, name) VALUES (?,?)', data)
// console.log('Данные добавлены')

// const data = [req.user.displayName, req.user.id];
// pool.execute('`UPDATE users SET name=? WHERE vkontakteid=?`', data)
// console.log('Данные обновлены')

Тут я попробовал всё это преобразовать в нормальный код, но это условие у меня вообще не проверяется
if (result.lenght === 0)
И автоматически выводится сразу же else

pool.query('SELECT * FROM users WHERE vkontakteid = ?', [req.user.id], console.log('Подключение к бд успешно, условие выполнено'))
            .then(result => {
                if (result.lenght === 0) {
                    const data = [req.user.id, req.user.displayName]
                    return pool.execute('INSERT INTO users (vkontakteid, name) VALUES (?,?)', data, console.log('Данные добавлены'))
                } else {
                    const data = [req.user.displayName, req.user.id];
                    return pool.execute('UPDATE users SET name=? WHERE vkontakteid=?', data, console.log('Данные обновлены'))
                }
            })
            .then(result => {
                console.log(result[0]);
                pool.end();
            })
            .then(() => {
                console.log("пул закрыт");
            })
            .catch(function(err) {
                console.log(err.message);
            });

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

Comments

[Stalker_RED]

Подключение к базе данных закрыто

вот прямо так и написано?
Вероятно настоящая ошибка скрыта. Найди логи, помотри настоящее сообщение об ошибке и код ошибки.

[Егор Живагин]

Что вот тут выведет консоль?

pool.query('SELECT * FROM users WHERE vkontakteid = ?', [req.user.id], console.log('Подключение к бд успешно, условие выполнено'))
            .then(result => {
                console.log(result);

[re_quest]

Так не пробовали?

const pool = mysql.createPool({
    //   ... 
});

pool.getConnection(function (err, connection) {
    connection.query('SELECT * FROM users WHERE vkontakteid = ?', [req.user.id], function (err, result) {
                if (err) console.log(err);
                console.log(result)
            }))
    pool.releaseConnection(connection);
})

[hatealleverything]

Stalker_RED, Нет не "прям" так написано, просто это очевидно, что на следующее нажатие кнопки ( после которой идёт подключение ) пишет, что закрыт пул

[hatealleverything]

Егор Живагин,
Извините, что так долго не отвечал, что-то я не увидел, что мне несколько человек написало не ответом, а комментарием...

Подключение к бд успешно, условие выполнено
[
  [],
  [
    ColumnDefinition {
      _buf: <Buffer 01 00 00 01 09 2d 00 00 02 03 64 65 66 09 74 61 73 74 79 64 72 6f 70 05 75 73 65 72 73 05 75 73 65 72 73 02 69 64 02 69 64 0c 3f 00 0b 00 00 00 03 03 ... 502 more bytes>,
      _clientEncoding: 'utf8',
      _catalogLength: 3,
      _catalogStart: 482,
      _schemaLength: 9,
      _schemaStart: 486,
      _tableLength: 5,
      _tableStart: 496,
      _orgTableLength: 5,
      _orgTableStart: 502,
      _orgNameLength: 6,
      _orgNameStart: 515,
      characterSet: 63,
      encoding: 'binary',
      name: 'status',
      columnLength: 11,
      columnType: 3,
      flags: 1,
      decimals: 0
    }
  ]
]

[hatealleverything]

re_quest, Сейчас попробовал, как по мне идеальное решение моего вопроса, большое спасибо. Всё прекрасно работает, но вопрос. А где нужно закрывать подключение и нужно ли вообще или оно само просто закрывается как функция отработала, а если ещё раз нужно она просто его релизит?

pool.getConnection(function(err, connect) {

            connect.query('SELECT * FROM users WHERE vkontakteid = ?', [req.user.id], function(err, result) {

                if (err) console.log(err);

                else {
                    if (result.length === 0) {
                        const data = [req.user.id, req.user.displayName]
                        connect.execute('INSERT INTO users (vkontakteid, name) VALUES (?,?)', data)
                        console.log('Вы были зарегистрированы')
                    } else {
                        const data = [req.user.displayName, req.user.id];
                        connect.execute('UPDATE users SET name=? WHERE vkontakteid=?', data)
                        console.log('Такой пользователь уже существует')
                    }
                }

            }, pool.releaseConnection(connect))
        })
        res.redirect('/')

[re_quest]

hatealleverything, Как я понял releaseConnection освобождает пулл, и делает его доступным для использования в других запросах. Я не очень разобрался в этом, и у себя не закрываю соединение. Вы можете почитать тут, может что то поймете.
Сейчас у себя я попробовал закрыть соединение, не увидел не каких изменений)

const pool = mysql.createPool({
    //   ... 
});

pool.getConnection(function (err, connection) {
    connection.query('SELECT * FROM users WHERE vkontakteid = ?', [req.user.id], function (err, result) {
                if (err) console.log(err);
                console.log(result)
            }))
    // pool.releaseConnection(connection);
    pool.end(function (err) {
            if (err) console.log(err)
            console.log('pool end')
    })
})

[hatealleverything]

re_quest, Можете ещё пожалуйста подсказать, как я могу вывести id в переменную?

pool.getConnection(function(err, connect) {

            connect.query('SELECT * FROM users WHERE vkontakteid = ?', [req.user.id], function(err, result) {

                if (err) console.log(err);

                else {
                    if (result.length === 0) {
                        const data = [req.user.id, req.user.displayName]
                        connect.execute('INSERT INTO users (vkontakteid, name) VALUES (?,?)', data)
                        console.log('Вы были зарегистрированы')
                        const id = result.id
                    } else {
                        const data = [req.user.displayName, req.user.id];
                        connect.execute('UPDATE users SET name=? WHERE vkontakteid=?', data)
                        console.log('Такой пользователь уже существует')
                    }
                }

            }, pool.releaseConnection(connect))
        })
        res.redirect('/')

Как я могу здесь вывести id, постоянно выводит undefind, требует result[Строку из бд].id,
как этого избежать и как избежать перебора всех чисел, так как выборка 'SELECT * FROM users WHERE vkontakteid = ?' есть, как мне можно вывести из этого массива id в переменную

[re_quest]

hatealleverything, Вам result.id нужно вывести где то в другом месте?

[hatealleverything]

re_quest, Да на фронтенде...

[hatealleverything]

re_quest, И тут просто будет удобно его присвоить, чтобы не создавать подключение

[hatealleverything]

pool.getConnection(function(err, connect) {

            connect.query('SELECT * FROM users WHERE vkontakteid = ?', [req.user.id], function(err, result) {

                if (err) console.log(err);

                else {
                    if (result.length === 0) {
                        const data = [req.user.id, req.user.displayName]
                        connect.execute('INSERT INTO users (vkontakteid, name) VALUES (?,?)', data)
                        console.log('Вы были зарегистрированы')
                    } else {
                        const data = [req.user.displayName, req.user.id];
                        connect.execute('UPDATE users SET name=? WHERE vkontakteid=?', data)
                        console.log('Такой пользователь уже существует')
                        console.log(result)
                    }
                }

            }, pool.releaseConnection(connect))
        })
        res.redirect('/')

Можно ли как-то вывести этот id в переменную?

[re_quest]

hatealleverything, Если я Вас правильно понял. Я делаю так

let id;

pool.getConnection(function(err, connect) {
    connect.query('SELECT * FROM users WHERE vkontakteid = ?', [req.user.id], function(err, result) {
             if (err) console.log(err);
                 id = result; // сохраняем в переменную
            }
})
// без тайм аута не сработает, будет пустая id
setTimeout(function () {
    console.log(id[0].id)
    res.render('test', {
        idVK: id // и на фронте уже вывожу
    })
},1000)

[re_quest]

hatealleverything, Если в запросе хотите получать только id из базы
SELECT id FROM users WHERE vkontakteid = ?

[hatealleverything]

re_quest, большое спасибо

[re_quest]

hatealleverything, Пожалуйста

Answer 1

[Антон Антон]

Конкретно эта задача решается через https://dev.mysql.com/doc/refman/8.0/en/insert-on-...

Comments

[hatealleverything]

Что-то я все равно не понял, как это можно реализовать в express js

[hatealleverything]

hatealleverything, Я вроде разобрался с обновлением идентификатора, если он уникальный, но а как быть со всем остальным...