sync

Documentation

Index

• Variables
• func GetSQLFileContent(filePattern string) (string, error)
• func ReplaceCharset(sqlStr string, srcCharset string, destCharset string, checkCreateDDL ...bool) string
• func Sync(c *Config, mc *EmailConfig, dbOperators ...internal.DBOperator) (sta *internal.Statics, err error)
• type Comparer
• type Config
  • func (c *Config) ToConfig(mc *EmailConfig) (*internal.Config, error)
• type DBOperator
• 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, error)
  • func (m *MySchemaData) GetTableSchema(name string) (schema string, err error)
  • func (m *MySchemaData) Query(query string, args ...interface{}) (*sql.Rows, error)
• type SendEmail

Variables

var HTMLDocTemplate = `` /* 373-byte string literal not displayed */

Functions

func GetSQLFileContent

func GetSQLFileContent(filePattern string) (string, error)

func ReplaceCharset

func ReplaceCharset(sqlStr string, srcCharset string, destCharset string, checkCreateDDL ...bool) string

ReplaceCharset 替换DDL语句中的字符集

func Sync

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

Types

type Comparer

type Comparer = internal.Comparer

type Config

type Config struct {
	Sync            bool
	Drop            bool
	SourceDSN       string
	DestDSN         string
	AlterIgnore     string
	Tables          string
	SkipTables      string
	MailTo          string
	MySQLOnlineDDL  bool                // 是否支持 MySQL 的 Online DDL 特性
	SQLPreprocessor func(string) string `json:"-" xml:"-"`
	Comparer        internal.Comparer   `json:"-" xml:"-"`
}

func (*Config) ToConfig

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

type DBOperator

type DBOperator = internal.DBOperator

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

GetTableNames table names

func (*MySchemaData) GetTableSchema

func (m *MySchemaData) GetTableSchema(name string) (schema string, err error)

GetTableSchema table schema

func (*MySchemaData) Query

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

Query execute sql query

type SendEmail

type SendEmail = internal.SendEmail