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 TiDB2BigQueryTypeMap map[string]string = map[string]string + func GenCreateSchema(columns []cloudstorage.TableCol, pkColumns []string, datasetID, tableID string) (string, error) + func GenDDLViaColumnsDiff(datasetID, tableID string, prevColumns []cloudstorage.TableCol, ...) ([]string, error) + func GenMergeInto(tableDef cloudstorage.TableDefinition, ...) string + func GetBigQueryColumnString(column cloudstorage.TableCol, createTable bool) (string, error) + func GetBigQueryColumnTypeString(column cloudstorage.TableCol) (string, error) + func GetColumnModifyString(diff *tidbsql.ColumnDiff) (string, error) + type BigQueryConfig struct + CredentialsFilePath string + DatasetID string + ProjectID string + func (cfg *BigQueryConfig) NewClient() (*bigquery.Client, error) + type BigQueryConnector struct + func NewBigQueryConnector(bqClient *bigquery.Client, incrementTableID, datasetID, tableID string, ...) (*BigQueryConnector, error) + func (bc *BigQueryConnector) Close() + func (bc *BigQueryConnector) CopyTableSchema(sourceDatabase string, sourceTable string, sourceTiDBConn *sql.DB) error + func (bc *BigQueryConnector) ExecDDL(tableDef cloudstorage.TableDefinition) error + func (bc *BigQueryConnector) InitSchema(columns []cloudstorage.TableCol) error + func (bc *BigQueryConnector) LoadIncrement(tableDef cloudstorage.TableDefinition, uri *url.URL, filePath string) error + func (bc *BigQueryConnector) LoadSnapshot(targetTable, filePath string) error
Go to main page