Versions in this module Expand all Collapse all v0 v0.0.1 Sep 24, 2018 Changes in this version + const DefaultConfigFilePath + const DiffStatusAdd + const DiffStatusDel + const DiffStatusInit + const DiffStatusMod + const DiffStatusNotModified + func GetAllColumnsOnTable(db DbHolder, tableName string, schema string) ([]string, error) + func GetAllTables(db DbHolder, config *Configuration) ([]string, error) + func GetPksOfTables(db DbHolder, config *Configuration, tableNames []string) (map[string][]string, error) + type AllTableStore struct + AllColumn map[string][]string + AllData map[string]map[string]*RowObject + TotalDataCount uint64 + func (ats *AllTableStore) CollectAllTableData(db DbHolder, config *Configuration, tablePks map[string][]string) error + func (ats *AllTableStore) ExtractChangedData(beforeData *AllTableStore) map[string][]*RowObject + type ColumnScan struct + Value sql.Scanner + func (rs *ColumnScan) GetValueString() string + func (rs *ColumnScan) Scan(value interface{}) error + func (rs *ColumnScan) String() string + type Configuration struct + Db Db + func GetConfiguration() (*Configuration, error) + func LoadConfiguration(configFilePath string) (*Configuration, error) + type DBManager struct + func GetDBInstance(dbConfig *Db) (*DBManager, error) + func (holder *DBManager) Begin() (*sql.Tx, error) + func (holder *DBManager) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error) + func (holder *DBManager) Close() error + func (holder *DBManager) Conn(ctx context.Context) (*sql.Conn, error) + func (holder *DBManager) Driver() driver.Driver + func (holder *DBManager) Exec(query string, args ...interface{}) (sql.Result, error) + func (holder *DBManager) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error) + func (holder *DBManager) Finalize() error + func (holder *DBManager) Ping() error + func (holder *DBManager) PingContext(ctx context.Context) error + func (holder *DBManager) Prepare(query string) (*sql.Stmt, error) + func (holder *DBManager) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error) + func (holder *DBManager) Query(query string, args ...interface{}) (*sql.Rows, error) + func (holder *DBManager) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error) + func (holder *DBManager) QueryRow(query string, args ...interface{}) *sql.Row + func (holder *DBManager) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row + func (holder *DBManager) SetConnMaxLifetime(d time.Duration) + func (holder *DBManager) SetMaxIdleConns(n int) + func (holder *DBManager) SetMaxOpenConns(n int) + func (holder *DBManager) Stats() sql.DBStats + type Db struct + DbType string + Host string + Name string + Password string + Port string + Schema string + User string + type DbHolder interface + Begin func() (*sql.Tx, error) + BeginTx func(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error) + Close func() error + Conn func(ctx context.Context) (*sql.Conn, error) + Driver func() driver.Driver + Exec func(query string, args ...interface{}) (sql.Result, error) + ExecContext func(ctx context.Context, query string, args ...interface{}) (sql.Result, error) + Finalize func() error + Ping func() error + PingContext func(ctx context.Context) error + Prepare func(query string) (*sql.Stmt, error) + PrepareContext func(ctx context.Context, query string) (*sql.Stmt, error) + Query func(query string, args ...interface{}) (*sql.Rows, error) + QueryContext func(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error) + QueryRow func(query string, args ...interface{}) *sql.Row + QueryRowContext func(ctx context.Context, query string, args ...interface{}) *sql.Row + SetConnMaxLifetime func(d time.Duration) + SetMaxIdleConns func(n int) + SetMaxOpenConns func(n int) + Stats func() sql.DBStats + type RowObject struct + ColScans []*ColumnScan + ColumnNames []string + DiffStatus int8 + IsBeforeData bool + ModifiedColumnIndex []uint8 + func (ro *RowObject) EqualColumns(that *RowObject) bool + func (ro *RowObject) GetKey(pkColumns []string) string + func (ro *RowObject) String() string