节点mysql超时

Question

因为我们知道节点有一些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); 
}); 

的[MySQL的的NodeJS错误：连接丢失服务器关闭了连接]