Skip to content

Commit 3a31413

Browse files
committed
add binlog parser command
1 parent c613854 commit 3a31413

File tree

2 files changed

+29
-0
lines changed

2 files changed

+29
-0
lines changed

Makefile

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@ build:
55
go build -o bin/go-mysqlbinlog cmd/go-mysqlbinlog/main.go
66
go build -o bin/go-mysqldump cmd/go-mysqldump/main.go
77
go build -o bin/go-canal cmd/go-canal/main.go
8+
go build -o bin/go-binlogparser cmd/go-binlogparser/main.go
89
rm -rf vendor
910

1011
test:

cmd/go-binlogparser/main.go

Lines changed: 28 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,28 @@
1+
package main
2+
3+
import (
4+
"flag"
5+
"os"
6+
7+
"github.com/siddontang/go-mysql/replication"
8+
)
9+
10+
var name = flag.String("name", "", "binlog file name")
11+
var offset = flag.Int64("offset", 0, "parse start offset")
12+
13+
func main() {
14+
flag.Parse()
15+
16+
p := replication.NewBinlogParser()
17+
18+
f := func(e *replication.BinlogEvent) error {
19+
e.Dump(os.Stdout)
20+
return nil
21+
}
22+
23+
err := p.ParseFile(*name, *offset, f)
24+
25+
if err != nil {
26+
println(err)
27+
}
28+
}

0 commit comments

Comments
 (0)