athena

Jul 7, 2026

Changes in this version

+ func IsPermissionError(err error) bool

May 11, 2026

Changes in this version

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

+ type AthenaConf struct

+ AccessKeyID string

+ AllowDefaultChain bool

+ AwsProfile string

+ Catalog string

+ ExternalID string

+ Region string

+ RoleArn string

+ RoleSessionName string

+ SecretAccessKey string

+ SessionToken string

+ Workgroup string

+ type AthenaExecutor struct

+ func NewAthenaExecutor(ctx context.Context, conf *AthenaConf) (*AthenaExecutor, error)

+ func (e *AthenaExecutor) AccountID() string

+ func (e *AthenaExecutor) AthenaClient() *awsathena.Client

+ func (e *AthenaExecutor) Catalog() string

+ func (e *AthenaExecutor) Close() error

+ func (e *AthenaExecutor) Exec(ctx context.Context, query string, args ...any) error

+ func (e *AthenaExecutor) GetDb() *sqlx.DB

+ func (e *AthenaExecutor) GlueClient() *awsglue.Client

+ func (e *AthenaExecutor) Instance() string

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

+ func (e *AthenaExecutor) Region() string

+ func (e *AthenaExecutor) Select(ctx context.Context, dest any, query string, args ...any) error

+ func (e *AthenaExecutor) Workgroup() string

+ type Executor interface

+ type Querier struct

+ 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)