history

Documentation

Index

• Constants
• func AddHistory(dbName string, SchemaName string, TableName string, Property HistoryProperty, ...) (int, error)
• func DBConnect(uri string) mysql.MysqlConnection
• func DelHistory(dbName string, ID int) bool
• func KillHistory(dbName string, ID int) error
• func Start(dbName string, ID int) error
• type HisotryStatus
• type History
  • func GetHistoryList(dbName, SchemaName, TableName string) []History
  • func (This *History) Start() error
  • func (This *History) Stop() error
• type HistoryProperty
• type TableStruct
  • func GetSchemaTableFieldList(db mysql.MysqlConnection, schema string, table string) []TableStruct
• type ThreadStatus

Constants

const (
	CLOSE   HisotryStatus = "close"
	RUNNING               = "running"
	OVER                  = "over"
	HALFWAY               = "halfway"
	KILLED                = "killed"
)

Functions

func AddHistory

func AddHistory(dbName string, SchemaName string, TableName string, Property HistoryProperty, ToServerIDList []int) (int, error)

func DBConnect

func DBConnect(uri string) mysql.MysqlConnection

func DelHistory

func DelHistory(dbName string, ID int) bool

func KillHistory

func KillHistory(dbName string, ID int) error

func Start

func Start(dbName string, ID int) error

Types

type HisotryStatus

type HisotryStatus string

type History

type History struct {
	sync.RWMutex
	ID         int
	DbName     string
	SchemaName string
	TableName  string
	Property   HistoryProperty
	Status     HisotryStatus
	NowStartI  int //当前第几条数据
	ThreadPool []*ThreadStatus

	Fields         []TableStruct `json:"-"`
	Uri            string        `json:"-"`
	ToServerIDList []int
	StartTime      string
	OverTime       string
	// contains filtered or unexported fields
}

func GetHistoryList

func GetHistoryList(dbName, SchemaName, TableName string) []History

func (*History) Start

func (This *History) Start() error

func (*History) Stop

func (This *History) Stop() error

type HistoryProperty

type HistoryProperty struct {
	ThreadNum      int // 协程数量,每个协程一个连接
	ThreadCountPer int // 协程每次最多处理多少条数据
}

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
	ToDataType        dataType.Type
}

func GetSchemaTableFieldList

func GetSchemaTableFieldList(db mysql.MysqlConnection, schema string, table string) []TableStruct

type ThreadStatus

type ThreadStatus struct {
	Num       int
	Error     error
	NowStartI int // 当前执行第几条
}