db

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

type Config struct {
	Host        string            `validate:"required" schema:"Хост"`
	Port        int               `validate:"required" schema:"Порт"`
	Database    string            `validate:"required" schema:"База данных"`
	Username    string            `schema:"Логин" yamlschema:"secret"`
	Password    string            `schema:"Пароль" yamlschema:"secret"`
	Schema      string            `schema:"Схема"`
	MaxOpenConn int               `schema:"Максимально количество соединений"`
	Params      map[string]string `schema:"Дополнительные параметры подключения"`
}

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 MigrationRunner interface {
	Run(ctx context.Context, db *sql.DB, gooseOpts ...goose.ProviderOption) error
}

type Option func(cli *Client)

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

type Tx struct {
	*sqlx.Tx
}

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

type TxOption func(options *txOptions)