NodeJS连接PostgreSQL时SQL关联查询报错求助

先帮你拆解下遇到的两个核心问题，再给出修正后的代码和关键说明：

1. SQL连接错误：column "id" specified in USING clause does not exist in left table #

这个错误的根源是你用USING("id")关联表时，左侧表（比如articles和authors连接时，左侧是articles）并没有和右侧表同名的id关联字段。

通常数据库设计里，articles不会直接用自身的id关联authors，而是会有author_id字段指向authors表的id；同理，articles和branches的关联应该是branch_id指向branches的id。USING子句要求两张表必须有完全同名的关联列，显然你的表结构不满足这个条件，所以触发了报错。

2. JavaScript TypeError：Cannot read property 'rows' of undefined #

当SQL查询出错时，回调里的result参数会是undefined，你直接访问result.rows[0]自然会报错。另外，你在服务器启动时就执行查询，但这是异步操作，用户访问/articles路由时，可能查询还没完成，data变量还是undefined，循环访问data[i]也会出问题。

修正后的完整代码 #

我调整了SQL逻辑和Node.js代码的异步处理，解决了这些问题：

const http = require('http');
const path = require('path');
const express = require('express');
const pg = require('pg')

const PGUSER = 'person'
const PGDATABASE = 'website'
const config = {
  user: PGUSER,
  password: 'person',
  database: PGDATABASE,
  max: 10,
  idleTimeoutMillis: 30000
}

const pool = new pg.Pool(config)
const router = express();
const server = http.createServer(router);

router.use(express.static(path.resolve(__dirname, 'client')));

// 将数据库查询移到路由内部，确保每次请求都能获取最新数据，同时处理异步逻辑
router.get('/articles', function (req, res) {
  res.header('Content-type', 'text/html');
  
  pool.connect(function (err, client, done) {
    if (err) {
      console.log(err);
      return res.end('<h1>数据库连接失败</h1>');
    }

    // 修正SQL关联逻辑：用ON指定正确的关联字段（如果你的字段名不是author_id/branch_id，请替换成实际字段）
    const myQuery = `
      SELECT "authors"."name", "branches"."branch", "articles"."title", "articles"."text"
      FROM "articles"
      INNER JOIN "authors" ON "articles"."author_id" = "authors"."id"
      INNER JOIN "branches" ON "articles"."branch_id" = "branches"."id"
      ORDER BY "authors"."name";
    `;

    client.query(myQuery, function (err, result) {
      // 无论查询成功或失败，都要释放连接池中的连接
      done();
      
      if (err) {
        console.log(err);
        return res.end('<h1>查询数据失败</h1>');
      }

      let resultHtml = "";
      // 根据实际返回的数据动态生成HTML，避免固定循环次数导致的越界
      result.rows.forEach(row => {
        resultHtml += `<h1>${row.name}</h1>`;
        resultHtml += `<h3>${row.branch}</h3>`;
        resultHtml += `<h2>${row.title}</h2>`;
        resultHtml += `<h4>${row.text}</h4>`;
        resultHtml += '<hr>';
      });

      // 无数据时给用户友好提示
      if (resultHtml === "") {
        resultHtml = '<h1>暂无文章数据</h1>';
      }

      return res.end(resultHtml);
    });
  });
});

server.listen(process.env.PORT || 8080, process.env.IP || "127.0.0.1", function(){
  const addr = server.address();
  console.log("Server listening at", addr.address + ":" + addr.port);
});

关键调整说明 #

• 修正SQL关联逻辑：把错误的USING("id")改成ON子句，明确指定表之间的关联字段（如果你的字段名不是author_id/branch_id，记得替换成你实际的字段名）。
• 查询移到路由内部：避免服务器启动时异步查询导致的data未初始化问题，每次请求/articles时才去数据库获取最新数据。
• 正确释放连接：调用done()释放连接池中的连接，防止连接泄漏导致的资源耗尽。
• 完善错误处理：在连接失败、查询失败时都返回友好提示，避免程序崩溃。
• 动态遍历数据：用forEach遍历查询结果，代替固定的i<3，适配不同的数据量。

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