Versions in this module Expand all Collapse all v0 v0.2.4 Apr 23, 2022 Changes in this version + var MockDataTypeMapping = []dataTypeLink + var NetezzaToSnowflakeDataTypeMapping = []dataTypeLink + var OracleToSnowflakeDataTypeMapping = []dataTypeLink + var SnowflakeToSnowflakeDataTypeMapping = []dataTypeLink + var SqlServerToSnowflakeDataTypeMapping = []dataTypeLink + func ColumnIsNumberOrDate(log logger.Logger, fnGetColumns GetColumnsFuncT, mapper Mapper, ...) (retval int, err error) + func ConvertTableDefinitionToSnowflake(log logger.Logger, tabCols TableColumns, snowSchemaTable rdbms.SchemaTable, ...) (snowflakeTableDefinition string, err error) + func GetTableColumns(log logger.Logger, fnGetColumns GetColumnsFuncT, ...) ([]string, error) + func TabDefinitionToChan(log logger.Logger, name string, conn *shared.ConnectionDetails, ...) (chan stream.Record, shared.Connector) + type DeltaType uint32 + const DeltaTypeDateTime + const DeltaTypeNumber + const DeltaTypeText + const DeltaTypeUnclassified + type GetColumnsFuncT func(log logger.Logger, schemaTable string) (chan stream.Record, shared.Connector) + func GetColumnsFunc(conn *shared.ConnectionDetails) GetColumnsFuncT + type Mapper interface + GetDeltaDataType func(inputDataType string) DeltaType + Map func(inputDataType string) (output string) + Sanitise func(inputDataType string, dataLen, precision, scale int) (output string) + func MustGetMapper(conn *shared.ConnectionDetails) Mapper + func NewMockDataTypeMapper() Mapper + func NewNetezzaToSnowflakeDataTypeMapper() Mapper + func NewOracleToSnowflakeDataTypeMapper() Mapper + func NewSnowflakeDataTypeMapper() Mapper + func NewSqlServerToSnowflakeDataTypeMapper() Mapper + type TableColumn struct + ColID int + ColName string + DataLen int + DataPrecision int + DataScale int + DataType string + Nullable bool + type TableColumns struct + Columns []TableColumn + Owner string + TableName string + func GetTableDefinition(log logger.Logger, fnGetColumns GetColumnsFuncT, ...) (tabCols TableColumns, err error)