tidbsql

Documentation

Index

• Constants
• func CompareColumn(lhs, rhs *cloudstorage.TableCol) (columnAction, error)
• func GetCurrentTSO(config *TiDBConfig) (uint64, error)
• func GetTiDBTableColumn(db *sql.DB, sourceDatabase, sourceTable string) ([]cloudstorage.TableCol, error)
• func GetTiDBTablePKColumns(db *sql.DB, sourceDatabase, sourceTable string) ([]string, error)
• type ColumnDiff
  • func GetColumnDiff(prev []cloudstorage.TableCol, curr []cloudstorage.TableCol) ([]ColumnDiff, error)
• type TiDBConfig
  • func (config *TiDBConfig) OpenDB() (*sql.DB, error)

Constants

const (
	UNCHANGE   columnAction = iota // 0
	ADD_COLUMN                     // 1
	DROP_COLUMN
	MODIFY_COLUMN
	RENAME_COLUMN
)

Functions

func CompareColumn

func CompareColumn(lhs, rhs *cloudstorage.TableCol) (columnAction, error)

func GetCurrentTSO

func GetCurrentTSO(config *TiDBConfig) (uint64, error)

func GetTiDBTableColumn

func GetTiDBTableColumn(db *sql.DB, sourceDatabase, sourceTable string) ([]cloudstorage.TableCol, error)

func GetTiDBTablePKColumns

func GetTiDBTablePKColumns(db *sql.DB, sourceDatabase, sourceTable string) ([]string, error)

Types

type ColumnDiff

type ColumnDiff struct {
	Action columnAction
	Before *cloudstorage.TableCol
	After  *cloudstorage.TableCol
}

func GetColumnDiff

func GetColumnDiff(prev []cloudstorage.TableCol, curr []cloudstorage.TableCol) ([]ColumnDiff, error)

type TiDBConfig

type TiDBConfig struct {
	Host  string
	Port  int
	User  string
	Pass  string
	SSLCA string
}

func (*TiDBConfig) OpenDB

func (config *TiDBConfig) OpenDB() (*sql.DB, error)

func Open opens a connection to TiDB