Node.js中使用sqlite3无法将数据行存入数组的问题求助

这个问题的核心在于Node.js的异步执行特性，你当前的代码里db.all是异步操作，而你可能尝试在回调外部访问数组，或者db.close的时机不对，导致数组还没被填充就被访问，甚至查询还没完成连接就被关闭了。下面给出两种实用的解决方案：

方案1：在回调内部处理数组（最直接） #

把数组的赋值和后续操作放在db.all的回调函数里，同时将db.close移到回调内，确保查询完成后再关闭连接：

var sqlite3 = require('sqlite3').verbose();
var db = new sqlite3.Database('./database.db', (err) => {
  if (err) {
    return console.error(err.message);
  }
  console.log('Connected...');
});

// 初始化存储结果的数组
let resultsArray = [];

db.all('SELECT * FROM langs ORDER BY name', [], (err, rows) => {
  if (err) {
    return console.error(err.message);
  }
  // 将查询结果赋值给数组
  resultsArray = rows;
  
  // 这里可以对数组做任何你需要的操作
  console.log('已存储的查询结果：', resultsArray);
  resultsArray.forEach((row) => {
    console.log(row.name);
  });
  
  // 查询完成后再关闭数据库连接
  db.close((err) => {
    if (err) {
      return console.error(err.message);
    }
    console.log('Closed...');
  });
});

方案2：用Promise+Async/Await封装（更易维护） #

如果你的项目逻辑比较复杂，回调嵌套会让代码难以阅读，推荐用Promise封装查询操作，再用async/await实现同步风格的代码：

const sqlite3 = require('sqlite3').verbose();

// 封装数据库查询为Promise
function runQuery(sql, params = []) {
  return new Promise((resolve, reject) => {
    const db = new sqlite3.Database('./database.db', (err) => {
      if (err) {
        reject(`连接失败：${err.message}`);
      }
      console.log('Connected...');
    });

    db.all(sql, params, (err, rows) => {
      if (err) {
        reject(`查询失败：${err.message}`);
      } else {
        resolve(rows);
      }
      
      // 无论查询成功失败，都关闭连接
      db.close((err) => {
        if (err) {
          console.error(`关闭连接失败：${err.message}`);
        }
        console.log('Closed...');
      });
    });
  });
}

// 使用async/await调用查询
async function getAndStoreResults() {
  try {
    // 等待查询完成，直接获取结果数组
    const resultsArray = await runQuery('SELECT * FROM langs ORDER BY name');
    
    // 这里可以自由使用结果数组
    console.log('已存储的查询结果：', resultsArray);
    resultsArray.forEach(row => console.log(row.name));
    
    // 后续可以继续用resultsArray做其他业务逻辑
  } catch (error) {
    console.error(error);
  }
}

// 执行函数
getAndStoreResults();

为什么你的原代码会出问题？ #

1. 异步执行顺序：db.all的回调函数是在数据库查询完成后才会执行的，而你原代码里db.close是在db.all之后立即执行的，这时候查询可能还没完成，不仅数组没被填充，还可能提前关闭连接导致查询失败。
2. 外部访问数组无效：如果你在db.all回调外面定义数组并尝试访问，由于异步特性，回调还没执行时数组还是空的，自然拿不到数据。

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