sync

Documentation

Index

• func Sync(c *Config, mc *EmailConfig, dbOperators ...internal.DBOperator) (sta *internal.Statics, err error)
• type Config
  • func (c *Config) ToConfig(mc *EmailConfig) (*internal.Config, error)
• type EmailConfig
• type MySchemaData
  • func NewMySchemaData(schema string, dbType string) *MySchemaData
  • func (m *MySchemaData) Begin() (*sql.Tx, error)
  • func (m *MySchemaData) Close() error
  • func (m *MySchemaData) DBEngine() string
  • func (m *MySchemaData) Exec(query string) (sql.Result, error)
  • func (m *MySchemaData) GetTableNames() []string
  • func (m *MySchemaData) GetTableSchema(name string) (schema string)
  • func (m *MySchemaData) Query(query string, args ...interface{}) (*sql.Rows, error)

Functions

func Sync

func Sync(c *Config, mc *EmailConfig, dbOperators ...internal.DBOperator) (sta *internal.Statics, err error)

Types

type Config

type Config struct {
	Sync            bool
	Drop            bool
	SourceDSN       string
	DestDSN         string
	AlterIgnore     string
	Tables          string
	SkipTables      string
	MailTo          string
	SQLPreprocessor func(string) string `json:"-" xml:"-"`
	Comparer        internal.Comparer   `json:"-" xml:"-"`
}

func (*Config) ToConfig

func (c *Config) ToConfig(mc *EmailConfig) (*internal.Config, error)

type EmailConfig

type EmailConfig struct {
	On       bool
	SMTPHost string
	From     string
	Password string
	To       string
}

type MySchemaData

type MySchemaData struct {
	Data string
	// contains filtered or unexported fields
}

MySchemaData db schema data

func NewMySchemaData

func NewMySchemaData(schema string, dbType string) *MySchemaData

NewMySchemaData object

func (*MySchemaData) Begin

func (m *MySchemaData) Begin() (*sql.Tx, error)

func (*MySchemaData) Close

func (m *MySchemaData) Close() error

func (*MySchemaData) DBEngine

func (m *MySchemaData) DBEngine() string

func (*MySchemaData) Exec

func (m *MySchemaData) Exec(query string) (sql.Result, error)

Exec execute sql query

func (*MySchemaData) GetTableNames

func (m *MySchemaData) GetTableNames() []string

GetTableNames table names

func (*MySchemaData) GetTableSchema

func (m *MySchemaData) GetTableSchema(name string) (schema string)

GetTableSchema table schema

func (*MySchemaData) Query

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

Query execute sql query