You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Liam (Jira)" <ji...@apache.org> on 2022/05/01 10:15:00 UTC

[jira] [Created] (FLINK-27463) The JDBC connector should support option for ‘upsert’ or ‘insert’

Liam created FLINK-27463:
----------------------------

             Summary: The JDBC connector should support option for ‘upsert’ or ‘insert’
                 Key: FLINK-27463
                 URL: https://issues.apache.org/jira/browse/FLINK-27463
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / JDBC
    Affects Versions: 1.14.4
            Reporter: Liam


If set a primary key to the table, then the connector will use the upsert query to sink data.

However, the upsert query is not always expected. Because some of the databases don't support upsert well, like Click House. (even though some databases are not supporting officially, I believe many users are extending the dialect by themself)

So I suggest adding an option like 'sink.append-only' to make the data populated by insert query.

 

If we can reach a consensus, I can implement it.



--
This message was sent by Atlassian Jira
(v8.20.7#820007)