mrpostgres

Documentation

Index

• type ConnAdapter
  • func New() *ConnAdapter
  • func (c *ConnAdapter) Begin(ctx context.Context) (pgx.Tx, error)
  • func (c *ConnAdapter) Cli() *pgxpool.Pool
  • func (c *ConnAdapter) Close() error
  • func (c *ConnAdapter) Connect(opt Options) error
  • func (c *ConnAdapter) Exec(ctx context.Context, sql string, args ...any) (pgconn.CommandTag, error)
  • func (c *ConnAdapter) Ping(ctx context.Context) error
  • func (c *ConnAdapter) Query(ctx context.Context, sql string, args ...any) (pgx.Rows, error)
  • func (c *ConnAdapter) QueryRow(ctx context.Context, sql string, args ...any) QueryRow
  • func (c *ConnAdapter) SqQuery(ctx context.Context, query squirrel.SelectBuilder) (pgx.Rows, error)
  • func (c *ConnAdapter) SqQueryRow(ctx context.Context, query squirrel.SelectBuilder) QueryRow
  • func (c *ConnAdapter) SqUpdate(ctx context.Context, query squirrel.UpdateBuilder) error
• type Options
• type QueryRow
  • func (qr QueryRow) Scan(dest ...any) error

Types

type ConnAdapter

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

func New

func New() *ConnAdapter

func (*ConnAdapter) Begin

func (c *ConnAdapter) Begin(ctx context.Context) (pgx.Tx, error)

func (*ConnAdapter) Cli

func (c *ConnAdapter) Cli() *pgxpool.Pool

func (*ConnAdapter) Close

func (c *ConnAdapter) Close() error

func (*ConnAdapter) Connect

func (c *ConnAdapter) Connect(opt Options) error

func (*ConnAdapter) Exec

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

func (*ConnAdapter) Ping

func (c *ConnAdapter) Ping(ctx context.Context) error

func (*ConnAdapter) Query

func (c *ConnAdapter) Query(ctx context.Context, sql string, args ...any) (pgx.Rows, error)

func (*ConnAdapter) QueryRow

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

func (*ConnAdapter) SqQuery

func (c *ConnAdapter) SqQuery(ctx context.Context, query squirrel.SelectBuilder) (pgx.Rows, error)

func (*ConnAdapter) SqQueryRow

func (c *ConnAdapter) SqQueryRow(ctx context.Context, query squirrel.SelectBuilder) QueryRow

func (*ConnAdapter) SqUpdate

func (c *ConnAdapter) SqUpdate(ctx context.Context, query squirrel.UpdateBuilder) error

type Options

type Options struct {
	Host         string
	Port         string
	Database     string
	Username     string
	Password     string
	MaxPoolSize  int32
	ConnAttempts int32
	ConnTimeout  time.Duration
}

type QueryRow

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

func (QueryRow) Scan

func (qr QueryRow) Scan(dest ...any) error