Versions in this module Expand all Collapse all v1 v1.0.1 Apr 26, 2020 v1.0.0 Mar 30, 2020 Changes in this version + func ParseTable(table string) (schemaName, tableName string) + type Batcher interface + AddRow func(colValues []interface{}) error + Complete func() (int, error) + GetBatchNum func() int + type InsertBatcher struct + func NewInsertBatch(table string, columnNames []string, batchNum int, db *sql.DB, ...) *InsertBatcher + func (b *InsertBatcher) AddRow(colValues []interface{}) error + func (b *InsertBatcher) Complete() (int, error) + func (b InsertBatcher) GetBatchNum() int + type MySQLSchema struct + DS string + func CreateMySQLSchema(dataSourceName string) (*MySQLSchema, error) + func (m *MySQLSchema) SetVerbose(verbose int) + func (m MySQLSchema) CompatibleDs() string + func (m MySQLSchema) Pump(table string, rowsPumped chan<- model.RowsPumped, config model.PumpConfig, ...) error + func (m MySQLSchema) TableColumns(table string) ([]model.TableColumn, error) + func (m MySQLSchema) Tables() ([]model.Table, error) + type MySQLTable struct + Comment string + Name string + func (m MySQLTable) GetComment() string + func (m MySQLTable) GetName() string + type MyTableColumn struct + CharacterSet string + Comment string + DataType string + Default string + Extra string + MaxLength int + Name string + Nullable string + NumericPrecision int + NumericScale int + Type string + func (c MyTableColumn) GetCharacterSet() string + func (c MyTableColumn) GetComment() string + func (c MyTableColumn) GetDataType() string + func (c MyTableColumn) GetMaxSize() int + func (c MyTableColumn) GetName() string + func (c MyTableColumn) GetRandomizer() model.Randomizer + func (c MyTableColumn) IsAutoIncrement() bool + func (c MyTableColumn) IsNullable() bool