sql_execution_engine

Jan 9, 2019

Changes in this version

+ const MySQLInsertIgnore

+ func GenerateInsertIgnoreSQL(msgBatch []*core.Msg, tableDef *schema_store.Table) (string, []interface{}, error)

Jan 8, 2019

Changes in this version

+ const ConflictDetectEngine

+ var DefaultMySQLReplaceEngineConfig = map[string]interface

+ func SQLWithAnnotation(sql string, annotationContent string) string

+ type EngineExecutor interface

+ Execute func(msgBatch []*core.Msg, tableDef *schema_store.Table) error

+ func NewEngineExecutor(pipelineName string, engineName string, db *sql.DB, ...) EngineExecutor

+ type EngineInitializer interface

+ Init func(db *sql.DB) error

Jan 7, 2019

Changes in this version

type MySQLExecutionEngineConfig

+ EngineType string

Dec 27, 2018

Changes in this version

+ const BiDirectionEngine

+ const BiDirectionShadingEngine

+ const ConflictEngine

+ const ConflictFileName

+ const ManualEngine

+ const MySQLReplaceEngine

+ const QueryExist

+ const QueryNotExist

+ const QueryUnknown

+ var ErrDeleteRowSkip = errors.New("sql_execution_engine: skip this delete event")

+ var ErrRowConflict = errors.New("sql_execution_engine: this row conflicts")

+ func DebugDmlMsg(msgBatch []*core.Msg) (interface{}, interface{})

+ func GenerateReplaceSQLWithMultipleValues(msgBatch []*core.Msg, tableDef *schema_store.Table) (string, []interface{}, error)

+ func GenerateSingleDeleteSQL(msg *core.Msg, tableDef *schema_store.Table) (string, []interface{}, error)

+ func GenerateSingleReplaceSQL(msg *core.Msg, tableDef *schema_store.Table) (string, []interface{}, error)

+ func GetBatchSize(defaultBatchSize int, DetectConflict bool, UseShadingProxy bool) (int, error)

+ func GetSingleSqlPlaceHolderAndArgWithEncodedData(msg *core.Msg, tableDef *schema_store.Table) (string, []interface{}, error)

+ func NewBidirectionEngine(db *sql.DB, mode utils.BidirectionMode) *bidirectionEngine

+ func PlaceHoldersAndArgsFromEncodedData(msgBatch []*core.Msg, tableDef *schema_store.Table) ([]string, []interface{}, error)

+ func SelectEngine(DetectConflict bool, UserBidirection bool, UseShadingProxy bool) (string, error)

+ func ValidateSchema(msg *core.Msg, tableDef *schema_store.Table) error

+ type MySQLExecutionEngineConfig struct

+ DetectConflict bool

+ EnableDDL bool

+ MaxConflictRetry int

+ OverrideConflict bool

+ SQLArgExpr []string

+ SQLExecutionEngine string

+ SQLTemplate string

+ UseBidirection bool

+ UseShadingProxy bool

+ type SQlExecutionEngine interface

+ Execute func(msgBatch []*core.Msg, tableDef *schema_store.Table) error

+ func NewConflictEngine(db *sql.DB, override bool, maxRetry int, retrySleepDuration time.Duration, ...) SQlExecutionEngine

+ func NewConflictPreviewEngine(db *sql.DB, maxRetryCount int, sleepDuration time.Duration, enableDelete bool) SQlExecutionEngine

+ func NewManualSQLEngine(db *sql.DB, config MySQLExecutionEngineConfig) SQlExecutionEngine

+ func NewMySQLReplaceEngine(db *sql.DB) SQlExecutionEngine

+ func NewSQLExecutionEngine(db *sql.DB, engineConfig MySQLExecutionEngineConfig) SQlExecutionEngine