sql

Mar 6, 2022

Changes in this version

type Logger

+ Info func(...interface{})

Nov 6, 2021

Changes in this version

+ func Connect(db *sql.DB) error

+ type Migration func(*sql.DB) error

type Option

+ func WithMigration(migration Migration) Option

Jun 14, 2021

Changes in this version

+ type Config interface

+ DSN func() string

+ DriverName func() string

type DB

+ Begin func(ctx context.Context, opts *TxOptions) (Tx, error)

+ Prepare func(ctx context.Context, query string) (Stmt, error)

+ type Logger = log.Logger

type Option

+ func WithLogger(logger Logger) Option

+ type Stmt interface

+ Close func() error

+ Exec func(ctx context.Context, args ...interface{}) (Result, error)

+ Query func(ctx context.Context, args ...interface{}) (*Rows, error)

+ QueryRow func(ctx context.Context, args ...interface{}) *Row

type Tx

+ Commit func() error

+ Exec func(ctx context.Context, query string, args ...interface{}) (Result, error)

+ Prepare func(ctx context.Context, query string) (Stmt, error)

+ Query func(ctx context.Context, query string, args ...interface{}) (*Rows, error)

+ QueryRow func(ctx context.Context, query string, args ...interface{}) *Row

+ Rollback func() error

+ Stmt func(ctx context.Context, stmt Stmt) Stmt

Oct 16, 2023

Changes in this version

type DB

+ DB *sql.DB

Oct 16, 2023

Changes in this version

+ const DefaultReconnectRetries

+ const DefaultTxRetries

+ var ErrNoRows = sql.ErrNoRows

+ func ErrCode(err error) string

+ func IsAdminShutdown(err error) bool

+ func IsRetryable(err error) bool

+ type DB struct

+ func Open(ctx context.Context, driver, connectURL string, opts ...Option) (*DB, error)

+ func (db *DB) BeginTx(ctx context.Context, opts *TxOptions) (*Tx, error)

+ func (db *DB) Close() error

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

+ func (db *DB) Ping(ctx context.Context) error

+ func (db *DB) Query(ctx context.Context, query string, args ...any) (*Rows, error)

+ func (db *DB) QueryRow(ctx context.Context, query string, args ...any) *Row

+ func (db *DB) Tx(ctx context.Context, opts *TxOptions, fn func(tx *Tx) error) error

+ type Func func(ctx context.Context) error

+ type MiddlewareFunc func(Func) Func

+ type NullString = sql.NullString

+ type Option interface

+ Apply func(*Options)

+ func WithReconnect(numRetries int) Option

+ func WithTxRetries(numRetries int) Option

+ type Options struct

+ ReconnectEnabled bool

+ ReconnectRetries int

+ TxRetries int

+ type Result = sql.Result

+ type Row = sql.Row

+ type Rows = sql.Rows

+ type Tx = sql.Tx

+ type TxOptions = sql.TxOptions