javascript - MySQL关闭后Node.js进程无法恢复，再开启

Question

我正在将 Node.js 与 MySQL 和 restify 结合使用。

我有以下代码作为 REST API 的一部分运行。它工作正常。

server.get('/test', function (req, res, next) {
    var query_string =
        "SELECT DATE(date_transacted) AS transaction_date, " +
        " MonthReports.tb AS MonthReports__tb " +
        " FROM monthly_reports MonthReports " +
        " WHERE ( date_transacted >= \'2015-01-00\' AND date_transacted <= \'2015-09-00\' ) ";

    connection.query(
        query_string
        , function (err, rows, fields) {
            if (err) throw err;
            res.send(rows);
        });
});

如果我故意关闭 MySQL 数据库并进行将运行查询的 REST API 调用，我将得到错误

Cannot enqueue Query after fatal error.

此时，我打开了MySQL数据库。 node.js 进程无法恢复，当我进行 REST API 调用时，同样的错误不断出现。 REST API 服务器已死。

如何使 Node.js REST API 服务器代码可恢复？

Answer 1

我假设您在脚本中进行全局连接。

一种简单的方法是为每个请求创建一个连接:

server.get('/test', function (req, res, next) {
    var query_string =
        "SELECT DATE(date_transacted) AS transaction_date, " +
        " MonthReports.tb AS MonthReports__tb " +
        " FROM monthly_reports MonthReports " +
        " WHERE ( date_transacted >= \'2015-01-00\' AND date_transacted <= \'2015-09-00\' ) ";



    var connection = getConnection(function connected(err) {
        if (err) {
           // error connecting  to mysql! alert user
        } else {
          connection.query(
            query_string
            , function (err, rows, fields) {
              if (err) throw err;
              res.send(rows);
          });
        }
    });

});

上面的代码是伪代码，因为我不熟悉 Node mysql 库。这将允许每个请求查看是否能够连接到 mysql，但代价是每个 Web 请求都有一个连接。

---

另一种策略可能是在发出查询时检查err，如果有错误则尝试重新建立全局连接

server.get('/test', function (req, res, next) {
    var query_string =
        "SELECT DATE(date_transacted) AS transaction_date, " +
        " MonthReports.tb AS MonthReports__tb " +
        " FROM monthly_reports MonthReports " +
        " WHERE ( date_transacted >= \'2015-01-00\' AND date_transacted <= \'2015-09-00\' ) ";

    connection.query(
        query_string
        , function (err, rows, fields) {
            if (err) {
              // Try to reconnect here instead of throwing error and stopping node process, and reissue query
            }
            res.send(rows);
        });
});