db

Documentation

Index

• type DB
  • func New(conn QueryRunner) *DB
  • func (d *DB) BeginTx(ctx context.Context, opts *sql.TxOptions) (Tx, error)
  • func (d *DB) Exec(query string, args ...interface{}) (sql.Result, error)
  • func (d *DB) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
  • func (d *DB) Query(query string, args ...interface{}) (*sql.Rows, error)
  • func (d *DB) QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
  • func (d *DB) QueryRow(query string, args ...interface{}) *sql.Row
  • func (d *DB) QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
  • func (d *DB) SetLogger(l logger.Logger)
• type QueryLogger
• type QueryRunner
• type Tx

Types

type DB

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

func New

func New(conn QueryRunner) *DB

func (*DB) BeginTx

func (d *DB) BeginTx(ctx context.Context, opts *sql.TxOptions) (Tx, error)

func (*DB) Exec

func (d *DB) Exec(query string, args ...interface{}) (sql.Result, error)

func (*DB) ExecContext

func (d *DB) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)

func (*DB) Query

func (d *DB) Query(query string, args ...interface{}) (*sql.Rows, error)

func (*DB) QueryContext

func (d *DB) QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)

func (*DB) QueryRow

func (d *DB) QueryRow(query string, args ...interface{}) *sql.Row

func (*DB) QueryRowContext

func (d *DB) QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row

func (*DB) SetLogger

func (d *DB) SetLogger(l logger.Logger)

type QueryLogger

type QueryLogger interface {
	Log(query string, args ...any)
	Println(v ...any)
	Printf(format string, v ...any)
}

type QueryRunner

type QueryRunner interface {
	QueryRow(query string, args ...interface{}) *sql.Row
	Query(query string, args ...interface{}) (*sql.Rows, error)
	Exec(query string, args ...interface{}) (sql.Result, error)
	QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
	QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
}

type Tx

type Tx interface {
	QueryRunner
	Commit() error
	Rollback() error
}