DataStream Connector的JDBC Sink

目录

at-least-once语义

JdbcSink.sink

SQL DML statement and JDBC statement builder

JDBC execution options

JDBC connection parameters

一个完整的例子

exactly-once语义

JdbcSink.exactlyOnceSink

一个完整的例子

XADataSourceexamples

DataStream Connector中的JDBC Connector提供一个接收器，用于将数据写入JDBC数据库。要使用它，需要在项目l中添加以下依赖：

        <dependency>             <groupId>org.apache.flink</groupId>             <artifactId>flink-connector-jdbc</artifactId>             <version>3.0.0-1.16</version>         </dependency>

请注意，流连接器目前不是二进制发行版的一部分。如果需要在集群中执行，需要将上面的依赖jar添加到Flink集群中。

JDBC接收器提供了至少一次（at-least-once）语义。但是，通过编写upsert SQL语句或幂等SQL更新，可以有效地实现“只执行一次”（exactly-once）语义。

at-least-once语义

JdbcSink.sink

使用JDBC Sink的at-least-once语义，直接调用JdbcSink的sink方法，如下：

Jd