From 5a5e21187a292c9df1a0863503d8c8dab69a5cc5 Mon Sep 17 00:00:00 2001 From: Kaushik Iska Date: Thu, 26 Oct 2023 14:19:59 -0400 Subject: [PATCH] simple query protocol --- flow/connectors/postgres/cdc.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/flow/connectors/postgres/cdc.go b/flow/connectors/postgres/cdc.go index a4e2b5bf2f..bf19f0fabb 100644 --- a/flow/connectors/postgres/cdc.go +++ b/flow/connectors/postgres/cdc.go @@ -12,6 +12,7 @@ import ( "github.com/PeerDB-io/peer-flow/model" "github.com/PeerDB-io/peer-flow/model/qvalue" "github.com/jackc/pglogrepl" + "github.com/jackc/pgx/v5" "github.com/jackc/pgx/v5/pgconn" "github.com/jackc/pgx/v5/pgproto3" "github.com/jackc/pgx/v5/pgtype" @@ -80,7 +81,7 @@ func getChildToParentRelIdMap(ctx context.Context, pool *pgxpool.Pool) (map[uint WHERE parent.relking='p'; ` - rows, err := pool.Query(ctx, query) + rows, err := pool.Query(ctx, query, pgx.QueryExecModeSimpleProtocol) if err != nil { return nil, fmt.Errorf("error querying for child to parent relid map: %w", err) }