Popularity
5.8
Growing
Activity
0.0
Stable
172
20
46
Programming language: Go
License: Do What The F*ck You Want To Public License
Tags:
Database
myreplication alternatives and similar packages
Based on the "Database" category.
Alternatively, view myreplication alternatives based on common mentions on social networks and blogs.
-
vitess
vitess provides servers and tools which facilitate scaling of MySQL databases for large scale web services. -
groupcache
Groupcache is a caching and cache-filling library, intended as a replacement for memcached in many cases. -
TinyGo
Go compiler for small places. Microcontrollers, WebAssembly, and command-line tools. Based on LLVM. -
go-cache
An in-memory key:value store/cache (similar to Memcached) library for Go, suitable for single-machine applications. -
go-mysql-elasticsearch
Sync your MySQL data into Elasticsearch automatically. -
VictoriaMetrics
fast, resource-effective and scalable open source time series database. May be used as long-term remote storage for Prometheus. Supports PromQL. -
buntdb
A fast, embeddable, in-memory key/value database for Go with custom indexing and spatial support. -
xo
Generate idiomatic Go code for databases based on existing schema definitions or custom queries supporting PostgreSQL, MySQL, SQLite, Oracle, and Microsoft SQL Server. -
sql-migrate
Database migration tool. Allows embedding migrations into the application using go-bindata. -
immudb
immudb is a lightweight, high-speed immutable database for systems and applications written in Go. -
nutsdb
Nutsdb is a simple, fast, embeddable, persistent key/value store written in pure Go. It supports fully serializable transactions and many data structures such as list, set, sorted set. -
skeema
Pure-SQL schema management system for MySQL, with support for sharding and external online schema change tools. -
Bitcask
Bitcask is an embeddable, persistent and fast key-value (KV) database written in pure Go with predictable read/write performance, low latency and high throughput thanks to the bitcask on-disk layout (LSM+WAL). -
ObjectBox Go Database
ObjectBox Go - a database for your Go structs/objects. Super-fast and simple.
Get performance insights in less than 4 minutes
Scout APM uses tracing logic that ties bottlenecks to source code so you know the exact line of code causing performance issues and can get back to building a great product faster.
Sponsored
scoutapm.com
Do you think we are missing an alternative of myreplication or a related project?
README
Go MySql binary log replication listener
Pure Go Implementation of MySQL replication protocol. This allow you to receive event like insert, update, delete with their datas and raw SQL queries. This code has been developed and maintained by Ven at January 2015.
Installation
go get github.com/2tvenom/myreplication
Test
The project is test with:
- Go 1.3.3
- MySQL 5.5, 5.6 and 5.7 (beta)
- Docker 1.4.1 build 5bc2ff8 (functional tests)
It's not tested in real production situation.
Unit tests
go test
Docker tests
Functonal tests with Docker. Test statement based and row based replication. MySql versions 5.5, 5.6, 5.7.
cd tests
sudo ./test.sh
MySQL server settings
In your MySQL server configuration file you need to enable replication:
[mysqld]
server-id = 1
log_bin = /var/log/mysql/mysql-bin.log
expire_logs_days = 10
max_binlog_size = 100M
binlog-format = row #Row based replication
Example
package main
import (
"fmt"
"myreplication"
)
var (
host = "localhost"
port = 3307
username = "admin"
password = "admin"
)
func main() {
newConnection := myreplication.NewConnection()
serverId := uint32(2)
err := newConnection.ConnectAndAuth(host, port, username, password)
if err != nil {
panic("Client not connected and not autentificate to master server with error:" + err.Error())
}
//Get position and file name
pos, filename, err := newConnection.GetMasterStatus()
if err != nil {
panic("Master status fail: " + err.Error())
}
el, err := newConnection.StartBinlogDump(pos, filename, serverId)
if err != nil {
panic("Cant start bin log: " + err.Error())
}
events := el.GetEventChan()
go func() {
for {
event := <-events
switch e := event.(type) {
case *myreplication.QueryEvent:
//Output query event
println(e.GetQuery())
case *myreplication.IntVarEvent:
//Output last insert_id if statement based replication
println(e.GetValue())
case *myreplication.WriteEvent:
//Output Write (insert) event
println("Write", e.GetTable())
//Rows loop
for i, row := range e.GetRows() {
//Columns loop
for j, col := range row {
//Output row number, column number, column type and column value
println(fmt.Sprintf("%d %d %d %v", i, j, col.GetType(), col.GetValue()))
}
}
case *myreplication.DeleteEvent:
//Output delete event
println("Delete", e.GetTable())
for i, row := range e.GetRows() {
for j, col := range row {
println(fmt.Sprintf("%d %d %d %v", i, j, col.GetType(), col.GetValue()))
}
}
case *myreplication.UpdateEvent:
//Output update event
println("Update", e.GetTable())
//Output old data before update
for i, row := range e.GetRows() {
for j, col := range row {
println(fmt.Sprintf("%d %d %d %v", i, j, col.GetType(), col.GetValue()))
}
}
//Output new
for i, row := range e.GetNewRows() {
for j, col := range row {
println(fmt.Sprintf("%d %d %d %v", i, j, col.GetType(), col.GetValue()))
}
}
default:
}
}
}()
err = el.Start()
println(err.Error())
}
Links
- MySql documentation http://dev.mysql.com/doc/internals/en/client-server-protocol.html
- Python implementation. MySql 5.6 checksum compatibility https://github.com/noplay/python-mysql-replication
- Go MySql client. Password encryption method https://github.com/ziutek/mymysql
- Java implementation. Decimal type parsing https://github.com/whitesock/open-replicator
- Ruby implementation. Decimal type parsing https://github.com/jeremycole/mysql_binlog
- Docker files https://github.com/docker-library/mysql