Node.js异步操作MySQL时遇TypeError及响应头错误，求排查

你的代码里存在两个核心问题，直接导致了抛出的错误，我来逐一拆解并给出具体的修复办法：

1. connection.execute is not a function 错误 #

这个问题根源在于你使用的MySQL客户端模块不支持execute方法：

• 如果你安装的是传统的mysql包，它的连接对象并没有execute这个方法——它的查询方法是query，而且默认是回调式的，要适配async/await需要额外做Promise化处理。
• 如果你想直接用execute方法，应该改用mysql2包，它原生支持Promise语法和execute方法，性能也更优，是现在Node.js操作MySQL的主流选择。

修复方案（二选一）： #

方案A：继续用mysql包，Promise化query方法

const util = require('util');
app.get('/test/:id', async (req, res) => {
  try {
    const connection = await mysql.createConnection(dbConnData);
    // 把回调式的query转为Promise风格
    const query = util.promisify(connection.query).bind(connection);
    const rows = await query('SELECT * FROM `courses`');
    connection.end(); // 用完记得关闭连接
    return res.send({ data: rows });
  } catch (err) {
    console.error('查询出错:', err);
    return res.status(500).send({ error: '服务器内部错误' });
  }
});

方案B：切换到mysql2包（推荐）

先安装依赖：

npm install mysql2

然后修改代码：

// 直接导入mysql2的Promise版本
const mysql = require('mysql2/promise');
app.get('/test/:id', async (req, res) => {
  try {
    const connection = await mysql.createConnection(dbConnData);
    const [rows, fields] = await connection.execute('SELECT * FROM `courses`');
    connection.end();
    return res.send({ data: rows });
  } catch (err) {
    console.error('查询出错:', err);
    return res.status(500).send({ error: err.message });
  }
});

2. ERR_HTTP_HEADERS_SENT 错误 #

这个错误是因为你的代码没有异常捕获机制：当异步操作（比如创建连接、执行查询）抛出错误时，Promise被拒绝但没有被处理，导致后续代码可能尝试多次向客户端发送响应（比如错误触发后，程序仍走到return res.send({})，但此时可能已经有错误响应被发送了）。

修复关键点： #

• 用try/catch包裹所有异步逻辑，统一处理成功和失败的响应，确保每个请求只发送一次响应。
• 一定要关闭数据库连接，不管操作成功还是失败，避免连接泄漏（可以用finally块来统一处理）。

优化后的代码（结合连接池，更推荐）：

const mysql = require('mysql2/promise');
// 提前创建连接池，不用每次请求都创建新连接
const pool = mysql.createPool(dbConnData);

app.get('/test/:id', async (req, res) => {
  try {
    // 从连接池获取连接并执行查询，不用手动关闭
    const [rows, fields] = await pool.execute('SELECT * FROM `courses`');
    return res.send({ data: rows });
  } catch (err) {
    console.error('查询出错:', err);
    return res.status(500).send({ error: '查询数据失败' });
  }
});

连接池会自动管理连接的复用和销毁，比每次创建新连接性能好很多，也避免了手动关闭连接的麻烦。

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