From 397289f222673dafaceafecbeb9b5c7c7044ab17 Mon Sep 17 00:00:00 2001
From: zhaown <jayce.zhao@artefact.com>
Date: Wed, 9 Feb 2022 11:15:10 +0800
Subject: [PATCH] fix postgre jdbc upsert mode has not been filtered primary
 key.

---
 .../flinkx/connector/postgresql/dialect/PostgresqlDialect.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git a/flinkx-connectors/flinkx-connector-postgresql/src/main/java/com/dtstack/flinkx/connector/postgresql/dialect/PostgresqlDialect.java b/flinkx-connectors/flinkx-connector-postgresql/src/main/java/com/dtstack/flinkx/connector/postgresql/dialect/PostgresqlDialect.java
index 7ae32253be..b3bae294e2 100644
--- a/flinkx-connectors/flinkx-connector-postgresql/src/main/java/com/dtstack/flinkx/connector/postgresql/dialect/PostgresqlDialect.java
+++ b/flinkx-connectors/flinkx-connector-postgresql/src/main/java/com/dtstack/flinkx/connector/postgresql/dialect/PostgresqlDialect.java
@@ -78,6 +78,7 @@ public Optional<String> getUpsertStatement(
                         .collect(Collectors.joining(", "));
         updateClause =
                 Arrays.stream(fieldNames)
+                        .filter(f -> !Arrays.asList(uniqueKeyFields).contains(f))
                         .map(f -> quoteIdentifier(f) + "=EXCLUDED." + quoteIdentifier(f))
                         .collect(Collectors.joining(", "));