bigquery

Documentation

Index

• type BigQueryConf
• type BigQueryExecutor
  • func NewBigqueryExecutor(ctx context.Context, conf *BigQueryConf) (*BigQueryExecutor, error)
  • func (e *BigQueryExecutor) Close() error
  • func (e *BigQueryExecutor) Exec(ctx context.Context, sql string) error
  • func (e *BigQueryExecutor) GetBigQueryClient() *bigquery.Client
  • func (e *BigQueryExecutor) QueryRowsIterator(ctx context.Context, sql string, args ...interface{}) (*bigquery.RowIterator, error)
• type Executor
• type Querier
  • func NewQuerier[T any](conn *BigQueryExecutor) *Querier[T]
  • func (q *Querier[T]) Close() error
  • func (q *Querier[T]) Exec(ctx context.Context, sql string) error
  • func (q *Querier[T]) QueryAndProcessMany(ctx context.Context, sql string, ...) error
  • func (q *Querier[T]) QueryMany(ctx context.Context, sql string, opts ...exec.QueryManyOpt[T]) ([]*T, error)
  • func (q *Querier[T]) QueryMaps(ctx context.Context, sql string) ([]exec.QueryMapResult, error)

Types

type BigQueryConf

type BigQueryConf struct {
	ProjectId       string
	Region          string
	CredentialsJson string
	CredentialsFile string
}

type BigQueryExecutor

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

func NewBigqueryExecutor

func NewBigqueryExecutor(ctx context.Context, conf *BigQueryConf) (*BigQueryExecutor, error)

func (*BigQueryExecutor) Close

func (e *BigQueryExecutor) Close() error

func (*BigQueryExecutor) Exec

func (e *BigQueryExecutor) Exec(ctx context.Context, sql string) error

func (*BigQueryExecutor) GetBigQueryClient

func (e *BigQueryExecutor) GetBigQueryClient() *bigquery.Client

func (*BigQueryExecutor) QueryRowsIterator

func (e *BigQueryExecutor) QueryRowsIterator(
	ctx context.Context,
	sql string,
	args ...interface{},
) (*bigquery.RowIterator, error)

type Executor

type Executor interface {
	QueryRowsIterator(ctx context.Context, q string, args ...interface{}) (*bigquery.RowIterator, error)
}

type Querier

type Querier[T any] struct {
	// contains filtered or unexported fields
}

func NewQuerier

func NewQuerier[T any](conn *BigQueryExecutor) *Querier[T]

func (*Querier[T]) Close

func (q *Querier[T]) Close() error

func (*Querier[T]) Exec

func (q *Querier[T]) Exec(ctx context.Context, sql string) error

func (*Querier[T]) QueryAndProcessMany

func (q *Querier[T]) QueryAndProcessMany(ctx context.Context, sql string, handler func(ctx context.Context, batch []*T) error, opts ...exec.QueryManyOpt[T]) error

func (*Querier[T]) QueryMany

func (q *Querier[T]) QueryMany(
	ctx context.Context,
	sql string,
	opts ...exec.QueryManyOpt[T],
) ([]*T, error)

func (*Querier[T]) QueryMaps

func (q *Querier[T]) QueryMaps(ctx context.Context, sql string) ([]exec.QueryMapResult, error)