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

pq

package module

Go to main page

Versions in this module

v1

v1.0.8

Nov 28, 2023

v1.0.7

Nov 28, 2023

v1.0.6

Nov 28, 2023

Changes in this version

+ const AUTH_REQ_CRYPT

+ const AUTH_REQ_KRB4

+ const AUTH_REQ_KRB5

+ const AUTH_REQ_SCM

+ const AUTH_REQ_SSPI

+ const AuthReqGss

+ const AuthReqGssContinue

+ const AuthReqMd5

+ const AuthReqMd5Sha256

+ const AuthReqOk

+ const AuthReqPassword

+ const AuthReqSha256

+ const AuthReqSm3

+ const ClientEncoding

+ const DefaultClientEncoding

+ const Edebug

+ const Efatal

+ const Einfo

+ const Elog

+ const Enotice

+ const Epanic

+ const Ewarning

+ const LogLevelDebug

+ const LogLevelError

+ const LogLevelInfo

+ const LogLevelNone

+ const LogLevelTrace

+ const LogLevelWarn

+ const Md5Password

+ const PlainPassword

+ const ServerEncoding

+ const ServerVersion

+ const Sha256Password

+ const Sm3Password

+ const TimeZone

+ var ErrChannelAlreadyOpen = errors.New("pq: channel is already open")

+ var ErrChannelNotOpen = errors.New("pq: channel is not open")

+ var ErrCouldNotDetectUsername = errors.New("pq: Could not detect default username. Please provide one explicitly")

+ var ErrInFailedTransaction = errors.New("pq: Could not complete operation in a failed transaction")

+ var ErrNotSupported = errors.New("pq: Unsupported command")

+ var ErrSSLKeyHasWorldPermissions = errors.New(...)

+ var ErrSSLKeyUnknownOwnership = errors.New(...)

+ var ErrSSLNotSupported = errors.New("pq: SSL is not enabled on the server")

+ func Array(a interface{}) interface

+ func ConnectorNoticeHandler(c driver.Connector) func(*Error)

+ func ConnectorNotificationHandler(c driver.Connector) func(*Notification)

+ func CopyIn(table string, columns ...string) string

+ func CopyInSchema(schema, table string, columns ...string) string

+ func DeregisterTLSConfig(key string)

+ func DialOpen(d Dialer, dsn string) (_ driver.Conn, err error)

+ func EnableInfinityTs(negative time.Time, positive time.Time)

+ func FormatTimestamp(t time.Time) []byte

+ func Md5Sha256encode(password, random64code string, salt []byte) []byte

+ func NetworkAddress(host string, port uint16) (network, address string)

+ func NoticeHandler(c driver.Conn) func(*Error)

+ func Open(dsn string) (_ driver.Conn, err error)

+ func ParseTimestamp(currentLocation *time.Location, str string) (time.Time, error)

+ func ParseURL(url string) (string, error)

+ func ParseURLToMap(connString string) (map[string]string, error)

+ func QuoteIdentifier(name string) string

+ func QuoteLiteral(literal string) string

+ func RFC5802Algorithm(password string, random64code string, token string, serverSignature string, ...) []byte

+ func RegisterGSSProvider(newGssArg NewGSSFunc)

+ func RegisterTLSConfig(key string, config *tls.Config) error

+ func SetNoticeHandler(c driver.Conn, handler func(*Error))

+ func SetNotificationHandler(c driver.Conn, handler func(*Notification))

+ func ValidateConnectTargetSessionAttrsPrimary(cn *conn) error

+ func ValidateConnectTargetSessionAttrsReadOnly(cn *conn) error

+ func ValidateConnectTargetSessionAttrsReadWrite(cn *conn) error

+ func ValidateConnectTargetSessionAttrsStandby(cn *conn) error

+ func XorBetweenPassword(password1 []byte, password2 []byte, length int) []byte

+ type ArrayDelimiter interface

+ ArrayDelimiter func() string

+ type BoolArray []bool

+ func (a *BoolArray) Scan(src interface{}) error

+ func (a BoolArray) Value() (driver.Value, error)

+ type ByteaArray [][]byte

+ func (a *ByteaArray) Scan(src interface{}) error

+ func (a ByteaArray) Value() (driver.Value, error)

+ type Config struct

+ ConnectTimeout time.Duration

+ Database string

+ DialFunc DialFunc

+ Fallbacks []*FallbackConfig

+ GssAPIParams map[string]string

+ Host string

+ LogLevel LogLevel

+ Logger Logger

+ LookupFunc LookupFunc

+ Password string

+ Port uint16

+ RuntimeParams map[string]string

+ TLSConfig *tls.Config

+ User string

+ ValidateConnect ValidateConnectFunc

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

+ func (c *Config) Copy() *Config

+ type Connector struct

+ func NewConnector(dsn string) (*Connector, error)

+ func NewConnectorConfig(config *Config) (*Connector, error)

+ func (c *Connector) Connect(ctx context.Context) (driver.Conn, error)

+ func (c *Connector) Driver() driver.Driver

+ type DialFunc func(ctx context.Context, network, addr string) (net.Conn, error)

+ type Dialer interface

+ Dial func(network, address string) (net.Conn, error)

+ DialTimeout func(network, address string, timeout time.Duration) (net.Conn, error)

+ type DialerContext interface

+ DialContext func(ctx context.Context, network, address string) (net.Conn, error)

+ type Driver struct

+ func (d Driver) Open(name string) (driver.Conn, error)

+ type Error struct

+ Code ErrorCode

+ Column string

+ Constraint string

+ DataTypeName string

+ Detail string

+ File string

+ Hint string

+ InternalPosition string

+ InternalQuery string

+ Line string

+ Message string

+ Position string

+ Routine string

+ Schema string

+ Severity string

+ Table string

+ Where string

+ func (err *Error) Fatal() bool

+ func (err *Error) Get(k byte) (v string)

+ func (err *Error) SQLState() string

+ func (err Error) Error() string

+ type ErrorClass string

+ func (ec ErrorClass) Name() string

+ type ErrorCode string

+ func (ec ErrorCode) Class() ErrorClass

+ func (ec ErrorCode) Name() string

+ func (ec ErrorCode) String() string

+ type EventCallbackType func(event ListenerEventType, err error)

+ type FallbackConfig struct

+ Host string

+ Port uint16

+ TLSConfig *tls.Config

+ type Float32Array []float32

+ func (a *Float32Array) Scan(src interface{}) error

+ func (a Float32Array) Value() (driver.Value, error)

+ type Float64Array []float64

+ func (a *Float64Array) Scan(src interface{}) error

+ func (a Float64Array) Value() (driver.Value, error)

+ type GSS interface

+ Continue func(inToken []byte) (done bool, outToken []byte, err error)

+ GetInitToken func(host string, service string) ([]byte, error)

+ GetInitTokenFromSpn func(spn string) ([]byte, error)

+ type GenericArray struct

+ A interface{}

+ func (a GenericArray) Scan(src interface{}) error

+ func (a GenericArray) Value() (driver.Value, error)

+ type Int32Array []int32

+ func (a *Int32Array) Scan(src interface{}) error

+ func (a Int32Array) Value() (driver.Value, error)

+ type Int64Array []int64

+ func (a *Int64Array) Scan(src interface{}) error

+ func (a Int64Array) Value() (driver.Value, error)

+ type Listener struct

+ Notify chan *Notification

+ func NewDialListener(d Dialer, name string, minReconnectInterval time.Duration, ...) *Listener

+ func NewListener(name string, minReconnectInterval time.Duration, ...) *Listener

+ func (l *Listener) Close() error

+ func (l *Listener) Listen(channel string) error

+ func (l *Listener) NotificationChannel() <-chan *Notification

+ func (l *Listener) Ping() error

+ func (l *Listener) Unlisten(channel string) error

+ func (l *Listener) UnlistenAll() error

+ type ListenerConn struct

+ func NewListenerConn(name string, notificationChan chan<- *Notification) (*ListenerConn, error)

+ func (l *ListenerConn) Close() error

+ func (l *ListenerConn) Err() error

+ func (l *ListenerConn) ExecSimpleQuery(q string) (executed bool, err error)

+ func (l *ListenerConn) Listen(channel string) (bool, error)

+ func (l *ListenerConn) Ping() error

+ func (l *ListenerConn) Unlisten(channel string) (bool, error)

+ func (l *ListenerConn) UnlistenAll() (bool, error)

+ type ListenerEventType int

+ const ListenerEventConnected

+ const ListenerEventConnectionAttemptFailed

+ const ListenerEventDisconnected

+ const ListenerEventReconnected

+ 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{})

+ var DefaultLogger Logger = NewPrintfLogger(LogLevelDebug)

+ func NewPrintfLogger(level LogLevel) Logger

+ type LookupFunc func(ctx context.Context, host string) (addrs []string, err error)

+ type NewGSSFunc func() (GSS, error)

+ type NoticeHandlerConnector struct

+ func ConnectorWithNoticeHandler(c driver.Connector, handler func(*Error)) *NoticeHandlerConnector

+ func (n *NoticeHandlerConnector) Connect(ctx context.Context) (driver.Conn, error)

+ type Notification struct

+ BePid int

+ Channel string

+ Extra string

+ type NotificationHandlerConnector struct

+ func ConnectorWithNotificationHandler(c driver.Connector, handler func(*Notification)) *NotificationHandlerConnector

+ func (n *NotificationHandlerConnector) Connect(ctx context.Context) (driver.Conn, error)

+ type NullTime struct

+ Time time.Time

+ Valid bool

+ func (nt *NullTime) Scan(value interface{}) error

+ func (nt NullTime) Value() (driver.Value, error)

+ type PGError interface

+ Error func() string

+ Fatal func() bool

+ Get func(k byte) (v string)

+ type StringArray []string

+ func (a *StringArray) Scan(src interface{}) error

+ func (a StringArray) Value() (driver.Value, error)

+ type ValidateConnectFunc func(conn *conn) error