JavaScript异步函数嵌套循环执行异常问题排查

你的核心问题是for...of循环内的异步操作未被正确等待，导致代码并行执行，出现表名连续打印、列数组延迟输出的情况。以下是具体解决步骤：

关键修复点 #

1. 确保所有异步操作都被await
   任何涉及数据库查询、数据处理的异步函数（比如获取列类型、插入记录），必须在调用时加上await，否则JavaScript会跳过等待直接执行后续代码。

2. 用await调用拆分后的表处理函数
   你已经尝试拆分代码到独立函数，但如果调用时没加await，函数会变成异步并行执行。必须在for...of循环内等待当前表的处理逻辑完全完成后，再进入下一个表。

3. 逐条处理记录时也要await
   遍历表内记录执行插入操作时，同样要在循环中使用await，确保每条记录的插入检查完成后再处理下一条。

示例修正代码 #

// 封装单表处理逻辑的异步函数
async function processSingleTable(pool, tableName) {
  console.log(`开始处理表: ${tableName}`);

  // 1. 等待获取列数据类型（必须加await）
  const columnTypes = await getColumnTypes(pool, tableName);
  console.log(`表 ${tableName} 的列类型数组:`, columnTypes);

  // 2. 等待获取表内所有记录
  const recordsResult = await pool.query(`SELECT * FROM ${tableName}`);

  // 3. 逐条处理记录，确保每条插入完成再继续
  for (const record of recordsResult.rows) {
    // 等待插入操作及内置检查完成
    await insertToTargetDatabase(record, columnTypes);
    console.log(`表 ${tableName} 已完成一条记录迁移`);
  }
}

async function main() {
  // 获取PostgreSQL数据库列表
  const databases = await getDatabaseList();

  // 遍历每个数据库，等待当前库处理完成再下一个
  for (const db of databases) {
    // 创建连接池
    const pool = createDatabasePool(db);

    // 获取当前库的所有表
    const tablesResult = await pool.query(
      'SELECT table_name FROM information_schema.tables WHERE table_schema = $1',
      ['public']
    );

    // 遍历每张表，等待当前表处理完成再下一个
    for (const table of tablesResult.rows) {
      await processSingleTable(pool, table.table_name);
    }

    // 处理完当前库后关闭连接池
    await pool.end();
  }
}

注意事项 #

• 避免使用forEach、map这类不支持await的遍历方法，它们会直接触发所有异步操作，无法保证顺序。
• 所有数据库操作（查询、插入）必须返回Promise，PostgreSQL的客户端库（比如pg）本身就支持异步Promise调用，确保你没有使用回调模式的API。
• 连接池的创建和关闭要配对，防止资源泄漏。

内容的提问来源于stack exchange，提问作者Nicolò Rancan