package cache

import (
	"fmt"
	"sdkCompare/config"

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

type MyEventHandler struct {
	canal.DummyEventHandler
}

func (h *MyEventHandler) OnRow(e *canal.RowsEvent) error {
	// 过滤历史消息和不关心的表
	if e.Table.Name != config.DbPersonCompInfo.PersonTable || e.Header == nil {
		return nil
	}

	fmt.Printf("%s %s %v\n", e.Table.Name, e.Action, e.Rows)

	return nil
}

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

func WatchDB() error {
	cfg := canal.NewDefaultConfig()
	cfg.Addr = config.DbPersonCompInfo.MysqlAddr
	cfg.User = config.DbPersonCompInfo.Username
	cfg.Password = config.DbPersonCompInfo.Password

	// 监听的数据库和表
	cfg.Dump.TableDB = config.DbPersonCompInfo.Database
	cfg.Dump.Tables = []string{config.DbPersonCompInfo.PersonTable}

	cfg.ParseTime = true

	c, err := canal.NewCanal(cfg)
	if err != nil {
		return err
	}

	// Register a handler to handle RowsEvent
	c.SetEventHandler(&MyEventHandler{})

	// Start canal
	err = c.Run()

	return err
}