如何在db.serialize()的后续db.run()中使用db.all()的结果集？

你的核心问题是：db.serialize() 内部的异步代码（Promise.then）会在序列化回调执行完后才触发，而后续的 db.close() 会直接执行，导致 db.run() 执行时数据库已经关闭。

问题根源 #

db.serialize() 只会保证回调内的同步数据库操作按顺序执行，但你用了 Promise.then 这种异步逻辑，它会被放入微任务队列，等序列化回调执行完毕、主线程空闲时才会运行。这时候 db.close() 已经执行，数据库连接断开，自然报错。

解决方案：用 async/await 统一控制异步流程 #

把所有数据库操作都封装成 Promise，再用 async/await 让整个流程按顺序执行，确保所有操作完成后再关闭数据库。

步骤1：封装 Promise 版的数据库方法

先把 db.all() 和 db.run() 转成支持 await 的函数：

// 封装 db.all 为 Promise
const dbAll = (sql, params = []) => {
  return new Promise((resolve, reject) => {
    db.all(sql, params, (err, rows) => {
      if (err) {
        dialog.showMessageBox(mainWindow, {
          message: `Internal Server Error, ${err.message}`,
          buttons: []
        });
        reject(err);
      } else {
        resolve(rows);
      }
    });
  });
};

// 封装 db.run 为 Promise
const dbRun = (sql, params = []) => {
  return new Promise((resolve, reject) => {
    db.run(sql, params, function(err) {
      if (err) reject(err);
      // this 指向当前运行的语句，可获取 lastID 和 changes
      else resolve({ lastID: this.lastID, changes: this.changes });
    });
  });
};

步骤2：用 async/await 编写完整流程

把查询、遍历操作、关闭数据库的逻辑串起来，确保顺序执行：

async function processShoeData() {
  try {
    // 执行右连接查询
    const rows = await dbAll(`
      SELECT temp_data.colour, temp_data.size, temp_data.price, temp_data.quantity, temp_data.barcode, shoe.shoe_id 
      FROM shoe 
      RIGHT JOIN temp_data ON shoe.article_name = temp_data.article_name
    `);

    if (!rows.length) {
      console.log('No result got from right join of TEMP_DATA and SHOE tables');
      return;
    }

    console.log('rows:', rows);

    // 遍历结果执行 db.run，这里用 for...of 保证串行执行（如果需要并行可以用 Promise.all）
    for (const row of rows) {
      // 替换成你的实际业务逻辑，比如插入/更新数据
      await dbRun(`
        INSERT INTO target_table (colour, size, price, quantity, barcode, shoe_id)
        VALUES (?, ?, ?, ?, ?, ?)
      `, [row.colour, row.size, row.price, row.quantity, row.barcode, row.shoe_id]);
      
      console.log(`Processed row with barcode: ${row.barcode}`);
    }

    console.log('All database operations completed');
  } catch (err) {
    console.error('Processing failed:', err);
  } finally {
    // 所有操作完成后再关闭数据库
    db.close();
  }
}

// 启动流程
processShoeData();

关键说明 #

• 不需要再嵌套 db.serialize()，因为 async/await 已经保证了操作的顺序性（如果是并行操作可以用 Promise.all）。
• 所有异步操作都通过 await 等待完成，确保 db.close() 只会在最后执行。
• 如果需要保证多个 db.run() 按顺序执行，用 for...of；如果不需要顺序，用 Promise.all(rows.map(row => dbRun(...))) 可以提升效率。

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