utils

Documentation

Index

• Variables
• func EscapeString(s string) string
• func GenIncrementTableColumns(columns []cloudstorage.TableCol) []cloudstorage.TableCol
• func SplitTableFQN(tableFQN string) (string, string)

Variables

var (
	CDCFlagColumnName       = "tidb2dw_flag"
	CDCTablenameColumnName  = "tidb2dw_tablename"
	CDCSchemanameColumnName = "tidb2dw_schemaname"
	CDCCommitTsColumnName   = "tidb2dw_commit_ts"
)

Functions

func EscapeString

func EscapeString(s string) string

func GenIncrementTableColumns

func GenIncrementTableColumns(columns []cloudstorage.TableCol) []cloudstorage.TableCol

func SplitTableFQN

func SplitTableFQN(tableFQN string) (string, string)

SplitTableFQN splits a full-qualified table name into database and table name e.g. "mydb.mytable" -> "mydb", "mytable" Note: this function does not check if the input is a valid table name