Skip to content

Commit c12762f

Browse files
authored
fix: PG<15 fallback parameters (#4473) (#4509)
## Summary Fixes #4473. This updates the Postgres <15 fallback normalize statements to use the same per-batch parameters as the PG15+ `MERGE` path: ```sql _peerdb_batch_id = $1 AND _peerdb_destination_table_name = $2 ```
1 parent 070420f commit c12762f

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

flow/connectors/postgres/client.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -82,14 +82,14 @@ const (
8282
fallbackUpsertStatementSQL = `WITH src_rank AS (
8383
SELECT _peerdb_data,_peerdb_record_type,_peerdb_unchanged_toast_columns,
8484
RANK() OVER (PARTITION BY %s ORDER BY _peerdb_timestamp DESC) AS _peerdb_rank
85-
FROM %s.%s WHERE _peerdb_batch_id>$1 AND _peerdb_batch_id<=$2 AND _peerdb_destination_table_name=$3
85+
FROM %s.%s WHERE _peerdb_batch_id=$1 AND _peerdb_destination_table_name=$2
8686
)
8787
INSERT INTO %s (%s) SELECT %s FROM src_rank WHERE _peerdb_rank=1 AND _peerdb_record_type!=2
8888
ON CONFLICT (%s) DO UPDATE SET %s`
8989
fallbackDeleteStatementSQL = `WITH src_rank AS (
9090
SELECT _peerdb_data,_peerdb_record_type,_peerdb_unchanged_toast_columns,
9191
RANK() OVER (PARTITION BY %s ORDER BY _peerdb_timestamp DESC) AS _peerdb_rank
92-
FROM %s.%s WHERE _peerdb_batch_id>$1 AND _peerdb_batch_id<=$2 AND _peerdb_destination_table_name=$3
92+
FROM %s.%s WHERE _peerdb_batch_id=$1 AND _peerdb_destination_table_name=$2
9393
)
9494
%s src_rank WHERE %s AND src_rank._peerdb_rank=1 AND src_rank._peerdb_record_type=2`
9595

0 commit comments

Comments
 (0)