JingWei Li created FLINK-33790: ---------------------------------- Summary: Upsert statement filter unique key field colume in mysql dielact Key: FLINK-33790 URL: https://issues.apache.org/jira/browse/FLINK-33790 Project: Flink Issue Type: Improvement Components: Connectors / JDBC Reporter: JingWei Li
example: `col2` and `col4` is unique key in table `my_table` {code:java} INSERT INTO `my_table`(`col1`, `col2`, `col3`, `col4`, `col5`) VALUES (?, ?, ?, ?, ?) ON DUPLICATE KEY UPDATE `col1`=VALUES(`col1`), `col2`=VALUES(`col2`), `col3`=VALUES(`col3`), `col4`=VALUES(`col4`), `col5`=VALUES(`col5`){code} result: {code:java} INSERT INTO `my_table`(`col1`, `col2`, `col3`, `col4`, `col5`) VALUES (?, ?, ?, ?, ?) ON DUPLICATE KEY UPDATE `col1`=VALUES(`col1`), `col3`=VALUES(`col3`), `col5`=VALUES(`col5`) {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)