遍历首个查询结果时执行其他查询报Connection terminated如何解决

你遇到的连接终止报错由两个核心问题导致：

• Array.forEach 本身不支持等待异步回调执行，代码运行到await client.end()时，循环内部的订单查询还未执行完成，连接被提前关闭，自然抛出连接终止异常。
• 单个PostgreSQL客户端实例同一时间只能处理一个查询请求，就算解决了等待问题，循环内并发发起的多个查询会挤在同一个连接上，触发请求冲突。

方案1：单连接串行执行（适合小数据量场景） #

把forEach替换为普通for...of循环，保证前一个查询执行完成后再发起下一个查询，等所有逻辑全部跑完再关闭连接。另外需要替换字符串拼接的SQL写法为参数化查询，避免SQL注入风险。

const client = new Client(credentials)
await client.connect()

try {
  const userQuery = await client.query('select c.* from clients c')
  const rows = userQuery.rows
  for (const row of rows) {
    console.log("user", row)
    // 参数化查询，用$1作为占位符，参数通过数组传入
    const orderQuery = await client.query(
      `select o.created from orders o where o."userId" = $1 order by o.created desc limit 1`,
      [row.id]
    )
    const orderRows = orderQuery.rows
    orderRows.forEach(order => {
      console.log(order)
    })
  }
} finally {
  // 放在finally块中，保证无论代码报错与否都能正常关闭连接
  await client.end()
}

方案2：连接池并发执行（适合数据量较大、需要提升查询速度的场景） #

使用PostgreSQL的连接池替代单个客户端连接，每次查询会自动分配空闲连接，避免单连接的并发冲突问题，同时用Promise.all等待所有异步查询执行完成后再关闭连接池。

const { Pool } = require('pg')
const pool = new Pool(credentials)

try {
  const userQuery = await pool.query('select c.* from clients c')
  const rows = userQuery.rows
  // 等待所有并发查询执行完成
  await Promise.all(rows.map(async row => {
    console.log("user", row)
    const orderQuery = await pool.query(
      `select o.created from orders o where o."userId" = $1 order by o.created desc limit 1`,
      [row.id]
    )
    orderQuery.rows.forEach(order => console.log(order))
  }))
} finally {
  await pool.end()
}

方案3：单SQL联表查询（性能最优，优先推荐） #

这是性能最优的方案，优先推荐使用。你的场景不需要循环发起N+1次查询，直接通过SQL联表+窗口函数一次取出所有需要的数据，能大幅减少数据库交互开销，从根源上避免循环查询的连接问题。

const client = new Client(credentials)
await client.connect()

try {
  // 一次查询取出所有客户及对应最新订单的创建时间
  const { rows } = await client.query(`
    select c.*, latest_order.created as latest_order_created
    from clients c
    left join (
      select "userId", created,
        row_number() over (partition by "userId" order by created desc) as rn
      from orders
    ) latest_order on c.id = latest_order."userId" and latest_order.rn = 1
  `)
  rows.forEach(row => {
    console.log("user", row)
    if (row.latest_order_created) {
      console.log({ created: row.latest_order_created })
    }
  })
} finally {
  await client.end()
}

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