TypeORM查询流管道传输到写入流时出现RowDataPacket错误如何解决

架构老林

2026-9-29

问题原因

TypeORM 提供的stream()方法返回的是**对象模式（Object Mode）**的可读流，每次推送的chunk是数据库行对应的RowDataPacket对象实例，而非普通流要求的字符串/Buffer/Uint8Array类型。你先将结果写入JSON文件再读取的流程，相当于额外做了一步对象序列化转字节流的操作，所以后续流程可以正常运行，直接管道就会触发类型校验报错。

解决方案

方案1：插入对象转字节的转换流

在TypeORM返回的对象流和jsonexport转换流之间，插入一个自定义Transform流，专门处理对象到字节的转换：

const { Transform } = require('stream');

// 自定义转换流，适配对象模式输入
const objectToBuffer = new Transform({
  writableObjectMode: true, // 允许接收对象类型的chunk
  transform(row, _, callback) {
    // 将行对象序列化为JSON字符串，尾部加换行适配逐行解析逻辑
    callback(null, JSON.stringify(row) + '\n');
  }
});

// 调整后的管道顺序
inputStream
  .pipe(objectToBuffer)
  .pipe(jsonexport())
  .pipe(wStreamCSV);

方案2：使用支持对象模式输入的CSV转换库

直接替换jsonexport为原生支持对象流的CSV处理库，省去额外转换步骤，比如@fast-csv/format：

const { format } = require('@fast-csv/format');

// 初始化csv转换流，开启对象模式，自动写入表头
const csvStream = format({ headers: true, objectMode: true });

// 直接对接TypeORM的对象流
inputStream
  .pipe(csvStream)
  .pipe(wStreamCSV);

该方案不需要额外做JSON序列化，性能和代码简洁度都更高。如果要继续使用jsonexport，也可以检查库的配置项是否支持开启objectMode开关，开启后也可以直接对接TypeORM的对象流。

注意事项