pgutil

Documentation

Index

• Constants
• func ErrIsDuplicateKey(err error) bool
• func NilifyErrDuplicateKey(err error) error
• func SelectArrayAny(db *pg.DB, table, arrayCol, arrayVar string, res any) error
• func SelectTagHistogramResults(db *pg.DB, table, tags, tag string, res any) error
• func TagHistogramSQL(table, tags, tag string) string
• type PgConn
  • func NewPgConnJSON(data []byte) (PgConn, error)
  • func (conn *PgConn) Address() string
  • func (conn *PgConn) Client() *pg.DB
  • func (conn *PgConn) Encode() string
  • func (conn *PgConn) GoPgOptions() *pg.Options
  • func (conn *PgConn) Trim()
• type TagInfo
  • func SelectTagHistogram(db *pg.DB, table, tags, tag string) ([]TagInfo, error)

Constants

const DuplicateKeyErrorPrefix = "ERROR #23505 duplicate key value violates unique constraint"

Functions

func ErrIsDuplicateKey

func ErrIsDuplicateKey(err error) bool

func NilifyErrDuplicateKey

func NilifyErrDuplicateKey(err error) error

func SelectArrayAny

func SelectArrayAny(db *pg.DB, table, arrayCol, arrayVar string, res any) error

func SelectTagHistogramResults

func SelectTagHistogramResults(db *pg.DB, table, tags, tag string, res any) error

func TagHistogramSQL

func TagHistogramSQL(table, tags, tag string) string

Types

type PgConn

type PgConn struct {
	Host     string
	Port     string
	Addr     string `josn:"Addr,omitempty"`
	User     string `json:"User,omitempty"`
	Password string `json:"Password,omitempty"`
	Database string `json:"Database,omitempty"`
	SSLMode  string `json:"sslmode,omitempty"`
}

func NewPgConnJSON

func NewPgConnJSON(data []byte) (PgConn, error)

func (*PgConn) Address

func (conn *PgConn) Address() string

func (*PgConn) Client

func (conn *PgConn) Client() *pg.DB

func (*PgConn) Encode

func (conn *PgConn) Encode() string

func (*PgConn) GoPgOptions

func (conn *PgConn) GoPgOptions() *pg.Options

func (*PgConn) Trim

func (conn *PgConn) Trim()

type TagInfo

type TagInfo struct {
	Name  string
	Count int
}

func SelectTagHistogram

func SelectTagHistogram(db *pg.DB, table, tags, tag string) ([]TagInfo, error)