错误：mysql 节点发生致命错误后无法将查询排入队列

我正在使用 felixge/node-mysql。另外，我正在使用express-myconnection，它可以防止mysql超时，从而防止杀死节点服务器。我正在做的就是记录 mysql 中的活动。场景是我有文件上传功能，一旦文件上传，我就对文件执行不同的操作。在处理的每个阶段，我都会将这些活动记录在数据库中。如果文件很小，这可以正常工作。如果文件很大，比如 100 MB，则需要一些时间来加载，因此同时 mysql 服务器会重新连接并创建一个新连接，但日志记录代码仍然使用旧的引用。错误：致命错误后无法对查询进行排队。所以，我的问题是有没有一种方法可以使用新的连接引用而不是旧的连接引用。有一个函数可以执行与文件相关的所有不同阶段的活动。任何帮助是极大的赞赏。谢谢

嗨@paul，如果您看过要点链接，您可以看到我有 upload.on('begin', function (fileInfo, reqs, resp) { } ，我在其中记录了文件上传过程已开始的活动。一旦文件已上传 upload.on('end', function (fileInfo,request,response) { } 被触发。我还在这里记录一些活动。正如我在问题中所说，如果文件很大，则上传需要时间。同时创建了一个新的 MySql 连接，但“end”事件中的插入查询仍然引用旧的 myconnection。所以，我想知道在这种情况下如何使用新的 mysql 连接引用？我希望这已经解释了场景更好。

实际上，我决定在谷歌上为您搜索您的错误，并在阅读此帖子后：https://github.com/felixge/node-mysql/issues/832我意识到在第一个查询完成后您不会释放连接，因此池永远不会尝试向您发出新的连接。您是对的，陈旧的连接可能是问题所在。如果出现这种情况，请按以下方法解决：

upload.on('begin', function (fileInfo, reqs, resp) { 
    var fileType = resp.req.fields.file_type;
    var originalFileName = fileInfo.name;
     var renamedFilename = file.fileRename(fileInfo,fileType);
    /*renaming the file */
    fileInfo.name = renamedFilename;

    /*start: log the details in database;*/
    var utcMoment = conf.moment.utc();
    var UtcSCPDateTime = new Date( utcMoment.format() );
    var activityData = {
        activity_type     : conf.LIST_UPLOAD_BEGIN,
        username          : test ,
        message           : 'test has started the upload process for the file',
        activity_datetime : UtcSCPDateTime 
    };
    reqs.params.activityData = activityData;
    req.getConnection(function(err,connection) {
    var dbData = req.params.activityData;
    var activity_type = dbData.activity_type;
    console.dir("[ Connection ID:- ] "+connection.threadId+' ] [ Activity type:- ] '+activity_type);
    var insertQuery = connection.query("INSERT INTO tblListmanagerActivityLog SET ? ",dbData, function(err, result) {
        if (err) {
            console.log("Error inserting while performing insert for activity "+activity_type+" : %s ",err );
        } else {
            console.log('Insert successfull');
        }
        /// Here is the change:
        connection.release();
    });

});
    /*end: log the details in database;*/
});