TypeORM搭配pg-query-stream调用stream()无输出如何解决

你的代码存在两个核心问题导致流无法正常触发回调：

1. 错误给.stream()调用加了await关键字：TypeORM@^0.2.45版本的SelectQueryBuilder.stream()本身是同步返回可读流对象的方法，而Node.js可读流是thenable对象（原生支持for await...of消费），await流会等待流完全执行结束、所有事件触发完毕后才会执行后续代码，等你绑定data等监听器时流早就跑完了，自然收不到任何事件。
2. 你监听的result事件是pg驱动普通查询模式下的专属事件，pg-query-stream返回的可读流不会触发这个事件，绑定后永远不会执行。

另外存在一个隐性兼容要求：pg-query-stream@^4.2.3必须搭配pg@8.x版本使用，如果项目中pg依赖版本低于8.0，会出现静默兼容问题，流不会触发任何事件也不抛错。

• 移除.stream()调用前的await，拿到流后第一时间绑定所有事件监听器，必须绑定error事件捕获初始化、运行时错误，避免错误被吞。
• 删除无效的result事件监听，流读取完成会触发标准的end事件。
• 如果项目用了打包工具（webpack/esbuild等）或者TS路径映射，建议手动引入pg-query-stream实例传入stream()方法，避免TypeORM自动加载依赖失败。

// 自动加载依赖失败时再手动引入，正常情况可以不写
import QueryStream from "pg-query-stream";

// 注意：不要加await
const stream = conn
  .getRepository(Entity)
  .createQueryBuilder("e")
  // 自动加载失败时传入手动实例：.stream(new QueryStream())
  .stream();

// 拿到流立刻绑定所有事件
stream.on("data", (row) => {
  console.log("读取到行数据:", row);
});

stream.on("end", () => {
  console.log("流全部读取完成");
});

// 必须绑定error事件，否则流报错会直接抛出导致进程退出
stream.on("error", (err) => {
  console.error("流执行出错:", err);
});

如果你偏好async/await风格的写法，可以直接用for await...of遍历流，不需要手动绑定事件，注意同样不要给stream()加await：

const stream = conn
  .getRepository(Entity)
  .createQueryBuilder("e")
  .stream();

for await (const row of stream) {
  console.log("读取到行数据:", row);
}
console.log("流全部读取完成");

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