Как переподключаться при отключении БД?

Question

[jtag]

Использую модуль 'mysql' для node.js . Сервер подключается к mysql удаленно. При отключении БД сервер постоянно падает и приходится включать вручную через "systemctl" (systemctl по какой-то причине делает около 10-и включений через 1 секунду и перестает). На гитхабе нашел код который делает reconnect пока соединение не будет восстановлено.

function handleDisconnect(myconnection) {
    myconnection.on('error', function (err) {
        console.log('\nRe-connecting lost connection: ' + new Date());
        con.destroy();
        con = mysql.createConnection(options);
        handleDisconnect(con);
        con.connect();
    });
}
handleDisconnect(con);

Функция работает как следует.

Однако когда начинаются запросы в БД( query("SELECT ..." ), то при отключенной БД срабатывает обработчик ошибок if(err) throw err; и сервер падает.
Какие имеются стандартные средства чтобы избежать падения сервера?

Answer 1

[Robot Chappie]

конструкция:

try { 
... 
} catch(err) {
...
}

тем самым сервер падать не будут подробнее тут

Comments

[jtag]

это что такая практика, что нужно все запросы оборачивать в try catch?

[Robot Chappie]

try {} catch(e) {} ловит ошибки, для того чтобы обработать их и при этом не прерывать работу самого скрипта. не обязательно все запросы оборачивать в данную конструкции. У вас есть проблема с коннектом к БД. если Вы ищете стандартное решение, чтобы скрипт не падал, то вот оно. а как вы им будете пользоваться, это зависит от Вас, так как полного вашего кода тут нет.

[jtag]

Но ведь никогда не известно во время какого запроса в коде отключится БД, и если запрос не обработан с помощью try catch то тогда... Мне очень любопытно как обычно на практике многими пишутся отказоустойчивые запросы. Вот мои код, прошу обратить внимание на запросы, которые происходят в цикле.

setInterval(function () {
    con.query("SELECT * FROM temp WHERE done<>'ok' ORDER BY iin DESC LIMIT 1", function (err, rowsFromTemp) {
        if (err) {throw err;}  
            if (rowsFromTemp.length != 0) {        
                con.query("SELECT * FROM balance WHERE iin = " + rowsFromTemp[0].iin + " AND pay_type=" + rowsFromTemp[0].pay_type, function (err, rowsFromBalance) { 
                    if (err) throw err;
                    if (rowsFromBalance.length != 0) {     
                        console.log("match")
                        var sum = rowsFromBalance[0].sum + rowsFromTemp[0].amount;
                        console.log("amount: ", rowsFromTemp[0].amount, " sum: ", rowsFromBalance[0].sum, " total: ", sum);
                        con.query("UPDATE balance SET iin=" + rowsFromTemp[0].iin + ", sum=" + sum + " WHERE iin=" + rowsFromBalance[0].iin, function (err) {
                            if (err) throw err;
                            con.query("UPDATE temp SET done='ok' WHERE uniq_id=" + rowsFromTemp[0].uniq_id, function (err) {
                                if (err) throw err;
                            });
                        });
                    } else {
                        con.query("INSERT INTO balance (id, iin, pay_type, sum) VALUES ( NULL, '" + rowsFromTemp[0].iin + "', '" + rowsFromTemp[0].pay_type + "', '" + rowsFromTemp[0].amount + "')", function (err, result) {
                            con.query("UPDATE temp SET done='ok' WHERE uniq_id=" + rowsFromTemp[0].uniq_id, function (err) {
                                if (err) throw err;
                            });
                        });
                    }

                })
            }
    });
}, 500);

[Robot Chappie]

в данном случаи каждый запрос обернуть в try {} cathe(e) {}