如何遍历数据库记录并执行逐行更新操作？

需求描述（VBA示例） #

我用熟悉的VBA代码描述核心需求，这段代码实现了循环遍历记录并设置字段值：

'Declare a recordset which will iterate through our records 
Dim rs as DAO.recordset

'Setup a connection to our data store with the table/query we want to process records in
Set rs = dbengine.workspaces.opendatabase("path/to/database").openrecordset("select * from sometable")

rs.movefirst
Do Until rs.eof
  'put record in edit mode 
  rs.Edit
  rs!field = "some value I want" 
  'put record in update mode 
  rs.update 
  rs.movenext
loop

我需要更复杂的操作（比如根据下一行数据更新当前行），但只要掌握了遍历记录并逐行执行更新的正确方式，就能自行完成后续开发。

当前的TypeScript代码 #

我目前写的代码如下，但存在执行逻辑问题：

//this function is just is called by another function. processRecord is what does the individual record processing 
async function processRecords(db: Database, SQL: string, processRecord: any) {
  db.each(SQL, async(e,r) => {
    if(e) {
      reject(e);
    } else {
      try {
        await processRecord(db,r);
        resolve(true);
      }
      catch(e) {
        reject(e); 
      }
    }
  });
}
async function processRecord(db: Database, r: Row) {
   try {
     //execute a query against the current row we are processing
     //SQL for updates uses a select in SET clause to pull data from the record with the next rowid
     //executeQuery is a "promisified" db.run
     executeQuery(db,updateSQL,r.rowID);
 
   } catch(e : any) {
     throw e;
   }
} 

//I borrowed this from somewhere else and modified it a bit. 
function executeQuery(db: Database, SQL: string, params: any = []) : Promise<number> {
  return new Promise(resolve,reject) => {
    db.Run(SQL,params,function(e) {
      if(e) {
        reject(e);
      } else {
        resolve(this.changes); 
      } 
    }
  }
}

问题分析与修正方案 #

当前代码的核心问题：

• processRecords未正确封装Promise，resolve/reject的调用时机错误，会导致遍历未完成就提前结束。
• db.each的异步回调会触发所有更新操作并行执行，无法保证逐行处理的顺序，依赖行顺序的逻辑会出错。
• processRecord中未等待executeQuery完成，更新操作可能未执行就进入下一行处理。

修正后的完整代码 #

// 修正executeQuery的语法错误，统一API大小写
function executeQuery(db: Database, SQL: string, params: any = []): Promise<number> {
  return new Promise((resolve, reject) => {
    db.run(SQL, params, function(e) {
      if (e) {
        reject(e);
      } else {
        resolve(this.changes);
      }
    });
  });
}

// 先获取所有记录，再串行逐行处理，对齐VBA遍历逻辑
async function processRecords(db: Database, SQL: string, processRecord: (db: Database, row: Row) => Promise<void>) {
  try {
    // 一次性获取所有待处理记录
    const rows = await new Promise<Row[]>((resolve, reject) => {
      db.all(SQL, (err, rows) => {
        if (err) reject(err);
        else resolve(rows);
      });
    });

    // 串行遍历，确保前一行处理完成后再执行下一行
    for (const row of rows) {
      await processRecord(db, row);
    }

    return true;
  } catch (e) {
    throw e;
  }
}

async function processRecord(db: Database, r: Row) {
  // 等待当前行的更新操作完成
  await executeQuery(db, updateSQL, [r.rowID]);
}

关键说明 #

1. 串行处理逻辑：用db.all先拉取全部记录，再通过for...of结合await实现串行遍历，和VBA逐行处理的逻辑完全一致，避免并行更新引发的数据一致性问题。
2. Promise封装规范：processRecords被正确封装为async函数，统一处理异步逻辑和错误捕获。
3. 修复语法细节：修正executeQuery中的API大小写（db.Run改为db.run），补全Promise的语法闭合。
4. 等待更新完成：processRecord中添加await，确保当前行的更新操作执行完毕后再继续。

如果需要根据下一行数据更新当前行，可在遍历阶段通过索引访问下一条记录：

for (let i = 0; i < rows.length; i++) {
  const currentRow = rows[i];
  const nextRow = rows[i + 1];
  if (nextRow) {
    // 基于下一行数据构造更新SQL
    const updateSQL = `UPDATE sometable SET target_field = ? WHERE rowID = ?`;
    await executeQuery(db, updateSQL, [nextRow.source_field, currentRow.rowID]);
  }
}

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