database

Dec 20, 2024

Changes in this version

+ func Rebind(query string) string

May 28, 2024

Changes in this version

type Option

+ func WithMaxIdleTime(ex time.Duration) Option

Apr 10, 2024

Changes in this version

type Database

+ func (d *Database) ExecContext(ctx context.Context, query string, args ...any) (int64, error)

type Tx

+ func (t *Tx) ExecContext(ctx context.Context, query string, args ...any) (int64, error)

Oct 24, 2023

Changes in this version

type Database

+ func NewDB(driverName string, db *sql.DB) *Database

Mar 6, 2023

Changes in this version

type Database

+ func (d *Database) BeginTxCtx(ctx context.Context) (*Tx, error)

Feb 27, 2023

Changes in this version

+ type Database struct

+ func OpenDB(driverName, dsn string, ops ...Option) (*Database, error)

+ func (d *Database) BeginTx() (*Tx, error)

+ func (d *Database) Client() *sql.DB

+ func (d *Database) Close() error

+ func (d *Database) Delete(query string, args ...any) (int64, error)

+ func (d *Database) Insert(query string, args ...any) (int64, error)

+ func (d *Database) InsertContext(ctx context.Context, query string, args ...any) (int64, error)

+ func (d *Database) Ping(ctx context.Context) error

+ func (d *Database) QueryForMap(query string, args ...any) (map[string]any, error)

+ func (d *Database) QueryForMapSlice(query string, args ...any) ([]map[string]any, error)

+ func (d *Database) QueryMapContext(ctx context.Context, query string, args ...any) (map[string]any, error)

+ func (d *Database) QueryMapSliceContext(ctx context.Context, query string, args ...any) ([]map[string]any, error)

+ func (d *Database) Reset(db *sql.DB, dsn string)

+ func (d *Database) Update(query string, args ...any) (int64, error)

+ func (d *Database) UpdateContext(ctx context.Context, query string, args ...any) (int64, error)

+ type Option func(*Database)

+ func WithMaxConns(count int) Option

+ func WithMaxIdle(count int) Option

+ func WithMaxLifetime(ex time.Duration) Option

+ type Tx struct

+ func (t *Tx) Close() error

+ func (t *Tx) Delete(query string, args ...any) (int64, error)

+ func (t *Tx) DeleteContext(ctx context.Context, query string, args ...any) (int64, error)

+ func (t *Tx) HasError()

+ func (t *Tx) Insert(query string, args ...any) (int64, error)

+ func (t *Tx) InsertContext(ctx context.Context, query string, args ...any) (int64, error)

+ func (t *Tx) QueryForMap(query string, args ...any) (map[string]any, error)

+ func (t *Tx) QueryForMapSlice(query string, args ...any) ([]map[string]any, error)

+ func (t *Tx) QueryMapContext(ctx context.Context, query string, args ...any) (map[string]any, error)

+ func (t *Tx) QueryMapSliceContext(ctx context.Context, query string, args ...any) ([]map[string]any, error)

+ func (t *Tx) Update(query string, args ...any) (int64, error)

+ func (t *Tx) UpdateContext(ctx context.Context, query string, args ...any) (int64, error)