From e0933373b0b275d20a12800fbf0dc865d6b2934b Mon Sep 17 00:00:00 2001 From: Kevin Biju Date: Thu, 28 Dec 2023 17:23:38 +0530 Subject: [PATCH] pg pkeys mixed case support --- flow/connectors/postgres/client.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flow/connectors/postgres/client.go b/flow/connectors/postgres/client.go index 304e313f4c..9bd55380c7 100644 --- a/flow/connectors/postgres/client.go +++ b/flow/connectors/postgres/client.go @@ -683,7 +683,7 @@ func (c *PostgresConnector) generateMergeStatement( } if slices.Contains(normalizedTableSchema.PrimaryKeyColumns, columnName) { primaryKeyColumnCasts[columnName] = fmt.Sprintf("(_peerdb_data->>'%s')::%s", columnName, pgType) - primaryKeySelectSQLArray = append(primaryKeySelectSQLArray, fmt.Sprintf("src.%s=dst.%s", + primaryKeySelectSQLArray = append(primaryKeySelectSQLArray, fmt.Sprintf(`src."%s"=dst."%s"`, columnName, columnName)) } }