internal

Sep 5, 2023

Changes in this version

type Config

+ MySQLOnlineDDL bool

Nov 1, 2021

Changes in this version

type Config

+ DestCharset string

+ IsSQL bool

+ SourceCharset string

Jan 22, 2021

Changes in this version

+ const AlterTypeAlter

+ const AlterTypeCreate

+ const AlterTypeDrop

+ const AlterTypeNo

+ const IndexTypeForeignKey

+ const IndexTypeIndex

+ const IndexTypePrimary

+ func Exec(mydb *sql.DB, query string) (sql.Result, error)

+ func NewMyTimer() *myTimer

+ type AlterType int

+ func (at AlterType) String() string

+ type Comparer interface

+ AlterData func(sc *SchemaSync, tableName string) *TableAlterData

type Config

+ func (cfg *Config) SetComparer(comparer Comparer)

type DBOperator

+ DBEngine func() string

+ Exec func(query string) (sql.Result, error)

type DbIndex

+ func (idx *DbIndex) AddRelationTable(table string)

+ func (idx *DbIndex) AlterAddSQL(drop bool) string

+ func (idx *DbIndex) AlterDropSQL() string

+ type IndexType string

+ type MyCompare struct

+ func NewMyCompare() *MyCompare

+ func (my *MyCompare) AlterData(sc *SchemaSync, table string) *TableAlterData

type MyDb

+ func (db *MyDb) DBEngine() string

+ func (mydb *MyDb) Exec(query string) (sql.Result, error)

type MySchema

+ func NewSchema(schema string) *MySchema

type SchemaDiff

+ func NewSchemaDiff(table string, source *MySchema, dest *MySchema) *SchemaDiff

type SchemaSync

+ Comparer Comparer

+ func (sc *SchemaSync) SetComparer(comparer Comparer) *SchemaSync

type TableAlterData

+ func NewAlterData(tableName string) *TableAlterData

Sep 7, 2020

Changes in this version

type Config

+ func (cfg *Config) SQLPreprocessor() func(string) string

+ func (cfg *Config) SetSQLPreprocessor(fn func(string) string)

Aug 3, 2020

Changes in this version

+ const AppURL

+ const Version

+ func ParseJSON(content string, val interface{}) error

+ type AlterIgnoreTable struct

+ Column []string

+ ForeignKey []string

+ Index []string

+ type Config struct

+ AlterIgnore map[string]*AlterIgnoreTable

+ ConfigPath string

+ DestDSN string

+ Drop bool

+ Email *EmailStruct

+ SkipTables []string

+ SourceDSN string

+ Sync bool

+ Tables []string

+ func LoadConfig(confPath string) *Config

+ func (cfg *Config) CheckMatchTables(name string) bool

+ func (cfg *Config) IsIgnoreField(table string, name string) bool

+ func (cfg *Config) IsIgnoreForeignKey(table string, name string) bool

+ func (cfg *Config) IsIgnoreIndex(table string, name string) bool

+ func (cfg *Config) IsSkipTables(name string) bool

+ func (cfg *Config) SendMailFail(errStr string)

+ func (cfg *Config) String() string

+ type DBOperator interface

+ Begin func() (*sql.Tx, error)

+ Close func() error

+ GetTableNames func() []string

+ GetTableSchema func(name string) (schema string)

+ Query func(query string, args ...interface{}) (*sql.Rows, error)

+ type DbIndex struct

+ IndexType indexType

+ Name string

+ RelationTables []string

+ SQL string

+ func (idx *DbIndex) String() string

+ type EmailStruct struct

+ From string

+ Password string

+ SMTPHost string

+ SendMailAble bool

+ To string

+ func (m *EmailStruct) SendMail(title string, body string)

+ type MyDb struct

+ func NewMyDb(dsn string, dbType string) *MyDb

+ func (mydb *MyDb) GetTableNames() []string

+ func (mydb *MyDb) GetTableSchema(name string) (schema string)

+ func (mydb *MyDb) Query(query string, args ...interface{}) (*sql.Rows, error)

+ type MySchema struct

+ Fields map[string]string

+ ForeignAll map[string]*DbIndex

+ IndexAll map[string]*DbIndex

+ SchemaRaw string

+ func ParseSchema(schema string) *MySchema

+ func (mys *MySchema) GetFieldNames() []string

+ func (mys *MySchema) RelationTables() []string

+ func (mys *MySchema) String() string

+ type SchemaDiff struct

+ Dest *MySchema

+ Source *MySchema

+ Table string

+ func (sdiff *SchemaDiff) RelationTables() []string

+ type SchemaSync struct

+ Config *Config

+ DestDb DBOperator

+ SourceDb DBOperator

+ func NewSchemaSync(config *Config, dbOperators ...DBOperator) *SchemaSync

+ func (sc *SchemaSync) Close() error

+ func (sc *SchemaSync) GetNewTableNames() []string

+ func (sc *SchemaSync) SyncSQL4Dest(sqlStr string, sqls []string) error

+ type SendEmail interface

+ SendEmail func(string, string)

+ type Statics struct

+ Config *Config

+ func CheckSchemaDiff(cfg *Config, dbOperators ...DBOperator) *Statics

+ func (s *Statics) ChangeTableNum() int

+ func (s *Statics) ChangeTables() []string

+ func (s *Statics) Diff(on bool) *Statics

+ func (s *Statics) Elapsed() time.Duration

+ func (s *Statics) EndTime() time.Time

+ func (s *Statics) FailedNum() int

+ func (s *Statics) StartTime() time.Time

+ func (s *Statics) String() string

+ type TableAlterData struct

+ SQL string

+ SchemaDiff *SchemaDiff

+ Table string

+ Type alterType

+ func (ta *TableAlterData) String() string