bq

Documentation

Index

• type Client
  • func New(ctx context.Context, projectID types.GoogleProjectID, ...) (*Client, error)
  • func (x *Client) CreateTable(ctx context.Context, table types.BQTableID, md *bigquery.TableMetadata) error
  • func (x *Client) GetMetadata(ctx context.Context, table types.BQTableID) (*bigquery.TableMetadata, error)
  • func (x *Client) Insert(ctx context.Context, table types.BQTableID, schema bigquery.Schema, data any) error
  • func (x *Client) UpdateTable(ctx context.Context, table types.BQTableID, md bigquery.TableMetadataToUpdate, ...) error

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, projectID types.GoogleProjectID, datasetID types.BQDatasetID, options ...option.ClientOption) (*Client, error)

func (*Client) CreateTable

func (x *Client) CreateTable(ctx context.Context, table types.BQTableID, md *bigquery.TableMetadata) error

CreateTable implements interfaces.BigQuery.

func (*Client) GetMetadata

func (x *Client) GetMetadata(ctx context.Context, table types.BQTableID) (*bigquery.TableMetadata, error)

GetMetadata implements interfaces.BigQuery. If the table does not exist, it returns nil.

func (*Client) Insert

func (x *Client) Insert(ctx context.Context, table types.BQTableID, schema bigquery.Schema, data any) error

Insert implements interfaces.BigQuery.

func (*Client) UpdateTable

func (x *Client) UpdateTable(ctx context.Context, table types.BQTableID, md bigquery.TableMetadataToUpdate, eTag string) error

UpdateTable implements interfaces.BigQuery.