pg

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

type Client interface {
	Query(sql string, dest any) Query
	Command(sql string, src any) Command
	Transactional(ctx context.Context, fn TxFunc, opts ...TxOption) error

	ToPgx() *pgxpool.Pool
	ToDB() *sql.DB
	Close()
}

type Command interface {
	WithArgs(args ...*Argument) Command
	WithArg(key string, value any) Command
	Returning(dest any) Command
	Exec(ctx context.Context) error
}

type Config struct {
	Host     string `confy:"host"     yaml:"host"     json:"host"     toml:"host"     env:"PG_HOST"    default:"localhost"`
	Port     int    `confy:"port"     yaml:"port"     json:"port"     toml:"port"     env:"PG_PORT"    default:"5432"`
	DBName   string `confy:"dbname"   yaml:"dbname"   json:"dbname"   toml:"dbname"   env:"PG_NAME"    default:"postgres"`
	Username string `confy:"username" yaml:"username" json:"username" toml:"username" env:"PG_USER"`
	Password string `confy:"password" env:"POSTGRES_PASSWORD"`
	SSLMode  string `confy:"sslmode"  yaml:"sslmode" json:"sslmode"  toml:"sslmode"   env:"PG_SSLMODE" default:"disable"`
}

type Query interface {
	WithArgs(args ...*Argument) Query
	WithArg(key string, value any) Query
	Exec(ctx context.Context) error
}

type TxAccessMode = pgx.TxAccessMode

type TxDeferrableMode = pgx.TxDeferrableMode

type TxFunc func(ctx context.Context) error

type TxIsoLevel = pgx.TxIsoLevel

type TxOption func(opts *pgx.TxOptions)