Support binary result format

packages/pg-protocol/src/parser.ts

@@ -278,13 +278,15 @@ export class Parser {
   }
 
   private parseDataRowMessage(offset: number, length: number, bytes: Buffer) {
-    this.reader.setBuffer(offset, bytes)
-    const fieldCount = this.reader.int16()
+    const reader = this.reader
+    reader.setBuffer(offset, bytes)
+    const fieldCount = reader.int16()
     const fields: any[] = new Array(fieldCount)
+    const textMode = this.mode === 'text'
     for (let i = 0; i < fieldCount; i++) {
-      const len = this.reader.int32()
+      const len = reader.int32()
       // a -1 for length means the value of the field is null
-      fields[i] = len === -1 ? null : this.reader.string(len)
+      fields[i] = len === -1 ? null : textMode ? reader.string(len) : reader.bytes(len)
     }
     return new DataRowMessage(length, fields)
   }

packages/pg-protocol/src/serializer.ts

@@ -160,7 +160,15 @@ const bind = (config: BindOpts = {}): Buffer => {
   writer.add(paramWriter.flush())
 
   // format code
-  writer.addInt16(binary ? ParamType.BINARY : ParamType.STRING)
+  if (binary) {
+    const columnFormatCount = 1
+    writer.addInt16(columnFormatCount)
+    writer.addInt16(ParamType.BINARY)
+  } else {
+    const columnFormatCount = 0
+    writer.addInt16(columnFormatCount)
+  }
+
   return writer.flush(code.bind)
 }