第一个go-mysql-binlog解析

1、这是我第一个二进制日志解析的例子，对官方给出的demo做出相应调整，使其能够运行

package main

import (

"context"

"os"

"time"

"github.com/siddontang/go-mysql/mysql"

"github.com/siddontang/go-mysql/replication"

)

// Create a binlog syncer with a unique server id, the server id must be different from other MySQL's.

// flavor is mysql or mariadb

func main () {

cfg := replication.BinlogSyncerConfig{

ServerID: 100 ,

Flavor: "mysql" ,

Host: "127.0.0.1" ,

Port: 3306 ,

User: "root" ,

Password: "123456" ,

}

syncer := replication. NewBinlogSyncer (cfg)

// Start sync with specified binlog file and position

streamer , _ := syncer. StartSync (mysql.Position{ "mysql.000001" , 405322 })

// or you can start a gtid replication like

// streamer, _ := syncer.StartSyncGTID(gtidSet)

// the mysql GTID set likes this "de278ad0-2106-11e4-9f8e-6edd0ca20947:1-2"

// the mariadb GTID set likes this "0-1-100"

for {

ev , _ := streamer. GetEvent (context. Background ())

// Dump event

ev. Dump (os.Stdout)

}

// or we can use a timeout context

for {

ctx , cancel := context. WithTimeout (context. Background (), 2 *time.Second)

ev , err := streamer. GetEvent (ctx)

cancel ()

if err == context.DeadlineExceeded {

// meet timeout

continue

}

ev. Dump (os.Stdout)

}

}