Electron+Node.js+SQLite3封装SELECT函数返回空对象问题

你遇到的核心问题是Node.js版SQLite3的API是异步的，你试图用同步的方式去获取异步操作的结果，这完全不符合Node.js的异步编程逻辑。

具体错误拆解 #

1. storage.each()的返回值不是查询结果：each方法本身返回的是你的数据库实例（也就是你看到的[object Database]），它的作用是逐行处理查询结果，真正的结果只会通过你传入的回调函数传递，而不是通过返回值返回。
2. 你的select函数逻辑错误：你直接返回了storage.each()的调用结果，自然拿到的是数据库对象，而非你想要的row[items]。而且each的回调会被执行多次（每查询到一行就执行一次），你在回调里return row[items]根本不会把值传递到函数外部。

解决方案：用Promise封装异步查询 #

推荐用Promise来封装你的查询逻辑，这样可以用async/await写出更易读的异步代码，同时解决结果返回的问题。

修改后的select函数

let select = (items, db, where, sign, whereNew) => {
  return new Promise((resolve, reject) => {
    // 构建基础SQL语句
    let q = `select ${items} from ${db}`;
    // 准备参数数组（防止SQL注入）
    let queryParams = [];
    
    // 拼接条件语句（用参数化查询替代直接字符串拼接）
    if (where && sign && whereNew) {
      q += ` where ${where} ${sign} ?`;
      queryParams.push(whereNew);
    }

    console.log('执行SQL:', q);
    // 用storage.all()一次性获取所有结果（比each更适合获取单条/多条结果）
    storage.all(q, queryParams, (err, rows) => {
      if (err) {
        reject(`查询失败 ${q}: ${err.message}`);
        return;
      }
      
      // 根据结果数量处理返回值：单条返回对应字段，多条返回数组
      if (rows.length === 0) {
        resolve(null); // 无结果返回null
      } else if (rows.length === 1) {
        resolve(rows[0][items]);
      } else {
        resolve(rows.map(row => row[items]));
      }
    });
  });
};

正确调用方式（用async/await）

// 必须在async函数内使用await
async function fetchUser() {
  try {
    let u = await select('firstname', 'users', 'id', '=', 1);
    console.log('查询结果:', u); // 这里会输出Mateusz
    // 把结果发送到前端
    n.webContents.send('userName', u);
  } catch (error) {
    console.error('查询出错:', error);
  }
}

// 调用函数
fetchUser();

额外优化点：避免SQL注入风险 #

你原来的代码直接把whereNew拼接到SQL字符串里，如果这个值来自用户输入，会存在严重的SQL注入风险。上面的解决方案用了参数化查询（把whereNew作为参数传入，用?占位），这是操作数据库的最佳实践，能有效避免注入攻击。

为什么不用each？ #

each方法适合处理大量数据（逐行处理，减少内存占用），但对于获取单条或少量结果的场景，all方法更直接——它一次性返回所有结果数组，更符合你的需求。

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