【Flink】FlinkSQL实现数据从MySQL到MySQL

 简介

我们在实际开发过程中可以使用Flink实现数据从MySQL传输到MySQL具体操作，本例子Flink版本1.13.6，具体操作如下：

创建mysql测试表

下面语句创建了mysql原表和目标表，并插入一条语句到mysql原表中

CREATE TABLE `mysql_source` (
`id` int(11) unsigned NOT NULL AUTO_INCREMENT COMMENT '自增ID',
`name` varchar(64) DEFAULT NULL COMMENT '姓名',
`create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
PRIMARY KEY (`id`)
) 
COMMENT = 'mysql源'
ENGINE = InnoDB;

CREATE TABLE `mysql_target` (
`id` int(11) unsigned NOT NULL AUTO_INCREMENT COMMENT '自增ID',
`name` varchar(64) DEFAULT NULL COMMENT '姓名',
`create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
PRIMARY KEY (`id`)
) 
COMMENT = 'mysql目标'
ENGINE = Inno