单库多表的场景如何支持？

[wangxiangyu]

单库多表： 数据库中多张表，每个表的DDL不同
这个需求应该还是比较通用的，如果对于单个数据库里面的每张表，都起一个sql作业同步一次binlog，显然成本太高，
这种场景，如何写sql语句支持呢？后续计划如何支持呢？

[yangrong688]

flink sql支持正则表达式
stream api 可以支持多表，建议使用 stream api 去实现多表同步的逻辑
具体的可以看下文档

https://ververica.github.io/flink-cdc-connectors/master/content/about.html

[wangxiangyu]

嗯，data stream api是可以解决这个问题的。 但是我们当前的集成任务都是flink sql支持的。我们的解决方法补充到了这里

#805 (comment)

[shadon178]

flink sql应该做不了吧

[J-Orange]

stream

请问哪里有文档或者demo

[yangrong688]

https://ververica.github.io/flink-cdc-connectors/master/content/about.html#usage-for-datastream-api

[J-Orange]

https://ververica.github.io/flink-cdc-connectors/master/content/about.html#usage-for-datastream-api

已经浏览了很多次了这里只有读取数据库变更的api 对于数据获取、处理以及数据如何同步到第三端的api好像并没有 官网对于steamapi的文档太稀缺了 按照官网能落地的还是flinksql的方式

[GourdErwa]

单库多表： 数据库中多张表，每个表的DDL不同 这个需求应该还是比较通用的，如果对于单个数据库里面的每张表，都起一个sql作业同步一次binlog，显然成本太高， 这种场景，如何写sql语句支持呢？后续计划如何支持呢？

API 方式可以分流，也可以使用 statementSet.attachAsDataStream(); ，让多个 sql 以 DataStream 方式运行在一个任务里。
可参考 MysqlCDC2ChangeLog