将SQLite数据映射到TypeScript对象：异步处理与类型安全实践

import * as sqlite3 from 'sqlite3'; // 假设 db 实例来自这里
// 假设 Obj 类已定义
interface Obj {
  id: number;
  name: string;
  amount: number;
}

// 示例数据库实例（实际应用中应妥善初始化）
const db = new sqlite3.Database(':memory:'); 

// 示例表创建函数（为演示目的，实际应用中可能在应用启动时执行）
export const CreateObjTable = (): Promise<sqlite3.RunResult> => {
  return new Promise((resolve, reject) => {
    db.run(`
      CREATE TABLE IF NOT EXISTS ObjTable
      (
        id INTEGER PRIMARY KEY AUTOINCREMENT,
        name TEXT,
        amount INTEGER
      )
    `, function(err) {
      if (err) {
        reject(err);
      } else {
        resolve(this); // 'this' 包含 lastID 和 changes
      }
    });
  });
};

// 示例数据插入（为演示目的）
export const InsertObj = (name: string, amount: number): Promise<sqlite3.RunResult> => {
  return new Promise((resolve, reject) => {
    db.run(`INSERT INTO ObjTable (name, amount) VALUES (?, ?)`, [name, amount], function(err) {
      if (err) {
        reject(err);
      } else {
        resolve(this);
      }
    });
  });
};

export const GetAllObjs = (): Promise<Obj[]> => {
    const query = db.prepare("SELECT * FROM ObjTable");

    return new Promise((resolve, reject) => {
        let objs: Obj[] = []; // 明确类型为 Obj[]

        // query.all() 方法接受一个回调函数，其中包含错误和行数据
        query.all((err, rows: any[]) => { // rows 参数的类型为 any[]
            if (err) {
                // 如果发生错误，拒绝Promise
                return reject(err);
            }

            // 正确地迭代数组元素
            for (const row of rows) { // 使用 for...of 迭代数组的元素
                objs.push(
                    {
                        // 直接通过属性名访问列值
                        id: row.id,
                        name: row.name,
                        amount: row.amount,
                    } as Obj // 使用类型断言确保对象的类型
                );
            }
            // 成功时，解决Promise并返回结果
            resolve(objs);
        });
    });
};

// 假设 db 已经连接
// db = new sqlite3.Database('your_database.db');

async function main() {
  try {
    // 确保表已创建
    await CreateObjTable();
    console.log("ObjTable created.");

    // 插入一些示例数据
    await InsertObj('Item A', 100);
    await InsertObj('Item B', 250);
    console.log("Sample data inserted.");

    // 获取所有对象
    const allObjs = await GetAllObjs();
    console.log("Fetched objects:", allObjs);

    // 预期输出:
    // Fetched objects: [
    //   { id: 1, name: 'Item A', amount: 100 },
    //   { id: 2, name: 'Item B', amount: 250 }
    // ]

  } catch (error) {
    console.error("An error occurred:", error);
  } finally {
    // 确保在应用退出时关闭数据库连接
    // db.close(); 
  }
}

main();