base

Documentation

Index

• func ApplyColumnTypes(db usql.QueryAble, databaseName, tableName string, ...) error
• func BuildCreateTableColsFromMap(cols []*ast.ColumnDef, columnMap []string) (r []*ast.ColumnDef)
• func GenerateSetSystemVariables(systemVariables [][2]string) string
• func GetCandidateUniqueKeys(logger g.LoggerType, db usql.QueryAble, databaseName, tableName string, ...) (uniqueKeys []*common.UniqueKey, err error)
• func GetIntervals(set *gomysql.MysqlGTIDSet, uuidStr string) gomysql.IntervalSlice
• func GetSelfBinlogCoordinates(db usql.QueryAble) (selfBinlogCoordinates *common.MySQLCoordinates, err error)
• func GetSomeSysVars(db usql.QueryAble, logger g.LoggerType) (r struct{ ... })
• func GetTableColumns(db usql.QueryAble, databaseName, tableName string) (*common.ColumnList, error)
• func GetTableColumnsSqle(sqleContext *sqle.Context, schema string, table string) (r *common.ColumnList, fkParents []*ast.TableName, err error)
• func GtidSetContains(lock *sync.RWMutex, set *gomysql.MysqlGTIDSet, uuidStr string, gno int64) bool
• func GtidSetDiff(set1 string, set2 string) (string, error)
• func MySQL57CollationMapping(name string) string
• func MySQL57CollationReplaceWorkaround(sql string) string
• func ParseBinlogCoordinatesFromRow(row *sql.Row) (r *common.MySQLCoordinates, err error)
• func ParserRestore(stmt ast.Node) (string, error)
• func PrettifyDurationOutput(d time.Duration) string
• func RenameCreateSchemaAddINE(createSchema string, newSchema string) (string, error)
• func RenameCreateTable(createTable string, newSchema string, newTable string, columnMap []string) (string, error)
• func ShowCreateTable(db usql.QueryAble, databaseName, tableName string) (statement string, err error)
• func ShowCreateView(db *gosql.DB, databaseName, tableName string, dropTableIfExists bool) (createTableStatement string, err error)
• func StringContainsAll(s string, substrings ...string) bool
• func StringInterval(intervals gomysql.IntervalSlice) string
• type BinlogEvent
• type GtidItem
• type GtidItemMap
  • func (m *GtidItemMap) GetItem(u uuid.UUID) (item *GtidItem)

Functions

func ApplyColumnTypes

func ApplyColumnTypes(db usql.QueryAble, databaseName, tableName string, columnsLists ...*common.ColumnList) error

func BuildCreateTableColsFromMap

func BuildCreateTableColsFromMap(cols []*ast.ColumnDef, columnMap []string) (r []*ast.ColumnDef)

func GenerateSetSystemVariables

func GenerateSetSystemVariables(systemVariables [][2]string) string

func GetCandidateUniqueKeys

func GetCandidateUniqueKeys(logger g.LoggerType, db usql.QueryAble, databaseName, tableName string,
	columns *common.ColumnList) (uniqueKeys []*common.UniqueKey, err error)

func GetIntervals

func GetIntervals(set *gomysql.MysqlGTIDSet, uuidStr string) gomysql.IntervalSlice

func GetSelfBinlogCoordinates

func GetSelfBinlogCoordinates(db usql.QueryAble) (selfBinlogCoordinates *common.MySQLCoordinates, err error)

func GetSomeSysVars

func GetSomeSysVars(db usql.QueryAble, logger g.LoggerType) (r struct {
	Err                 error
	Version             string
	TimeZome            string
	LowerCaseTableNames umconf.LowerCaseTableNamesValue
	NetWriteTimeout     int
})

func GetTableColumns

func GetTableColumns(db usql.QueryAble, databaseName, tableName string) (*common.ColumnList, error)

func GetTableColumnsSqle

func GetTableColumnsSqle(sqleContext *sqle.Context, schema string,
	table string) (r *common.ColumnList, fkParents []*ast.TableName, err error)

func GtidSetContains

func GtidSetContains(lock *sync.RWMutex, set *gomysql.MysqlGTIDSet, uuidStr string, gno int64) bool

func GtidSetDiff

func GtidSetDiff(set1 string, set2 string) (string, error)

func MySQL57CollationMapping

func MySQL57CollationMapping(name string) string

func MySQL57CollationReplaceWorkaround

func MySQL57CollationReplaceWorkaround(sql string) string

func ParseBinlogCoordinatesFromRow

func ParseBinlogCoordinatesFromRow(row *sql.Row) (r *common.MySQLCoordinates, err error)

func ParserRestore

func ParserRestore(stmt ast.Node) (string, error)

func PrettifyDurationOutput

func PrettifyDurationOutput(d time.Duration) string

func RenameCreateSchemaAddINE

func RenameCreateSchemaAddINE(createSchema string, newSchema string) (string, error)

rename schema and add `if not exists`

func RenameCreateTable

func RenameCreateTable(createTable string, newSchema string, newTable string, columnMap []string) (string, error)

func ShowCreateTable

func ShowCreateTable(db usql.QueryAble, databaseName, tableName string) (statement string, err error)

func ShowCreateView

func ShowCreateView(db *gosql.DB, databaseName, tableName string, dropTableIfExists bool) (createTableStatement string, err error)

func StringContainsAll

func StringContainsAll(s string, substrings ...string) bool

StringContainsAll returns true if `s` contains all non empty given `substrings` The function returns `false` if no non-empty arguments are given.

func StringInterval

func StringInterval(intervals gomysql.IntervalSlice) string

Types

type BinlogEvent

type BinlogEvent struct {
	BinlogFile string
	RealPos    uint32
	Header     *replication.EventHeader
	Evt        replication.Event
	RawBs      []byte
	Query      []string //[]StreamEvent

	Err error
}

type GtidItem

type GtidItem struct {
	NRow int
}

type GtidItemMap

type GtidItemMap map[uuid.UUID]*GtidItem

func (*GtidItemMap) GetItem

func (m *GtidItemMap) GetItem(u uuid.UUID) (item *GtidItem)