canal

Documentation

Index

• func FormatColName(col *pbe.Column) string
• func FormatColValue(col *pbe.Column) string
• func FormatSql(cols []*pbe.Column, isUpdate bool) (keyColName string, keyColValue string, colNames string, colValues string, ...)
• type Channel
  • func RunCanalClient(address string, port int, username string, password string, destination string, ...) *Channel
• type Sql
  • func GetSql(entrys []pbe.Entry) []Sql

Functions

func FormatColName

func FormatColName(col *pbe.Column) string

FormatColName 格式化列名 使用反引号包围

func FormatColValue

func FormatColValue(col *pbe.Column) string

FormatColValue 格式化列数据 除去int bit类型的都要使用单引号包围

func FormatSql

func FormatSql(cols []*pbe.Column, isUpdate bool) (keyColName string, keyColValue string, colNames string, colValues string, updateChanges string)

Types

type Channel

type Channel struct {
	ChannelSql chan []Sql
	Stop       bool
}

func RunCanalClient

func RunCanalClient(address string, port int, username string, password string, destination string, soTimeOut int32, idleTimeOut int32, regex string) *Channel

type Sql

type Sql struct {
	Content string
	Type    string
	Insert  string
}

func GetSql

func GetSql(entrys []pbe.Entry) []Sql