mysql - 错误 : Cannot enqueue Query after fatal error in mysql node

Question

我正在使用 felixge/node-mysql。我还使用 express-myconnection 来防止 mysql 超时，进而防止 Node 服务器被杀死。我正在做的是在 mysql 中记录事件。场景是文件上传后我有文件上传功能，我正在对文件执行不同的操作。在处理的每个阶段，我都将这些事件记录在数据库中。如果文件很小，这很好用。如果文件很大，比如 100 MB，加载需要一些时间，所以与此同时 mysql 服务器重新连接并创建一个新连接，但日志记录代码仍然使用旧引用。错误: fatal error 后无法对查询进行排队。所以，我的问题是有没有一种方法可以使用新的连接引用而不是旧的连接引用。有一个单一的功能，其中发生了与文件有关的所有不同阶段的事件。任何帮助是极大的赞赏。谢谢

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

Answer 1

实际上，我决定用谷歌搜索你的错误，在读完这个帖子后: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;*/
});