processor

Dec 16, 2024

Changes in this version

type WaitingRecs

+ func (w *WaitingRecs) String() string

Nov 12, 2024

Changes in this version

+ type PostgresProcessor struct

+ BuildinDatatypeRules []*buildin.BuildinDatatypeRule

+ BuildinDefaultValueRules []*buildin.BuildinDefaultvalRule

+ ColumnRouteRules map[string]string

+ Ctx context.Context

+ DBCharset string

+ Database database.IDatabase

+ IsBaseline bool

+ SchemaName string

+ TableCharset string

+ TableCollation string

+ TableName string

+ TaskFlow string

+ TaskName string

+ func (p *PostgresProcessor) GenDatabaseSchemaTable() (string, string)

+ func (p *PostgresProcessor) GenDatabaseTableCharset() (string, error)

+ func (p *PostgresProcessor) GenDatabaseTableCheckConstraintDetail() (map[string]structure.ConstraintCheck, error)

+ func (p *PostgresProcessor) GenDatabaseTableCollation() (string, error)

+ func (p *PostgresProcessor) GenDatabaseTableColumnDetail() (map[string]structure.NewColumn, map[string]map[string]structure.OldColumn, ...)

+ func (p *PostgresProcessor) GenDatabaseTableComment() (string, error)

+ func (p *PostgresProcessor) GenDatabaseTableForeignConstraintDetail() (map[string]structure.ConstraintForeign, error)

+ func (p *PostgresProcessor) GenDatabaseTableIndexDetail() (map[string]structure.Index, error)

+ func (p *PostgresProcessor) GenDatabaseTablePartitionDetail() ([]structure.Partition, error)

+ func (p *PostgresProcessor) GenDatabaseTablePrimaryConstraintDetail() (map[string]structure.ConstraintPrimary, error)

+ func (p *PostgresProcessor) GenDatabaseTableUniqueConstraintDetail() (map[string]structure.ConstraintUnique, error)

Oct 25, 2024

Changes in this version

+ func GenPostgresCompatibleDatabaseDeleteStmtSQL(schemaName, tableName, sqlHint string, columnDetailSlice []string, ...) string

+ func GenPostgresCompatibleDatabaseInsertStmtSQL(schemaName, tableName, sqlHint string, columnDetailSlice []string, ...) string

+ func InspectPostgresMigrateTask(taskName, taskFlow, taskMode string, databaseS database.IDatabase, ...) (string, error)

+ func OptimizerMYSQLCompatibleMigratePostgresDataCompareColumnST(columnNameS, datatypeS string, datatypeIsBooleanT bool, ...) (string, string, error)

+ func OptimizerPostgresCompatibleMigrateMySQLCompatibleDataCompareColumnST(columnNameS, datatypeS string, datetimePrecisionS int64, ...) (string, string, error)

+ func OptimizerPostgresDataMigrateColumnS(columnName, datatype, datetimePrecision string) (string, error)

type DataCompareTask

+ GlobalSnapshotS string

+ GlobalSnapshotT string

type DataMigrateRule

+ func (r *DataMigrateRule) String() string

type DataMigrateTask

+ SchemaNameT string

type SqlMigrateRow

+ EnablePrepareStmt bool

type StmtMigrateRow

+ EnablePrepareStmt bool

type StructMigrateRule

+ TableCharsetAttr string

+ TableCollationAttr string

+ func (r *StructMigrateRule) GetTableCharsetRule() (string, error)

+ func (r *StructMigrateRule) GetTableCollationRule() (string, error)

+ func (r *StructMigrateRule) GetTableColumnCharsetRule() (map[string]string, error)

Sep 23, 2024

Changes in this version

+ type CsvMigrateTask struct

+ CsvParams *pb.CsvMigrateParam

+ Ctx context.Context

+ DBCharsetS string

+ DBCharsetT string

+ DBRoleS string

+ DBVersionS string

+ DatabaseS database.IDatabase

+ DatabaseT database.IDatabase

+ GlobalSnapshotS string

+ ResumeC chan *WaitingRecs

+ SchemaNameS string

+ SchemaNameT string

+ Task *task.Task

+ WaiterC chan *WaitingRecs

+ func (cmt *CsvMigrateTask) Init() error

+ func (cmt *CsvMigrateTask) Last() error

+ func (cmt *CsvMigrateTask) PrepareStatisticsRange(globalScn string, attsRule *database.DataMigrateAttributesRule, ...) (*task.DataMigrateTask, error)

+ func (cmt *CsvMigrateTask) Process(s *WaitingRecs) error

+ func (cmt *CsvMigrateTask) ProcessChunkScan(ctx context.Context, globalScn string, tableRows uint64, tableSize float64, ...) error

+ func (cmt *CsvMigrateTask) ProcessStatisticsScan(ctx context.Context, dbTypeS, globalScn string, tableRows uint64, ...) error

+ func (cmt *CsvMigrateTask) ProcessTableScan(ctx context.Context, globalScn string, tableRows uint64, tableSize float64, ...) error

+ func (cmt *CsvMigrateTask) Resume() error

+ func (cmt *CsvMigrateTask) Run() error

type DataCompareFile

+ SchemaNameS string

+ TableNameS string

+ type ImportTiDBDatabase struct

+ CharsetSet string

+ FieldsDefinedNullBy string

+ FieldsEnclosedBy string

+ FieldsEscapedBy string

+ FieldsTerminatedBy string

+ LinesTerminatedBy string

+ SkipRows int

+ func (i *ImportTiDBDatabase) Import(ctx context.Context, db database.IDatabase, ...) error

+ type ImportTiDBParams struct

+ ChecksumTable string

+ CloudStorageUri string

+ Detached string

+ DisableTikvImportMode string

+ DiskQuota string

+ MaxWriteSpeed string

+ SplitFile string

+ Thread string

+ func (p *ImportTiDBParams) Builder() (string, error)

Sep 6, 2024

Changes in this version

type DataCompareRow

+ Separator string

type StructMigrateTask

+ SequenceReadyInit chan bool

+ StructReadyInit chan bool

Aug 26, 2024

Changes in this version

type Table

+ func (t *Table) CompareTableIndexCounts() string

Aug 24, 2024

Changes in this version

type DataCompareTask

+ func (dmt *DataCompareTask) Last() error

type DataMigrateTask

+ GlobalSnapshotS string

+ func (cmt *DataMigrateTask) Last() error

type DataScanTask

+ func (dst *DataScanTask) Last() error

type SqlMigrateTask

+ func (smt *SqlMigrateTask) Last() error

type StructCompareTask

+ func (dmt *StructCompareTask) Last() error

type StructMigrateTask

+ func (st *StructMigrateTask) Last() error

Aug 23, 2024

Changes in this version

type SequenceMigrateDatabase

+ SeqMigrateTask []*task.SequenceMigrateTask

+ TaskMode string

Aug 22, 2024

Changes in this version

+ func GetDownstreamTableColumnDatatype(schemaNameT, tableNameT string, databaseT database.IDatabase, ...) ([]string, error)

+ func ProcessDownstreamStatisticsBucket(dbTypeT, dbCharsetT string, bs []*structure.Range, r *structure.Rule) ([]*structure.Range, error)

+ type DataCompareTask struct

+ Ctx context.Context

+ DBCharsetS string

+ DBCharsetT string

+ DatabaseS database.IDatabase

+ DatabaseT database.IDatabase

+ ResumeC chan *WaitingRecs

+ SchemaNameS string

+ Task *task.Task

+ TaskParams *pb.DataCompareParam

+ WaiterC chan *WaitingRecs

+ func (dmt *DataCompareTask) Init() error

+ func (dmt *DataCompareTask) PrepareStatisticsRange(globalScnS, globalScnT string, attsRule *database.DataCompareAttributesRule, ...) ([]*task.DataCompareTask, error)

+ func (dmt *DataCompareTask) Process(s *WaitingRecs) error

+ func (dmt *DataCompareTask) ProcessStatisticsScan(ctx context.Context, dbTypeS, dbTypeT, globalScnS, globalScnT string, ...) error

+ func (dmt *DataCompareTask) ProcessTableScan(ctx context.Context, schemaNameS, tableNameS, globalScnS, globalScnT string, ...) error

+ func (dmt *DataCompareTask) Resume() error

+ func (dmt *DataCompareTask) Run() error

+ type DataMigrateTask struct

+ BatchSize uint64

+ CallTimeout uint64

+ ChunkSize uint64

+ CsvParams *pb.CsvMigrateParam

+ Ctx context.Context

+ DBCharsetS string

+ DBCharsetT string

+ DBRoleS string

+ DBVersionS string

+ DatabaseS database.IDatabase

+ DatabaseT database.IDatabase

+ EnableCheckpoint bool

+ EnableConsistentRead bool

+ GlobalSqlHintS string

+ GlobalSqlHintT string

+ ResumeC chan *WaitingRecs

+ SchemaNameS string

+ SqlThreadS uint64

+ StmtParams *pb.StatementMigrateParam

+ TableThread uint64

+ Task *task.Task

+ WaiterC chan *WaitingRecs

+ WriteThread uint64

+ func (cmt *DataMigrateTask) Init() error

+ func (cmt *DataMigrateTask) PrepareStatisticsRange(globalScn string, attsRule *database.DataMigrateAttributesRule, ...) (*task.DataMigrateTask, error)

+ func (cmt *DataMigrateTask) Process(s *WaitingRecs) error

+ func (cmt *DataMigrateTask) ProcessChunkScan(ctx context.Context, globalScn string, tableRows uint64, tableSize float64, ...) error

+ func (cmt *DataMigrateTask) ProcessStatisticsScan(ctx context.Context, dbTypeS, globalScn string, tableRows uint64, ...) error

+ func (cmt *DataMigrateTask) ProcessTableScan(ctx context.Context, schemaNameS, tableNameS, globalScn string, ...) error

+ func (cmt *DataMigrateTask) Resume() error

+ func (cmt *DataMigrateTask) Run() error

+ type DataScanTask struct

+ Ctx context.Context

+ DBCharsetS string

+ DBRoleS string

+ DBVersionS string

+ DatabaseS database.IDatabase

+ ResumeC chan *WaitingRecs

+ SchemaNameS string

+ Task *task.Task

+ TaskParams *pb.DataScanParam

+ WaiterC chan *WaitingRecs

+ func (dst *DataScanTask) Init() error

+ func (dst *DataScanTask) PrepareStatisticsRange(globalScn string, attsRule *database.DataScanAttributesRule, ...) ([]*task.DataScanTask, error)

+ func (dst *DataScanTask) Process(s *WaitingRecs) error

+ func (dst *DataScanTask) ProcessChunkScan(ctx context.Context, schemaNameS, tableNameS, globalScn string, ...) error

+ func (dst *DataScanTask) ProcessStatisticsScan(ctx context.Context, dbTypeS, schemaNameS, tableNameS, globalScn string, ...) error

+ func (dst *DataScanTask) ProcessTableScan(ctx context.Context, schemaNameS, tableNameS, globalScn string, ...) error

+ func (dst *DataScanTask) Resume() error

+ func (dst *DataScanTask) Run() error

type Datasource

+ DBTypeS string

+ DBVersionS string

+ type Divide struct

+ ChunkSize int64

+ Cons *structure.Selectivity

+ DBCharsetS string

+ DBTypeS string

+ DatabaseS database.IDatabase

+ RangeC chan []*structure.Range

+ SchemaNameS string

+ TableNameS string

+ func (d *Divide) ProcessUpstreamStatisticsBucket() error

+ type SqlMigrateTask struct

+ Ctx context.Context

+ DBCharsetS string

+ DBCharsetT string

+ DBRoleS string

+ DBVersionS string

+ DatabaseS database.IDatabase

+ DatabaseT database.IDatabase

+ Task *task.Task

+ TaskParams *pb.SqlMigrateParam

+ func (smt *SqlMigrateTask) Init() error

+ func (smt *SqlMigrateTask) Process() error

+ func (smt *SqlMigrateTask) Resume() error

+ func (smt *SqlMigrateTask) Run() error

+ type StructCompareTask struct

+ BuildInDatatypeRulesS []*buildin.BuildinDatatypeRule

+ BuildInDatatypeRulesT []*buildin.BuildinDatatypeRule

+ BuildInDefaultValueRulesS []*buildin.BuildinDefaultvalRule

+ BuildInDefaultValueRulesT []*buildin.BuildinDefaultvalRule

+ Ctx context.Context

+ DBCharsetS string

+ DBCharsetT string

+ DBTypeS string

+ DBTypeT string

+ DatabaseS database.IDatabase

+ DatabaseT database.IDatabase

+ ReadyInit chan bool

+ SchemaNameS string

+ SchemaNameT string

+ StartTime time.Time

+ Task *task.Task

+ TaskParams *pb.StructCompareParam

+ func (dmt *StructCompareTask) Init() error

+ func (dmt *StructCompareTask) Process() error

+ func (dmt *StructCompareTask) Resume() error

+ func (dmt *StructCompareTask) Run() error

type StructMigrateRule

+ DBVersionS string

+ type StructMigrateTable struct

+ DBCharsetT string

+ DatasourceS *Datasource

+ TableAttributes *database.StructMigrateAttributes

+ TableAttributesRule *database.StructMigrateAttributesRule

+ TaskFlow string

+ TaskName string

+ func (t *StructMigrateTable) GenSchemaNameS() string

+ func (t *StructMigrateTable) GenSchemaNameT() (string, error)

+ func (t *StructMigrateTable) GenTableCheckKey() ([]string, error)

+ func (t *StructMigrateTable) GenTableColumnComment() ([]string, error)

+ func (t *StructMigrateTable) GenTableColumns() ([]string, error)

+ func (t *StructMigrateTable) GenTableComment() (string, error)

+ func (t *StructMigrateTable) GenTableCreatePrefixT() string

+ func (t *StructMigrateTable) GenTableForeignKey() ([]string, error)

+ func (t *StructMigrateTable) GenTableNameS() string

+ func (t *StructMigrateTable) GenTableNameT() (string, error)

+ func (t *StructMigrateTable) GenTableNormalIndex() ([]string, []string, error)

+ func (t *StructMigrateTable) GenTableOriginDDlS() string

+ func (t *StructMigrateTable) GenTablePrimaryKey() (string, error)

+ func (t *StructMigrateTable) GenTableSuffix() (string, error)

+ func (t *StructMigrateTable) GenTableTypeS() string

+ func (t *StructMigrateTable) GenTableUniqueIndex() ([]string, []string, error)

+ func (t *StructMigrateTable) GenTableUniqueKey() ([]string, error)

+ func (t *StructMigrateTable) String() string

+ type StructMigrateTask struct

+ BuildInDatatypeRules []*buildin.BuildinDatatypeRule

+ BuildInDefaultValueRules []*buildin.BuildinDefaultvalRule

+ Ctx context.Context

+ DBCharsetS string

+ DBCharsetT string

+ DBTypeS string

+ DBVersionS string

+ DatabaseS database.IDatabase

+ DatabaseT database.IDatabase

+ ReadyInit chan bool

+ SchemaNameS string

+ SchemaNameT string

+ StartTime time.Time

+ Task *task.Task

+ TaskParams *pb.StructMigrateParam

+ func (st *StructMigrateTask) Init() error

+ func (st *StructMigrateTask) Process() error

+ func (st *StructMigrateTask) Resume() error

+ func (st *StructMigrateTask) Run() error

+ type WaitingRecs struct

+ SchemaNameS string

+ SchemaNameT string

+ TableNameS string

+ TableNameT string

+ TaskName string

Aug 8, 2024

Changes in this version

type DataCompareRow

+ func (r *DataCompareRow) CompareMd5ORCrc32() error

type DataCompareRule

+ DisableDatabaseCompareMd5 bool

+ GlobalSqlHintT string

+ OnlyDatabaseCompareRow bool

+ OnlyProgramCompareCRC32 bool

Jul 24, 2024

Changes in this version

+ func Cmp(src map[string]int64, dest map[string]int64) (map[string]int64, map[string]int64)

+ func DivideDatabaseTableColumnStatisticsBucket(divideDbType, divideDbCharset string, database database.IDatabase, ...) ([]*structure.Range, error)

+ func ExtractDatabaseTableStatisticsValuesFromBuckets(divideDbType, valueString string, columnNames []string, ...) ([]string, error)

+ func GenMYSQLCompatibleDatabaseDeleteStmtSQL(schemaName, tableName, sqlHint string, columnDetailSlice []string, ...) string

+ func GenMYSQLCompatibleDatabaseInsertStmtSQL(schemaName, tableName, sqlHint string, columnDetailSlice []string, ...) string

+ func GenMYSQLCompatibleDatabasePrepareStmt(schemaName, tableName string, sqlHint, columnDetailSlice string, ...) string

+ func GenOracleCompatibleDatabaseDeleteStmtSQL(schemaName, tableName, sqlHint string, columnDetailSlice []string, ...) string

+ func GenOracleCompatibleDatabaseInsertStmtSQL(schemaName, tableName, sqlHint string, columnDetailSlice []string, ...) string

+ func GetDownstreamDatabaseTableColumnDatatype(schemaNameT, tableNameT string, databaseT database.IDatabase, ...) ([]string, error)

+ func InspectOracleMigrateTask(taskName, taskFlow, taskMode string, databaseS database.IDatabase, ...) (string, string, error)

+ func OptimizerMYSQLCompatibleDataMigrateColumnS(columnName, datatype, datetimePrecision string) (string, error)

+ func OptimizerMYSQLCompatibleMigrateOracleDataCompareColumnST(columnNameS, datatypeS string, datetimePrecisionS, dataLengthS int64, ...) (string, string, error)

+ func OptimizerOracleDataMigrateColumnS(columnName, datatype, dataScale string) (string, error)

+ func OptimizerOracleMigrateMYSQLCompatibleDataCompareColumnST(columnNameS, datatypeS string, dataLengthS int64, ...) (string, string, error)

+ func ProcessDownstreamDatabaseTableColumnStatisticsBucket(dbTypeT string, bs []*structure.Range, r *structure.Rule) ([]*structure.Range, error)

+ func ProcessUpstreamDatabaseTableColumnStatisticsBucket(divideDbType, divideDbCharset string, caseFieldRule string, ...) (*structure.HighestBucket, []*structure.Range, error)

+ func ReverseUpstreamHighestBucketDownstreamRule(taskFlow, dbTypeT, dbCharsetS string, columnDatatypeT []string, ...) (*structure.Rule, error)

+ type CsvMigrateRow struct

+ BufioSize int

+ Ctx context.Context

+ DBCharsetS string

+ DBCharsetT string

+ DatabaseS database.IDatabase

+ Dmt *task.DataMigrateTask

+ ReadChan chan []string

+ TaskFlow string

+ TaskMode string

+ TaskParams *pb.CsvMigrateParam

+ WriteChan chan string

+ func (r *CsvMigrateRow) MigrateApply() error

+ func (r *CsvMigrateRow) MigrateProcess() error

+ func (r *CsvMigrateRow) MigrateRead() error

+ type DataCompareFile struct

+ CompFile *os.File

+ CompWriter *bufio.Writer

+ Ctx context.Context

+ Mutex *sync.Mutex

+ OutputDir string

+ TaskFlow string

+ TaskName string

+ func NewDataCompareFile(ctx context.Context, taskName, taskFlow, outputDir string) *DataCompareFile

+ func (s *DataCompareFile) Close() error

+ func (s *DataCompareFile) InitFile() error

+ func (s *DataCompareFile) SyncFile() error

+ type DataCompareRow struct

+ BatchSize int

+ CallTimeout int

+ Ctx context.Context

+ DBCharsetS string

+ DBCharsetT string

+ DatabaseS database.IDatabase

+ DatabaseT database.IDatabase

+ Dmt *task.DataCompareTask

+ RepairStmtFlow string

+ StartTime time.Time

+ TaskFlow string

+ TaskMode string

+ WriteThread int

+ func (r *DataCompareRow) CompareCRC32() error

+ func (r *DataCompareRow) CompareMD5() error

+ func (r *DataCompareRow) CompareMethod() string

+ func (r *DataCompareRow) CompareRows() error

+ type DataCompareRule struct

+ CaseFieldRuleS string

+ CaseFieldRuleT string

+ ColumnNameSliS []string

+ Ctx context.Context

+ DBCharsetS string

+ DBCharsetT string

+ DatabaseS database.IDatabase

+ DatabaseT database.IDatabase

+ GlobalIgnoreConditionFields []string

+ GlobalSqlHintS string

+ IgnoreSelectFields []string

+ OnlyCompareCRC bool

+ OnlyCompareRow bool

+ SchemaNameS string

+ SchemaNameT string

+ TableNameS string

+ TableNameT string

+ TableTypeS map[string]string

+ TaskFlow string

+ TaskMode string

+ TaskName string

+ func (r *DataCompareRule) GenSchemaNameRule() (string, string, error)

+ func (r *DataCompareRule) GenSchemaTableColumnSelectRule() (string, string, string, string, error)

+ func (r *DataCompareRule) GenSchemaTableCompareMethodRule() string

+ func (r *DataCompareRule) GenSchemaTableCustomRule() (string, string, []string, error)

+ func (r *DataCompareRule) GenSchemaTableNameRule() (string, string, error)

+ func (r *DataCompareRule) GenSchemaTableTypeRule() string

+ func (r *DataCompareRule) GetSchemaTableColumnNameRule() (map[string]string, error)

+ type DataMigrateRule struct

+ CaseFieldRuleS string

+ CaseFieldRuleT string

+ Ctx context.Context

+ DBCharsetS string

+ DatabaseS database.IDatabase

+ GlobalSqlHintS string

+ SchemaNameS string

+ TableNameS string

+ TableTypeS map[string]string

+ TaskFlow string

+ TaskMode string

+ TaskName string

+ func (r *DataMigrateRule) GenSchemaNameRule() (string, string, error)

+ func (r *DataMigrateRule) GenSchemaTableColumnSelectRule() (string, string, string, string, error)

+ func (r *DataMigrateRule) GenSchemaTableCustomRule() (bool, string, string, error)

+ func (r *DataMigrateRule) GenSchemaTableNameRule() (string, string, error)

+ func (r *DataMigrateRule) GenSchemaTableTypeRule() string

+ func (r *DataMigrateRule) GetSchemaTableColumnNameRule() (map[string]string, error)

+ type DataScanFile struct

+ CompFile *os.File

+ CompWriter *bufio.Writer

+ Ctx context.Context

+ Mutex *sync.Mutex

+ OutputDir string

+ TaskFlow string

+ TaskMode string

+ TaskName string

+ func NewDataScanFile(ctx context.Context, taskName, taskMode, taskFlow, outputDir string) *DataScanFile

+ func (s *DataScanFile) Close() error

+ func (s *DataScanFile) InitFile() error

+ func (s *DataScanFile) SyncFile() error

+ type DataScanRow struct

+ Ctx context.Context

+ DBCharsetS string

+ DatabaseS database.IDatabase

+ Dst *task.DataScanTask

+ StartTime time.Time

+ TaskFlow string

+ TaskMode string

+ TaskName string

+ func (r *DataScanRow) ScanRows() error

+ type DataScanRule struct

+ Ctx context.Context

+ DBCharsetS string

+ DatabaseS database.IDatabase

+ GlobalSamplerateS string

+ GlobalSqlHintS string

+ SchemaNameS string

+ TableNameS string

+ TableTypeS map[string]string

+ TaskFlow string

+ TaskMode string

+ TaskName string

+ func (r *DataScanRule) GenSchemaNameRule() (string, error)

+ func (r *DataScanRule) GenSchemaTableCustomRule() (string, string, error)

+ func (r *DataScanRule) GenSchemaTableTypeRule() string

+ func (r *DataScanRule) GenTableColumnNameRule() (string, string, error)

+ func (r *DataScanRule) GenTableNameRule() (string, error)

+ type Datasource struct

+ DatabaseS database.IDatabase

+ SchemaNameS string

+ TableNameS string

+ TableTypeS string

+ func (d *Datasource) GetTableCharsetCollation() (string, string, error)

+ func (d *Datasource) GetTableCheckKey() ([]map[string]string, error)

+ func (d *Datasource) GetTableColumnComment() ([]map[string]string, error)

+ func (d *Datasource) GetTableColumns() ([]map[string]string, error)

+ func (d *Datasource) GetTableComment() ([]map[string]string, error)

+ func (d *Datasource) GetTableForeignKey() ([]map[string]string, error)

+ func (d *Datasource) GetTableNormalIndex() ([]map[string]string, error)

+ func (d *Datasource) GetTableOriginStruct() (string, error)

+ func (d *Datasource) GetTablePrimaryKey() ([]map[string]string, error)

+ func (d *Datasource) GetTableUniqueIndex() ([]map[string]string, error)

+ func (d *Datasource) GetTableUniqueKey() ([]map[string]string, error)

+ func (d *Datasource) String() string

+ type ScanResultMYSQLCompatible struct

+ Bigint string

+ BigintUnsigned string

+ ColumnName string

+ DecimalInt string

+ DecimalPoint string

+ Unknown string

+ type SequenceMigrateDatabase struct

+ Ctx context.Context

+ DatasourceT database.IDatabase

+ SchemaNameS string

+ SchemaNameT string

+ Sequences []string

+ TaskFlow string

+ TaskName string

+ TaskStartTime time.Time

+ func NewSequenceMigrateDatabase(ctx context.Context, taskName, taskFlow, schemaNameS, schemaNameT string, ...) *SequenceMigrateDatabase

+ func (s *SequenceMigrateDatabase) GenSequenceDigest() (string, error)

+ func (s *SequenceMigrateDatabase) SyncSequenceDatabase() error

+ func (s *SequenceMigrateDatabase) WriteSequenceDatabase() error

+ type SqlMigrateRow struct

+ BatchSize int

+ CallTimeout int

+ Ctx context.Context

+ DBCharsetS string

+ DBCharsetT string

+ DatabaseS database.IDatabase

+ DatabaseT database.IDatabase

+ DatabaseTStmt *sql.Stmt

+ ReadChan chan []interface{}

+ SafeMode bool

+ Smt *task.SqlMigrateTask

+ SqlThreadT int

+ TaskFlow string

+ TaskMode string

+ WriteChan chan []interface{}

+ func (r *SqlMigrateRow) MigrateApply() error

+ func (r *SqlMigrateRow) MigrateProcess() error

+ func (r *SqlMigrateRow) MigrateRead() error

+ type SqlMigrateRule struct

+ CaseFieldRuleS string

+ CaseFieldRuleT string

+ ColumnRouteRule map[string]string

+ Ctx context.Context

+ DBCharsetS string

+ DatabaseS database.IDatabase

+ GlobalSqlHintT string

+ SchemaNameT string

+ SqlHintT string

+ SqlQueryS string

+ TableNameT string

+ TaskFlow string

+ TaskMode string

+ TaskName string

+ func (r *SqlMigrateRule) GenSqlMigrateSchemaNameRule() (string, error)

+ func (r *SqlMigrateRule) GenSqlMigrateTableColumnRule() (string, string, string, error)

+ func (r *SqlMigrateRule) GenSqlMigrateTableCustomRule() (string, string)

+ func (r *SqlMigrateRule) GenSqlMigrateTableNameRule() (string, error)

+ type StmtMigrateRow struct

+ BatchSize int

+ CallTimeout int

+ Ctx context.Context

+ DBCharsetS string

+ DBCharsetT string

+ DatabaseS database.IDatabase

+ DatabaseT database.IDatabase

+ DatabaseTStmt *sql.Stmt

+ Dmt *task.DataMigrateTask

+ ReadChan chan []interface{}

+ SafeMode bool

+ SqlThreadT int

+ TaskFlow string

+ TaskMode string

+ WriteChan chan []interface{}

+ func (r *StmtMigrateRow) MigrateApply() error

+ func (r *StmtMigrateRow) MigrateProcess() error

+ func (r *StmtMigrateRow) MigrateRead() error

+ type StructCompareFile struct

+ CompFile *os.File

+ CompWriter *bufio.Writer

+ Ctx context.Context

+ Mutex *sync.Mutex

+ OutputDir string

+ TaskFlow string

+ TaskName string

+ func NewStructCompareFile(ctx context.Context, taskName, taskFlow, outputDir string) *StructCompareFile

+ func (s *StructCompareFile) Close() error

+ func (s *StructCompareFile) InitFile() error

+ func (s *StructCompareFile) SyncFile() error

+ type StructMigrateDatabase struct

+ Ctx context.Context

+ DatasourceT database.IDatabase

+ TableStruct *database.TableStruct

+ TaskFlow string

+ TaskName string

+ TaskStartTime time.Time

+ func NewStructMigrateDatabase(ctx context.Context, taskName, taskFlow string, datasourceT database.IDatabase, ...) *StructMigrateDatabase

+ func (s *StructMigrateDatabase) GenTableStructDDL() ([]string, []string, error)

+ func (s *StructMigrateDatabase) GenTableStructDigest() (string, string, string, error)

+ func (s *StructMigrateDatabase) SyncStructDatabase() error

+ func (s *StructMigrateDatabase) WriteStructDatabase() error

+ type StructMigrateFile struct

+ CompFile *os.File

+ CompWriter *bufio.Writer

+ Ctx context.Context

+ DBCharsetS string

+ DBCollationS bool

+ DBNlsComp string

+ InCompFile *os.File

+ InCompWriter *bufio.Writer

+ Mutex *sync.Mutex

+ OutputDir string

+ SchemaCollationS string

+ SchemaNameS string

+ SchemaNameT string

+ TaskFlow string

+ TaskName string

+ func NewStructMigrateFile(ctx context.Context, taskName, taskFlow, schemaNameS string, outputDir string) *StructMigrateFile

+ func (s *StructMigrateFile) Close() error

+ func (s *StructMigrateFile) InitOutputFile() error

+ func (s *StructMigrateFile) SyncSequenceFile() error

+ func (s *StructMigrateFile) SyncStructFile() error

+ type StructMigrateRule struct

+ BuildinDatatypeRules []*buildin.BuildinDatatypeRule

+ BuildinDefaultValueRules []*buildin.BuildinDefaultvalRule

+ CaseFieldRuleT string

+ CreateIfNotExist bool

+ Ctx context.Context

+ DBCharsetS string

+ DBCharsetT string

+ DBCollationS bool

+ SchemaNameS string

+ TableColumnsAttrs []map[string]string

+ TableCommentAttrs []map[string]string

+ TableNameS string

+ TablePrimaryAttrs []map[string]string

+ TaskFlow string

+ TaskMode string

+ TaskName string

+ func (r *StructMigrateRule) GetCaseFieldRule() string

+ func (r *StructMigrateRule) GetCreatePrefixRule() string

+ func (r *StructMigrateRule) GetSchemaNameRule() (map[string]string, error)

+ func (r *StructMigrateRule) GetTableAttributesRule() (string, error)

+ func (r *StructMigrateRule) GetTableColumnCollationRule() (map[string]string, error)

+ func (r *StructMigrateRule) GetTableColumnCommentRule() (map[string]string, error)

+ func (r *StructMigrateRule) GetTableColumnRule() (map[string]string, map[string]string, map[string]string, error)

+ func (r *StructMigrateRule) GetTableCommentRule() (string, error)

+ func (r *StructMigrateRule) GetTableNameRule() (map[string]string, error)

+ func (r *StructMigrateRule) String() string

Jun 8, 2024

Changes in this version

+ type MySQLProcessor struct

+ BuildinDatatypeRules []*buildin.BuildinDatatypeRule

+ BuildinDefaultValueRules []*buildin.BuildinDefaultvalRule

+ ColumnRouteRules map[string]string

+ Ctx context.Context

+ DBCharset string

+ Database database.IDatabase

+ IsBaseline bool

+ SchemaName string

+ TableName string

+ TaskFlow string

+ TaskName string

+ func (p *MySQLProcessor) GenDatabaseSchemaTable() (string, string)

+ func (p *MySQLProcessor) GenDatabaseTableCharset() (string, error)

+ func (p *MySQLProcessor) GenDatabaseTableCheckConstraintDetail() (map[string]structure.ConstraintCheck, error)

+ func (p *MySQLProcessor) GenDatabaseTableCollation() (string, error)

+ func (p *MySQLProcessor) GenDatabaseTableColumnDetail() (map[string]structure.NewColumn, map[string]map[string]structure.OldColumn, ...)

+ func (p *MySQLProcessor) GenDatabaseTableComment() (string, error)

+ func (p *MySQLProcessor) GenDatabaseTableForeignConstraintDetail() (map[string]structure.ConstraintForeign, error)

+ func (p *MySQLProcessor) GenDatabaseTableIndexDetail() (map[string]structure.Index, error)

+ func (p *MySQLProcessor) GenDatabaseTablePartitionDetail() ([]structure.Partition, error)

+ func (p *MySQLProcessor) GenDatabaseTablePrimaryConstraintDetail() (map[string]structure.ConstraintPrimary, error)

+ func (p *MySQLProcessor) GenDatabaseTableUniqueConstraintDetail() (map[string]structure.ConstraintUnique, error)

+ type OracleProcessor struct

+ BuildinDatatypeRules []*buildin.BuildinDatatypeRule

+ BuildinDefaultValueRules []*buildin.BuildinDefaultvalRule

+ ColumnRouteRules map[string]string

+ Ctx context.Context

+ DBCharset string

+ DBCollation bool

+ Database database.IDatabase

+ IsBaseline bool

+ NLSComp string

+ SchemaCollation string

+ SchemaName string

+ TableCollation string

+ TableName string

+ TaskFlow string

+ TaskName string

+ func (p *OracleProcessor) GenDatabaseSchemaTable() (string, string)

+ func (p *OracleProcessor) GenDatabaseTableCharset() (string, error)

+ func (p *OracleProcessor) GenDatabaseTableCheckConstraintDetail() (map[string]structure.ConstraintCheck, error)

+ func (p *OracleProcessor) GenDatabaseTableCollation() (string, error)

+ func (p *OracleProcessor) GenDatabaseTableColumnDetail() (map[string]structure.NewColumn, map[string]map[string]structure.OldColumn, ...)

+ func (p *OracleProcessor) GenDatabaseTableComment() (string, error)

+ func (p *OracleProcessor) GenDatabaseTableForeignConstraintDetail() (map[string]structure.ConstraintForeign, error)

+ func (p *OracleProcessor) GenDatabaseTableIndexDetail() (map[string]structure.Index, error)

+ func (p *OracleProcessor) GenDatabaseTablePartitionDetail() ([]structure.Partition, error)

+ func (p *OracleProcessor) GenDatabaseTablePrimaryConstraintDetail() (map[string]structure.ConstraintPrimary, error)

+ func (p *OracleProcessor) GenDatabaseTableUniqueConstraintDetail() (map[string]structure.ConstraintUnique, error)

+ type Table struct

+ Source *structure.Table

+ Target *structure.Table

+ TaskFlow string

+ TaskName string

+ func (t *Table) ComparePartitionTableType() string

+ func (t *Table) CompareTableCharsetCollation() string

+ func (t *Table) CompareTableCheckConstraint() (string, error)

+ func (t *Table) CompareTableColumnCharsetCollation() string

+ func (t *Table) CompareTableColumnCounts() string

+ func (t *Table) CompareTableColumnDetail() (string, error)

+ func (t *Table) CompareTableComment() string

+ func (t *Table) CompareTableForeignConstraint() (string, error)

+ func (t *Table) CompareTableIndexDetail() (string, error)

+ func (t *Table) CompareTablePartitionDetail() (string, error)

+ func (t *Table) CompareTablePrimaryConstraint() (string, error)

+ func (t *Table) CompareTableUniqueConstraint() (string, error)