Documentation
¶
Index ¶
- func IsPermissionError(err error) bool
- func NewQuerier[T any](conn *DuckDBExecutor) querier.Querier[T]
- type DuckDBConf
- type DuckDBExecutor
- func (e *DuckDBExecutor) Close() error
- func (e *DuckDBExecutor) Exec(ctx context.Context, query string, args ...any) error
- func (e *DuckDBExecutor) GetDb() *sqlx.DB
- func (e *DuckDBExecutor) QueryRows(ctx context.Context, sql string, args ...interface{}) (*sqlx.Rows, error)
- func (e *DuckDBExecutor) Select(ctx context.Context, dest any, query string, args ...any) error
- type Executor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func IsPermissionError ¶ added in v0.15.3
IsPermissionError reports whether err indicates the DWH credentials lack the privileges required for the attempted operation.
func NewQuerier ¶
func NewQuerier[T any](conn *DuckDBExecutor) querier.Querier[T]
Types ¶
type DuckDBConf ¶
type DuckDBExecutor ¶
type DuckDBExecutor struct {
// contains filtered or unexported fields
}
func NewDuckDBExecutor ¶
func NewDuckDBExecutor(ctx context.Context, conf *DuckDBConf) (*DuckDBExecutor, error)
func NewLocalDuckDBExecutor ¶ added in v0.9.0
func NewLocalDuckDBExecutor(ctx context.Context, dsn string) (*DuckDBExecutor, error)
NewLocalDuckDBExecutor creates a DuckDB executor with a local database. Use dsn="" for an in-memory database, or a file path for a persistent database.
func (*DuckDBExecutor) Close ¶
func (e *DuckDBExecutor) Close() error
func (*DuckDBExecutor) GetDb ¶
func (e *DuckDBExecutor) GetDb() *sqlx.DB
Source Files
Click to show internal directories.
Click to hide internal directories.