undo

type BranchUndoLog struct {
	// Xid
	Xid string `json:"xid"`
	// BranchID
	BranchID uint64 `json:"branchId"`
	// Logs
	Logs []SQLUndoLog `json:"sqlUndoLogs"`
}

type CompressConfig struct {
	Enable    bool   `yaml:"enable" json:"enable,omitempty" koanf:"enable"`
	Type      string `yaml:"type" json:"type,omitempty" koanf:"type"`
	Threshold string `yaml:"threshold" json:"threshold,omitempty"  koanf:"threshold"`
}

type Config struct {
	DataValidation        bool           `yaml:"data-validation" json:"data-validation,omitempty" koanf:"data-validation"`
	LogSerialization      string         `yaml:"log-serialization" json:"log-serialization,omitempty" koanf:"log-serialization"`
	LogTable              string         `yaml:"log-table" json:"log-table,omitempty" koanf:"log-table"`
	OnlyCareUpdateColumns bool           `yaml:"only-care-update-columns" json:"only-care-update-columns,omitempty" koanf:"only-care-update-columns"`
	CompressConfig        CompressConfig `yaml:"compress" json:"compress,omitempty" koanf:"compress"`
}

type SQLUndoLog struct {
	SQLType     types.SQLType      `json:"sqlType"`
	TableName   string             `json:"tableName"`
	BeforeImage *types.RecordImage `json:"beforeImage"`
	AfterImage  *types.RecordImage `json:"afterImage"`
}

type UndoExecutor interface {
	ExecuteOn(ctx context.Context, dbType types.DBType, conn *sql.Conn) error
}

type UndoExecutorHolder interface {
	// GetInsertExecutor get the specific Insert UndoExecutor by sqlUndoLog
	GetInsertExecutor(sqlUndoLog SQLUndoLog) UndoExecutor

	// GetUpdateExecutor get the specific Update UndoExecutor by sqlUndoLog
	GetUpdateExecutor(sqlUndoLog SQLUndoLog) UndoExecutor

	// GetDeleteExecutor get the specific Delete UndoExecutor by sqlUndoLog
	GetDeleteExecutor(sqlUndoLog SQLUndoLog) UndoExecutor
}

type UndoLogBuilder interface {
	BeforeImage(ctx context.Context, execCtx *types.ExecContext) ([]*types.RecordImage, error)
	AfterImage(ctx context.Context, execCtx *types.ExecContext, beforImages []*types.RecordImage) ([]*types.RecordImage, error)
	GetExecutorType() types.ExecutorType
}

type UndoLogManager interface {
	Init()
	// DeleteUndoLog
	DeleteUndoLog(ctx context.Context, xid string, branchID int64, conn *sql.Conn) error
	// BatchDeleteUndoLog
	BatchDeleteUndoLog(xid []string, branchID []int64, conn *sql.Conn) error
	//FlushUndoLog
	FlushUndoLog(tranCtx *types.TransactionContext, conn driver.Conn) error
	// RunUndo
	RunUndo(ctx context.Context, xid string, branchID int64, conn *sql.DB, dbName string) error
	// DBType
	DBType() types.DBType
	// HasUndoLogTable
	HasUndoLogTable(ctx context.Context, conn *sql.Conn) (bool, error)
}

type UndoLogStatue int8

type UndologRecord struct {
	BranchID     uint64        `json:"branchId"`
	XID          string        `json:"xid"`
	Context      []byte        `json:"context"`
	RollbackInfo []byte        `json:"rollbackInfo"`
	LogStatus    UndoLogStatue `json:"logStatus"`
	LogCreated   []byte        `json:"logCreated"`
	LogModified  []byte        `json:"logModified"`
}