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

pgx

package module

Go to main page

Versions in this module

v4

v4.13.4

Aug 18, 2021

v4.13.3

Aug 18, 2021

v4.13.2

Aug 18, 2021

Changes in this version

+ const BinaryFormatCode

+ const Deferrable

+ const LogLevelDebug

+ const LogLevelError

+ const LogLevelInfo

+ const LogLevelNone

+ const LogLevelTrace

+ const LogLevelWarn

+ const NotDeferrable

+ const ReadCommitted

+ const ReadOnly

+ const ReadUncommitted

+ const ReadWrite

+ const RepeatableRead

+ const Serializable

+ const TextFormatCode

+ var ErrInvalidLogLevel = errors.New("invalid log level")

+ var ErrNoRows = errors.New("no rows in result set")

+ var ErrTxClosed = errors.New("tx is closed")

+ var ErrTxCommitRollback = errors.New("commit unexpectedly resulted in rollback")

+ func ScanRow(connInfo *pgtype.ConnInfo, fieldDescriptions []pgproto3.FieldDescription, ...) error

+ type Batch struct

+ func (b *Batch) Len() int

+ func (b *Batch) Queue(query string, arguments ...interface{})

+ type BatchResults interface

+ Close func() error

+ Exec func() (pgconn.CommandTag, error)

+ Query func() (Rows, error)

+ QueryRow func() Row

+ type BuildStatementCacheFunc func(conn *pgconn.PgConn) stmtcache.Cache

+ type Conn struct

+ func Connect(ctx context.Context, connString string) (*Conn, error)

+ func ConnectConfig(ctx context.Context, connConfig *ConnConfig) (*Conn, error)

+ func (c *Conn) Begin(ctx context.Context) (Tx, error)

+ func (c *Conn) BeginFunc(ctx context.Context, f func(Tx) error) (err error)

+ func (c *Conn) BeginTx(ctx context.Context, txOptions TxOptions) (Tx, error)

+ func (c *Conn) BeginTxFunc(ctx context.Context, txOptions TxOptions, f func(Tx) error) (err error)

+ func (c *Conn) Close(ctx context.Context) error

+ func (c *Conn) Config() *ConnConfig

+ func (c *Conn) ConnInfo() *pgtype.ConnInfo

+ func (c *Conn) CopyFrom(ctx context.Context, tableName Identifier, columnNames []string, ...) (int64, error)

+ func (c *Conn) Deallocate(ctx context.Context, name string) error

+ func (c *Conn) Exec(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error)

+ func (c *Conn) IsClosed() bool

+ func (c *Conn) PgConn() *pgconn.PgConn

+ func (c *Conn) Ping(ctx context.Context) error

+ func (c *Conn) Prepare(ctx context.Context, name, sql string) (sd *pgconn.StatementDescription, err error)

+ func (c *Conn) Query(ctx context.Context, sql string, args ...interface{}) (Rows, error)

+ func (c *Conn) QueryFunc(ctx context.Context, sql string, args []interface{}, scans []interface{}, ...) (pgconn.CommandTag, error)

+ func (c *Conn) QueryRow(ctx context.Context, sql string, args ...interface{}) Row

+ func (c *Conn) SendBatch(ctx context.Context, b *Batch) BatchResults

+ func (c *Conn) StatementCache() stmtcache.Cache

+ func (c *Conn) WaitForNotification(ctx context.Context) (*pgconn.Notification, error)

+ type ConnConfig struct

+ BuildStatementCache BuildStatementCacheFunc

+ LogLevel LogLevel

+ Logger Logger

+ PreferSimpleProtocol bool

+ func ParseConfig(connString string) (*ConnConfig, error)

+ func (cc *ConnConfig) ConnString() string

+ func (cc *ConnConfig) Copy() *ConnConfig

+ type CopyFromSource interface

+ Err func() error

+ Next func() bool

+ Values func() ([]interface{}, error)

+ func CopyFromRows(rows [][]interface{}) CopyFromSource

+ func CopyFromSlice(length int, next func(int) ([]interface{}, error)) CopyFromSource

+ type Identifier []string

+ func (ident Identifier) Sanitize() string

+ type LargeObject struct

+ func (o *LargeObject) Close() error

+ func (o *LargeObject) Read(p []byte) (int, error)

+ func (o *LargeObject) Seek(offset int64, whence int) (n int64, err error)

+ func (o *LargeObject) Tell() (n int64, err error)

+ func (o *LargeObject) Truncate(size int64) (err error)

+ func (o *LargeObject) Write(p []byte) (int, error)

+ type LargeObjectMode int32

+ const LargeObjectModeRead

+ const LargeObjectModeWrite

+ type LargeObjects struct

+ func (o *LargeObjects) Create(ctx context.Context, oid uint32) (uint32, error)

+ func (o *LargeObjects) Open(ctx context.Context, oid uint32, mode LargeObjectMode) (*LargeObject, error)

+ func (o *LargeObjects) Unlink(ctx context.Context, oid uint32) error

+ type LogLevel int

+ func LogLevelFromString(s string) (LogLevel, error)

+ func (ll LogLevel) String() string

+ type Logger interface

+ Log func(ctx context.Context, level LogLevel, msg string, data map[string]interface{})

+ type QueryFuncRow interface

+ FieldDescriptions func() []pgproto3.FieldDescription

+ RawValues func() [][]byte

+ type QueryResultFormats []int16

+ type QueryResultFormatsByOID map[uint32]int16

+ type QuerySimpleProtocol bool

+ type Row interface

+ Scan func(dest ...interface{}) error

+ type Rows interface

+ Close func()

+ CommandTag func() pgconn.CommandTag

+ Err func() error

+ FieldDescriptions func() []pgproto3.FieldDescription

+ Next func() bool

+ RawValues func() [][]byte

+ Scan func(dest ...interface{}) error

+ Values func() ([]interface{}, error)

+ type ScanArgError struct

+ ColumnIndex int

+ Err error

+ func (e ScanArgError) Error() string

+ func (e ScanArgError) Unwrap() error

+ type SerializationError string

+ func (e SerializationError) Error() string

+ type Tx interface

+ Begin func(ctx context.Context) (Tx, error)

+ BeginFunc func(ctx context.Context, f func(Tx) error) (err error)

+ Commit func(ctx context.Context) error

+ Conn func() *Conn

+ CopyFrom func(ctx context.Context, tableName Identifier, columnNames []string, ...) (int64, error)

+ Exec func(ctx context.Context, sql string, arguments ...interface{}) (commandTag pgconn.CommandTag, err error)

+ LargeObjects func() LargeObjects

+ Prepare func(ctx context.Context, name, sql string) (*pgconn.StatementDescription, error)

+ Query func(ctx context.Context, sql string, args ...interface{}) (Rows, error)

+ QueryFunc func(ctx context.Context, sql string, args []interface{}, scans []interface{}, ...) (pgconn.CommandTag, error)

+ QueryRow func(ctx context.Context, sql string, args ...interface{}) Row

+ Rollback func(ctx context.Context) error

+ SendBatch func(ctx context.Context, b *Batch) BatchResults

+ type TxAccessMode string

+ type TxDeferrableMode string

+ type TxIsoLevel string

+ type TxOptions struct

+ AccessMode TxAccessMode

+ DeferrableMode TxDeferrableMode

+ IsoLevel TxIsoLevel

Other modules containing this package

github.com/nalcheg/pgx