各位老师,请问在flinkcdc中,sqlserver如何获取到ddl?
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
在Flink CDC中,针对SQL Server获取DDL的操作主要依赖于所采用的同步模式。根据提供的知识库资料,SQL Server到MySQL或PolarDB MySQL版的增量同步模式有几种,其中一种模式能够帮助捕获DDL语句,具体如下:
dts_cdc_sync_ddl
、心跳表dts_sync_progress
、DDL存储表dts_cdc_ddl_history
,同时开启库级别和部分表的CDC功能。这意味着,通过配置Flink CDC任务时选择上述增量同步模式,即可在同步过程中自动捕获并处理SQL Server的DDL变更,从而实现数据库结构的同步更新。
SELECT INTO
和TRUNCATE
语句将不被支持。综上所述,要获取SQL Server中的DDL变更,应选择一个支持日志解析与CDC混合模式的同步策略,这将允许您捕捉到DDL操作并相应地应用到目标数据库系统中。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。