go-mysql库使用指南

go-mysql是一个用Go语言实现的MySQL工具库，主要用于处理MySQL协议和复制功能。下面我将介绍它的主要功能和使用方法。

主要功能

1. MySQL复制协议处理：可以作为一个MySQL slave从master获取binlog
2. MySQL协议解析：解析MySQL网络协议
3. binlog解析：解析MySQL的binlog事件
4. 简单MySQL服务器实现：可以模拟MySQL服务器

安装

go get github.com/go-mysql-org/go-mysql

核心组件使用示例

1. 解析binlog

package main

import (
	"os"
	"github.com/go-mysql-org/go-mysql/mysql"
	"github.com/go-mysql-org/go-mysql/replication"
)

func main() {
	// 创建一个binlog解析器
	parser := replication.NewBinlogParser()
	
	// 解析binlog文件
	f, _ := os.Open("mysql-bin.000001")
	defer f.Close()
	
	// 设置解析器格式描述
	parser.ParseFormatDescriptionEvent(f)
	
	// 解析事件
	for {
		header := &replication.EventHeader{}
		if err := parser.ParseEventHeader(f, header); err != nil {
			break
		}
		
		event, err := parser.ParseEvent(f, header)
		if err != nil {
			panic(err)
		}
		
		// 处理不同事件类型
		switch e := event.(type) {
		case *replication.RowsEvent:
			// 处理行变更事件
			for _, row := range e.Rows {
				// 处理每一行数据
			}
		case *replication.QueryEvent:
			// 处理查询事件
		}
	}
}

2. 作为MySQL Slave同步binlog

package main

import (
	"context"
	"fmt"
	"os"
	"os/signal"
	"syscall"
	"time"

	"github.com/go-mysql-org/go-mysql/mysql"
	"github.com/go-mysql-org/go-mysql/replication"
)

func main() {
	// 创建binlog同步器
	cfg := replication.BinlogSyncerConfig{
		ServerID: 100,
		Flavor:   "mysql",
		Host:     "127.0.0.1",
		Port:     3306,
		User:     "root",
		Password: "password",
	}
	
	syncer := replication.NewBinlogSyncer(cfg)
	
	// 从指定位置开始同步
	streamer, _ := syncer.StartSync(mysql.Position{
		Name: "mysql-bin.000001",
		Pos:  4,
	})
	
	// 处理信号
	signals := make(chan os.Signal, 1)
	signal.Notify(signals, syscall.SIGINT, syscall.SIGTERM)
	
	// 处理binlog事件
	ctx, cancel := context.WithTimeout(context.Background(), 2*time.Second)
	defer cancel()
	
	for {
		select {
		case <-signals:
			fmt.Println("Received signal, exiting...")
			syncer.Close()
			return
		default:
			ev, err := streamer.GetEvent(ctx)
			if err == context.DeadlineExceeded {
				continue
			}
			if err != nil {
				panic(err)
			}
			
			// 处理事件
			switch e := ev.Event.(type) {
			case *replication.RowsEvent:
				fmt.Printf("RowsEvent: %v\n", e)
			case *replication.QueryEvent:
				fmt.Printf("QueryEvent: %v\n", e)
			}
		}
	}
}

3. 实现简单的MySQL服务器

package main

import (
	"fmt"
	"net"

	"github.com/go-mysql-org/go-mysql/server"
	"github.com/go-mysql-org/go-mysql/mysql"
)

type MyHandler struct{}

func (h *MyHandler) UseDB(dbName string) error { return nil }
func (h *MyHandler) HandleQuery(query string) (*mysql.Result, error) {
	fmt.Println("Query:", query)
	return &mysql.Result{}, nil
}
func (h *MyHandler) HandleFieldList(table string, fieldWildcard string) ([]*mysql.Field, error) {
	return nil, nil
}
func (h *MyHandler) HandleStmtPrepare(query string) (int, int, interface{}, error) {
	return 0, 0, nil, nil
}
func (h *MyHandler) HandleStmtExecute(context interface{}, query string, args []interface{}) (*mysql.Result, error) {
	return nil, nil
}
func (h *MyHandler) HandleStmtClose(context interface{}) error { return nil }
func (h *MyHandler) HandleOtherCommand(cmd byte, data []byte) error { return nil }

func main() {
	l, _ := net.Listen("tcp", "0.0.0.0:3306")
	
	for {
		c, _ := l.Accept()
		
		// 创建连接
		conn, _ := server.NewConn(
			c,
			"root", // 用户名
			"",     // 密码
			&MyHandler{},
		)
		
		// 处理连接
		go func() {
			for {
				err := conn.HandleCommand()
				if err != nil {
					return
				}
			}
		}()
	}
}

高级用法

1. 使用canal库简化binlog处理

package main

import (
	"fmt"
	"os"
	"os/signal"
	"syscall"

	"github.com/go-mysql-org/go-mysql/canal"
)

type MyEventHandler struct {
	canal.DummyEventHandler
}

func (h *MyEventHandler) OnRow(e *canal.RowsEvent) error {
	fmt.Printf("%s %v\n", e.Action, e.Rows)
	return nil
}

func (h *MyEventHandler) String() string {
	return "MyEventHandler"
}

func main() {
	cfg := canal.NewDefaultConfig()
	cfg.Addr = "127.0.0.1:3306"
	cfg.User = "root"
	cfg.Password = "password"
	cfg.Dump.TableDB = "test"
	cfg.Dump.Tables = []string{"test_table"}
	
	c, _ := canal.NewCanal(cfg)
	
	// 注册事件处理器
	c.SetEventHandler(&MyEventHandler{})
	
	// 从指定位置开始
	pos, _ := c.GetMasterPos()
	c.RunFrom(pos)
	
	// 等待信号
	signals := make(chan os.Signal, 1)
	signal.Notify(signals, syscall.SIGINT, syscall.SIGTERM)
	<-signals
	
	c.Close()
}

2. 使用Dump功能导出数据

package main

import (
	"fmt"
	"os"

	"github.com/go-mysql-org/go-mysql/client"
	"github.com/go-mysql-org/go-mysql/dump"
)

func main() {
	conn, _ := client.Connect("127.0.0.1:3306", "root", "password", "test")
	
	dumper := dump.NewDumper(conn, "test")
	dumper.SetCharset("utf8")
	dumper.SetWhere("id > 100")
	dumper.SetErrOut(os.Stderr)
	
	// 导出表结构和数据
	err := dumper.DumpToFile("test_table", "dump.sql")
	if err != nil {
		panic(err)
	}
	
	fmt.Println("Dump completed")
}

注意事项

1. 处理binlog时要注意事件顺序和位置管理
2. 在生产环境中使用要考虑断点续传和错误处理
3. MySQL用户需要有REPLICATION SLAVE权限
4. 注意处理大事务和长连接问题

go-mysql库功能强大，可以用于构建MySQL中间件、数据同步工具、监控系统等。以上示例展示了其主要功能，实际使用时需要根据具体需求进行调整。