Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

pg

package module

Go to main page

Versions in this module

v8

v8.0.7

Jun 18, 2020

Changes in this version

type Listener

+ func (ln *Listener) Unlisten(channels ...string) error

v8.0.6

Aug 23, 2019

v8.0.5

Jul 29, 2019

v8.0.4

Apr 17, 2019

v8.0.3

Mar 25, 2019

Changes in this version

type Listener

+ func (ln *Listener) ChannelSize(size int) <-chan *Notification

+ func (ln *Listener) String() string

v8.0.2

Mar 9, 2019

v8.0.1

Feb 21, 2019

v8.0.0

Feb 20, 2019

Changes in this version

+ var Discard orm.Discard

+ var ErrMultiRows = internal.ErrMultiRows

+ var ErrNoRows = internal.ErrNoRows

+ func Array(v interface{}) *types.Array

+ func F(field string) types.ValueAppender

+ func Hstore(v interface{}) *types.Hstore

+ func In(slice interface{}) types.ValueAppender

+ func InMulti(values ...interface{}) types.ValueAppender

+ func Model(model ...interface{}) *orm.Query

+ func ModelContext(c context.Context, model ...interface{}) *orm.Query

+ func Q(query string, params ...interface{}) types.ValueAppender

+ func Scan(values ...interface{}) orm.ColumnScanner

+ func SetLogger(logger *log.Logger)

+ type Conn struct

+ func (db *Conn) Context() context.Context

+ func (db *Conn) WithContext(ctx context.Context) *Conn

+ func (db *Conn) WithParam(param string, value interface{}) *Conn

+ func (db *Conn) WithTimeout(d time.Duration) *Conn

+ func (db Conn) AddQueryHook(hook QueryHook)

+ func (db Conn) Begin() (*Tx, error)

+ func (db Conn) Close() error

+ func (db Conn) CopyFrom(r io.Reader, query interface{}, params ...interface{}) (res Result, err error)

+ func (db Conn) CopyTo(w io.Writer, query interface{}, params ...interface{}) (res Result, err error)

+ func (db Conn) CreateComposite(model interface{}, opt *orm.CreateCompositeOptions) error

+ func (db Conn) CreateTable(model interface{}, opt *orm.CreateTableOptions) error

+ func (db Conn) Delete(model interface{}) error

+ func (db Conn) DropComposite(model interface{}, opt *orm.DropCompositeOptions) error

+ func (db Conn) DropTable(model interface{}, opt *orm.DropTableOptions) error

+ func (db Conn) Exec(query interface{}, params ...interface{}) (res Result, err error)

+ func (db Conn) ExecContext(c context.Context, query interface{}, params ...interface{}) (Result, error)

+ func (db Conn) ExecOne(query interface{}, params ...interface{}) (Result, error)

+ func (db Conn) ExecOneContext(c context.Context, query interface{}, params ...interface{}) (Result, error)

+ func (db Conn) ForceDelete(model interface{}) error

+ func (db Conn) FormatQuery(dst []byte, query string, params ...interface{}) []byte

+ func (db Conn) Insert(model ...interface{}) error

+ func (db Conn) Model(model ...interface{}) *orm.Query

+ func (db Conn) ModelContext(c context.Context, model ...interface{}) *orm.Query

+ func (db Conn) Param(param string) interface{}

+ func (db Conn) PoolStats() *PoolStats

+ func (db Conn) Prepare(q string) (*Stmt, error)

+ func (db Conn) Query(model, query interface{}, params ...interface{}) (res Result, err error)

+ func (db Conn) QueryContext(c context.Context, model, query interface{}, params ...interface{}) (Result, error)

+ func (db Conn) QueryOne(model, query interface{}, params ...interface{}) (Result, error)

+ func (db Conn) QueryOneContext(c context.Context, model, query interface{}, params ...interface{}) (Result, error)

+ func (db Conn) RunInTransaction(fn func(*Tx) error) error

+ func (db Conn) Select(model interface{}) error

+ func (db Conn) Update(model interface{}) error

+ type DB struct

+ func Connect(opt *Options) *DB

+ func (db *DB) Conn() *Conn

+ func (db *DB) Context() context.Context

+ func (db *DB) Listen(channels ...string) *Listener

+ func (db *DB) Options() *Options

+ func (db *DB) String() string

+ func (db *DB) WithContext(ctx context.Context) *DB

+ func (db *DB) WithParam(param string, value interface{}) *DB

+ func (db *DB) WithTimeout(d time.Duration) *DB

+ func (db DB) AddQueryHook(hook QueryHook)

+ func (db DB) Begin() (*Tx, error)

+ func (db DB) Close() error

+ func (db DB) CopyFrom(r io.Reader, query interface{}, params ...interface{}) (res Result, err error)

+ func (db DB) CopyTo(w io.Writer, query interface{}, params ...interface{}) (res Result, err error)

+ func (db DB) CreateComposite(model interface{}, opt *orm.CreateCompositeOptions) error

+ func (db DB) CreateTable(model interface{}, opt *orm.CreateTableOptions) error

+ func (db DB) Delete(model interface{}) error

+ func (db DB) DropComposite(model interface{}, opt *orm.DropCompositeOptions) error

+ func (db DB) DropTable(model interface{}, opt *orm.DropTableOptions) error

+ func (db DB) Exec(query interface{}, params ...interface{}) (res Result, err error)

+ func (db DB) ExecContext(c context.Context, query interface{}, params ...interface{}) (Result, error)

+ func (db DB) ExecOne(query interface{}, params ...interface{}) (Result, error)

+ func (db DB) ExecOneContext(c context.Context, query interface{}, params ...interface{}) (Result, error)

+ func (db DB) ForceDelete(model interface{}) error

+ func (db DB) FormatQuery(dst []byte, query string, params ...interface{}) []byte

+ func (db DB) Insert(model ...interface{}) error

+ func (db DB) Model(model ...interface{}) *orm.Query

+ func (db DB) ModelContext(c context.Context, model ...interface{}) *orm.Query

+ func (db DB) Param(param string) interface{}

+ func (db DB) PoolStats() *PoolStats

+ func (db DB) Prepare(q string) (*Stmt, error)

+ func (db DB) Query(model, query interface{}, params ...interface{}) (res Result, err error)

+ func (db DB) QueryContext(c context.Context, model, query interface{}, params ...interface{}) (Result, error)

+ func (db DB) QueryOne(model, query interface{}, params ...interface{}) (Result, error)

+ func (db DB) QueryOneContext(c context.Context, model, query interface{}, params ...interface{}) (Result, error)

+ func (db DB) RunInTransaction(fn func(*Tx) error) error

+ func (db DB) Select(model interface{}) error

+ func (db DB) Update(model interface{}) error

+ type Error interface

+ Field func(byte) string

+ IntegrityViolation func() bool

+ type IntSet map[int64]struct

+ func (IntSet) AddModel(_ orm.ColumnScanner) error

+ func (set *IntSet) Init() error

+ func (set *IntSet) NewModel() orm.ColumnScanner

+ func (setptr *IntSet) ScanColumn(colIdx int, colName string, rd types.Reader, n int) error

+ type Ints []int64

+ func (Ints) AddModel(_ orm.ColumnScanner) error

+ func (ints *Ints) Init() error

+ func (ints *Ints) NewModel() orm.ColumnScanner

+ func (ints *Ints) ScanColumn(colIdx int, colName string, rd types.Reader, n int) error

+ func (ints Ints) AppendValue(dst []byte, quote int) []byte

+ type Listener struct

+ func (ln *Listener) Channel() <-chan *Notification

+ func (ln *Listener) Close() error

+ func (ln *Listener) Listen(channels ...string) error

+ func (ln *Listener) Receive() (channel string, payload string, err error)

+ func (ln *Listener) ReceiveTimeout(timeout time.Duration) (channel, payload string, err error)

+ type Notification struct

+ Channel string

+ Payload string

+ type NullTime = types.NullTime

+ type Options struct

+ Addr string

+ ApplicationName string

+ Database string

+ DialTimeout time.Duration

+ Dialer func(network, addr string) (net.Conn, error)

+ IdleCheckFrequency time.Duration

+ IdleTimeout time.Duration

+ MaxConnAge time.Duration

+ MaxRetries int

+ MaxRetryBackoff time.Duration

+ MinIdleConns int

+ MinRetryBackoff time.Duration

+ Network string

+ OnConnect func(*Conn) error

+ Password string

+ PoolSize int

+ PoolTimeout time.Duration

+ ReadTimeout time.Duration

+ RetryStatementTimeout bool

+ TLSConfig *tls.Config

+ User string

+ WriteTimeout time.Duration

+ func ParseURL(sURL string) (*Options, error)

+ type PoolStats pool.Stats

+ type QueryEvent struct

+ Attempt int

+ Ctx context.Context

+ DB orm.DB

+ Data map[interface{}]interface{}

+ Error error

+ Params []interface{}

+ Query interface{}

+ Result Result

+ func (ev *QueryEvent) FormattedQuery() (string, error)

+ func (ev *QueryEvent) UnformattedQuery() (string, error)

+ type QueryHook interface

+ AfterQuery func(*QueryEvent)

+ BeforeQuery func(*QueryEvent)

+ type Result = orm.Result

+ type Stmt struct

+ func (stmt *Stmt) Close() error

+ func (stmt *Stmt) Exec(params ...interface{}) (Result, error)

+ func (stmt *Stmt) ExecContext(c context.Context, params ...interface{}) (Result, error)

+ func (stmt *Stmt) ExecOne(params ...interface{}) (Result, error)

+ func (stmt *Stmt) ExecOneContext(c context.Context, params ...interface{}) (Result, error)

+ func (stmt *Stmt) Query(model interface{}, params ...interface{}) (Result, error)

+ func (stmt *Stmt) QueryContext(c context.Context, model interface{}, params ...interface{}) (Result, error)

+ func (stmt *Stmt) QueryOne(model interface{}, params ...interface{}) (Result, error)

+ func (stmt *Stmt) QueryOneContext(c context.Context, model interface{}, params ...interface{}) (Result, error)

+ type Strings []string

+ func (Strings) AddModel(_ orm.ColumnScanner) error

+ func (strings *Strings) Init() error

+ func (strings *Strings) NewModel() orm.ColumnScanner

+ func (strings *Strings) ScanColumn(colIdx int, _ string, rd types.Reader, n int) error

+ func (strings Strings) AppendValue(dst []byte, quote int) []byte

+ type Tx struct

+ func (tx *Tx) Begin() (*Tx, error)

+ func (tx *Tx) Commit() error

+ func (tx *Tx) Context() context.Context

+ func (tx *Tx) CopyFrom(r io.Reader, query interface{}, params ...interface{}) (res Result, err error)

+ func (tx *Tx) CopyTo(w io.Writer, query interface{}, params ...interface{}) (res Result, err error)

+ func (tx *Tx) CreateTable(model interface{}, opt *orm.CreateTableOptions) error

+ func (tx *Tx) Delete(model interface{}) error

+ func (tx *Tx) DropTable(model interface{}, opt *orm.DropTableOptions) error

+ func (tx *Tx) Exec(query interface{}, params ...interface{}) (Result, error)

+ func (tx *Tx) ExecContext(c context.Context, query interface{}, params ...interface{}) (Result, error)

+ func (tx *Tx) ExecOne(query interface{}, params ...interface{}) (Result, error)

+ func (tx *Tx) ExecOneContext(c context.Context, query interface{}, params ...interface{}) (Result, error)

+ func (tx *Tx) ForceDelete(model interface{}) error

+ func (tx *Tx) FormatQuery(dst []byte, query string, params ...interface{}) []byte

+ func (tx *Tx) Insert(model ...interface{}) error

+ func (tx *Tx) Model(model ...interface{}) *orm.Query

+ func (tx *Tx) ModelContext(c context.Context, model ...interface{}) *orm.Query

+ func (tx *Tx) Prepare(q string) (*Stmt, error)

+ func (tx *Tx) Query(model interface{}, query interface{}, params ...interface{}) (Result, error)

+ func (tx *Tx) QueryContext(c context.Context, model interface{}, query interface{}, params ...interface{}) (Result, error)

+ func (tx *Tx) QueryOne(model interface{}, query interface{}, params ...interface{}) (Result, error)

+ func (tx *Tx) QueryOneContext(c context.Context, model interface{}, query interface{}, params ...interface{}) (Result, error)

+ func (tx *Tx) Rollback() error

+ func (tx *Tx) RunInTransaction(fn func(*Tx) error) error

+ func (tx *Tx) Select(model interface{}) error

+ func (tx *Tx) Stmt(stmt *Stmt) *Stmt

+ func (tx *Tx) Update(model interface{}) error

Other modules containing this package