Node.js-sqlite3中db.each()回调内代码无法执行的问题

可能的原因及解决方法 #

• SQL语法错误/注入风险导致查询失败
  你直接用字符串拼接id生成SQL语句，一旦id包含单引号等特殊字符，会直接破坏SQL语法，导致查询执行失败，但因为你没给db.each绑定错误处理的完成回调，错误会被静默忽略，回调自然不会执行。

  解决：改用参数化查询，彻底避免字符串拼接的问题：

  var db = new sqlite3.Database("database.sqlite")
  console.log("2")
  db.each("SELECT * FROM gban WHERE id = ?", [id], function(err, row) {
    console.log("3")
    if (err) {
      console.error(err); // 不要直接throw，避免程序崩溃
      return;
    }
    console.log(row)
    if(row){
     // 存在数据的逻辑
    } else {
    // 无数据的逻辑
    }
  })
  

• async回调引发的异常静默丢失
  你给db.each传了async function作为回调，但sqlite3的回调机制不支持Promise，回调内部的任何异常都会变成未捕获的Promise rejection，不会触发你写的throw err逻辑，反而会导致回调执行中断甚至整个流程异常。

  解决：去掉async关键字，如果确实需要在回调里执行异步操作，用自执行异步函数+try/catch包裹：

  db.each("SELECT * FROM gban WHERE id = ?", [id], function(err, row) {
    console.log("3")
    if (err) {
      console.error(err);
      return;
    }
    // 异步操作包裹在自执行函数里
    (async () => {
      try {
        // 你的异步代码
      } catch (e) {
        console.error("异步操作出错:", e);
      }
    })();
    console.log(row)
    // 其他逻辑
  })
  

• 未监听查询完成状态，无法确认结果
  如果查询没有匹配到数据，db.each的行回调确实不会执行，但你没有绑定完成回调，无法区分是查询出错还是真的无数据。

  解决：加上第三个参数（完成回调），用来处理查询结束或全局错误：

  db.each("SELECT * FROM gban WHERE id = ?", [id], function(err, row) {
    console.log("3")
    if (err) {
      console.error(err);
      return;
    }
    console.log(row)
    // 数据处理逻辑
  }, function(err, count) {
    if (err) {
      console.error("查询全局出错:", err);
      return;
    }
    console.log(`查询完成，共找到${count}条数据`);
    if (count === 0) {
      // 无匹配数据的逻辑
    }
  })
  

额外建议 #

• 初始化数据库时监听连接错误，确认数据库文件正常：

  var db = new sqlite3.Database("database.sqlite", function(err) {
    if (err) {
      console.error("数据库连接失败:", err);
    } else {
      console.log("数据库连接成功");
    }
  });
  

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