model

type DBSchema interface {
	Tables() ([]Table, error)
	TableColumns(table string) ([]TableColumn, error)
	// CompatibleDs returns the dataSourceName from various the compatible format.
	CompatibleDs() string
	Pump(table string, rowsPumped chan<- RowsPumped, config PumpConfig, ready chan bool,
		onerr string, retryMaxTimes int) error
}

type PumpColumnConfig struct {
}

type PumpConfig struct {
	ColumnsConfig map[string]PumpColumnConfig
	PumpMinRows   int
	PumpMaxRows   int
	BatchNum      int
}

type Randomizer interface {
	Value() interface{}
}

type RowsPumped struct {
	Table     string
	TotalRows int
	Rows      int
	Cost      time.Duration
	// contains filtered or unexported fields
}

type Table interface {
	GetName() string
	GetComment() string
}

type TableColumn interface {
	// GetName get the column's name.
	GetName() string
	// GetComment get the column's comment.
	GetComment() string
	// GetDataType get the columns's data type
	GetDataType() string
	// GetMaxSize get the max size of the column
	GetMaxSize() int
	// IsNullable tells if the column is nullable or not
	IsNullable() bool
	// GetRandomizer returns the randomizer of the column
	GetRandomizer() Randomizer
	// GetCharacterSet returns the CharacterSet of the column
	GetCharacterSet() string
}