pg pkeys mixed case support

PeerDB-io · Dec 28, 2023 · e093337 · e093337
1 parent c9e5e90
commit e093337
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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))
 		}
 	}