0
点赞
收藏
分享

微信扫一扫

Dinky的使用——数据更新

小编 2022-10-23 阅读 70

通过dinky写flinksql实现数据更新

通过upsert模式来实现表数据的更新,在定义表的时候必须要指定主键

可以参考文档:https://www.bookstack.cn/read/ApacheFlink-1.13-zh/6dd60342342b2f49.md

Dinky的使用——数据更新_mysql

 

 

 

一、创建作业

Dinky的使用——数据更新_flink_02

 

 

二、编写flinksql代码

CREATE TABLE orc_out( 
`uuid` int,
`id` STRING,
`name` STRING,
`sex` STRING,
`age` STRING,
`work` STRING,
PRIMARY KEY (uuid) NOT ENFORCED
) WITH (
'connector' = 'jdbc',
'url' = 'jdbc:mysql://172.16.119.50:3306/test?createDatabaseIfNotExist=true&useSSL=false&characterEncoding=UTF-8',
'username' = 'root',
'password' = 'Tj@20220710',
'table-name' = 'orc_out'
);

upsert into orc_out(uuid,id,name,sex,age,work) values (183,'007','龚大伯','man','36','bigdata') ;

 

 

三、运行作业

选定提前部署好的flink集群,检查语法没有问题,直接运行

Dinky的使用——数据更新_数据更新_03

 

 

通过flink页面查看任务运行情况

Dinky的使用——数据更新_mysql_04

 

 

查看mysql数据表,可以看到数据更新过来了

Dinky的使用——数据更新_flink_05

 

举报

相关推荐

0 条评论