pg

package

v0.1.1 Latest Latest Go to latest Published: Oct 5, 2023 License: GPL-3.0 Imports: 10 Imported by: 0

Details

This section is empty.

View Source

var InvalidOption = errors.New("invalid role option")

func FormattedString(s string) string

func Initialize(logger *zap.SugaredLogger)

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

func NewConn(connParams Dsn, retries uint, delay time.Duration) (c *Conn)

func (c *Conn) Connect() (err error)

func (c *Conn) DSN() (dsn string)

func (c *Conn) RunQuery(query string, args ...interface{}) (result Results, err error)

type Dsn map[string]string

type Result map[string]ResultValue

func NewResultFromByteArrayArray(cols []string, values []interface{}) (r Result, err error)

func (r Result) Columns() (cols []string)

func (r Result) Compare(other Result) (err error)

func (r Result) OneField() (rv ResultValue, err error)

func (r Result) String() (s string)

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

func NewResultValue(org interface{}) ResultValue

func (rv *ResultValue) AsFloat() (float64, error)

func (rv *ResultValue) AsString() string

func (rv *ResultValue) Formatted() string

func (rv *ResultValue) Org() interface{}

type Results []Result

func (rs Results) Compare(other Results) (err error)

func (rs Results) OneField() (rv ResultValue, err error)

func (rs Results) String() (s string)