Dinky如何实现高效的数据更新操作？

本文共计279个文字，预计阅读时间需要2分钟。

使用Dinky编写Flink SQL实现数据更新，通过upsert模式更新表数据，定义表时必须指定主键。可参考文档：[Apache Flink 1.13 中文文档](https://www.bookstack.cn/read/ApacheFlink-1.13-zh/6dd60342342b2f49.md)。

通过dinky写flinksql实现数据更新

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

可以参考文档：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数据表，可以看到数据更新过来了