日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

Flink的JDBC連接器sink可以用于刪除數據，通過設置DELETE語句和WHERE條件來實現(xiàn)。

Flink中使用JDBC連接器sink刪除數據

10年的桐廬網站建設經驗，針對設計、前端、開發(fā)、售后、文案、推廣等六對一服務，響應快，48小時及時工作處理。全網營銷推廣的優(yōu)勢是能夠根據用戶設備顯示端的尺寸不同，自動調整桐廬建站的顯示方式，使網站能夠適用不同顯示終端，在瀏覽器中調整網站的寬度，無論在任何一種瀏覽器上瀏覽網站，都能展現(xiàn)優(yōu)雅布局與設計，從而大程度地提升瀏覽體驗。創(chuàng)新互聯(lián)建站從事“桐廬網站設計”,“桐廬網站推廣”以來，每個客戶項目都認真落實執(zhí)行。

使用JDBC連接器sink刪除數據

在Flink中，可以使用JDBC連接器的sink來刪除數據，具體步驟如下：

1、引入依賴：

```xml

org.apache.flink

flinkconnectorjdbc_2.11

${flink.version}

```

2、創(chuàng)建JDBC連接參數：

```java

Map jdbcOptions = new HashMap<>();

jdbcOptions.put("url", "jdbc:mysql://localhost:3306/mydatabase");

jdbcOptions.put("table", "mytable");

jdbcOptions.put("user", "username");

jdbcOptions.put("password", "password");

```

3、創(chuàng)建JDBC Sink：

```java

JdbcSink sink = JdbcSink.sink(

"INSERT INTO mytable (column1, column2) VALUES (?, ?)",

(ps, t) > {

ps.setString(1, t.getField(0));

ps.setString(2, t.getField(1));

},

jdbcOptions,

new JdbcExecutionOptions.Builder().build()

);

```

4、將數據寫入JDBC Sink：

```java

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

FlinkJdbcConnectionOptions options = new FlinkJdbcConnectionOptions.Builder()

.withUrl("jdbc:mysql://localhost:3306/mydatabase")

.withDriverName("com.mysql.jdbc.Driver")

.build();

FlinkJdbcTableEnvironment tableEnv = StreamTableEnvironment.create(env, options);

tableEnv.executeSql("DELETE FROM mytable"); // 刪除表中的數據

```

相關問題與解答

問題1：如何在Flink中使用JDBC連接器sink更新數據？

答案：在Flink中使用JDBC連接器sink更新數據，可以按照以下步驟進行操作：

1、創(chuàng)建JDBC連接參數；

2、創(chuàng)建JDBC Sink，并指定更新語句和更新邏輯；

3、將數據寫入JDBC Sink。

問題2：如何設置JDBC連接器sink的事務支持？

答案：要設置JDBC連接器sink的事務支持，可以在創(chuàng)建JDBC Sink時添加TransactionConfig配置，示例如下：

TransactionConfig transactionConfig = new TransactionConfig(true, 2); // true表示開啟事務支持，2表示事務隔離級別為READ_COMMITTED
JdbcSink sink = JdbcSink.sink(..., ..., jdbcOptions, transactionConfig, new JdbcExecutionOptions.Builder().build());

本文名稱：Flink有沒有人用過JDBC連接器sink的時候刪除數據？
分享鏈接：http://www.5511xx.com/article/cosehii.html