database

Documentation

Index

• type Database
  • func NewDB(driverName string, db *sql.DB) *Database
  • func OpenDB(driverName, dsn string, ops ...Option) (*Database, error)
  • func (d *Database) BeginTx() (*Tx, error)
  • func (d *Database) BeginTxCtx(ctx context.Context) (*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) ExecContext(ctx context.Context, 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 WithMaxConns(count int) Option
  • func WithMaxIdle(count int) Option
  • func WithMaxLifetime(ex time.Duration) Option
• type Tx
  • 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) ExecContext(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)

Types

type Database

type Database struct {
	// contains filtered or unexported fields
}

func NewDB

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

func OpenDB

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

func (*Database) BeginTx

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

func (*Database) BeginTxCtx

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

func (*Database) Client

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

func (*Database) Close

func (d *Database) Close() error

func (*Database) Delete

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

func (*Database) ExecContext

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

func (*Database) Insert

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

func (*Database) InsertContext

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

func (*Database) Ping

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

func (*Database) QueryForMap

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

func (*Database) QueryForMapSlice

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

func (*Database) QueryMapContext

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

func (*Database) QueryMapSliceContext

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

func (*Database) Reset

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

func (*Database) Update

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

func (*Database) UpdateContext

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

type Option

type Option func(*Database)

func WithMaxConns

func WithMaxConns(count int) Option

func WithMaxIdle

func WithMaxIdle(count int) Option

func WithMaxLifetime

func WithMaxLifetime(ex time.Duration) Option

type Tx

type Tx struct {
	// contains filtered or unexported fields
}

func (*Tx) Close

func (t *Tx) Close() error

func (*Tx) Delete

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

func (*Tx) DeleteContext

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

func (*Tx) ExecContext

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

func (*Tx) HasError

func (t *Tx) HasError()

func (*Tx) Insert

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

func (*Tx) InsertContext

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

func (*Tx) QueryForMap

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

func (*Tx) QueryForMapSlice

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

func (*Tx) QueryMapContext

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

func (*Tx) QueryMapSliceContext

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

func (*Tx) Update

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

func (*Tx) UpdateContext

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