pgx

package module

Go to main page

Versions in this module

v5

v5.7.1

Sep 10, 2024

v5.7.0

Sep 7, 2024

Changes in this version

type Conn

+ func (c *Conn) LoadTypes(ctx context.Context, typeNames []string) ([]*pgtype.Type, error)

v5.6.0

May 25, 2024

Changes in this version

type QueuedQuery

+ Fn batchItemFunc

+ type StrictNamedArgs map[string]any

+ func (sna StrictNamedArgs) RewriteQuery(ctx context.Context, conn *Conn, sql string, args []any) (newSQL string, newArgs []any, err error)

v5.5.5

Mar 9, 2024

v5.5.4

Mar 4, 2024

v5.5.3

Feb 3, 2024 GO-2024-2606

GO-2024-2606: SQL injection in github.com/jackc/pgproto3 and github.com/jackc/pgx

Changes in this version

+ func AppendRows[T any, S ~[]T](slice S, rows Rows, fn RowToFunc[T]) (S, error)

type Batch

+ QueuedQueries []*QueuedQuery

type QueuedQuery

+ Arguments []any

+ SQL string

v5.5.2

Jan 13, 2024 GO-2024-2606

GO-2024-2606: SQL injection in github.com/jackc/pgproto3 and github.com/jackc/pgx

v5.5.1

Dec 9, 2023 GO-2024-2567 +1 more

GO-2024-2567: Panic in Pipeline when PgConn is busy or closed in github.com/jackc/pgx

GO-2024-2606: SQL injection in github.com/jackc/pgproto3 and github.com/jackc/pgx

Changes in this version

type CopyFromSource

+ func CopyFromFunc(nxtf func() (row []any, err error)) CopyFromSource

v5.5.0

Nov 4, 2023 GO-2024-2567 +1 more

GO-2024-2567: Panic in Pipeline when PgConn is busy or closed in github.com/jackc/pgx

GO-2024-2606: SQL injection in github.com/jackc/pgproto3 and github.com/jackc/pgx

Changes in this version

+ var ErrTooManyRows = errors.New("too many rows in result set")

+ func CollectExactlyOneRow(rows Rows, fn RowToFunc[T]) (T, error)

v5.4.3

Aug 5, 2023 GO-2024-2567 +1 more

GO-2024-2567: Panic in Pipeline when PgConn is busy or closed in github.com/jackc/pgx

GO-2024-2606: SQL injection in github.com/jackc/pgproto3 and github.com/jackc/pgx

v5.4.2

Jul 12, 2023 GO-2024-2567 +1 more

GO-2024-2567: Panic in Pipeline when PgConn is busy or closed in github.com/jackc/pgx

GO-2024-2606: SQL injection in github.com/jackc/pgproto3 and github.com/jackc/pgx

v5.4.1

Jun 18, 2023 GO-2024-2567 +1 more

GO-2024-2567: Panic in Pipeline when PgConn is busy or closed in github.com/jackc/pgx

GO-2024-2606: SQL injection in github.com/jackc/pgproto3 and github.com/jackc/pgx

Changes in this version

type TxOptions

+ BeginQuery string

v5.4.0

Jun 14, 2023 GO-2024-2567 +1 more

GO-2024-2567: Panic in Pipeline when PgConn is busy or closed in github.com/jackc/pgx

GO-2024-2606: SQL injection in github.com/jackc/pgproto3 and github.com/jackc/pgx

Changes in this version

+ func RowToAddrOfStructByNameLax(row CollectableRow) (*T, error)

+ func RowToStructByNameLax(row CollectableRow) (T, error)

v5.3.1

Feb 28, 2023 GO-2024-2567 +1 more

GO-2024-2567: Panic in Pipeline when PgConn is busy or closed in github.com/jackc/pgx

GO-2024-2606: SQL injection in github.com/jackc/pgproto3 and github.com/jackc/pgx

v5.3.0

Feb 11, 2023 GO-2024-2567 +1 more

GO-2024-2567: Panic in Pipeline when PgConn is busy or closed in github.com/jackc/pgx

GO-2024-2606: SQL injection in github.com/jackc/pgproto3 and github.com/jackc/pgx

v5.2.0

Dec 6, 2022 GO-2024-2567 +1 more

GO-2024-2567: Panic in Pipeline when PgConn is busy or closed in github.com/jackc/pgx

GO-2024-2606: SQL injection in github.com/jackc/pgproto3 and github.com/jackc/pgx

v5.1.1

Nov 18, 2022 GO-2024-2567 +1 more

GO-2024-2567: Panic in Pipeline when PgConn is busy or closed in github.com/jackc/pgx

GO-2024-2606: SQL injection in github.com/jackc/pgproto3 and github.com/jackc/pgx

v5.1.0

Nov 12, 2022 GO-2024-2567 +1 more

GO-2024-2567: Panic in Pipeline when PgConn is busy or closed in github.com/jackc/pgx

GO-2024-2606: SQL injection in github.com/jackc/pgproto3 and github.com/jackc/pgx

Changes in this version

+ func RowToAddrOfStructByName(row CollectableRow) (*T, error)

+ func RowToStructByName(row CollectableRow) (T, error)

type Conn

+ func ConnectWithOptions(ctx context.Context, connString string, options ParseConfigOptions) (*Conn, error)

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

type ConnConfig

+ func ParseConfigWithOptions(connString string, options ParseConfigOptions) (*ConnConfig, error)

+ type ParseConfigOptions struct

v5.0.4

Oct 25, 2022 GO-2024-2567 +1 more

GO-2024-2567: Panic in Pipeline when PgConn is busy or closed in github.com/jackc/pgx

GO-2024-2606: SQL injection in github.com/jackc/pgproto3 and github.com/jackc/pgx

v5.0.3

Oct 15, 2022 GO-2024-2567 +1 more

GO-2024-2567: Panic in Pipeline when PgConn is busy or closed in github.com/jackc/pgx

GO-2024-2606: SQL injection in github.com/jackc/pgproto3 and github.com/jackc/pgx

v5.0.2

Oct 8, 2022 GO-2024-2567 +1 more

GO-2024-2567: Panic in Pipeline when PgConn is busy or closed in github.com/jackc/pgx

GO-2024-2606: SQL injection in github.com/jackc/pgproto3 and github.com/jackc/pgx

v5.0.1

Sep 24, 2022 GO-2024-2567 +1 more

GO-2024-2567: Panic in Pipeline when PgConn is busy or closed in github.com/jackc/pgx

GO-2024-2606: SQL injection in github.com/jackc/pgproto3 and github.com/jackc/pgx

v5.0.0

Sep 17, 2022 GO-2024-2567 +1 more

GO-2024-2567: Panic in Pipeline when PgConn is busy or closed in github.com/jackc/pgx

GO-2024-2606: SQL injection in github.com/jackc/pgproto3 and github.com/jackc/pgx

Changes in this version

+ const BinaryFormatCode

+ const TextFormatCode

+ 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 BeginFunc(ctx context.Context, db interface{ ... }, fn func(Tx) error) (err error)

+ func BeginTxFunc(ctx context.Context, db interface{ ... }, txOptions TxOptions, ...) (err error)

+ func CollectOneRow(rows Rows, fn RowToFunc[T]) (T, error)

+ func CollectRows(rows Rows, fn RowToFunc[T]) ([]T, error)

+ func ForEachRow(rows Rows, scans []any, fn func() error) (pgconn.CommandTag, error)

+ func RowTo(row CollectableRow) (T, error)

+ func RowToAddrOf(row CollectableRow) (*T, error)

+ func RowToAddrOfStructByPos(row CollectableRow) (*T, error)

+ func RowToMap(row CollectableRow) (map[string]any, error)

+ func RowToStructByPos(row CollectableRow) (T, error)

+ func ScanRow(typeMap *pgtype.Map, fieldDescriptions []pgconn.FieldDescription, ...) error

+ type Batch struct

+ func (b *Batch) Len() int

+ func (b *Batch) Queue(query string, arguments ...any) *QueuedQuery

+ type BatchResults interface

+ Close func() error

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

+ Query func() (Rows, error)

+ QueryRow func() Row

+ type BatchTracer interface

+ TraceBatchEnd func(ctx context.Context, conn *Conn, data TraceBatchEndData)

+ TraceBatchQuery func(ctx context.Context, conn *Conn, data TraceBatchQueryData)

+ TraceBatchStart func(ctx context.Context, conn *Conn, data TraceBatchStartData) context.Context

+ type CollectableRow interface

+ FieldDescriptions func() []pgconn.FieldDescription

+ RawValues func() [][]byte

+ Scan func(dest ...any) error

+ Values func() ([]any, error)

+ 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) BeginTx(ctx context.Context, txOptions TxOptions) (Tx, error)

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

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

+ 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 ...any) (pgconn.CommandTag, error)

+ func (c *Conn) IsClosed() bool

+ func (c *Conn) LoadType(ctx context.Context, typeName string) (*pgtype.Type, error)

+ 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 ...any) (Rows, error)

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

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

+ func (c *Conn) TypeMap() *pgtype.Map

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

+ type ConnConfig struct

+ DefaultQueryExecMode QueryExecMode

+ DescriptionCacheCapacity int

+ StatementCacheCapacity int

+ Tracer QueryTracer

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

+ func (cc *ConnConfig) ConnString() string

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

+ type ConnectTracer interface

+ TraceConnectEnd func(ctx context.Context, data TraceConnectEndData)

+ TraceConnectStart func(ctx context.Context, data TraceConnectStartData) context.Context

+ type CopyFromSource interface

+ Err func() error

+ Next func() bool

+ Values func() ([]any, error)

+ func CopyFromRows(rows [][]any) CopyFromSource

+ func CopyFromSlice(length int, next func(int) ([]any, error)) CopyFromSource

+ type CopyFromTracer interface

+ TraceCopyFromEnd func(ctx context.Context, conn *Conn, data TraceCopyFromEndData)

+ TraceCopyFromStart func(ctx context.Context, conn *Conn, data TraceCopyFromStartData) context.Context

+ type ExtendedQueryBuilder struct

+ ParamFormats []int16

+ ParamValues [][]byte

+ ResultFormats []int16

+ func (eqb *ExtendedQueryBuilder) Build(m *pgtype.Map, sd *pgconn.StatementDescription, args []any) error

+ 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 NamedArgs map[string]any

+ func (na NamedArgs) RewriteQuery(ctx context.Context, conn *Conn, sql string, args []any) (newSQL string, newArgs []any)

+ type PrepareTracer interface

+ TracePrepareEnd func(ctx context.Context, conn *Conn, data TracePrepareEndData)

+ TracePrepareStart func(ctx context.Context, conn *Conn, data TracePrepareStartData) context.Context

+ type QueryExecMode int32

+ const QueryExecModeCacheDescribe

+ const QueryExecModeCacheStatement

+ const QueryExecModeDescribeExec

+ const QueryExecModeExec

+ const QueryExecModeSimpleProtocol

+ func (m QueryExecMode) String() string

+ type QueryResultFormats []int16

+ type QueryResultFormatsByOID map[uint32]int16

+ type QueryRewriter interface

+ RewriteQuery func(ctx context.Context, conn *Conn, sql string, args []any) (newSQL string, newArgs []any)

+ type QueryTracer interface

+ TraceQueryEnd func(ctx context.Context, conn *Conn, data TraceQueryEndData)

+ TraceQueryStart func(ctx context.Context, conn *Conn, data TraceQueryStartData) context.Context

+ type QueuedQuery struct

+ func (qq *QueuedQuery) Exec(fn func(ct pgconn.CommandTag) error)

+ func (qq *QueuedQuery) Query(fn func(rows Rows) error)

+ func (qq *QueuedQuery) QueryRow(fn func(row Row) error)

+ type Row interface

+ Scan func(dest ...any) error

+ type RowScanner interface

+ ScanRow func(rows Rows) error

+ type RowToFunc func(row CollectableRow) (T, error)

+ type Rows interface

+ Close func()

+ CommandTag func() pgconn.CommandTag

+ Conn func() *Conn

+ Err func() error

+ FieldDescriptions func() []pgconn.FieldDescription

+ Next func() bool

+ RawValues func() [][]byte

+ Scan func(dest ...any) error

+ Values func() ([]any, error)

+ func RowsFromResultReader(typeMap *pgtype.Map, resultReader *pgconn.ResultReader) Rows

+ type ScanArgError struct

+ ColumnIndex int

+ Err error

+ func (e ScanArgError) Error() string

+ func (e ScanArgError) Unwrap() error

+ type TraceBatchEndData struct

+ Err error

+ type TraceBatchQueryData struct

+ Args []any

+ CommandTag pgconn.CommandTag

+ Err error

+ SQL string

+ type TraceBatchStartData struct

+ Batch *Batch

+ type TraceConnectEndData struct

+ Conn *Conn

+ Err error

+ type TraceConnectStartData struct

+ ConnConfig *ConnConfig

+ type TraceCopyFromEndData struct

+ CommandTag pgconn.CommandTag

+ Err error

+ type TraceCopyFromStartData struct

+ ColumnNames []string

+ TableName Identifier

+ type TracePrepareEndData struct

+ AlreadyPrepared bool

+ Err error

+ type TracePrepareStartData struct

+ Name string

+ SQL string

+ type TraceQueryEndData struct

+ CommandTag pgconn.CommandTag

+ Err error

+ type TraceQueryStartData struct

+ Args []any

+ SQL string

+ type Tx interface

+ Begin func(ctx context.Context) (Tx, 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 ...any) (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 ...any) (Rows, error)

+ QueryRow func(ctx context.Context, sql string, args ...any) Row

+ Rollback func(ctx context.Context) error

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

+ type TxAccessMode string

+ const ReadOnly

+ const ReadWrite

+ type TxDeferrableMode string

+ const Deferrable

+ const NotDeferrable

+ type TxIsoLevel string

+ const ReadCommitted

+ const ReadUncommitted

+ const RepeatableRead

+ const Serializable

+ type TxOptions struct

+ AccessMode TxAccessMode

+ DeferrableMode TxDeferrableMode

+ IsoLevel TxIsoLevel

v5.0.0-beta.5

Sep 6, 2022 GO-2024-2567

GO-2024-2567: Panic in Pipeline when PgConn is busy or closed in github.com/jackc/pgx

v5.0.0-beta.4

Sep 3, 2022 GO-2024-2567

GO-2024-2567: Panic in Pipeline when PgConn is busy or closed in github.com/jackc/pgx

v5.0.0-beta.3

Aug 23, 2022 GO-2024-2567

GO-2024-2567: Panic in Pipeline when PgConn is busy or closed in github.com/jackc/pgx

v5.0.0-beta.2

Aug 13, 2022 GO-2024-2567

GO-2024-2567: Panic in Pipeline when PgConn is busy or closed in github.com/jackc/pgx

v5.0.0-beta.1

Aug 6, 2022 GO-2024-2567

GO-2024-2567: Panic in Pipeline when PgConn is busy or closed in github.com/jackc/pgx

v5.0.0-alpha.5

Jul 16, 2022 GO-2024-2567

GO-2024-2567: Panic in Pipeline when PgConn is busy or closed in github.com/jackc/pgx

v5.0.0-alpha.4

Jun 25, 2022

v5.0.0-alpha.3

Apr 23, 2022

v5.0.0-alpha.2

Apr 2, 2022

v5.0.0-alpha.1

Mar 19, 2022

Other modules containing this package

github.com/jackc/pgx

github.com/jackc/pgx/v4

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL