mysql - 节点mysql超时

Question

我们知道node有一些mysql模块，一些是纯js实现的（比如node-mysql），一些是基于c libmysql的。

我更喜欢 node-mysql，因为它不需要额外的 mysql 库，看起来更“干净”。但我也注意到它不支持连接和查询中的超时功能，这可能会在某些环境中导致问题。

所以我的问题是：有人干净地解决了这个超时问题吗？

Answer 1

我们解决此问题的方法是检查错误消息，并在必要时重新连接

这就是他们在https://github.com/felixge/node-mysql#server-disconnects建议的方式

这是文档更改时的示例代码

function handleDisconnect(connection) {
  connection.on('error', function(err) {
    if (!err.fatal) {
      return;
    }

    if (err.code !== 'PROTOCOL_CONNECTION_LOST') {
      throw err;
    }

    console.log('Re-connecting lost connection: ' + err.stack);

    connection = mysql.createConnection(connection.config);
    handleDisconnect(connection);
    connection.connect();
  });
}

handleDisconnect(connection);

Answer 2

我遇到了同样的问题，使用方法 mysql.createPool 而不是方法 createConnection 对我有用。

这是我的代码；

/*jslint node: true */
'use strict';
var Q = require('q');

var mysql = require('mysql');
var _config;
var env = process.env.NODE_ENV || 'development';
if (env === 'development') {
  _config = {
    host     : 'localhost',
    user     : 'root',
    charset : 'latin1',
    password : '123456',
    database : 'DEVDB',
    connectionLimit: 10
  };
}else {
  _config = {
    host : 'PRODUCTIONHOST',
    user     : 'root',
    charset : 'latin1',
        password : 'PRODUCTIONPASS',
    database: 'PRODUCTIONDB',
    connectionLimit: 10
  };
}

var _pool = mysql.createPool(_config);

var runquery = function() {
  var deferred = Q.defer();
  var args = Array.prototype.slice.call(arguments);

  //console.log(args);
  args.push(function(err, results){
    if (err) {
      deferred.reject(new Error(err));
    } else {
      deferred.resolve(results);
    }
  });

  _pool.query.apply(_pool, args);

  return deferred.promise;
};


module.exports = runquery;

使用示例；

runquery('select id from users where mail = ?', 'eugenioclrc')
.then(function(rows){
  console.log(rows);
});