PERN应用中Passport.js无法获取数据库数据问题排查

核心问题1：数据库查询结果处理错误 #

PostgreSQL驱动（pg）的db.query回调返回的第二个参数是Result对象，用户数据实际存在于rows数组中，你直接把Result对象当成了用户数据。同时rowCount: 0说明数据库里没有匹配传入username的记录，大概率是两个原因导致：

• 表名问题：user是PostgreSQL的保留关键字，直接写FROM user会触发解析错误，必须用双引号包裹表名：FROM "user"
• 传入的username和数据库中存储的用户名不匹配（比如大小写敏感、输入错误）

核心问题2：代码逻辑错误 #

你的代码存在几处逻辑漏洞：

1. 错误判断用户是否存在：if (!user)永远不会成立，因为Result对象始终存在。正确的判断方式是检查rowCount或rows.length：

   if (result.rowCount === 0) {
     return done(null, false, { msg: "用户名不存在" });
   }
   

2. 未正确提取用户数据：SELECT查询返回的是数组，需要从result.rows[0]中取出单个用户对象：

   const user = result.rows[0];
   

3. 重复定义serializeUser：你写了两次passport.serializeUser，后面的会覆盖前面的。通常只序列化用户的id而非整个对象，避免session体积过大，同时必须搭配deserializeUser实现反序列化：

   passport.serializeUser((user, done) => {
     console.debug("serializing ", user);
     done(null, user.id);
   });
   
   passport.deserializeUser((userId, done) => {
     db.query('SELECT * FROM "user" WHERE id=$1', [userId], (err, result) => {
       if (err) return done(err);
       done(null, result.rows[0]);
     });
   });
   

修复后的完整代码 #

const bcrypt = require('bcrypt');

module.exports = (passport) => {
  passport.use(
    new LocalStrategy((username, password, done) => {
      // 表名用双引号包裹避免关键字冲突
      db.query(
        'SELECT * FROM "user" WHERE username=$1', 
        [username],
        (error, result) => {
          if (error) return done(error);
          // 判断是否找到匹配用户
          if (result.rowCount === 0) {
            return done(null, false, { msg: "用户名不存在" });
          }
          // 提取数据库中的用户数据
          const user = result.rows[0];
          // 比对密码哈希值
          bcrypt.compare(password, user.password, (error, isMatch) => {
            if (error) return done(error);
            if (isMatch) {
              return done(null, user);
            } else {
              return done(null, false, { msg: "密码错误" });
            }
          });
        }
      );
    })
  );

  // 序列化用户id到session
  passport.serializeUser((user, done) => {
    console.debug("serializing ", user);
    done(null, user.id);
  });

  // 从session中恢复用户数据
  passport.deserializeUser((userId, done) => {
    db.query('SELECT * FROM "user" WHERE id=$1', [userId], (err, result) => {
      if (err) return done(err);
      done(null, result.rows[0]);
    });
  });
};

额外排查步骤 #

1. 手动在PostgreSQL客户端执行查询：SELECT * FROM "user" WHERE username='你的测试用户名';，确认是否有返回结果
2. 在LocalStrategy函数开头添加console.log("传入的用户名：", username)，验证参数是否正确
3. 确认数据库连接配置无误，应用确实连接到了目标数据库

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