Versions in this module Expand all Collapse all v0 v0.0.4 Mar 15, 2024 v0.0.3 Oct 8, 2023 Changes in this version + var TiDB2DatabricksTypeMap = map[string]string + func GenCreateExternalTableSQL(tableName string, tableColumns []cloudstorage.TableCol, storageUri string, ...) (string, error) + func GenCreateTableSQL(tableName string, tableColumns []cloudstorage.TableCol) (string, error) + func GenDDLViaColumnsDiff(prevColumns []cloudstorage.TableCol, curTableDef cloudstorage.TableDefinition) ([]string, error) + func GenDropTableSQL(sourceTable string) string + func GenMergeIntoSQL(tableDef cloudstorage.TableDefinition, tableName, externalTableName string) string + func GetCredentialNameSet(db *sql.DB) (map[string]interface{}, error) + func GetDatabricksColumnString(column cloudstorage.TableCol) (string, error) + func GetDatabricksTypeString(column cloudstorage.TableCol) (string, error) + func LoadCSVFromS3(db *sql.DB, columns []cloudstorage.TableCol, ...) error + type DataBricksConfig struct + Catalog string + Endpoint string + Host string + Port int + Schema string + Token string + func (config *DataBricksConfig) OpenDB() (*sql.DB, error) + type DatabricksConnector struct + func NewDatabricksConnector(databricksDB *sql.DB, credential string, storageURI *url.URL) (*DatabricksConnector, error) + func (dc *DatabricksConnector) Close() + func (dc *DatabricksConnector) CopyTableSchema(sourceDatabase string, sourceTable string, sourceTiDBConn *sql.DB) error + func (dc *DatabricksConnector) ExecDDL(tableDef cloudstorage.TableDefinition) error + func (dc *DatabricksConnector) InitSchema(columns []cloudstorage.TableCol) error + func (dc *DatabricksConnector) LoadIncrement(tableDef cloudstorage.TableDefinition, uri *url.URL, filePath string) error + func (dc *DatabricksConnector) LoadSnapshot(targetTable, filePath string) error
Go to main page