开发者社区> 问答> 正文

Flink如何读取一个分库分表的MySQL数据库

已解决

Flink如何读取一个分库分表的MySQL数据库

展开
收起
提个问题 2024-06-03 15:22:57 69 0
1 条回答
写回答
取消 提交回答
  • 开发者社区问答官方账号
    官方回答
    采纳回答
    • 使用CREATE TABLE AS(CTAS)语句匹配数据源的多张分库分表,合并后同步到下游的一张表中;
    • 使用CREATE DATABASE AS(CDAS)语句匹配数据源的多个分库下的源表,合并后同步到下游每张对应表名的目标表中;
    • 如果MySQL是一个分库分表的数据库,分成了user_00、user_02和user_99等多个表,且所有表的schema一致。则可以通过table-name选项,指定一个正则表达式来匹配读取多张表,例如设置table-name为user_.*,监控所有user_前缀的表。database-name选项也支持该功能,但需要所有的表schema一致。
    2024-06-03 15:22:58
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
搭建电商项目架构连接MySQL 立即下载
搭建4层电商项目架构,实战连接MySQL 立即下载
PolarDB MySQL引擎重磅功能及产品能力盛大发布 立即下载

相关镜像