bigquery

package

v1.20.3-profiles1 Latest Latest Go to latest Published: Jan 6, 2026 License: MIT Imports: 21 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/rudderlabs/sqlconnect-go

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func GoquDialectOptions() *sqlgen.SQLDialectOptions
func GoquExpressions() *base.Expressions
type Config
- func (c *Config) GetMaxRetryDuration() *time.Duration
- func (c *Config) Parse(configJSON json.RawMessage) error
type DB
- func NewDB(configJSON json.RawMessage) (*DB, error)

Constants ¶

View Source

const (
	DatabaseType = "bigquery"
)

Variables ¶

This section is empty.

Functions ¶

func GoquDialectOptions ¶ added in v1.10.0

func GoquDialectOptions() *sqlgen.SQLDialectOptions

func GoquExpressions ¶ added in v1.10.0

func GoquExpressions() *base.Expressions

Types ¶

type Config ¶

type Config struct {
	ProjectID       string `json:"project"`
	CredentialsJSON string `json:"credentials"`

	UseLegacyMappings bool `json:"useLegacyMappings"`

	// Retry configuration for BigQuery API calls
	// MaxRetries limits the number of retry attempts (default: unlimited if not set)
	MaxRetries *int `json:"maxRetries,omitempty"`
	// MaxRetryDuration limits total time spent retrying (e.g., "10m", "30s")
	// If both MaxRetries and MaxRetryDuration are set, whichever limit is hit first applies
	MaxRetryDuration *string `json:"maxRetryDuration,omitempty"`
}

func (*Config) GetMaxRetryDuration ¶

func (c *Config) GetMaxRetryDuration() *time.Duration

GetMaxRetryDuration parses the MaxRetryDuration string into a time.Duration Returns nil if MaxRetryDuration is not set or invalid

func (*Config) Parse ¶

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

Parse parses the given JSON into the config

type DB ¶

type DB struct {
	*base.DB
}

func NewDB ¶

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

NewDB creates a new bigquery db client

func (*DB) CurrentCatalog ¶ added in v1.1.0

func (db *DB) CurrentCatalog(ctx context.Context) (string, error)

func (*DB) ListSchemas ¶

func (db *DB) ListSchemas(ctx context.Context) ([]sqlconnect.SchemaRef, error)

ListSchemas uses the bigquery client instead of [INFORMATION_SCHEMA.SCHEMATA] due to absence of a region qualifier https://cloud.google.com/bigquery/docs/information-schema-datasets-schemata#scope_and_syntax

func (*DB) SchemaExists ¶

func (db *DB) SchemaExists(ctx context.Context, schemaRef sqlconnect.SchemaRef) (bool, error)

SchemaExists uses the bigquery client instead of [INFORMATION_SCHEMA.SCHEMATA] due to absence of a region qualifier https://cloud.google.com/bigquery/docs/information-schema-datasets-schemata#scope_and_syntax

func (*DB) WithBigqueryClient ¶

func (db *DB) WithBigqueryClient(ctx context.Context, f func(*bigquery.Client) error) error

WithBigqueryClient runs the provided function by providing access to a native bigquery client, the underlying client that is used by the bigquery driver

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
driver

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