写了一个 mysql cdc table，有用么

[bluebo]

基于 mysql 的存储插件，与 mysql 的 binlog 开发了一个 mysql cdc table 。可以在 mysql select binlog 中表的变化数据

__op

0 – delete data

1 – insert data

2 – update before data

3 – update after date

__gtid

全局事务 id

__tm

row event 发生的时间

效果大概是这样

https://madbluecat.github.io/post/mysqlcdctable/

[zhenjiachen]

我们直接用 flink cdc ，mysql ，postgresql ，sqlserver 都支持。

[wenxueywx]

@bluebo 是的，__optime 就是数据变更时间__tm ；
优势就是实现了 mysql 引擎的接口可以内置到 mysql 中使用，可以对接 mysql 生态。
然后用户使用 gtid 去拿数据有点不符合操作习惯，你还得先知道 gtid ；使用时间就比较正常了。正常操作你只需设置一下时间，再用原来的 sql 直接执行就行，也基本没有增加使用负担。

[lvlongxiang199]

MySQL 中的表发生 DDL 你是咋处理的 ? MySQL8 之前的 binlog 里头没列名, binlog 中元素对应的表结构可能跟当前 MySQL 那边的表结构不一样

[bluebo]

@lvlongxiang199 DDL ，我没捕获， 但是 DDL 应该是对系统表做了增删改的操作，需要捕获系统表，而且不同版本的 mysql 不知道系统表有没有变化。

[bluebo]

@wenxueywx gtid 确实不直观，但是比__tm 更精准些。想想能不能直接在 mysql 上操作其他数据库(CRUD)。 应该也能实现，体量太大了

[bluebo]

@zhenjiachen 暂时只是做了捕获和展示的动作， 数据落地应该不会接着做了