entpgx

Documentation

Index

• func NewPgxPoolDriver(pool pool.PGXConnPool) dialect.Driver
• type EntPgxPoolTx
  • func (e *EntPgxPoolTx) Commit() error
  • func (e *EntPgxPoolTx) Exec(ctx context.Context, query string, args, result any) error
  • func (e *EntPgxPoolTx) ExecContext(ctx context.Context, query string, args ...any) (stdsql.Result, error)
  • func (e *EntPgxPoolTx) PGXTransaction() pgx.Tx
  • func (e *EntPgxPoolTx) Query(ctx context.Context, query string, args, v any) error
  • func (e *EntPgxPoolTx) Rollback() error
• type EntPgxpoolDriver
  • func (e *EntPgxpoolDriver) BeginTx(ctx context.Context, opts *sql.TxOptions) (dialect.Tx, error)
  • func (e *EntPgxpoolDriver) Close() error
  • func (e *EntPgxpoolDriver) Dialect() string
  • func (e *EntPgxpoolDriver) Exec(ctx context.Context, query string, args, result any) error
  • func (e *EntPgxpoolDriver) ExecContext(ctx context.Context, query string, args ...any) (stdsql.Result, error)
  • func (e *EntPgxpoolDriver) Query(ctx context.Context, query string, args, v any) error
  • func (e *EntPgxpoolDriver) Tx(ctx context.Context) (dialect.Tx, error)

Functions

func NewPgxPoolDriver

func NewPgxPoolDriver(pool pool.PGXConnPool) dialect.Driver

Types

type EntPgxPoolTx

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

func (*EntPgxPoolTx) Commit

func (e *EntPgxPoolTx) Commit() error

func (*EntPgxPoolTx) Exec

func (e *EntPgxPoolTx) Exec(ctx context.Context, query string, args, result any) error

func (*EntPgxPoolTx) ExecContext

func (e *EntPgxPoolTx) ExecContext(ctx context.Context, query string, args ...any) (stdsql.Result, error)

func (*EntPgxPoolTx) PGXTransaction

func (e *EntPgxPoolTx) PGXTransaction() pgx.Tx

func (*EntPgxPoolTx) Query

func (e *EntPgxPoolTx) Query(ctx context.Context, query string, args, v any) error

func (*EntPgxPoolTx) Rollback

func (e *EntPgxPoolTx) Rollback() error

type EntPgxpoolDriver

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

func (*EntPgxpoolDriver) BeginTx

func (e *EntPgxpoolDriver) BeginTx(ctx context.Context, opts *sql.TxOptions) (dialect.Tx, error)

func (*EntPgxpoolDriver) Close

func (e *EntPgxpoolDriver) Close() error

func (*EntPgxpoolDriver) Dialect

func (e *EntPgxpoolDriver) Dialect() string

func (*EntPgxpoolDriver) Exec

func (e *EntPgxpoolDriver) Exec(ctx context.Context, query string, args, result any) error

func (*EntPgxpoolDriver) ExecContext

func (e *EntPgxpoolDriver) ExecContext(ctx context.Context, query string, args ...any) (stdsql.Result, error)

func (*EntPgxpoolDriver) Query

func (e *EntPgxpoolDriver) Query(ctx context.Context, query string, args, v any) error

func (*EntPgxpoolDriver) Tx

func (e *EntPgxpoolDriver) Tx(ctx context.Context) (dialect.Tx, error)