Versions in this module Expand all Collapse all v0 v0.2.4 Apr 23, 2022 Changes in this version + var DefaultSnowflakeConnectionKeyNames = struct{ ... } + func NewCqnConnection(dsnString string) (shared.OracleCqnExecutor, error) + func NewDBConnectionWithMockDripFeed(log logger.Logger, numRowsToGenerate int, sleepIntervalSec int, dbType string) (shared.Connector, chan string) + func NewMockConnectionWithBatchWithMockTx(log logger.Logger) (shared.Connector, chan string) + func NewOdbcConnection(log logger.Logger, d *shared.DsnConnectionDetails) (shared.Connector, error) + func NewOracleConnection(log logger.Logger, d *shared.DsnConnectionDetails) (shared.Connector, error) + func OpenDbConnection(log logger.Logger, c shared.ConnectionDetails) (db shared.Connector, err error) + func OracleExecWithConnDetails(log logger.Logger, connDetails *shared.DsnConnectionDetails, sql string) error + func SnowflakeDDLExec(log logger.Logger, connDetails *shared.DsnConnectionDetails, sql string) error + func SnowflakeGetDSN(c *SnowflakeConnectionDetails) (string, error) + func SqlQuery(ctx context.Context, log logger.Logger, db shared.Connector, sqltext string, ...) error + type SchemaTable struct + SchemaTable string + func NewSchemaTable(schema string, table string) SchemaTable + func (st *SchemaTable) AppendSuffix(suffix string) string + func (st *SchemaTable) GetSchema() string + func (st *SchemaTable) GetTable() string + func (st *SchemaTable) String() string + type SnowflakeConnectionDetails struct + Account string + DBName string + Dsn string + OriginalScheme string + Password string + RoleName string + Schema string + User string + Warehouse string + func SnowflakeParseDSN(d string) (*SnowflakeConnectionDetails, error) + func (d SnowflakeConnectionDetails) GetMap(m map[string]string) map[string]string + func (d SnowflakeConnectionDetails) GetScheme() (string, error) + func (d SnowflakeConnectionDetails) Parse() error + func (d SnowflakeConnectionDetails) String() string
Go to main page