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)
