src

Documentation

Overview

日志模式同步 update 转成 insert on update insert 转成 replace into delete 转成 insert on update 只要是同一条数据，只要有遍历过，后面遍历出来的数据，则不再进行操作

普通模式同步 update 转成 insert on update insert 转成 replace into delete 转成 delete 只要是同一条数据，只要有遍历过，后面遍历出来的数据，则不再进行操作

Index

• Constants
• func NewMysqlDBConn(uri string) *mysqlDB
• type Conn
  • func (This *Conn) Close() bool
  • func (This *Conn) Commit() (b *pluginDriver.PluginBinlog, e error)
  • func (This *Conn) CommitLogMod_Append(list []*pluginDriver.PluginDataType) (e error)
  • func (This *Conn) CommitLogMod_Update(list []*pluginDriver.PluginDataType) (e error)
  • func (This *Conn) CommitNormal(list []*pluginDriver.PluginDataType) (e error)
  • func (This *Conn) Connect() bool
  • func (This *Conn) Del(data *pluginDriver.PluginDataType) (*pluginDriver.PluginBinlog, error)
  • func (This *Conn) GetConnStatus() string
  • func (This *Conn) GetParam(p interface{}) (*PluginParam, error)
  • func (This *Conn) HeartCheck()
  • func (This *Conn) Insert(data *pluginDriver.PluginDataType) (*pluginDriver.PluginBinlog, error)
  • func (This *Conn) Query(data *pluginDriver.PluginDataType) (*pluginDriver.PluginBinlog, error)
  • func (This *Conn) ReConnect() bool
  • func (This *Conn) SetConnStatus(status string)
  • func (This *Conn) SetParam(p interface{}) (interface{}, error)
  • func (This *Conn) StmtClose()
  • func (This *Conn) Update(data *pluginDriver.PluginDataType) (*pluginDriver.PluginBinlog, error)
• type EventType
• type MyConn
  • func (MyConn *MyConn) CheckUri(uri string) error
  • func (MyConn *MyConn) GetUriExample() string
  • func (MyConn *MyConn) Open(uri string) pluginDriver.ConnFun
• type PluginParam
• type SyncMode
• type TableStruct

Constants

const BIFROST_VERION = "v1.3.2"

const VERSION = "v1.3.2"

Functions

func NewMysqlDBConn

func NewMysqlDBConn(uri string) *mysqlDB

Types

type Conn

type Conn struct {
	// contains filtered or unexported fields
}

func (*Conn) Close

func (This *Conn) Close() bool

func (*Conn) Commit

func (This *Conn) Commit() (b *pluginDriver.PluginBinlog, e error)

func (*Conn) CommitLogMod_Append

func (This *Conn) CommitLogMod_Append(list []*pluginDriver.PluginDataType) (e error)

func (*Conn) CommitLogMod_Update

func (This *Conn) CommitLogMod_Update(list []*pluginDriver.PluginDataType) (e error)

func (*Conn) CommitNormal

func (This *Conn) CommitNormal(list []*pluginDriver.PluginDataType) (e error)

func (*Conn) Connect

func (This *Conn) Connect() bool

func (*Conn) Del

func (This *Conn) Del(data *pluginDriver.PluginDataType) (*pluginDriver.PluginBinlog, error)

func (*Conn) GetConnStatus

func (This *Conn) GetConnStatus() string

func (*Conn) GetParam

func (This *Conn) GetParam(p interface{}) (*PluginParam, error)

func (*Conn) HeartCheck

func (This *Conn) HeartCheck()

func (*Conn) Insert

func (This *Conn) Insert(data *pluginDriver.PluginDataType) (*pluginDriver.PluginBinlog, error)

func (*Conn) Query

func (This *Conn) Query(data *pluginDriver.PluginDataType) (*pluginDriver.PluginBinlog, error)

func (*Conn) ReConnect

func (This *Conn) ReConnect() bool

func (*Conn) SetConnStatus

func (This *Conn) SetConnStatus(status string)

func (*Conn) SetParam

func (This *Conn) SetParam(p interface{}) (interface{}, error)

func (*Conn) StmtClose

func (This *Conn) StmtClose()

func (*Conn) Update

func (This *Conn) Update(data *pluginDriver.PluginDataType) (*pluginDriver.PluginBinlog, error)

type EventType

type EventType int8

const (
	INSERT         EventType = 0
	UPDATE         EventType = 1
	DELETE         EventType = 2
	REPLACE_INSERT EventType = 3
	SQLTYPE        EventType = 4
)

type MyConn

type MyConn struct{}

func (*MyConn) CheckUri

func (MyConn *MyConn) CheckUri(uri string) error

func (*MyConn) GetUriExample

func (MyConn *MyConn) GetUriExample() string

func (*MyConn) Open

func (MyConn *MyConn) Open(uri string) pluginDriver.ConnFun

type PluginParam

type PluginParam struct {
	Field     []fieldStruct
	BatchSize int
	Schema    string
	Table     string
	Datakey   string

	PriKey []fieldStruct

	Data *dataTableStruct

	NullTransferDefault bool //是否将null值强制转成相对应类型的默认值
	SyncMode            SyncMode
	// contains filtered or unexported fields
}

type SyncMode

type SyncMode string

const (
	SYNCMODE_NORMAL     SyncMode = "Normal"
	SYNCMODE_LOG_UPDATE SyncMode = "LogUpdate"
	SYNCMODE_LOG_APPEND SyncMode = "LogAppend"
)

type TableStruct

type TableStruct struct {
	COLUMN_NAME       string
	COLUMN_DEFAULT    *string
	IS_NULLABLE       string
	COLUMN_TYPE       string
	COLUMN_KEY        string
	EXTRA             string
	COLUMN_COMMENT    string
	DATA_TYPE         string
	NUMERIC_PRECISION *uint64
	NUMERIC_SCALE     *uint64
}