Nodejs连接mysql查询报错Cannot enqueue quit after invoking quit

Node.js 连接 MySQL 查询报错 Cannot enqueue quit after invoking quit

问题描述

在使用 Node.js 连接 MySQL 数据库时，如果你尝试多次执行数据库查询操作，并且在每次查询后立即关闭连接，可能会遇到错误 Cannot enqueue quit after invoking quit。这个问题通常发生在你试图在一个已经关闭的连接上执行新的查询或关闭操作。

示例代码分析

以下是原始代码：

exports.user_info_getinfo = function(user_id, callback) {
    client.connect(function(err) {
        if (err) {
            callback(err);
            client.end();
            return;
        }
        client.query("use koc_share_user;");
        client.query("select * from user_info where user_id = ?",
            [user_id],
            function(err, result) {
                if (err) {
                    callback(err);
                } else {
                    callback(result);
                }
                client.end();
            }
        );
    });
};

问题所在

在这个代码中，每次调用 user_info_getinfo 函数时，都会重新连接数据库并执行查询。查询完成后立即关闭连接。当第二次调用该函数时，由于前一次查询已经关闭了连接，所以再次执行查询时会抛出 Cannot enqueue quit after invoking quit 错误。

解决方案

为了修复这个问题，可以考虑以下几种方法：

1. 复用数据库连接： 不要在每次查询时都重新连接和关闭数据库。可以创建一个全局的数据库连接对象，在整个应用生命周期内复用它。

2. 使用连接池： 使用连接池来管理数据库连接，这样可以在多个请求之间共享连接，提高性能和稳定性。

下面是使用连接池的示例代码：

const mysql = require('mysql');
const pool = mysql.createPool({
    host: 'localhost',
    user: 'your_username',
    password: 'your_password',
    database: 'koc_share_user'
});

exports.user_info_getinfo = function(user_id, callback) {
    pool.getConnection(function(err, connection) {
        if (err) {
            callback(err);
            return;
        }
        connection.query("select * from user_info where user_id = ?", [user_id], function(err, result) {
            connection.release(); // 释放连接到连接池
            if (err) {
                callback(err);
            } else {
                callback(result);
            }
        });
    });
};

解释

• 创建连接池：通过 mysql.createPool 创建一个连接池。
• 获取连接：在每次查询时从连接池中获取一个连接。
• 执行查询：执行查询后，使用 connection.release() 将连接释放回连接池，而不是直接关闭连接。
• 错误处理：如果在获取连接或执行查询过程中发生错误，则调用回调函数返回错误。

通过这种方式，你可以避免频繁地创建和销毁连接，从而避免 Cannot enqueue quit after invoking quit 错误。