database

Feb 10, 2026

Changes in this version

+ const ContextKeyManager

+ var ErrNoPoolWorker = errors.Base("no pool worker function provided")

+ var ErrNotAWorkerPool = errors.Base("not configured for worker pools")

+ var ErrTxnSerialization = errors.Base("serialization failure")

+ var ErrValueNotManager = errors.Base("value is not Manager")

+ func SetManager(ctx context.Context, inst Manager) (context.Context, error)

+ func SetManagerIfAbsent(ctx context.Context, inst Manager) (context.Context, error)

+ func WithManager(ctx context.Context, fn func(Manager))

+ type BatchJob interface

+ Run func(ctx context.Context, runner Runner, data []dynworker.UserData) error

type Config

+ BatchTimeout types.Duration

+ PoolDrainTimeout types.Duration

+ PoolIdleTimeout types.Duration

+ PoolMaxWorkers int

+ PoolMinWorkers int

+ UsePool bool

type Database

+ Rebind func(string) string

+ Runner func() Runner

+ WithTransaction func(context.Context, TxnFn) error

type Manager

+ func FromManager(ctx context.Context) Manager

+ func GetManager(ctx context.Context) (Manager, error)

+ func MustGetManager(ctx context.Context) Manager

+ func TryGetManager(ctx context.Context) (Manager, bool)

+ OpenWorker func(context.Context, *Config, BatchJob) (Worker, error)

+ type Runner interface

+ GetContext func(context.Context, any, string, ...any) error

+ SelectContext func(context.Context, any, string, ...any) error

+ type TxnFn func(context.Context, Runner) error

+ type TxnProvider interface

+ Txn func(context.Context, Runner) error

+ type Worker interface

+ Database func() Database

+ Name func() string

+ Start func()

+ Stop func()

+ SubmitBatch func(dynworker.UserData) error

+ SubmitJob func(WorkerJob) error

+ func NewWorker(parent context.Context, cfg *Config, dbase Database, handler BatchJob) Worker

+ type WorkerJob interface

+ Run func(ctx context.Context, runner Runner) error

Jul 10, 2025

Changes in this version

+ func Exec(ctx context.Context, query string, args ...any) (sql.Result, error)

+ func ExecStmt(ctx context.Context, stmt *stmt, args ...any) (sql.Result, error)

+ func Get(ctx context.Context, dest any, query string, args ...any) error

+ func NamedExec(ctx context.Context, query string, arg any) (sql.Result, error)

+ func Prepare(ctx context.Context, query string, args ...any) (*stmt, error)

+ func Queryx(ctx context.Context, query string, args ...any) (*sqlx.Rows, error)

+ func QueryxContext(ctx context.Context, query string, args ...any) (*sqlx.Rows, error)

+ func Select(ctx context.Context, dest any, query string, args ...any) error

Sep 17, 2024

Changes in this version

type Manager

+ func NewManager() Manager

Sep 11, 2024

Changes in this version

+ const StringConnClosed

+ const StringDeadlock

+ const StringLostConn

+ var ErrLostConn error = errors.Base("lost connection during query")

+ var ErrServerConnClosed error = errors.Base("server connection closed")

+ var ErrTxnDeadlock error = errors.Base("deadlock found when trying to get lock")

type Database

+ GetError func(error) error

Sep 10, 2024

Changes in this version

+ const KeyTransaction

+ var ErrNoDatabase error = errors.Base("no database name provided")

+ var ErrNoDriver error = errors.Base("no driver provided")

+ var ErrNoHostname error = errors.Base("no hostname provided")

+ var ErrNoPassword error = errors.Base("no password provided")

+ var ErrNoUsername error = errors.Base("no username provided")

+ var ErrTxnContext error = errors.Base("could not create transaction context")

+ var ErrTxnKeyNotFound error = errors.Base("transaction key not found")

+ var ErrTxnKeyNotTxn error = errors.Base("key value is not a transaction")

+ var ErrTxnStart error = errors.Base("could not start transaction")

type Database

+ func FromDB(db *sql.DB, driver string) Database

+ Commit func(context.Context) error

+ Rollback func(context.Context) error

+ Tx func(context.Context) (*sqlx.Tx, error)

+ type Manager interface

+ CheckDB func(Database) error

+ Open func(string, string) (Database, error)

+ OpenConfig func(*Config) (Database, error)

Jul 30, 2023

Changes in this version

type Config

+ PasswordSecret string

+ UsernameSecret string

+ func (c *Config) Validate() error

+ type Cursor struct

+ Limit int64

+ Offset int64

+ var EmptyCursor *Cursor = &Cursor{ ... }

+ func NewCursor(offset, limit int64) *Cursor

+ func (c Cursor) Valid() bool

+ type NullBool struct

+ func (x NullBool) MarshalJSON() ([]byte, error)

+ type NullByte struct

+ func (x NullByte) MarshalJSON() ([]byte, error)

+ type NullFloat64 struct

+ func (x NullFloat64) MarshalJSON() ([]byte, error)

+ type NullInt16 struct

+ func (x NullInt16) MarshalJSON() ([]byte, error)

+ type NullInt32 struct

+ func (x NullInt32) MarshalJSON() ([]byte, error)

+ type NullInt64 struct

+ func (x NullInt64) MarshalJSON() ([]byte, error)

+ type NullString struct

+ func (x NullString) MarshalJSON() ([]byte, error)

+ type NullTime struct

+ func (x NullTime) MarshalJSON() ([]byte, error)

Mar 24, 2022

Changes in this version

+ type Config struct

+ BatchSize int

+ Database string

+ Driver string

+ Hostname string

+ MaxIdleConns int

+ MaxOpenConns int

+ Password string

+ Port int

+ SetPoolLimits bool

+ Username string

+ func NewConfig() *Config

+ func (c *Config) ToDSN() string

+ type Database struct

+ func (db *Database) Begin() (*sql.Tx, error)

+ func (db *Database) Beginx() (*sqlx.Tx, error)

+ func (db *Database) Close() error

+ func (db *Database) Exec(query string, args ...interface{}) (sql.Result, error)

+ func (db *Database) Get(what interface{}, query string, args ...interface{}) error

+ func (db *Database) MustBegin() *sqlx.Tx

+ func (db *Database) NamedExec(query string, args interface{}) (sql.Result, error)

+ func (db *Database) Ping() error

+ func (db *Database) Prepare(query string) (*sql.Stmt, error)

+ func (db *Database) Query(query string, args ...interface{}) (IRows, error)

+ func (db *Database) QueryRowx(query string, args ...interface{}) IRow

+ func (db *Database) Queryx(query string, args ...interface{}) (IRowsx, error)

+ func (db *Database) Select(what interface{}, query string, args ...interface{}) error

+ func (db *Database) SetMaxIdleConns(limit int)

+ func (db *Database) SetMaxOpenConns(limit int)

+ type DatabaseMgr struct

+ func (dbm *DatabaseMgr) CheckDB(db IDatabase) error

+ func (dbm *DatabaseMgr) Open(driver string, dsn string) (IDatabase, error)

+ func (dbm *DatabaseMgr) OpenConfig(conf *Config) (IDatabase, error)

+ type IDatabase interface

+ Begin func() (*sql.Tx, error)

+ Beginx func() (*sqlx.Tx, error)

+ Close func() error

+ Exec func(string, ...interface{}) (sql.Result, error)

+ Get func(interface{}, string, ...interface{}) error

+ MustBegin func() *sqlx.Tx

+ NamedExec func(string, interface{}) (sql.Result, error)

+ Ping func() error

+ Prepare func(string) (*sql.Stmt, error)

+ Query func(string, ...interface{}) (IRows, error)

+ QueryRowx func(string, ...interface{}) IRow

+ Queryx func(string, ...interface{}) (IRowsx, error)

+ Select func(interface{}, string, ...interface{}) error

+ SetMaxIdleConns func(int)

+ SetMaxOpenConns func(int)

+ func Open(driver string, dsn string) (IDatabase, error)

+ type IDatabaseMgr interface

+ CheckDB func(IDatabase) error

+ Open func(string, string) (IDatabase, error)

+ OpenConfig func(*Config) (IDatabase, error)

+ type IRow interface

+ Err func() error

+ Scan func(dest ...interface{}) error

+ type IRows interface

+ Close func() error

+ ColumnTypes func() ([]*sql.ColumnType, error)

+ Columns func() ([]string, error)

+ Err func() error

+ Next func() bool

+ NextResultSet func() bool

+ Scan func(...interface{}) error

+ type IRowsx interface

+ Close func() error

+ ColumnTypes func() ([]*sql.ColumnType, error)

+ Columns func() ([]string, error)

+ Err func() error

+ Next func() bool

+ NextResultSet func() bool

+ Scan func(...interface{}) error

+ StructScan func(interface{}) error

+ type ITx interface

+ Commit func()

+ NamedExec func(string, interface{}) (sql.Result, error)

+ type Tx struct

+ func (tx *Tx) Commit()

+ func (tx *Tx) NamedExec(query string, arg interface{}) (sql.Result, error)