如何在 JavaScript 中正确实现 SQL 数据库操作的顺序执行-js教程-PHP中文网

如何在 JavaScript 中正确实现 SQL 数据库操作的顺序执行

本文详解如何使用 async/await 和 promise 封装 sqlite3（及兼容方案）的数据库操作，解决因异步流程失控导致的“connection was never established”等常见错误，确保建表、插入、查询严格按序执行。

本文详解如何使用 async/await 和 promise 封装 sqlite3（及兼容方案）的数据库操作，解决因异步流程失控导致的“connection was never established”等常见错误，确保建表、插入、查询严格按序执行。

在 Node.js 中操作嵌入式 SQL 数据库（如 sqlite3 或 duckdb）时，一个典型陷阱是误将异步操作当作同步执行。原始代码中直接调用 createAndStoreData() 后立即执行 readData()，而二者内部均涉及文件 I/O、SQL 编译与执行、连接关闭等异步过程——但未做任何等待机制，导致 readData() 在数据库尚未写入完成甚至尚未关闭时就尝试打开并查询，从而抛出 Connection Error: Connection was never established or has been closed already。

根本原因在于：sqlite3 的 .run()、.all()、.close() 等方法本身不返回 Promise，而是通过回调函数通知完成状态；若不显式封装为 Promise，就无法用 await 控制执行时序。

✅ 正确做法是：将每个数据库操作封装为返回 Promise 的异步函数，并在主流程中使用 await 串行调用。以下是以 sqlite3 为例的完整可运行方案（兼容性强，推荐初学者优先采用）：

Java Maven Code Review

审查Java Maven项目（ZIP压缩包或GitLab仓库URL），检查代码规范、命名、模块边界、可维护性问题以及重复代码。

下载

const sqlite3 = require('sqlite3').verbose();
const csvParser = require('csv-parser');
const stream = require('stream');

const csvData = `Wind speed (m/s),Output power (kW)
0,0
1,0
2,0
3,0
4,80
5,140
6,360
7,610
8,1000
9,1470
10,1900
11,2320
12,2690
13,2850
14,2950
15,3000
16,3000
17,3000
18,3000
19,3000
20,3000
21,3000
22,3000
23,3000
24,3000
25,3000`;

// ✅ 封装为 Promise：创建表 + 批量插入
async function createAndStoreData() {
  console.log('→ 正在初始化数据库并导入数据...');
  const db = new sqlite3.Database('power_curve.db');

  return new Promise((resolve, reject) => {
    db.serialize(() => {
      // 确保表结构干净
      db.run('DROP TABLE IF EXISTS power_curve', (err) => {
        if (err) return reject(err);
      });
      db.run('CREATE TABLE power_curve (ws REAL PRIMARY KEY, power REAL)', (err) => {
        if (err) return reject(err);
      });

      const stmt = db.prepare('INSERT INTO power_curve (ws, power) VALUES (?, ?)');
      const dataStream = new stream.Readable();
      dataStream.push(csvData);
      dataStream.push(null);

      dataStream
        .pipe(csvParser())
        .on('data', (row) => {
          stmt.run(
            parseFloat(row['Wind speed (m/s)']),
            parseFloat(row['Output power (kW)'])
          );
        })
        .on('end', () => {
          stmt.finalize();
          db.close((err) => {
            if (err) reject(err);
            else {
              console.log('✔ 数据已成功存入 power_curve.db');
              resolve();
            }
          });
        })
        .on('error', reject);
    });
  });
}

// ✅ 封装为 Promise：查询全部数据
async function readData() {
  console.log('→ 正在从数据库读取数据...');
  const db = new sqlite3.Database('power_curve.db');

  return new Promise((resolve, reject) => {
    db.all('SELECT * FROM power_curve ORDER BY ws', (err, rows) => {
      if (err) {
        db.close();
        return reject(err);
      }
      console.table(rows);
      console.log('✔ 数据读取完成');
      db.close((closeErr) => {
        if (closeErr) reject(closeErr);
        else resolve();
      });
    });
  });
}

// ✅ 主流程：严格顺序执行
async function main() {
  try {
    await createAndStoreData(); // 等待写入完成
    await readData();           // 再执行读取
  } catch (err) {
    console.error('❌ 操作失败：', err.message);
    process.exit(1);
  }
}

if (require.main === module) {
  main();
}

? 关键要点总结：

永远不要忽略回调时机：sqlite3 的 .close() 必须在所有 .run() / .all() 完成后调用，且需等待其回调触发才真正释放资源；
类型安全建议：CSV 字段应显式 parseFloat() 转换，避免字符串写入导致后续数值查询异常；
DuckDB 注意事项：当前 DuckDB for Node.js（非 WASM 版）API 与 sqlite3 不完全兼容（如无 .serialize()，.prepare() 行为不同），若坚持使用 DuckDB，请参考其官方文档采用 db.exec() + await db.insert() 等现代异步接口，或改用 @duckdb/duckdb-wasm 的 Promise-first API；
生产增强建议：添加事务（BEGIN / COMMIT）、错误重试、连接池（如 sqlite3-pool）以提升健壮性。