NodeJS使用mysql包时，如何避免提前关连接引发的报错

DevOps 小满

2026-6-15

问题分析与解决

报错原因

你当前代码里的con.end()写在con.connect()的回调中，且位于第一个查询的回调函数外部。由于数据库查询是异步操作，con.end()会在第一个查询返回结果、子查询开始执行前就关闭了连接，后续子查询尝试向已关闭的连接发送请求，就触发了“Cannot enqueue Query after invoking quit”错误。

何时关闭连接？

必须等所有子查询全部执行完成后，再调用con.end()关闭连接。因为子查询是异步的，需要通过计数器等方式跟踪它们的完成状态，当所有子查询都执行完毕时再执行关闭操作。

是否需要为每个子查询重新建立连接？

不需要，复用同一个连接即可完成所有查询操作。重新建立连接会额外消耗资源，复用现有连接是更高效的选择。

修改后的代码示例

var mysql = require('mysql');
var con = mysql.createConnection({/* 你的数据库配置信息 */});

con.connect(function(err) {
    if (err) throw err;
    con.query('first query that returns a set of rows', function(err, result) {
        if (err) throw err;
        // 初始化子查询计数器
        let completedSubQueries = 0;
        const totalSubQueries = result.length;

        // 处理查询结果为空的边界情况
        if (totalSubQueries === 0) {
            con.end();
            return;
        }

        result.forEach(element => {
            con.query('second query that runs multiple times', function(err) {
                if (err) throw err;
                // 每完成一个子查询，计数器加1
                completedSubQueries++;
                // 所有子查询完成后关闭连接
                if (completedSubQueries === totalSubQueries) {
                    con.end();
                }
            });
        });
    });
});