snowflake

Nov 11, 2022

Changes in this version

type HandleT

+ func (sf *HandleT) AddColumns(tableName string, columnsInfo []warehouseutils.ColumnInfo) (err error)

Oct 12, 2022

Changes in this version

type HandleT

+ func (sf *HandleT) DeleteBy(tableNames []string, params warehouseutils.DeleteByParams) (err error)

Aug 25, 2022

Changes in this version

+ func Connect(cred SnowflakeCredentialsT) (*sql.DB, error)

type SnowflakeCredentialsT

+ Account string

+ DBName string

+ Password string

+ Username string

+ WHName string

Oct 14, 2021

Changes in this version

+ const PROVIDER

type HandleT

+ Stage string

Jun 14, 2022

Changes in this version

+ func ColumnsWithDataTypes(columns map[string]string, prefix string) string

+ func Init()

type HandleT

+ ConnectTimeout time.Duration

+ Uploader warehouseutils.UploaderI

+ func (sf *HandleT) AddColumn(tableName string, columnName string, columnType string) (err error)

+ func (sf *HandleT) AlterColumn(tableName string, columnName string, columnType string) (err error)

+ func (sf *HandleT) Cleanup()

+ func (sf *HandleT) Connect(warehouse warehouseutils.WarehouseT) (client.Client, error)

+ func (sf *HandleT) CreateSchema() (err error)

+ func (sf *HandleT) CreateTable(tableName string, columnMap map[string]string) (err error)

+ func (sf *HandleT) DownloadIdentityRules(gzWriter *misc.GZipWriter) (err error)

+ func (sf *HandleT) DropTable(tableName string) (err error)

+ func (sf *HandleT) FetchSchema(warehouse warehouseutils.WarehouseT) (schema warehouseutils.SchemaT, err error)

+ func (sf *HandleT) GetTotalCountInTable(tableName string) (total int64, err error)

+ func (sf *HandleT) IsEmpty(warehouse warehouseutils.WarehouseT) (empty bool, err error)

+ func (sf *HandleT) LoadIdentityMappingsTable() (err error)

+ func (sf *HandleT) LoadIdentityMergeRulesTable() (err error)

+ func (sf *HandleT) LoadTable(tableName string) error

+ func (sf *HandleT) LoadTestTable(location string, tablename string, payloadMap map[string]interface{}, ...) (err error)

+ func (sf *HandleT) LoadUserTables() map[string]error

+ func (sf *HandleT) SetConnectionTimeout(timeout time.Duration)

+ func (sf *HandleT) Setup(warehouse warehouseutils.WarehouseT, uploader warehouseutils.UploaderI) (err error)

+ func (sf *HandleT) TestConnection(warehouse warehouseutils.WarehouseT) (err error)

Apr 30, 2020

Changes in this version

+ const AWSAccessKey

+ const AWSAccessSecret

+ const SFAccount

+ const SFDbName

+ const SFPassword

+ const SFUserName

+ const SFWarehouse

+ const StorageIntegration

+ type HandleT struct

+ CloudProvider string

+ CurrentSchema map[string]map[string]string

+ Db *sql.DB

+ DbHandle *sql.DB

+ Namespace string

+ ObjectStorage string

+ Upload warehouseutils.UploadT

+ Warehouse warehouseutils.WarehouseT

+ func (sf *HandleT) CrashRecover(config warehouseutils.ConfigT) (err error)

+ func (sf *HandleT) Export() (err error)

+ func (sf *HandleT) MigrateSchema() (err error)

+ func (sf *HandleT) Process(config warehouseutils.ConfigT) (err error)

+ type OptionalCredsT struct

+ type SnowflakeCredentialsT struct