duckdb

package

v0.1.0 Latest Latest Go to latest Published: Mar 3, 2025 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

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

type DuckDBConf struct {
	MotherduckAccount string
	MotherduckToken   string
}

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

func NewDuckDBExecutor(ctx context.Context, conf *DuckDBConf) (*DuckDBExecutor, error)

func (e *DuckDBExecutor) Close() error

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

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

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

type Executor interface {
	QueryRows(ctx context.Context, q string, args ...interface{}) (*sqlx.Rows, error)
}