sqlflow

Mar 17, 2026

Changes in this version

+ var ErrEncryptionNotSupported = errors.New(...)

type Option

+ func WithDriver(d drivers.Config) Option

+ func WithPragma(name, value string) Option

Mar 17, 2026

Changes in this version

type Option

+ func WithDSNParams(params string) Option

Mar 10, 2026

Changes in this version

type Pool

+ func (p *Pool[Queries, D]) SetInactivityTimeout(d time.Duration)

Mar 6, 2026

Changes in this version

+ type Config struct

+ OnCloseFn func()

+ OnOpenFn func(path string, db *sql.DB) error

+ type Option func(*Config[Q])

+ func OnClose[Q any](fn func()) Option[Q]

+ func OnOpen[Q any](fn func(path string, db *sql.DB) error) Option[Q]

+ type PoolConfig struct

+ DBFactory func() []Option[Q]

+ type PoolOption func(*PoolConfig[Q])

+ func WithDBFactory[Q any](factory func() []Option[Q]) PoolOption[Q]

Mar 6, 2026

Changes in this version

+ var ErrKeyNotAvailable = errors.New("data key not available")

+ func NoRows(err error) bool

+ type DB struct

+ func GetDB[Queries any](dbName string, fsys fs.FS, querier Querier[Queries]) (*DB[Queries], error)

+ func GetEncryptedDB[Queries any](dbName string, fsys fs.FS, querier Querier[Queries], key []byte) (*DB[Queries], error)

+ func OpenDB[Queries any](dbName string, fsys fs.FS, querier Querier[Queries]) (*DB[Queries], error)

+ func OpenEncryptedDB[Queries any](dbName string, fsys fs.FS, querier Querier[Queries], key []byte) (*DB[Queries], error)

+ func TestDB[Queries any](fsys fs.FS, querier Querier[Queries]) *DB[Queries]

+ func (db *DB[Queries]) Checkpoint(ctx context.Context) error

+ func (db *DB[Queries]) Close() error

+ func (db *DB[Queries]) Read(ctx context.Context, f func(*Queries) error) error

+ func (db *DB[Queries]) Write(ctx context.Context, f func(*Queries) error) error

+ type DBTX interface

+ ExecContext func(context.Context, string, ...any) (sql.Result, error)

+ PrepareContext func(context.Context, string) (*sql.Stmt, error)

+ QueryContext func(context.Context, string, ...any) (*sql.Rows, error)

+ QueryRowContext func(context.Context, string, ...any) *sql.Row

+ type Pool struct

+ func NewEncryptedPool[Queries any](dir string, fsys fs.FS, querier Querier[Queries], maxCached int64, ...) (*Pool[Queries], error)

+ func NewPool[Queries any](dir string, fsys fs.FS, querier Querier[Queries], maxCached int64, ...) (*Pool[Queries], error)

+ func TestPool[Queries any](dir string, fsys fs.FS, querier Querier[Queries]) *Pool[Queries]

+ func (p *Pool[Queries]) Close() error

+ func (p *Pool[Queries]) Evict(userID string)

+ func (p *Pool[Queries]) ListKeys() ([]string, error)

+ func (p *Pool[Queries]) MigrateAll() error

+ func (p *Pool[Queries]) Read(ctx context.Context, key string, f func(*Queries) error) error

+ func (p *Pool[Queries]) Wait()

+ func (p *Pool[Queries]) Write(ctx context.Context, key string, f func(*Queries) error) error

+ type Querier func(tx DBTX) *Queries