db

Documentation

Index

• func ToSnakeCase(s string) string
• type Client
  • func Open(ctx context.Context, dsn string, opts ...Option) (*Client, error)
  • func (db *Client) Exec(ctx context.Context, query string, args ...any) (sql.Result, error)
  • func (db *Client) ExecNamed(ctx context.Context, query string, arg any) (sql.Result, error)
  • func (db *Client) RunInTransaction(ctx context.Context, txFunc TxFunc, opts ...TxOption) (err error)
  • func (db *Client) Select(ctx context.Context, ptr any, query string, args ...any) error
  • func (db *Client) SelectRow(ctx context.Context, ptr any, query string, args ...any) error
• type DB
• type Option
  • func WithQueryTracer(tracers ...pgx.QueryTracer) Option
• type Transactional
• type Tx
  • func (t *Tx) Exec(ctx context.Context, query string, args ...any) (sql.Result, error)
  • func (t *Tx) ExecNamed(ctx context.Context, query string, arg any) (sql.Result, error)
  • func (t *Tx) Select(ctx context.Context, ptr any, query string, args ...any) error
  • func (t *Tx) SelectRow(ctx context.Context, ptr any, query string, args ...any) error
• type TxFunc
• type TxOption
  • func IsolationLevel(level sql.IsolationLevel) TxOption
  • func ReadOnly() TxOption

Functions

func ToSnakeCase

func ToSnakeCase(s string) string

Types

type Client

type Client struct {
	*sqlx.DB
	// contains filtered or unexported fields
}

func Open

func Open(ctx context.Context, dsn string, opts ...Option) (*Client, error)

func (*Client) Exec

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

func (*Client) ExecNamed

func (db *Client) ExecNamed(ctx context.Context, query string, arg any) (sql.Result, error)

func (*Client) RunInTransaction

func (db *Client) RunInTransaction(ctx context.Context, txFunc TxFunc, opts ...TxOption) (err error)

func (*Client) Select

func (db *Client) Select(ctx context.Context, ptr any, query string, args ...any) error

func (*Client) SelectRow

func (db *Client) SelectRow(ctx context.Context, ptr any, query string, args ...any) error

type DB

type DB interface {
	Select(ctx context.Context, ptr any, query string, args ...any) error
	SelectRow(ctx context.Context, ptr any, query string, args ...any) error
	Exec(ctx context.Context, query string, args ...any) (sql.Result, error)
	ExecNamed(ctx context.Context, query string, arg any) (sql.Result, error)
}

type Option

type Option func(db *Client)

func WithQueryTracer

func WithQueryTracer(tracers ...pgx.QueryTracer) Option

type Transactional

type Transactional interface {
	RunInTransaction(ctx context.Context, txFunc TxFunc, opts ...TxOption) error
}

type Tx

type Tx struct {
	*sqlx.Tx
}

func (*Tx) Exec

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

func (*Tx) ExecNamed

func (t *Tx) ExecNamed(ctx context.Context, query string, arg any) (sql.Result, error)

func (*Tx) Select

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

func (*Tx) SelectRow

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

type TxFunc

type TxFunc func(ctx context.Context, tx *Tx) error

type TxOption

type TxOption func(options *txOptions)

func IsolationLevel

func IsolationLevel(level sql.IsolationLevel) TxOption

func ReadOnly

func ReadOnly() TxOption