common

type RowData struct {
	Data   map[string]*dbutil.ColumnData
	Source int
}

type RowDatas struct {
	Rows         []RowData
	OrderKeyCols []*model.ColumnInfo
}

type TableDiff struct {
	// Schema represents the database name.
	Schema string `json:"schema"`

	// Table represents the table name.
	Table string `json:"table"`

	// Info is the parser.TableInfo, include some meta infos for this table.
	// It used for TiDB/MySQL/MySQL Shard sources.
	Info *model.TableInfo `json:"info"`

	// columns be ignored
	IgnoreColumns []string `json:"-"`

	// field should be the primary key, unique key or field with index
	Fields string `json:"fields"`

	// select range, for example: "age > 10 AND age < 20"
	Range string `json:"range"`

	// ignore check table's data
	IgnoreDataCheck bool `json:"-"`

	// the table has column timestamp, which need to reset time_zone.
	NeedUnifiedTimeZone bool `json:"-"`

	Collation string `json:"collation"`

	ChunkSize int64 `json:"chunk-size"`

	// TableLack = 1: the table only exists downstream,
	// TableLack = -1: the table only exists upstream,
	// TableLack = 0: the table exists both upstream and downstream.
	TableLack int `json:"-"`
}

type TableShardSource struct {
	TableSource
	// DBConn represents the origin DB connection for this TableSource.
	// This TableSource may exists in different MySQL shard.
	DBConn *sql.DB
}

type TableSource struct {
	OriginSchema string
	OriginTable  string
}