Method Open

backend/plugin/db/spanner/spanner.go:65–101

Open opens a Spanner 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 Spanner 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

	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)
	}
	if config.ConnectionContext.DatabaseName != "" {
		d.databaseName = config.ConnectionContext.DatabaseName
		dsn := getDSN(d.config.DataSource.Host, config.ConnectionContext.DatabaseName)
		client, err := spanner.NewClient(
			ctx,
			dsn,
			o...,
		)
		if err != nil {
			return nil, err
		}
		d.client = client
	}

	dbClient, err := spannerdb.NewDatabaseAdminClient(ctx, o...)
	if err != nil {
		return nil, err
	}

	d.dbClient = dbClient
	return d, nil
}

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