impldb

Documentation

Index

• func Close(h *Handle) error
• func NullInt64(v int64) sql.NullInt64
• func NullStr(s string) sql.NullString
• func RollbackTx(tx *sql.Tx)
• type Handle
  • func Open(ctx context.Context, dbPath string, opts OpenOptions) (*Handle, error)
  • func OpenNoMigrate(ctx context.Context, dbPath string, opts OpenOptions) (*Handle, error)
• type OpenOptions
  • func DefaultOpenOptions() OpenOptions

Functions

func Close

func Close(h *Handle) error

func NullInt64

func NullInt64(v int64) sql.NullInt64

NullInt64 returns a valid sql.NullInt64 if v > 0, otherwise null.

func NullStr

func NullStr(s string) sql.NullString

NullStr returns a valid sql.NullString if s is non-empty, otherwise null.

func RollbackTx

func RollbackTx(tx *sql.Tx)

Types

type Handle

type Handle struct {
	DB      *sql.DB
	Queries *impldbgen.Queries
}

func Open

func Open(ctx context.Context, dbPath string, opts OpenOptions) (*Handle, error)

func OpenNoMigrate

func OpenNoMigrate(ctx context.Context, dbPath string, opts OpenOptions) (*Handle, error)

OpenNoMigrate opens the database without running migrations. Use this on hot paths (e.g., broker observation emission) where the database is expected to already exist and be at the current schema version. Returns an error if the database file does not exist.

type OpenOptions

type OpenOptions struct {
	BusyTimeout time.Duration
	Synchronous string
	TxImmediate bool // if true, all BEGIN statements use IMMEDIATE locking
}

func DefaultOpenOptions

func DefaultOpenOptions() OpenOptions

DefaultOpenOptions returns the standard options used by most callers: BusyTimeout 250ms, Synchronous "NORMAL".