Dinky的使用——数据更新

通过dinky写flinksql实现数据更新

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

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

 

 

 

一、创建作业

 

 

二、编写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集群，检查语法没有问题，直接运行

 

 

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

 

 

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