Method Open

backend/plugin/db/snowflake/snowflake.go:51–71

Open opens a Snowflake driver.

(_ context.Context, dbType storepb.Engine, config db.ConnectionConfig)

// Open opens a Snowflake driver.
func (d *Driver) Open(_ context.Context, dbType storepb.Engine, config db.ConnectionConfig) (db.Driver, error) {
	dsn, loggedDSN, err := buildSnowflakeDSN(config)
	if err != nil {
		return nil, err
	}

	slog.Debug("Opening Snowflake driver",
		slog.String("dsn", loggedDSN),
		slog.String("environment", config.ConnectionContext.EnvironmentID),
		slog.String("database", config.ConnectionContext.InstanceID),
	)
	db, err := sql.Open("snowflake", dsn)
	if err != nil {
		panic(err)
	}
	d.dbType = dbType
	d.db = db
	d.connectionCtx = config.ConnectionContext
	d.databaseName = config.ConnectionContext.DatabaseName
	return d, nil
}

// buildSnowflakeDSN returns the Snowflake Golang DSN and a redacted version of the DSN.
func buildSnowflakeDSN(config db.ConnectionConfig) (string, string, error) {