第一个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)

}

}

本文来自:51CTO博客

感谢作者:xingzhehxiang

查看原文:第一个go-mysql-binlog解析

• 编辑
• 预览