pgy

Documentation

Index

• type Connection
  • func NewConnection(dsn string) (*Connection, error)
  • func (c *Connection) Exec(ctx context.Context, sql string, args ...any) error
  • func (c *Connection) ExecM(ctx context.Context, sql string, argMap map[string]any) error
  • func (c *Connection) GetTransactionManager() TransactionManagerI
  • func (c *Connection) Query(ctx context.Context, sql string, args ...any) (RowsI, error)
  • func (c *Connection) QueryM(ctx context.Context, sql string, argMap map[string]any) (RowsI, error)
  • func (c *Connection) QueryRow(ctx context.Context, sql string, args ...any) RowI
  • func (c *Connection) QueryRowM(ctx context.Context, sql string, argMap map[string]any) RowI
• type ConnectionI
• type RowI
• type RowsI
• type TransactionManager
  • func NewTransactionManager(connection *pgxpool.Pool) *TransactionManager
  • func (t *TransactionManager) RenewContextTx(ctx context.Context) error
  • func (t *TransactionManager) TxAddAsyncCallback(ctx context.Context, f func())
  • func (t *TransactionManager) TxFn(ctx context.Context, f func(context.Context) error) error
• type TransactionManagerI
• type Tx

Types

type Connection

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

func NewConnection

func NewConnection(dsn string) (*Connection, error)

func (*Connection) Exec

func (c *Connection) Exec(ctx context.Context, sql string, args ...any) error

func (*Connection) ExecM

func (c *Connection) ExecM(ctx context.Context, sql string, argMap map[string]any) error

func (*Connection) GetTransactionManager

func (c *Connection) GetTransactionManager() TransactionManagerI

func (*Connection) Query

func (c *Connection) Query(ctx context.Context, sql string, args ...any) (RowsI, error)

func (*Connection) QueryM

func (c *Connection) QueryM(ctx context.Context, sql string, argMap map[string]any) (RowsI, error)

func (*Connection) QueryRow

func (c *Connection) QueryRow(ctx context.Context, sql string, args ...any) RowI

func (*Connection) QueryRowM

func (c *Connection) QueryRowM(ctx context.Context, sql string, argMap map[string]any) RowI

type ConnectionI

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

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

type RowsI

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

type TransactionManager

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

func NewTransactionManager

func NewTransactionManager(connection *pgxpool.Pool) *TransactionManager

func (*TransactionManager) RenewContextTx

func (t *TransactionManager) RenewContextTx(ctx context.Context) error

func (*TransactionManager) TxAddAsyncCallback

func (t *TransactionManager) TxAddAsyncCallback(ctx context.Context, f func())

func (*TransactionManager) TxFn

func (t *TransactionManager) TxFn(ctx context.Context, f func(context.Context) error) error

type TransactionManagerI

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

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