snowflake

Documentation

Index

• Constants
• func GoquDialectOptions() *sqlgen.SQLDialectOptions
• func GoquExpressions() *base.Expressions
• type Config
  • func (c Config) ConnectionString() (dsn string, err error)
  • func (c *Config) Parse(configJSON json.RawMessage) error
  • func (c *Config) ParsePrivateKey() (*rsa.PrivateKey, error)
• type DB
  • func NewDB(configJSON json.RawMessage) (*DB, error)

Constants

const (
	DatabaseType = "snowflake"
)

Functions

func GoquDialectOptions

func GoquDialectOptions() *sqlgen.SQLDialectOptions

func GoquExpressions

func GoquExpressions() *base.Expressions

Types

type Config

type Config struct {
	Account   string `json:"account"`
	Warehouse string `json:"warehouse"`
	DBName    string `json:"dbname"`
	User      string `json:"user"`
	Schema    string `json:"schema"`
	Role      string `json:"role"`
	Region    string `json:"region"`

	Protocol string `json:"protocol"` // http or https (optional)
	Host     string `json:"host"`     // hostname (optional)
	Port     int    `json:"port"`     // port (optional)

	Password string `json:"password"`

	UseKeyPairAuth       bool   `json:"useKeyPairAuth"`
	PrivateKey           string `json:"privateKey"`
	PrivateKeyPassphrase string `json:"privateKeyPassphrase"`

	UseOAuth   bool   `json:"useOAuth"`
	OAuthToken string `json:"oauthToken"`

	Application string `json:"application"`

	LoginTimeout time.Duration `json:"loginTimeout"` // default: 5m

	KeepSessionAlive  bool   `json:"keepSessionAlive"`
	UseLegacyMappings bool   `json:"useLegacyMappings"`
	QueryTag          string `json:"queryTag"`

	EnableMFACaching   bool   `json:"enableMFACaching"`
	Passcode           string `json:"passcode"`
	PasscodeInPassword bool   `json:"passcodeInPassword"`
}

func (Config) ConnectionString

func (c Config) ConnectionString() (dsn string, err error)

func (*Config) Parse

func (c *Config) Parse(configJSON json.RawMessage) error

func (*Config) ParsePrivateKey

func (c *Config) ParsePrivateKey() (*rsa.PrivateKey, error)

type DB

type DB struct {
	*base.DB
}

func NewDB

func NewDB(configJSON json.RawMessage) (*DB, error)

NewDB creates a new snowflake db client