Node.js中使用mysql2执行查询后是否需关闭查询或连接？

核心问题解答 #

• 是否需要关闭单个查询？
  不需要。mysql2 中，execute 方法的回调函数执行完成后，该查询对应的数据库请求资源会自动释放，无需手动关闭单个查询。

• 如何关闭单个查询？
  单个查询没有单独的关闭方法——它是一次性操作，执行完毕后相关资源就会被自动回收。只有在查询正在执行且需要强制中断的极端场景下，才会用到查询对象的 destroy() 方法，你的 insert 场景完全不需要这么做。

• 是否必须关闭连接后重新连接才能执行其他查询？
  完全不需要。你创建的单连接可以重复用来执行多个查询（包括 insert、select、update 等），只要连接处于活跃状态就能复用。频繁关闭和重建连接反而会降低性能，还可能引发连接泄漏问题。

你的代码优化建议 #

1. 修复 connection.js 的冗余错误处理 #

原代码中连接成功后仍判断 err !== null 属于无效逻辑，同时建议增加连接错误监听，避免意外断开导致程序崩溃：

const mysql = require('mysql2');

const con = mysql.createConnection({
    host: "127.0.0.1",
    user: "user",
    password: "passwd",
    database: "db"
});

con.connect(function (err) {
    if (err) {
        console.error('数据库连接失败:', err);
        process.exit(1); // 连接失败直接退出进程，避免后续无效操作
    }
    console.log('数据库连接成功');
});

// 监听连接异常，便于排查问题
con.on('error', function(err) {
    console.error('数据库连接异常:', err);
    // 可选：如果是连接断开，可根据业务需求添加重连逻辑
});

module.exports = con; // 直接导出连接对象，无需包裹在对象中

2. 修复查询代码的错误捕获问题 #

原代码中外层 try/catch 无法捕获回调内的异步错误，需要在回调内部处理错误：

const con = require("./connection");

let sql = "insert into reports(someValues) values (?)";
con.execute(sql, [someValues], function (err, result) {
    if (err) {
        console.error('插入操作失败:', err);
        return;
    }
    console.log('插入成功，影响行数:', result.affectedRows);
});

3. 更推荐的 Promise/Async-Await 写法（新手友好） #

使用 mysql2/promise 可以用 async/await 处理异步，错误捕获更直观：

优化后的 connection.js

const mysql = require('mysql2/promise');

async function getConnection() {
    try {
        const con = await mysql.createConnection({
            host: "127.0.0.1",
            user: "user",
            password: "passwd",
            database: "db"
        });
        console.log('数据库连接成功');
        return con;
    } catch (err) {
        console.error('数据库连接失败:', err);
        process.exit(1);
    }
}

module.exports = getConnection(); // 导出连接 Promise

优化后的查询代码

const conPromise = require("./connection");

async function insertReport(someValues) {
    try {
        const con = await conPromise;
        const [result] = await con.execute("insert into reports(someValues) values (?)", [someValues]);
        console.log('插入成功，影响行数:', result.affectedRows);
    } catch (err) {
        console.error('插入操作失败:', err);
    }
}

// 调用插入函数
insertReport(someValues);

内容的提问来源于stack exchange，提问作者kitsaras