Use copy with binary.

dimitri · Jul 31, 2024 · e726e1f · e726e1f
1 parent 792c554
commit e726e1f
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/bin/pgcopydb/pgsql.c b/src/bin/pgcopydb/pgsql.c
@@ -2929,7 +2929,7 @@ pg_copy_from_stdin(PGSQL *pgsql, const char *qname)
 {
 	char sql[BUFSIZE] = { 0 };
 
-	sformat(sql, sizeof(sql), "COPY %s FROM stdin", qname);
+	sformat(sql, sizeof(sql), "COPY %s FROM stdin WITH (format binary)", qname);
 
 	char *endpoint =
 		pgsql->connectionType == PGSQL_CONN_SOURCE ? "SOURCE" : "TARGET";
@@ -3073,7 +3073,7 @@ pg_copy_send_query(PGSQL *pgsql, CopyArgs *args, ExecStatusType status)
 							  args->srcAttrList,
 							  args->srcQname);
 		}
-		appendPQExpBuffer(sql, "to stdout");
+		appendPQExpBuffer(sql, "to stdout with (format binary);");
 	}
 	else if (status == PGRES_COPY_IN)
 	{
@@ -3090,7 +3090,7 @@ pg_copy_send_query(PGSQL *pgsql, CopyArgs *args, ExecStatusType status)
 
 		if (args->freeze)
 		{
-			appendPQExpBuffer(sql, " with (freeze)");
+			appendPQExpBuffer(sql, " with (freeze, format binary)");
 		}
 	}
 	else