ouyangwulin created FLINK-34901:
-----------------------------------
Summary: Improve the performance of the update Postgres database
Key: FLINK-34901
URL: https://issues.apache.org/jira/browse/FLINK-34901
Project: Flink
Issue Type: Improvement
Components: Connectors / JDBC
Reporter: ouyangwulin
When writing Postgres data using flinker-connector-jdbc, using upsert mode, we
need only update no uniqueColumns to improve performance.
Whether you can modify the code is as follows：
String updateClause =
{code:java}
Arrays.stream(fieldNames)
.filter(fieldName -> !Arrays.asList(uniqueKeyFields).contains(fieldName))
.map(f -> quoteIdentifier(f) + "=EXCLUDED." + quoteIdentifier(f))
.collect(Collectors.joining(", "));{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
