Name		Name	Last commit message	Last commit date
dump		dump
replication		replication
scripts		scripts
tests/binlogStream		tests/binlogStream
.travis.yml		.travis.yml
LICENSE		LICENSE
Makefile		Makefile
README.md		README.md
doc.go		doc.go
example_test.go		example_test.go
logger.go		logger.go
logger_test.go		logger_test.go
mysql_table.go		mysql_table.go
mysql_table_test.go		mysql_table_test.go
mysql_types.go		mysql_types.go
mysql_types_test.go		mysql_types_test.go
position.go		position.go
position_test.go		position_test.go
row_streamer.go		row_streamer.go
row_streamer_test.go		row_streamer_test.go
slave_conn.go		slave_conn.go
slave_conn_test.go		slave_conn_test.go
transaction.go		transaction.go
transaction_test.go		transaction_test.go

Repository files navigation

binlog

binlog将自己伪装成slave获取mysql主从复杂流来获取mysql数据库的数据变更，提供轻量级，快速的dump协议交互以及binlog的row模式下的格式解析

Features

轻量级，快速的dump协议交互以及binlog的row模式格式解析
支持mysql5.6以及mysql5.7除了JSON的所有数据类型变更
支持使用完整dump协议连接数据库并接受binlog数据
提供函数来接受解析后完整的事务数据
事务数据提供变更的列名，列数据类型，bytes类型的数据

Requests

mysql 5.6/mysql 5.7
golang 1.9+

Installation

go get github.com/onlyac0611/binlog

Quick Start

Prepare

对于自建MySQL，需要先开启Binlog写入功能，配置binlog-format为ROW模式
授权examle链接MySQL账号具有作为MySQL slave的权限，如果已有账户可直接grant

Coding

检查mysql的binlog格式是否是row模式，并且获取一个正确的binlog位置（以文件名和位移量作定义）
实现MysqlTableMapper接口，该接口是用于获取表信息的，主要是获取列属性
表MysqlTable和列MysqlColumn需要实现，用于MysqlTableMapper接口
生成一个RowStreamer，设置一个正确的binlog位置并使用Stream接受数据，具体可以使用sendTransaction进行具体的行为定义

See the binlogStream and documentation for more details.

About

binlog将自己伪装成slave获取mysql主从复杂流来获取mysql数据库的数据变更，提供轻量级，快速的dump协议交互以及binlog的row模式下的格式解析

Apache-2.0 license

1 star

1 watching

Report repository

Releases

Packages

Contributors

Languages