gobinlog将自己伪装成slave获取mysql主从复杂流来获取mysql数据库的数据变更,提供轻量级,快速的dump协议交互以及binlog的row模式下的格式解析
- 轻量级,快速的dump协议交互以及binlog的row模式格式解析
- 支持mysql 5.6.x,5.7.x,8.0.x的所有数据类型变更
- 支持使用完整dump协议连接数据库并接受binlog数据
- 提供函数来接受解析后完整的事务数据
- 事务数据提供变更的列名,列数据类型,bytes类型的数据
- mysql 5.6+
- golang 1.11+
第三方库管理已经托管到go mod下,请开启环境变量
- 对于自建MySQL,需要先开启Binlog写入功能,配置binlog-format为ROW模式
- 授权examle链接MySQL账号具有作为MySQL slave的权限,如果已有账户可直接grant
- 检查mysql的binlog格式是否是row模式,并且获取一个正确的binlog位置(以文件名和位移量作定义)
- 实现MysqlTableMapper接口,该接口是用于获取表信息的,主要是获取列属性
- 表MysqlTable和列MysqlColumn需要实现,用于MysqlTableMapper接口
- 生成一个RowStreamer,设置一个正确的binlog位置并使用Stream接受数据,具体可以使用sendTransaction进行具体的行为定义
See the binlogStream and documentation for more details.