src

Documentation

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) 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) 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 TableStruct

Constants

const BIFROST_VERION = "v1.1.0"

const VERSION = "v1.1.0-apha.01"

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) 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) 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
	SQLTYPE EventType = 3
)

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
	// contains filtered or unexported fields
}

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 *string
	NUMERIC_SCALE     *string
}