Node.js使用MySQL模块循环读取数据库时请求入队失败问题排查

嘿，我来帮你搞定这个问题！你遇到的这俩错误全是JavaScript异步特性在搞鬼，咱们一步步拆解解决：

错误原因分析 #

1. Cannot enqueue Query after invoking quit：
   你把connection.end()写在了代码最外层，这行代码会在connection.query（查询总行数的异步操作）执行完成前就跑起来，直接关闭了数据库连接。后面循环里的fetch_data再去发送查询请求时，连接已经关闭，自然就报错了。

2. TypeError: Cannot read property '0' of undefined：
   因为连接提前关闭，后续查询失败，导致results变量变成了undefined，你直接去访问results[0]就会触发这个类型错误。

修复方案 #

要解决这个问题，核心是控制异步操作的顺序，确保所有查询和后续处理完成后再关闭连接，同时用异步遍历替代同步for循环，避免批量压入查询请求。

修正后的代码（使用async/await） #

const mysql = require('mysql');

// 把MySQL的回调式查询包装成Promise，方便用async/await
function queryPromise(connection, sql, params = []) {
  return new Promise((resolve, reject) => {
    connection.query(sql, params, (error, results) => {
      if (error) {
        reject(error);
      } else {
        resolve(results);
      }
    });
  });
}

async function processBankData() {
  // 创建连接
  const connection = mysql.createConnection({ 
    host: "localhost", 
    user: "root", 
    password: "123456789", 
    database: "bank114" 
  });

  try {
    // 等待连接建立完成
    await new Promise((resolve, reject) => {
      connection.connect(err => err ? reject(err) : resolve());
    });

    // 查询需要处理的总行数（或者直接查询f6781为空的行，更高效）
    const countResult = await queryPromise(connection, 'SELECT COUNT(*) AS total FROM bank114_x;');
    const totalRows = countResult[0].total;
    console.log(`待处理总行数：${totalRows}`);

    // 异步遍历每一行，确保前一个查询完成后再执行下一个
    for (let id = 1; id <= totalRows; id++) {
      try {
        const rowData = await queryPromise(connection, 'SELECT * FROM bank114_x WHERE id = ?', [id]);
        const row = rowData[0];

        if (!row) {
          console.log(`ID为${id}的行不存在，跳过`);
          continue;
        }

        // 检查f6781是否为空
        if (row.f6781 === null) {
          // 这里调用你的Web服务处理f6780
          // 示例：假设用axios发送请求
          // const webResponse = await axios.post('你的Web服务地址', { data: row.f6780 });
          // 更新f6781字段
          // await queryPromise(connection, 'UPDATE bank114_x SET f6781 = ? WHERE id = ?', [webResponse.data, id]);
          console.log(`正在处理ID ${id}的f6780字段：${row.f6780}`);
        }
      } catch (err) {
        console.error(`处理ID ${id}时出错：`, err);
      }
    }

    console.log('所有数据处理完成！');
  } catch (globalErr) {
    console.error('全局错误：', globalErr);
  } finally {
    // 无论成功失败，最后都关闭连接
    connection.end();
  }
}

// 启动处理函数
processBankData();

代码关键点说明 #

• Promise包装查询：把MySQL的回调API转成Promise，这样就能用async/await写同步风格的异步代码，避免回调嵌套混乱。
• 异步遍历：用for循环配合await，确保每次查询完成后再执行下一次，不会瞬间给数据库发大量请求，也能保证顺序。
• 完善的错误处理：每层逻辑都加了try/catch，某一行出错不会导致整个程序崩溃，还能清晰打印错误信息。
• 延迟关闭连接：把connection.end()放在finally块里，确保所有异步操作完成后才关闭连接。

额外优化建议 #

你当前按ID遍历所有行的方式效率较低，其实可以直接查询f6781为空的行，减少不必要的查询：

// 替换原来的总行数查询和遍历逻辑
const targetRows = await queryPromise(connection, 'SELECT * FROM bank114_x WHERE f6781 IS NULL;');
for (const row of targetRows) {
  // 直接处理每行数据
  console.log(`处理ID ${row.id}的f6780字段：${row.f6780}`);
  // 调用Web服务并更新f6781...
}

这样只处理需要更新的行，性能会提升很多。

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