flinkcdc 同步源码

基于Flink CDC使用datastream方式全量增量同步mysql to mysql的源码可以在MysqlCDC中找到。只需配置完源数据库和目标数据库信息，运行MysqlCDC中的main函数，即可实现多库多表同步。此外，DDL 数据同步的原理是创建一个触发器，当原表结构有变化时会将结构变化的语句保存到触发器创建的表中，再利用Flinkcdc的数据同步方法，把变化的sql语句在结果库创建一遍。在源码中，需要配置源数据库和目标数据库的信息，包括主机名、端口号、数据库名、用户名和密码等。同时，还需要配置源表和目标表的结构映射关系，以便正确地同步数据。