Express+PostgreSQL中Visitor.js的add函数异步问题求助

你的add函数之所以总是返回false，核心问题在于Node.js中数据库操作是异步的：

当你调用db.query时，它会立即发起数据库请求，但不会阻塞后续代码执行。你的函数先把ret设为false，调用db.query后直接返回ret——这时候db.query的回调函数还没执行，ret根本没机会被改成true，所以返回的永远是初始的false。

另外还要注意：原函数里的id和data没有作为参数传入，运行时会抛出ReferenceError，这个也需要一起修正。

下面提供几种主流的异步处理方案，按推荐程度排序：

1. 使用 Async/Await（最简洁易读） #

现代Node.js推荐用async/await处理异步操作，它能让异步代码看起来像同步代码一样直观。我们可以把add函数标记为async，然后用await等待db.query完成：

var visitor = function() { 
  // 标记add为async函数
  this.add = async function(id, data) { 
    try {
      // 用await等待数据库查询完成
      await db.query({
        text: 'INSERT INTO visitor(visitorid, data, status) VALUES($1, $2, $3)', 
        values: [id, JSON.stringify(data), "1"]
      });
      // 成功则返回true
      return true;
    } catch (err) {
      // 捕获错误，可根据需求返回false或抛出错误
      console.error('插入数据失败:', err);
      return false;
    }
  } 
}

// 使用方式：需要在async函数中调用
async function addNewVisitor() {
  const v = new visitor();
  // 等待add执行完成再获取结果
  const result = await v.add(1001, {name: "Kerem", visitTime: new Date()});
  console.log('插入结果:', result); // 此时会返回true（成功时）
}
addNewVisitor();

2. 使用 Promise 封装 #

如果你的Node.js版本不支持async/await（现在很少见），可以手动把db.query封装成Promise：

var visitor = function() { 
  this.add = function(id, data) { 
    // 返回一个Promise对象
    return new Promise((resolve, reject) => {
      db.query({
        text: 'INSERT INTO visitor(visitorid, data, status) VALUES($1, $2, $3)', 
        values: [id, JSON.stringify(data), "1"]
      }, (err, response) => {
        if (!err) {
          // 成功时调用resolve，传递true
          resolve(true);
        } else {
          // 失败时调用reject，传递错误信息
          reject(err);
        }
      });
    });
  } 
}

// 使用方式1：用.then()链式调用
const v = new visitor();
v.add(1001, {name: "Kerem"})
  .then(result => {
    console.log('插入结果:', result); // true
  })
  .catch(err => {
    console.error('插入失败:', err);
  });

// 使用方式2：同样可以配合async/await使用，和方案1效果一致

3. 使用回调函数（传统异步处理方式） #

这是最早期的异步处理方案，代码可读性不如前两种，但也是有效的：

var visitor = function() { 
  // 新增callback参数，用于传递结果
  this.add = function(id, data, callback) { 
    db.query({
      text: 'INSERT INTO visitor(visitorid, data, status) VALUES($1, $2, $3)', 
      values: [id, JSON.stringify(data), "1"]
    }, (err, response) => {
      if (!err) {
        // 成功时调用callback，传递null（无错误）和true
        callback(null, true);
      } else {
        // 失败时传递错误信息和false
        callback(err, false);
      }
    });
  } 
}

// 使用方式：传入回调函数处理结果
const v = new visitor();
v.add(1001, {name: "Kerem"}, (err, result) => {
  if (err) {
    console.error('插入失败:', err);
    return;
  }
  console.log('插入结果:', result); // true
});

• 一定要把id和data作为参数传入add函数，否则会出现变量未定义的错误。
• 不管用哪种方案，都要处理可能出现的数据库错误（比如连接失败、SQL语法错误等），避免程序崩溃。

内容的提问来源于stack exchange，提问作者Kerem Çakır