Version 2.0.0 of the Go Snowflake Driver was released on March 3rd, 2026. This major version includes breaking changes that require code updates when migrating from v1.x.
Update your go.mod to use v2:
go get -u github.com/snowflakedb/gosnowflake/v2Update imports in your code:
// Old (v1)
import "github.com/snowflakedb/gosnowflake"
// New (v2)
import "github.com/snowflakedb/gosnowflake/v2"The public Arrow batches API now lives in github.com/snowflakedb/gosnowflake/v2/arrowbatches.
Importing that sub-package pulls in the additional Arrow compute dependency only for applications
that use Arrow batches directly.
Migration:
import (
"context"
"database/sql/driver"
sf "github.com/snowflakedb/gosnowflake/v2"
"github.com/snowflakedb/gosnowflake/v2/arrowbatches"
)
ctx := arrowbatches.WithArrowBatches(context.Background())
var rows driver.Rows
err := conn.Raw(func(x any) error {
rows, err = x.(driver.QueryerContext).QueryContext(ctx, query, nil)
return err
})
if err != nil {
// handle error
}
batches, err := arrowbatches.GetArrowBatches(rows.(sf.SnowflakeRows))
if err != nil {
// handle error
}Optional helper mapping:
sf.WithArrowBatchesTimestampOption→arrowbatches.WithTimestampOptionsf.WithArrowBatchesUtf8Validation→arrowbatches.WithUtf8Validationsf.ArrowSnowflakeTimestampToTime→arrowbatches.ArrowSnowflakeTimestampToTimesf.WithOriginalTimestamp→arrowbatches.WithTimestampOption(ctx, arrowbatches.UseOriginalTimestamp)
Renamed fields:
// Old (v1)
config := &gosnowflake.Config{
KeepSessionAlive: true,
InsecureMode: true,
DisableTelemetry: true,
}
// New (v2)
config := &gosnowflake.Config{
ServerSessionKeepAlive: true, // Renamed for consistency with other drivers
DisableOCSPChecks: true, // Replaces InsecureMode
// DisableTelemetry removed - use CLIENT_TELEMETRY_ENABLED session parameter
}Removed fields:
ClientIP- No longer usedMfaTokenandIdToken- Now unexportedDisableTelemetry- UseCLIENT_TELEMETRY_ENABLEDsession parameter instead
The built-in logger is now based on Go's standard log/slog:
logger := gosnowflake.GetLogger()
_ = logger.SetLogLevel("debug")For custom logging, continue implementing SFLogger.
If you want to customize the built-in slog handler, type-assert GetLogger() to SFSlogLogger
and call SetHandler.
Configuration options:
// Old (v1)
options := &gosnowflake.SnowflakeFileTransferOptions{
RaisePutGetError: true,
GetFileToStream: true,
}
ctx = gosnowflake.WithFileStream(ctx, stream)
// New (v2)
// RaisePutGetError removed - errors always raised
// GetFileToStream removed - use WithFileGetStream instead
ctx = gosnowflake.WithFilePutStream(ctx, stream) // Renamed from WithFileStream
ctx = gosnowflake.WithFileGetStream(ctx, stream) // For GET operations// Old (v1)
ctx, err := gosnowflake.WithMultiStatement(ctx, 0)
if err != nil {
// handle error
}
// New (v2)
ctx = gosnowflake.WithMultiStatement(ctx, 0) // No error returned// Old (v1)
values := gosnowflake.Array(data)
// New (v2)
values, err := gosnowflake.Array(data) // Now returns error for unsupported types
if err != nil {
// handle error
}// Old (v1)
ctx = gosnowflake.WithMapValuesNullable(ctx)
ctx = gosnowflake.WithArrayValuesNullable(ctx)
// New (v2)
ctx = gosnowflake.WithEmbeddedValuesNullable(ctx) // Handles both maps and arraysChunk download workers:
// Old (v1)
gosnowflake.MaxChunkDownloadWorkers = 10 // Global variable
// New (v2)
// Configure via CLIENT_PREFETCH_THREADS session parameter.
// NOTE: The default is 4.
db.Exec("ALTER SESSION SET CLIENT_PREFETCH_THREADS = 10")import "crypto/tls"
// Old (v1)
gosnowflake.SnowflakeTransport = yourTransport
// New (v2)
config := &gosnowflake.Config{
Transporter: yourCustomTransport,
}
// Or, if you only need custom TLS settings/certificates:
tlsConfig := &tls.Config{
// ...
}
_ = gosnowflake.RegisterTLSConfig("custom", tlsConfig)
config.TLSConfigName = "custom"If you use the skip registration environment variable:
# Old (v1)
GOSNOWFLAKE_SKIP_REGISTERATION=true # Note the typo
# New (v2)
GOSNOWFLAKE_SKIP_REGISTRATION=true # Typo fixed- Full list of changes: See CHANGELOG.md
- Questions or issues: GitHub Issues
For official support and urgent, production-impacting issues, please contact Snowflake Support.
This topic provides instructions for installing, running, and modifying the Go Snowflake Driver. The driver supports Go's database/sql package.
The following software packages are required to use the Go Snowflake Driver.
The latest driver requires the Go language 1.24 or higher. The supported operating systems are 64-bits Linux, Mac OS, and Windows, but you may run the driver on other platforms if the Go language works correctly on those platforms.
If you don't have a project initialized, set it up.
go mod init example.com/snowflakeGet Gosnowflake source code, if not installed.
go get -u github.com/snowflakedb/gosnowflake/v2For detailed documentation and basic usage examples, please see the documentation at godoc.org.
This driver currently does not support GCP regional endpoints. Please ensure that any workloads using through this driver do not require support for regional endpoints on GCP. If you have questions about this, please contact Snowflake Support.
The driver uses Rust library called sf_mini_core, you can find its source code here
Snowflake provides a set of sample programs to test with. Set the environment variable $GOPATH to the top directory of your workspace, e.g., ~/go and make certain to
include $GOPATH/bin in the environment variable $PATH. Run the make command to build all sample programs.
make installIn the following example, the program select1.go is built and installed in $GOPATH/bin and can be run from the command line:
SNOWFLAKE_TEST_ACCOUNT=<your_account> \
SNOWFLAKE_TEST_USER=<your_user> \
SNOWFLAKE_TEST_PASSWORD=<your_password> \
select1
Congrats! You have successfully run SELECT 1 with Snowflake DB!The developer notes are hosted with the source code on GitHub.
Set the Snowflake connection info in parameters.json:
{
"testconnection": {
"SNOWFLAKE_TEST_USER": "<your_user>",
"SNOWFLAKE_TEST_PASSWORD": "<your_password>",
"SNOWFLAKE_TEST_ACCOUNT": "<your_account>",
"SNOWFLAKE_TEST_WAREHOUSE": "<your_warehouse>",
"SNOWFLAKE_TEST_DATABASE": "<your_database>",
"SNOWFLAKE_TEST_SCHEMA": "<your_schema>",
"SNOWFLAKE_TEST_ROLE": "<your_role>",
"SNOWFLAKE_TEST_DEBUG": "false"
}
}Install jq so that the parameters can get parsed correctly, and run make test in your Go development environment:
make testThis is for debugging Large SQL statements (greater than 300 characters). If you want to enable debug mode, set SNOWFLAKE_TEST_DEBUG to true in parameters.json, or export it in your shell instance.
If you would like to ensure that certain tags are always present in the logs, RegisterClientLogContextHook can be used in your init function. See example below.
import "github.com/snowflakedb/gosnowflake/v2"
func init() {
// each time the logger is used, the logs will contain a REQUEST_ID field with requestID the value extracted
// from the context
gosnowflake.RegisterClientLogContextHook("REQUEST_ID", func(ctx context.Context) interface{} {
return requestIdFromContext(ctx)
})
}If you want to change the log level, SetLogLevel can be used in your init function like this:
import "github.com/snowflakedb/gosnowflake/v2"
func init() {
// The following line changes the log level to debug
_ = gosnowflake.GetLogger().SetLogLevel("debug")
}The following is a list of options you can pass in to set the level from least to most verbose:
"OFF""fatal""error""warn""info""debug""trace"
Configure your testing environment as described above and run make cov. The coverage percentage will be printed on the console when the testing completes.
make covFor more detailed analysis, results are printed to coverage.txt in the project directory.
To read the coverage report, run:
go tool cover -html=coverage.txtYou may use your preferred editor to edit the driver code. Make certain to run make fmt lint before submitting any pull request to Snowflake. This command formats your source code according to the standard Go style and detects any coding style issues.