extractor

type ColumnDefinition struct {
	Name          string
	Datatype      string
	DataLength    uint32
	DataPrecision sql.NullInt32
	DataScale     sql.NullInt32
	DefaultLength sql.NullInt32
	CharLength    sql.NullInt32
	Nullable      OracleBoolean
	DataDefault   sql.NullString
}

type ExtractorOracle struct {
	MySQLVersion          string
	TotalTransferredBytes int
	// Original comment: TotalRowsCopied returns the accurate number of rows being copied (affected)
	// This is not exactly the same as the rows being iterated via chunks, but potentially close enough.
	// TODO What is the difference between mysqlContext.RowsEstimate ?
	TotalRowsCopied int64

	LogMinerStream *LogMinerStream

	OracleContext *OracleContext
	// contains filtered or unexported fields
}

type LogFile struct {
	Name        string
	FirstChange int64
}

type LogMinerRecord struct {
	SCN       int64
	SegOwner  string
	TableName string
	SQLRedo   string
	SQLUndo   string
	Operation int
	XId       []byte
	Csf       int
	RowId     string
	Rollback  int
	RsId      string
	StartTime string
	Username  string
}

type LogMinerStream struct {
	OracleTxNum uint32
	// contains filtered or unexported fields
}

type LogMinerTx struct {
	// contains filtered or unexported fields
}

type LogMinerTxCache struct {
	Handler func(tx *LogMinerTx) error
	// contains filtered or unexported fields
}

type OracleBoolean bool

type OracleContext struct {
	// contains filtered or unexported fields
}

type OracleSchemaInfo struct {
	Tables map[string]*ast.CreateTableStmt
}

type Stmt struct {
	Schema            string
	Table             string
	Columns           []string
	Operation         int8
	Data              map[string]interface{}
	Before            map[string]interface{}
	WhereExpr         string
	WhereColumnValues []interface{}
	NewColumnValues   []interface{}
	Error             error
	// contains filtered or unexported fields
}

type TimestampContext struct {

	// Do not pass 0 to the chan.
	TimestampCh chan uint32
	// contains filtered or unexported fields
}