Node.js服务器与PostgreSQL数据库交互失败问题排查求助

核心问题：未初始化PostgreSQL客户端连接 #

你只导入了pg的Client类，但没有创建客户端实例、配置连接参数，也没有建立数据库连接。这会导致client.query()完全无法执行，且因为使用了回调模式，没有错误抛出，请求会一直挂起，页面持续加载，控制台也看不到任何日志。

修复步骤 #

1. 初始化并连接PostgreSQL客户端

在代码中导入Client后，添加客户端初始化和连接逻辑，同时通过环境变量配置连接信息（确保.env文件中配置了对应的数据库参数）：

const { Client } = require('pg');

// 初始化PostgreSQL客户端
const client = new Client({
  host: process.env.DB_HOST || 'localhost',
  port: process.env.DB_PORT || 5432,
  user: process.env.DB_USER, // 比如postgres
  password: process.env.DB_PASSWORD, // 你的数据库密码
  database: process.env.DB_NAME // 你的数据库名称
});

// 建立连接并处理连接错误
client.connect((err) => {
  if (err) {
    console.error('数据库连接失败:', err.stack);
    process.exit(1); // 连接失败时退出进程
  } else {
    console.log('已成功连接到PostgreSQL');
  }
});

在.env文件中添加以下配置：

DB_HOST=localhost
DB_PORT=5432
DB_USER=your_db_user
DB_PASSWORD=your_db_password
DB_NAME=your_db_name

2. 修正注册路由的数据库操作逻辑

原代码使用回调模式执行查询，若客户端未初始化，回调永远不会触发，导致请求挂起。建议改为async/await模式，统一错误处理：

app.post("/register", checkNotAuthenticated, async (req, res) => {
  try {
    const hashedPassword = await bcrypt.hash(req.body.password, 10);
    const newUser = {
      id: Date.now().toString(),
      name: req.body.name,
      email: req.body.email,
      password: hashedPassword
    };
    
    const insertQuery = `INSERT INTO users (id, name, email, password) VALUES ($1, $2, $3, $4) RETURNING *`;
    const values = [newUser.id, newUser.name, newUser.email, newUser.password];

    // 使用async/await执行查询
    const result = await client.query(insertQuery, values);
    console.log("用户已插入:", result.rows[0]);
    res.redirect("/login");
  } catch (e) {
    console.error("注册失败:", e);
    res.redirect("/register");
  }
});

3. 验证数据库表结构匹配

检查你的PostgreSQLusers表结构：

• id字段类型需为VARCHAR（因为你用Date.now().toString()生成字符串ID），若表中id是SERIAL或INT类型，会导致插入失败。
• name、email字段需为VARCHAR类型，password字段需足够存储bcrypt哈希值（建议VARCHAR(255)）。

4. 后续优化：Passport适配数据库查询

当前Passport仍依赖内存数组users查找用户，后续需改为从数据库查询，确保登录逻辑正常：

initializePassport(
  passport,
  async (email) => {
    const result = await client.query('SELECT * FROM users WHERE email = $1', [email]);
    return result.rows[0];
  },
  async (id) => {
    const result = await client.query('SELECT * FROM users WHERE id = $1', [id]);
    return result.rows[0];
  }
);

同时可以移除内存数组const users = [];，因为不再需要。

测试验证 #

1. 启动服务器，确认控制台输出已成功连接到PostgreSQL。
2. 提交注册表单，查看控制台是否输出用户插入日志，同时检查PostgreSQL数据库是否有新数据。
3. 若仍有错误，控制台会打印详细错误信息，可根据信息进一步排查。

内容的提问来源于stack exchange，提问作者이도헌