pgq

README

Date type

Postgres Date type is intentionally not supported because it creates pitfalls with timezones, use timestamptz instead

Documentation

Index

• type Builder
  • func (s *Builder) Args() []interface{}
  • func (s *Builder) SQL(qp string, args ...interface{}) *Builder
  • func (s *Builder) String() string
  • func (s *Builder) Where(qp string, args ...interface{}) *Builder
• type Cmd
• type Iterator
  • func NewIterator(src []byte) *Iterator
  • func (iter *Iterator) Err() error
  • func (iter *Iterator) Iterator() *pgetc.Iterator
  • func (iter *Iterator) ReadBool() bool
  • func (iter *Iterator) ReadBoolPtr() *bool
  • func (iter *Iterator) ReadCompositeTypeHeader() uint32
  • func (iter *Iterator) ReadEnum(oid pgetc.OID) string
  • func (iter *Iterator) ReadEnumN(oid pgetc.OID) *string
  • func (iter *Iterator) ReadInt() int
  • func (iter *Iterator) ReadInt16() int16
  • func (iter *Iterator) ReadInt16N() *int16
  • func (iter *Iterator) ReadInt64() int64
  • func (iter *Iterator) ReadInt64N() *int64
  • func (iter *Iterator) ReadIntN() *int
  • func (iter *Iterator) ReadJSONB(v interface{})
  • func (iter *Iterator) ReadString() string
  • func (iter *Iterator) ReadStringPtr() *string
  • func (iter *Iterator) ReadTime() time.Time
  • func (iter *Iterator) ReadUUID() uuid.UUID
  • func (iter *Iterator) ReportError(err error)
• type Pool
  • func (p *Pool) QueryRow(ctx context.Context, sql string, row interface{})
• type Row
  • func (r *Row) Scan(dst interface{})
• type SelectCmd
  • func Select() *SelectCmd
  • func (c *SelectCmd) Distinct(expr string)
  • func (c *SelectCmd) From(fromItem string) *SelectCmd
  • func (c *SelectCmd) SQL() string
  • func (c *SelectCmd) Select(expr string) *SelectCmd
  • func (c *SelectCmd) Where(cond string) *SelectCmd
• type Stream
  • func NewStream(buf []byte) *Stream
  • func (stream *Stream) Bytes() []byte
  • func (stream *Stream) Err() error
  • func (stream *Stream) Len() int
  • func (stream *Stream) ReportError(err error)
  • func (stream *Stream) Stream() *pgetc.Stream
  • func (stream *Stream) WriteBool(b bool)
  • func (stream *Stream) WriteCompositeType(oid pgetc.OID, v Streamable)
  • func (stream *Stream) WriteEnum(oid pgetc.OID, s string)
  • func (stream *Stream) WriteInt(i int)
  • func (stream *Stream) WriteInt16(i int16)
  • func (stream *Stream) WriteInt64(n int64)
  • func (stream *Stream) WriteJSONB(v interface{})
  • func (stream *Stream) WriteString(s string)
  • func (stream *Stream) WriteTime(t time.Time)
  • func (stream *Stream) WriteUUID(id uuid.UUID)
• type Streamable

Types

type Builder

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

func (*Builder) Args

func (s *Builder) Args() []interface{}

func (*Builder) SQL

func (s *Builder) SQL(qp string, args ...interface{}) *Builder

func (*Builder) String

func (s *Builder) String() string

func (*Builder) Where

func (s *Builder) Where(qp string, args ...interface{}) *Builder

type Cmd

type Cmd struct {
}

type Iterator

type Iterator pgetc.Iterator

func NewIterator

func NewIterator(src []byte) *Iterator

func (*Iterator) Err

func (iter *Iterator) Err() error

func (*Iterator) Iterator

func (iter *Iterator) Iterator() *pgetc.Iterator

func (*Iterator) ReadBool

func (iter *Iterator) ReadBool() bool

func (*Iterator) ReadBoolPtr

func (iter *Iterator) ReadBoolPtr() *bool

func (*Iterator) ReadCompositeTypeHeader

func (iter *Iterator) ReadCompositeTypeHeader() uint32

func (*Iterator) ReadEnum

func (iter *Iterator) ReadEnum(oid pgetc.OID) string

func (*Iterator) ReadEnumN

func (iter *Iterator) ReadEnumN(oid pgetc.OID) *string

func (*Iterator) ReadInt

func (iter *Iterator) ReadInt() int

func (*Iterator) ReadInt16

func (iter *Iterator) ReadInt16() int16

func (*Iterator) ReadInt16N

func (iter *Iterator) ReadInt16N() *int16

func (*Iterator) ReadInt64

func (iter *Iterator) ReadInt64() int64

func (*Iterator) ReadInt64N

func (iter *Iterator) ReadInt64N() *int64

func (*Iterator) ReadIntN

func (iter *Iterator) ReadIntN() *int

func (*Iterator) ReadJSONB

func (iter *Iterator) ReadJSONB(v interface{})

func (*Iterator) ReadString

func (iter *Iterator) ReadString() string

func (*Iterator) ReadStringPtr

func (iter *Iterator) ReadStringPtr() *string

func (*Iterator) ReadTime

func (iter *Iterator) ReadTime() time.Time

func (*Iterator) ReadUUID

func (iter *Iterator) ReadUUID() uuid.UUID

func (*Iterator) ReportError

func (iter *Iterator) ReportError(err error)

type Pool

type Pool struct {
	*pgxpool.Pool
}

func (*Pool) QueryRow

func (p *Pool) QueryRow(ctx context.Context, sql string, row interface{})

type Row

type Row struct {
	pgx.Row
}

func (*Row) Scan

func (r *Row) Scan(dst interface{})

type SelectCmd

type SelectCmd struct {
	Cmd
	// contains filtered or unexported fields
}

func Select

func Select() *SelectCmd

func (*SelectCmd) Distinct

func (c *SelectCmd) Distinct(expr string)

func (*SelectCmd) From

func (c *SelectCmd) From(fromItem string) *SelectCmd

func (*SelectCmd) SQL

func (c *SelectCmd) SQL() string

func (*SelectCmd) Select

func (c *SelectCmd) Select(expr string) *SelectCmd

func (*SelectCmd) Where

func (c *SelectCmd) Where(cond string) *SelectCmd

type Stream

type Stream pgetc.Stream

func NewStream

func NewStream(buf []byte) *Stream

func (*Stream) Bytes

func (stream *Stream) Bytes() []byte

func (*Stream) Err

func (stream *Stream) Err() error

func (*Stream) Len

func (stream *Stream) Len() int

func (*Stream) ReportError

func (stream *Stream) ReportError(err error)

func (*Stream) Stream

func (stream *Stream) Stream() *pgetc.Stream

func (*Stream) WriteBool

func (stream *Stream) WriteBool(b bool)

func (*Stream) WriteCompositeType

func (stream *Stream) WriteCompositeType(oid pgetc.OID, v Streamable)

func (*Stream) WriteEnum

func (stream *Stream) WriteEnum(oid pgetc.OID, s string)

func (*Stream) WriteInt

func (stream *Stream) WriteInt(i int)

func (*Stream) WriteInt16

func (stream *Stream) WriteInt16(i int16)

func (*Stream) WriteInt64

func (stream *Stream) WriteInt64(n int64)

func (*Stream) WriteJSONB

func (stream *Stream) WriteJSONB(v interface{})

func (*Stream) WriteString

func (stream *Stream) WriteString(s string)

func (*Stream) WriteTime

func (stream *Stream) WriteTime(t time.Time)

func (*Stream) WriteUUID

func (stream *Stream) WriteUUID(id uuid.UUID)

type Streamable

type Streamable interface {
	WriteTo(stream *Stream)
}