Interface DataAbnormalFixInterface

dbExec/data_fixsql.go:28–42

	PartitionColumns        []string          // 分区表的分区列，用于生成正确的主键定义
}
type DataAbnormalFixInterface interface {
	FixInsertSqlExec(db *sql.DB, sourceDrive string, logThreadSeq int64) (string, error)
	FixDeleteSqlExec(db *sql.DB, sourceDrive string, logThreadSeq int64) (string, error)
	// FixUpdateSqlExec generates UPDATE SET <compareColNames> WHERE <pk> for columns-mode two-sided rows.
	// srcRowData is the source-side row data string; ColData on the receiver must match the filtered column list.
	// srcToDstCol maps source column names to destination column names for the SET clause; nil or empty means names are identical.
	FixUpdateSqlExec(db *sql.DB, srcRowData string, compareColNames []string, srcToDstCol map[string]string, logThreadSeq int64) (string, error)
	FixAlterIndexSqlExec(e, f []string, si map[string][]string, sourceDrive string, logThreadSeq int64) []string
	FixAlterColumnSqlDispos(alterType string, columnDataType []string, columnSeq int, lastColumn, curryColumn string, logThreadSeq int64) string
	FixAlterColumnSqlGenerate(modifyColumn []string, logThreadSeq int64) []string
	FixAlterColumnAndIndexSqlGenerate(columnOperations, indexOperations []string, logThreadSeq int64) []string
	FixAlterIndexSqlGenerate(indexOperations []string, logThreadSeq int64) []string
	FixTableCharsetSqlGenerate(charset, collation string, logThreadSeq int64) []string
	FixTableAutoIncrementSqlGenerate(nextValue int64, logThreadSeq int64) []string
}

type unsupportedDataAbnormalFix struct {
	destDevice string