Method Open

backend/plugin/db/bigquery/bigquery.go:50–72

Open opens a BigQuery driver. It must connect to a specific database. If database isn't provided, part of the driver cannot function.

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

// Open opens a BigQuery driver. It must connect to a specific database.
// If database isn't provided, part of the driver cannot function.
func (d *Driver) Open(ctx context.Context, _ storepb.Engine, config db.ConnectionConfig) (db.Driver, error) {
	if config.DataSource.Host == "" {
		return nil, errors.New("host cannot be empty")
	}
	d.config = config
	d.connCtx = config.ConnectionContext
	d.databaseName = config.ConnectionContext.DatabaseName

	var o []option.ClientOption
	if gcpCredential := config.DataSource.GetGcpCredential(); gcpCredential != nil {
		credOption, err := util.GCPCredentialOption([]byte(gcpCredential.Content))
		if err != nil {
			return nil, err
		}
		o = append(o, credOption)
	}
	client, err := bigquery.NewClient(ctx, config.DataSource.Host, o...)
	if err != nil {
		return nil, err
	}
	d.client = client
	return d, nil
}

// Close closes the driver.
func (d *Driver) Close(_ context.Context) error {