Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

gosnowflake

package module

Go to main page

Versions in this module

v1

v1.9.0

May 2, 2024

Changes in this version

+ const ErrCodeClientConfigFailed

+ const ErrInvalidPadding

+ const ErrTooHighTimestampPrecision

+ const UseMicrosecondTimestamp

+ const UseMillisecondTimestamp

+ const UseNanosecondTimestamp

+ const UseOriginalTimestamp

+ const UseSecondTimestamp

+ func GetFromEnv(name string, failOnMissing bool) (string, error)

+ func WithArrowAllocator(ctx context.Context, pool memory.Allocator) context.Context

+ func WithArrowBatchesTimestampOption(ctx context.Context, option snowflakeArrowBatchesTimestampOption) context.Context

+ func WithArrowBatchesUtf8Validation(ctx context.Context) context.Context

+ func WithOriginalTimestamp(ctx context.Context) context.Context

+ func WithQueryTag(ctx context.Context, tag string) context.Context

type ArrowBatch

+ func (rb *ArrowBatch) ArrowSnowflakeTimestampToTime(rec arrow.Record, colIdx int, recIdx int) *time.Time

+ func (rb *ArrowBatch) GetRowCount() int

+ func (rb *ArrowBatch) WithContext(ctx context.Context) *ArrowBatch

+ type ArrowStreamBatch struct

+ Loc *time.Location

+ func (asb *ArrowStreamBatch) GetStream(ctx context.Context) (io.ReadCloser, error)

+ func (asb *ArrowStreamBatch) NumRows() int64

+ type ArrowStreamLoader interface

+ GetBatches func() ([]ArrowStreamBatch, error)

+ JSONData func() [][]*string

+ Location func() *time.Location

+ RowTypes func() []execResponseRowType

+ TotalRows func() int64

type AuthType

+ const AuthTypeUsernamePasswordMFA

+ type ClientConfig struct

+ Common *ClientConfigCommonProps

+ type ClientConfigCommonProps struct

+ LogLevel string

+ LogPath string

type Config

+ ClientConfigFile string

+ ClientRequestMfaToken ConfigBool

+ ClientStoreTemporaryCredential ConfigBool

+ DisableConsoleLogin ConfigBool

+ DisableQueryContextCache bool

+ ExternalBrowserTimeout time.Duration

+ IDToken string

+ IncludeRetryReason ConfigBool

+ JWTClientTimeout time.Duration

+ MaxRetryCount int

+ MfaToken string

+ TmpDirPath string

+ Tracing string

+ func GetConfigFromEnv(properties []*ConfigParam) (*Config, error)

+ func (c *Config) Validate() error

+ type ConfigParam struct

+ EnvName string

+ FailOnMissing bool

+ Name string

type SFLogger

+ CloseFileOnLoggerReplace func(file *os.File) error

+ GetLogLevel func() string

+ Replace func(newLogger *SFLogger)

+ type SnowflakeRows interface

+ GetArrowBatches func() ([]*ArrowBatch, error)

+ GetQueryID func() string

+ GetStatus func() queryStatus

+ type SnowflakeStmt interface

+ GetQueryID func() string

+ type TypedNullTime struct

+ Time sql.NullTime

+ TzType timezoneType

+ type UUID [16]byte

+ func NewUUID() UUID

+ func ParseUUID(str string) UUID

+ func (u UUID) String() string

v1.6.9

Mar 10, 2022

v1.6.8

Mar 9, 2022

v1.6.7

Mar 8, 2022

Changes in this version

+ const DateType

+ const ErrAsync

+ const ErrBindSerialization

+ const ErrBindUpload

+ const ErrCodeEmptyAccountCode

+ const ErrCodeEmptyPasswordCode

+ const ErrCodeEmptyUsernameCode

+ const ErrCodeFailedToConnect

+ const ErrCodeFailedToParseAuthenticator

+ const ErrCodeFailedToParseHost

+ const ErrCodeFailedToParsePort

+ const ErrCodeIdpConnectionError

+ const ErrCodePrivateKeyParseError

+ const ErrCodeRegionOverlap

+ const ErrCodeSSOURLNotMatch

+ const ErrCodeServiceUnavailable

+ const ErrCommandNotRecognized

+ const ErrCompressionNotSupported

+ const ErrFailedToAuth

+ const ErrFailedToAuthOKTA

+ const ErrFailedToAuthSAML

+ const ErrFailedToCancelQuery

+ const ErrFailedToCloseSession

+ const ErrFailedToConvertToS3Client

+ const ErrFailedToDownloadFromStage

+ const ErrFailedToGetChunk

+ const ErrFailedToGetExternalBrowserResponse

+ const ErrFailedToGetSSO

+ const ErrFailedToHeartbeat

+ const ErrFailedToParseResponse

+ const ErrFailedToPostQuery

+ const ErrFailedToRenewSession

+ const ErrFailedToUploadToStage

+ const ErrFileNotExists

+ const ErrInternalNotMatchEncryptMaterial

+ const ErrInvalidBinaryHexForm

+ const ErrInvalidOffsetStr

+ const ErrInvalidStageFs

+ const ErrInvalidStageLocation

+ const ErrInvalidTimestampTz

+ const ErrLocalPathNotDirectory

+ const ErrNoDefaultTransactionIsolationLevel

+ const ErrNoReadOnlyTransaction

+ const ErrNoResultIDs

+ const ErrNotImplemented

+ const ErrOCSPInvalidValidity

+ const ErrOCSPNoOCSPResponderURL

+ const ErrOCSPStatusRevoked

+ const ErrOCSPStatusUnknown

+ const ErrObjectNotExistOrAuthorized

+ const ErrQueryIDFormat

+ const ErrQueryIsRunning

+ const ErrQueryReportedError

+ const ErrQueryStatus

+ const ErrRoleNotExist

+ const ErrSessionGone

+ const QueryFailed

+ const QueryStatusComplete

+ const QueryStatusInProgress

+ const SFQueryAborted

+ const SFQueryAborting

+ const SFQueryBlocked

+ const SFQueryDisconnected

+ const SFQueryFailedWithError

+ const SFQueryFailedWithIncident

+ const SFQueryNoData

+ const SFQueryQueueRepairingWarehouse

+ const SFQueryQueued

+ const SFQueryRestarted

+ const SFQueryResumingWarehouse

+ const SFQueryRunning

+ const SFQuerySuccess

+ const SFSessionIDKey

+ const SFSessionUserKey

+ const SQLStateConnectionFailure

+ const SQLStateConnectionRejected

+ const SQLStateConnectionWasNotEstablished

+ const SQLStateFeatureNotSupported

+ const SQLStateInvalidDataTimeFormat

+ const SQLStateNumericValueOutOfRange

+ const SnowflakeGoDriverVersion

+ const TimeType

+ const TimestampLTZType

+ const TimestampNTZType

+ const TimestampTZType

+ var CustomJSONDecoderEnabled = false

+ var DataTypeArray = []byte

+ var DataTypeBinary = []byte

+ var DataTypeBoolean = []byte

+ var DataTypeDate = []byte

+ var DataTypeFixed = []byte

+ var DataTypeObject = []byte

+ var DataTypeReal = []byte

+ var DataTypeText = []byte

+ var DataTypeTime = []byte

+ var DataTypeTimestampLtz = []byte

+ var DataTypeTimestampNtz = []byte

+ var DataTypeTimestampTz = []byte

+ var DataTypeVariant = []byte

+ var ErrEmptyAccount = &SnowflakeError

+ var ErrEmptyPassword = &SnowflakeError

+ var ErrEmptyUsername = &SnowflakeError

+ var ErrInvalidRegion = &SnowflakeError

+ var LogKeys = [...]contextKey

+ var MaxChunkDownloadWorkers = 10

+ var SnowflakeTransport = &http.Transport

+ var SnowflakeTransportTest = SnowflakeTransport

+ func Array(a interface{}, typ ...timezoneType) interface

+ func DSN(cfg *Config) (dsn string, err error)

+ func Location(offset int) *time.Location

+ func LocationWithOffsetString(offsets string) (loc *time.Location, err error)

+ func SFCallerPrettyfier(frame *runtime.Frame) (string, string)

+ func SetLogger(inLogger *SFLogger)

+ func WithArrowBatches(ctx context.Context) context.Context

+ func WithAsyncMode(ctx context.Context) context.Context

+ func WithDescribeOnly(ctx context.Context) context.Context

+ func WithFetchResultByID(ctx context.Context, queryID string) context.Context

+ func WithFileStream(ctx context.Context, reader io.Reader) context.Context

+ func WithFileTransferOptions(ctx context.Context, options *SnowflakeFileTransferOptions) context.Context

+ func WithHigherPrecision(ctx context.Context) context.Context

+ func WithMultiStatement(ctx context.Context, num int) (context.Context, error)

+ func WithQueryIDChan(ctx context.Context, c chan<- string) context.Context

+ func WithRequestID(ctx context.Context, requestID uuid) context.Context

+ func WithStreamDownloader(ctx context.Context) context.Context

+ type ArrowBatch struct

+ func (rb *ArrowBatch) Fetch() (*[]array.Record, error)

+ type AuthType int

+ const AuthTypeExternalBrowser

+ const AuthTypeJwt

+ const AuthTypeOAuth

+ const AuthTypeOkta

+ const AuthTypeSnowflake

+ const AuthTypeTokenAccessor

+ func (authType AuthType) String() string

+ type Config struct

+ Account string

+ Application string

+ Authenticator AuthType

+ ClientIP net.IP

+ ClientTimeout time.Duration

+ Database string

+ DisableFileTransfers bool

+ DisableTelemetry bool

+ Host string

+ InsecureMode bool

+ JWTExpireTimeout time.Duration

+ KeepSessionAlive bool

+ LoginTimeout time.Duration

+ OCSPFailOpen OCSPFailOpenMode

+ OktaURL *url.URL

+ Params map[string]*string

+ Passcode string

+ PasscodeInPassword bool

+ Password string

+ Port int

+ PrivateKey *rsa.PrivateKey

+ Protocol string

+ Region string

+ RequestTimeout time.Duration

+ Role string

+ Schema string

+ Token string

+ TokenAccessor TokenAccessor

+ Transporter http.RoundTripper

+ User string

+ ValidateDefaultParameters ConfigBool

+ Warehouse string

+ func ParseDSN(dsn string) (cfg *Config, err error)

+ type ConfigBool uint8

+ const ConfigBoolFalse

+ const ConfigBoolTrue

+ type Connector struct

+ func NewConnector(driver InternalSnowflakeDriver, config Config) Connector

+ func (t Connector) Connect(ctx context.Context) (driver.Conn, error)

+ func (t Connector) Driver() driver.Driver

+ type InternalClient interface

+ Get func(context.Context, *url.URL, map[string]string, time.Duration) (*http.Response, error)

+ Post func(context.Context, *url.URL, map[string]string, []byte, time.Duration, bool) (*http.Response, error)

+ type InternalSnowflakeDriver interface

+ Open func(dsn string) (driver.Conn, error)

+ OpenWithConfig func(ctx context.Context, config Config) (driver.Conn, error)

+ type OCSPFailOpenMode uint32

+ const OCSPFailOpenFalse

+ const OCSPFailOpenTrue

+ type SFLogger interface

+ SetLogLevel func(level string) error

+ SetOutput func(output io.Writer)

+ WithContext func(ctx context.Context) *rlog.Entry

+ func CreateDefaultLogger() SFLogger

+ func GetLogger() SFLogger

+ type SnowflakeConnection interface

+ GetQueryStatus func(ctx context.Context, queryID string) (*SnowflakeQueryStatus, error)

+ type SnowflakeDriver struct

+ func (d SnowflakeDriver) Open(dsn string) (driver.Conn, error)

+ func (d SnowflakeDriver) OpenWithConfig(ctx context.Context, config Config) (driver.Conn, error)

+ type SnowflakeError struct

+ IncludeQueryID bool

+ Message string

+ MessageArgs []interface{}

+ Number int

+ QueryID string

+ SQLState string

+ func (se *SnowflakeError) Error() string

+ type SnowflakeFileTransferOptions struct

+ DisablePutOverwrite bool

+ MultiPartThreshold int64

+ RaisePutGetError bool

+ type SnowflakeParameter struct

+ ActivateVersion string

+ Default string

+ Description string

+ ExpiresAt string

+ IsExpired string

+ Key string

+ Level string

+ ParameterComment string

+ PartialRollout string

+ SetByClass string

+ SetByControllingParameter string

+ SetByThreadID string

+ SetByThreadName string

+ SetByUser string

+ SetInJob string

+ SetOn string

+ Type string

+ Unknown string

+ Value string

+ func ScanSnowflakeParameter(rows *sql.Rows) (*SnowflakeParameter, error)

+ type SnowflakeQueryStatus struct

+ EndTime int64

+ ErrorCode string

+ ErrorMessage string

+ ProducedRows int64

+ SQLText string

+ ScanBytes int64

+ StartTime int64

+ type SnowflakeResult interface

+ GetArrowBatches func() ([]*ArrowBatch, error)

+ GetQueryID func() string

+ GetStatus func() queryStatus

+ type TokenAccessor interface

+ GetTokens func() (token string, masterToken string, sessionID int64)

+ Lock func() error

+ SetTokens func(token string, masterToken string, sessionID int64)

+ Unlock func()