使用Node.js执行PostgreSQL查询失败，请求技术协助

你的代码核心问题是把Web服务端口（默认3000）当成了PostgreSQL数据库的端口，PostgreSQL默认监听端口是5432，这会导致客户端连接到错误的端口，无法正常查询数据。

修正步骤 #

1. 正确配置数据库端口 #

将客户端配置中的port改为PostgreSQL的默认端口5432，也可以通过环境变量指定数据库端口避免硬编码：

const { Client } = require('pg');
// 数据库端口单独配置，默认5432，可通过环境变量PGPORT覆盖
const DB_PORT = process.env.PGPORT || 5432;
// Web服务端口和数据库端口分开定义
const WEB_PORT = process.env.PORT || 3000;

const client = new Client({
    host: 'localhost',
    port: DB_PORT,
    user: 'postgres',
    password: 'postgres',
    database: 'ecommerce'
})

2. 完善连接错误处理 #

原代码没有处理client.connect()的错误，若连接失败会直接进入查询回调，导致错误定位困难，建议补充连接错误处理：

client.connect((err) => {
    if (err) {
        console.error('连接数据库失败:', err);
        return;
    }
    console.log('已成功连接到数据库');
    
    client.query('select * from customers', (err, result) => {
        if (!err) {
            console.log('查询结果:', result.rows)
        } else {
            console.error('查询出错:', err)
        }
        client.end();
    })
});

3. 可选：改用Async/Await写法（更易维护） #

回调嵌套过多时，用async/await可以让代码更清晰：

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

const DB_PORT = process.env.PGPORT || 5432;

async function queryCustomers() {
    const client = new Client({
        host: 'localhost',
        port: DB_PORT,
        user: 'postgres',
        password: 'postgres',
        database: 'ecommerce'
    });

    try {
        await client.connect();
        const result = await client.query('select * from customers');
        console.log('查询结果:', result.rows);
    } catch (err) {
        console.error('操作出错:', err);
    } finally {
        await client.end();
    }
}

queryCustomers();

额外检查点 #

• 确认PostgreSQL服务正在本地运行，且监听5432端口（可通过psql -U postgres测试连接）
• 确认postgres用户有权限访问ecommerce数据库和customers表
• 若修改过PostgreSQL端口，确保配置的DB_PORT和实际端口一致

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