Конфигурация mysql узел js error Не удается поставить в очередь запрос после фатальной ошибки

Question

У меня есть приложение nodejs, запущенное поверх pm2.

Мое приложение имеет странное поведение, когда я не могу определить проблему, в течение некоторого времени работает, 3, 4 или 5 дней, когда приложение пытаетсясделать простой вход в систему, где требуется соединение с базой данных, возникает следующая ошибка:

Не удается поставить в очередь запрос после фатальной ошибки

Я сделал все возможное, чтобы попытаться определить причину этой проблемыи не было обнаружено падения на сервере базы данных.

Кто-то может попытаться помочь, может быть, это неправильный способ подключения к банку.

База данныхконфигурация соединения db.js

const mysql = require('mysql');

const connection = mysql.createConnection({
    connectionLimit : 20,
    host     : '******',
    port     : 3306,
    user     : '******',
    password : '******',
    database : '******'
});

connection.connect(function(err) {
    if (err) {
        console.log('Conexão com banco ocorreu erro. ' + err + ' ' + err.code);
        return;
    }
    console.log('Conexão com banco ok!');
});

module.exports = connection;

маршрут usuario

var express = require('express');
var router = express.Router();

var usuarioController  = require('../controllers/usuario-controller');

router.get('/find/:id', usuarioController.findUsuario);

module.exports = router;

usuarioController

var db = require('../models/db');

var usuarioController = {


    findUsuario: function(req, res) {

        var codigoPessoa = req.params.id;

        var sql = "SELECT p.codigoPessoa As codigo, "+
                  "  p.nome AS nome "+
                  "  FROM tpessoa p, "+
                  "      tusuario u "+
                  "  WHERE p.codigoPessoa = u.codigoPessoa "+
                  "  AND u.codigoPessoa = " + codigoPessoa;

        db.query(sql, function (err, rows) {
            if (err) {

                var message = err.message;

                return res.status(500).send(message);

            } else {

                res.status(200).json(rows);
            }
        });
    },
};

module.exports = usuarioController;

Ошибка

Error: Connection lost: The server closed the connection.
    at Protocol.end (/home/softaction/apps_nodejs/node_modules/mysql/lib/protocol/Protocol.js:112:13)
    at Socket.<anonymous> (/home/softaction/apps_nodejs/node_modules/mysql/lib/Connection.js:97:28)
    at Socket.<anonymous> (/home/softaction/apps_nodejs/node_modules/mysql/lib/Connection.js:502:10)
    at emitNone (events.js:111:20)
    at Socket.emit (events.js:208:7)
    at endReadableNT (_stream_readable.js:1064:12)
    at args.(anonymous function) (/opt/nvm/versions/node/v8.11.3/lib/node_modules/pm2/node_modules/event-loop-inspector/index.js:138:29)
    at _combinedTickCallback (internal/process/next_tick.js:138:11)
    at process._tickCallback (internal/process/next_tick.js:180:9)
Error: Cannot enqueue Query after fatal error.
    at Protocol._validateEnqueue (/home/softaction/apps_nodejs/node_modules/mysql/lib/protocol/Protocol.js:200:16)
    at Protocol._enqueue (/home/softaction/apps_nodejs/node_modules/mysql/lib/protocol/Protocol.js:138:13)
    at Connection.query (/home/softaction/apps_nodejs/node_modules/mysql/lib/Connection.js:200:25)
    at Strategy._verify (/home/softaction/apps_nodejs/security/autenticacao.js:66:16)
    at Strategy.authenticate (/home/softaction/apps_nodejs/node_modules/passport-local/lib/strategy.js:88:12)
    at attempt (/home/softaction/apps_nodejs/node_modules/passport/lib/middleware/authenticate.js:361:16)
    at authenticate (/home/softaction/apps_nodejs/node_modules/passport/lib/middleware/authenticate.js:362:7)

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

Пример:

-app
--models
---db.js
--controllers
---usuario-controller.js
--routes
---usuario-route.js

Answer 1

Обычный способ справиться с этим, кажется, использует пул соединений .

Вы можете увидеть примеры, основанные на той же проблеме, что и у вас, в этом посте ,В одном из ответов там показан способ переопределения метода query, чтобы вам не приходилось перезаписывать каждый вызов с помощью getConnection / release.

Вероятно, вы можете проверить это с локальной БД:

• запустить DB
• запустить сервер
• попробовать войти (или поддельный маршрут, который запрашивает что-то)
• убедиться, что он работает
• убить / перезапустить БД
• попробовать маршрут еще раз
• убедиться, что у вас такая же ошибка
• реализовать решение, основанное на ссылке выше
• протестируйте снова и убедитесь, что проблема исчезла