sql

type Act = func(ctx context.Context) error

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

type BeginAction func(ctx context.Context, opts *TxOptions) (Tx, error)

type Behavior interface {
	Apply(
		ctx context.Context,
		action func(ctx context.Context) error,
		query string,
		args ...interface{},
	) error
}

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

type ColumnType struct {
	Name string
	OID  uint32
}

type CommitAction func(ctx context.Context) error

type ContextWithoutCancel struct {
	context.Context
}

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

type DB interface {
	Scope
	Pool() *pgxpool.Pool
	Scope(ctx context.Context) Scope
	Transact(ctx context.Context, action Act) error
	Transaction(ctx context.Context, action Action) error
	TransactionTx(ctx context.Context, action Action, options *TxOptions) error
	InTransaction(ctx context.Context) bool
	WithCancel(ctx context.Context) Scope
	Close()
}

type DBStats = sql.DBStats

type DSN struct {
	Host     string
	Port     uint16
	User     string
	Password string
	Database string
	SSLMode  string
	Charset  string
}

type DbId string

type DummyBehavior struct{}

type DummyHandler struct{}

type ErrorBuilder interface {
	Build(ctx context.Context, err error, msg string) error
}

type ExecAction func(ctx context.Context, query string, args ...interface{}) (Result, error)

type Fetcher func(func(rows Rows) error) error

type Handler interface {
	Query(ctx context.Context, action QueryAction, query string, args ...interface{}) (Rows, error)
	QueryRow(ctx context.Context, action QueryRowAction, query string, args ...interface{}) Row
	Exec(ctx context.Context, action ExecAction, query string, args ...interface{}) (Result, error)
	BeginTx(ctx context.Context, opts *TxOptions, action BeginAction) (Tx, error)
	Commit(ctx context.Context, action CommitAction) error
	Rollback(ctx context.Context, action RollbackAction) error
}

type IsolationLevel = sql.IsolationLevel

type LogOptions struct {
	MaxTemplateLen     int           // например, 500
	MaxAllowedDuration time.Duration // например, 200ms
}

type Manipulator interface {
	Exec(ctx context.Context, args ...interface{}) (Result, error)
	Query(ctx context.Context, args ...interface{}) (Rows, error)
	QueryRow(ctx context.Context, args ...interface{}) Row
}

type Middleware func(handler Handler) Handler

type NullBool = sql.NullBool

type NullFloat64 = sql.NullFloat64

type NullInt64 = sql.NullInt64

type NullString = sql.NullString

type NullTime = sql.NullTime

type Out = sql.Out

type QueryAction func(ctx context.Context, query string, args ...interface{}) (Rows, error)

type QueryRowAction func(ctx context.Context, query string, args ...interface{}) Row

type RawBytes = sql.RawBytes

type Result interface {
	RowsAffected() (int64, error)
}

type RollbackAction func(ctx context.Context) error

type Row interface {
	Scanner
	Err() error
}

type Rows interface {
	Scanner
	Err() error
	Next() bool
	Columns() ([]string, error)
	ColumnTypes() ([]*ColumnType, error)
	Close() error
}

type Scanner interface {
	Scan(src ...interface{}) error
}

type Scope interface {
	DbId(ctx context.Context) DbId
	WithCancel(ctx context.Context) Scope
	Exec(ctx context.Context, query string, args ...interface{}) (Result, error)
	Query(ctx context.Context, query string, args ...interface{}) (Rows, error)
	QueryRow(ctx context.Context, query string, args ...interface{}) Row
	Fetch(ctx context.Context, query string, args ...any) Fetcher
	Begin(ctx context.Context) (Tx, error)
	BeginTx(ctx context.Context, opts *TxOptions) (Tx, error)
}

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

type Tx interface {
	Scope
	Commit(ctx context.Context) error
	Rollback(ctx context.Context) error
}

type TxOptions = pgx.TxOptions