store

type QueryInterceptor ¶

type QueryInterceptor interface {
	QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
	QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
}

QueryInterceptor provides database query methods with transaction awareness. Implementations route queries through an active transaction if present in context.

NOTE: DuckDB durability is handled by the WAL — it replays on startup. Explicit checkpointing is only needed before file-level operations (close, clone) and is available via Store2.Checkpoint().

func NewQueryInterceptor(db *sql.DB) QueryInterceptor

type Transactor ¶

type Transactor interface {
	WithTx(ctx context.Context, fn func(ctx context.Context) error) error
}

Transactor provides transaction management.

func NewTransactor(db *sql.DB) Transactor