请问Flink CDC中有数据库方言转换方案推荐吗？客户现场存在异构数据源的同一系统，如mysql版
问题1:请问Flink CDC中有数据库方言转换方案推荐吗？客户现场存在异构数据源的同一系统，如mysql版本、达梦数据库版本，现在客户想实现两套系统进行数据实时同步功能。我的思路是，通过拦截SQL方式通过消息中间件（kafka、rabbitmq）发送给另外一个节点，节点收到数据后，进行一个SQL解析和转换，把源SQL转换为当前设备数据库SQL。我打算通过mybatis，把sql拦截下来，然后通过消息中间件发给另外一台机器，另外一台机器把源数据源sql转换为目标数据源sql，比如mysql 语句转换为达梦的。 问题2:现在是SQL解析转换这块，没有一个很好的思路，您有好的建议吗？
写回答
-
回答1:你想做达梦数据数据库cdc吗，目前没有，你可以写代码，和人大金仓的一起搞，mybatis这个对大数据不，只要能够拦截，并且方便就可以了。并不需要一定要用大数据体系的。满足业务是第一需求，然后才轮到选择使用哪种手段太合适，还有spring boot之类 回答2:druid就有现成的代码，就是不知道是否能解析达梦数据库的sql语句，此回答整理自钉群“Flink CDC 社区”
2023-06-29 09:57:04赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
