executers

Documentation

Overview

nolint: sqlclosecheck, wrapcheck

nolint: sqlclosecheck, wrapcheck

Index

• type Executer
• type PreparedExecuter
  • func FromDB(filename string) (*PreparedExecuter, error)
  • func NewPrepared(db *sql.DB) *PreparedExecuter
  • func (p *PreparedExecuter) Close() error
  • func (p *PreparedExecuter) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
  • func (p *PreparedExecuter) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
  • func (p *PreparedExecuter) QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
  • func (p *PreparedExecuter) QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
  • func (p *PreparedExecuter) WithTX(ctx context.Context, fun func(Executer) error) error
• type TxExecuter
  • func NewTX(tx *sql.Tx) *TxExecuter
  • func (t *TxExecuter) Close() error
  • func (t *TxExecuter) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
  • func (t *TxExecuter) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
  • func (t *TxExecuter) QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
  • func (t *TxExecuter) QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
  • func (t *TxExecuter) WithTX(_ context.Context, fun func(Executer) error) error

Types

type Executer

type Executer interface {
	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)
	PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
	WithTX(ctx context.Context, fun func(Executer) error) error
	Close() error
}

type PreparedExecuter

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

func FromDB

func FromDB(filename string) (*PreparedExecuter, error)

func NewPrepared

func NewPrepared(db *sql.DB) *PreparedExecuter

func (*PreparedExecuter) Close

func (p *PreparedExecuter) Close() error

func (*PreparedExecuter) ExecContext

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

func (*PreparedExecuter) PrepareContext

func (p *PreparedExecuter) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)

func (*PreparedExecuter) QueryContext

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

func (*PreparedExecuter) QueryRowContext

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

func (*PreparedExecuter) WithTX

func (p *PreparedExecuter) WithTX(ctx context.Context, fun func(Executer) error) error

type TxExecuter

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

func NewTX

func NewTX(tx *sql.Tx) *TxExecuter

func (*TxExecuter) Close

func (t *TxExecuter) Close() error

func (*TxExecuter) ExecContext

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

func (*TxExecuter) PrepareContext

func (t *TxExecuter) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)

func (*TxExecuter) QueryContext

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

func (*TxExecuter) QueryRowContext

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

func (*TxExecuter) WithTX

func (t *TxExecuter) WithTX(_ context.Context, fun func(Executer) error) error