sync

Documentation

Index

• func Sync(c *Config, mc *EmailConfig, dbOperators ...internal.DBOperator) (sta *internal.Statics, err error)
• type Config
• 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) 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
}

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) 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