rdbms

package

v0.2.4 Latest Latest Go to latest Published: Apr 23, 2022 License: MIT Imports: 16 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/relloyd/halfpipe

Links

Open Source Insights

README ¶

To add new connection types:

add to subcommand 'config connections add ' and see actions.RunConnectionAdd()
add to functionality to config.GetConnectionDetails()
ensure the connection type is valid in the action register as part of adding it to func actions.RunConnectionAdd()
add helper types and methods to file rdbms/shared/connection-details-generic.go
enhance ConnectionDetails{}.String() since this redacts user passwords.
DefaultConnectionVariableSuffixes{} needs a new key to support populating ConnectionDetails from environment.
table definition handlers in table-definition/columns.go

Documentation ¶

Index ¶

Variables
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
- func NewSchemaTable(schema string, table string) SchemaTable
type SnowflakeConnectionDetails
- func SnowflakeParseDSN(d string) (*SnowflakeConnectionDetails, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var DefaultSnowflakeConnectionKeyNames = struct {
	AccountName  string
	DatabaseName string
	Warehouse    string
	SchemaName   string
	UserName     string
	Password     string
	RoleName     string
}{
	AccountName:  "accountName",
	DatabaseName: "databaseName",
	Warehouse:    "warehouse",
	SchemaName:   "schemaName",
	UserName:     "userName",
	Password:     "password",
	RoleName:     "roleName",
}

Functions ¶

func NewCqnConnection ¶

func NewCqnConnection(dsnString string) (shared.OracleCqnExecutor, error)

func NewDBConnectionWithMockDripFeed ¶

func NewDBConnectionWithMockDripFeed(log logger.Logger, numRowsToGenerate int, sleepIntervalSec int, dbType string) (shared.Connector, chan string)

func NewMockConnectionWithBatchWithMockTx ¶

func NewMockConnectionWithBatchWithMockTx(log logger.Logger) (shared.Connector, chan string)

func NewOdbcConnection ¶

func NewOdbcConnection(log logger.Logger, d *shared.DsnConnectionDetails) (shared.Connector, error)

func NewOracleConnection ¶

func NewOracleConnection(log logger.Logger, d *shared.DsnConnectionDetails) (shared.Connector, error)

func OpenDbConnection ¶

func OpenDbConnection(log logger.Logger, c shared.ConnectionDetails) (db shared.Connector, err error)

OpenDbConnection opens a database connection using the supplied ConnectionDetails struct in c.

func OracleExecWithConnDetails ¶

func OracleExecWithConnDetails(log logger.Logger, connDetails *shared.DsnConnectionDetails, sql string) error

func SnowflakeDDLExec ¶

func SnowflakeDDLExec(log logger.Logger, connDetails *shared.DsnConnectionDetails, sql string) error

func SnowflakeGetDSN ¶

func SnowflakeGetDSN(c *SnowflakeConnectionDetails) (string, error)

SnowflakeGetDSN constructs a DSN based on SnowflakeConnectionDetails. The prefix 'snowflake://' is added to the DSN.

func SqlQuery ¶

func SqlQuery(ctx context.Context, log logger.Logger, db shared.Connector, sqltext string, i shared.SqlResultHandler) error

Types ¶

type SchemaTable ¶

type SchemaTable struct {
	SchemaTable string `errorTxt:"[<schema>.]<object>" mandatory:"yes"`
}

func NewSchemaTable ¶

func NewSchemaTable(schema string, table string) SchemaTable

func (*SchemaTable) AppendSuffix ¶

func (st *SchemaTable) AppendSuffix(suffix string) string

func (*SchemaTable) GetSchema ¶

func (st *SchemaTable) GetSchema() string

func (*SchemaTable) GetTable ¶

func (st *SchemaTable) GetTable() string

func (*SchemaTable) String ¶

func (st *SchemaTable) String() string

type SnowflakeConnectionDetails ¶

type SnowflakeConnectionDetails struct {
	Account        string `errorTxt:"Snowflake account" mandatory:"yes"`
	DBName         string `errorTxt:"Snowflake db name" mandatory:"yes"`
	Schema         string `errorTxt:"Snowflake schema" mandatory:"yes"`
	User           string `errorTxt:"Snowflake username" mandatory:"yes"`
	Password       string `errorTxt:"Snowflake password" mandatory:"yes"`
	Warehouse      string `errorTxt:"Snowflake warehouse"`
	RoleName       string `errorTxt:"Snowflake role name"`
	Dsn            string
	OriginalScheme string
}

func SnowflakeParseDSN ¶

func SnowflakeParseDSN(d string) (*SnowflakeConnectionDetails, error)

SnowflakeParseDSN converts a Snowflake DSN into native connection details. The prefix 'snowflake://' is removed from the DSN if it exists.

func (SnowflakeConnectionDetails) GetMap ¶

func (d SnowflakeConnectionDetails) GetMap(m map[string]string) map[string]string

func (SnowflakeConnectionDetails) GetScheme ¶

func (d SnowflakeConnectionDetails) GetScheme() (string, error)

func (SnowflakeConnectionDetails) Parse ¶

func (d SnowflakeConnectionDetails) Parse() error

func (SnowflakeConnectionDetails) String ¶

func (d SnowflakeConnectionDetails) String() string

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
odbc
oracle
shared

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL