pgy

type Connection struct {
	Con                *pgxpool.Pool
	TransactionManager *TransactionManager
}

type ConnectionI interface {
	Exec(ctx context.Context, sql string, args ...any) error
	Query(ctx context.Context, sql string, args ...any) (RowsI, error)
	QueryRow(ctx context.Context, sql string, args ...any) RowI
	ExecM(ctx context.Context, sql string, argMap map[string]any) error
	QueryM(ctx context.Context, sql string, argMap map[string]any) (RowsI, error)
	QueryRowM(ctx context.Context, sql string, argMap map[string]any) RowI
	GetTransactionManager() TransactionManagerI
}

type RowI interface {
	Scan(dest ...any) error
}

type RowsI interface {
	Close()
	Err() error
	Next() bool
	Scan(dest ...any) error
}

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

type TransactionManagerI interface {
	TxFn(ctx context.Context, f func(context.Context) error) error
	RenewContextTx(ctx context.Context) error
	TxAddAsyncCallback(ctx context.Context, f func())
}

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