db

type Client interface {
	DB() DB
	Close() error
}

type DB interface {
	SQLExecer
	Transactor
	Pinger
	Close()
}

type Handler func(ctx context.Context) error

type HandlerFn interface {
	Handler
}

type NamedExecer interface {
	ScanOneContext(ctx context.Context, dest interface{}, q Query, args ...interface{}) error
	ScanAllContext(ctx context.Context, dest interface{}, q Query, args ...interface{}) error
}

type Pinger interface {
	Ping(ctx context.Context) error
}

type Query struct {
	Name     string
	QueryRaw string
}

type QueryExecer interface {
	ExecContext(ctx context.Context, q Query, args ...interface{}) (pgconn.CommandTag, error)
	QueryContext(ctx context.Context, q Query, args ...interface{}) (pgx.Rows, error)
	QueryRowContext(ctx context.Context, q Query, args ...interface{}) pgx.Row
}

type SQLExecer interface {
	NamedExecer
	QueryExecer
}

type Transactor interface {
	BeginTx(ctx context.Context, txOptions pgx.TxOptions) (pgx.Tx, error)
}

type TxManager interface {
	ReadCommitted(ctx context.Context, f Handler) error
}