coreinterfaces

type Config interface {
	// OpenDB opens a connection to the database
	OpenDB() (*sql.DB, error)
}

type Connector interface {
	// InitSchema initializes the schema of the table
	InitSchema(columns []cloudstorage.TableCol) error
	// CopyTableSchema copies the table schema from the source database to the Data Warehouse
	CopyTableSchema(sourceDatabase string, sourceTable string, sourceTiDBConn *sql.DB) error
	// LoadSnapshot loads the snapshot file into the Data Warehouse
	LoadSnapshot(targetTable, filePath string) error
	// ExecDDL executes the DDL statements in Data Warehouse
	ExecDDL(tableDef cloudstorage.TableDefinition) error
	// LoadIncrement loads the increment data into the Data Warehouse
	LoadIncrement(tableDef cloudstorage.TableDefinition, filePath string) error
	// Close closes the connection to the Data Warehouse
	Close()
}