trino

Documentation

Index

• func NewQuerier[T any](conn *TrinoExecutor) querier.Querier[T]
• type Executor
• type Querier
  • 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)
• type TrinoConf
• type TrinoExecutor
  • func NewTrinoExecutor(ctx context.Context, conf *TrinoConf) (*TrinoExecutor, error)
  • func (e *TrinoExecutor) Close() error
  • func (e *TrinoExecutor) Exec(ctx context.Context, q string) error
  • func (e *TrinoExecutor) GetDb() *sqlx.DB
  • func (e *TrinoExecutor) QueryRows(ctx context.Context, sql string, args ...interface{}) (*sqlx.Rows, error)

Functions

func NewQuerier

func NewQuerier[T any](conn *TrinoExecutor) querier.Querier[T]

Types

type Executor

type Executor interface {
	stdsql.StdSqlExecutor
}

type Querier

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

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)

type TrinoConf

type TrinoConf struct {
	Host      string
	Port      int
	Plaintext bool
	User      string
	Password  string
	Source    string // optional, e.g. "synq"
}

type TrinoExecutor

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

func NewTrinoExecutor

func NewTrinoExecutor(ctx context.Context, conf *TrinoConf) (*TrinoExecutor, error)

func (*TrinoExecutor) Close

func (e *TrinoExecutor) Close() error

func (*TrinoExecutor) Exec

func (e *TrinoExecutor) Exec(ctx context.Context, q string) error

func (*TrinoExecutor) GetDb

func (e *TrinoExecutor) GetDb() *sqlx.DB

func (*TrinoExecutor) QueryRows

func (e *TrinoExecutor) QueryRows(ctx context.Context, sql string, args ...interface{}) (*sqlx.Rows, error)