type github.com/jackc/pgx/v5.Conn
105 uses
github.com/jackc/pgx/v5 (current package)
batch.go#L119: conn *Conn
batch.go#L280: conn *Conn
batch.go#L455: conn *Conn
batch.go#L494: func invalidateCachesOnBatchResultsError(conn *Conn, b *Batch, err error) {
conn.go#L67: type Conn struct {
conn.go#L135: func Connect(ctx context.Context, connString string) (*Conn, error) {
conn.go#L145: func ConnectWithOptions(ctx context.Context, connString string, options ParseConfigOptions) (*Conn, error) {
conn.go#L155: func ConnectConfig(ctx context.Context, connConfig *ConnConfig) (*Conn, error) {
conn.go#L243: func connect(ctx context.Context, config *ConnConfig) (c *Conn, err error) {
conn.go#L257: c = &Conn{
conn.go#L301: func (c *Conn) Close(ctx context.Context) error {
conn.go#L319: func (c *Conn) Prepare(ctx context.Context, name, sql string) (sd *pgconn.StatementDescription, err error) {
conn.go#L375: func (c *Conn) Deallocate(ctx context.Context, name string) error {
conn.go#L397: func (c *Conn) DeallocateAll(ctx context.Context) error {
conn.go#L409: func (c *Conn) bufferNotifications(_ *pgconn.PgConn, n *pgconn.Notification) {
conn.go#L415: func (c *Conn) WaitForNotification(ctx context.Context) (*pgconn.Notification, error) {
conn.go#L434: func (c *Conn) IsClosed() bool {
conn.go#L438: func (c *Conn) die() {
conn.go#L453: func (c *Conn) Ping(ctx context.Context) error {
conn.go#L462: func (c *Conn) PgConn() *pgconn.PgConn { return c.pgConn }
conn.go#L465: func (c *Conn) TypeMap() *pgtype.Map { return c.typeMap }
conn.go#L468: func (c *Conn) Config() *ConnConfig { return c.config.Copy() }
conn.go#L472: func (c *Conn) Exec(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error) {
conn.go#L490: func (c *Conn) exec(ctx context.Context, sql string, arguments ...any) (commandTag pgconn.CommandTag, err error) {
conn.go#L580: func (c *Conn) execSimpleProtocol(ctx context.Context, sql string, arguments []any) (commandTag pgconn.CommandTag, err error) {
conn.go#L596: func (c *Conn) execParams(ctx context.Context, sd *pgconn.StatementDescription, arguments []any) (pgconn.CommandTag, error) {
conn.go#L607: func (c *Conn) execPrepared(ctx context.Context, sd *pgconn.StatementDescription, arguments []any) (pgconn.CommandTag, error) {
conn.go#L618: func (c *Conn) execSQLParams(ctx context.Context, sql string, args []any) (pgconn.CommandTag, error) {
conn.go#L629: func (c *Conn) getRows(ctx context.Context, sql string, args []any) *baseRows {
conn.go#L727: RewriteQuery(ctx context.Context, conn *Conn, sql string, args []any) (newSQL string, newArgs []any, err error)
conn.go#L751: func (c *Conn) Query(ctx context.Context, sql string, args ...any) (Rows, error) {
conn.go#L891: func (c *Conn) getStatementDescription(
conn.go#L930: func (c *Conn) QueryRow(ctx context.Context, sql string, args ...any) Row {
conn.go#L941: func (c *Conn) SendBatch(ctx context.Context, b *Batch) (br BatchResults) {
conn.go#L1016: func (c *Conn) sendBatchQueryExecModeSimpleProtocol(ctx context.Context, b *Batch) *batchResults {
conn.go#L1038: func (c *Conn) sendBatchQueryExecModeExec(ctx context.Context, b *Batch) *batchResults {
conn.go#L1072: func (c *Conn) sendBatchQueryExecModeCacheStatement(ctx context.Context, b *Batch) (pbr *pipelineBatchResults) {
conn.go#L1104: func (c *Conn) sendBatchQueryExecModeCacheDescribe(ctx context.Context, b *Batch) (pbr *pipelineBatchResults) {
conn.go#L1135: func (c *Conn) sendBatchQueryExecModeDescribeExec(ctx context.Context, b *Batch) (pbr *pipelineBatchResults) {
conn.go#L1157: func (c *Conn) sendBatchExtendedWithDescription(ctx context.Context, b *Batch, distinctNewQueries []*pgconn.StatementDescription, sdCache stmtcache.Cache) (pbr *pipelineBatchResults) {
conn.go#L1259: func (c *Conn) sanitizeForSimpleQuery(sql string, args ...any) (string, error) {
conn.go#L1289: func (c *Conn) LoadType(ctx context.Context, typeName string) (*pgtype.Type, error) {
conn.go#L1363: func (c *Conn) getArrayElementOID(ctx context.Context, oid uint32) (uint32, error) {
conn.go#L1374: func (c *Conn) getRangeElementOID(ctx context.Context, oid uint32) (uint32, error) {
conn.go#L1385: func (c *Conn) getMultiRangeElementOID(ctx context.Context, oid uint32) (uint32, error) {
conn.go#L1396: func (c *Conn) getCompositeFields(ctx context.Context, oid uint32) ([]pgtype.CompositeCodecField, error) {
conn.go#L1430: func (c *Conn) deallocateInvalidatedCachedStatements(ctx context.Context) error {
copy_from.go#L110: conn *Conn
copy_from.go#L265: func (c *Conn) CopyFrom(ctx context.Context, tableName Identifier, columnNames []string, rowSrc CopyFromSource) (int64, error) {
derived_types.go#L162: func (c *Conn) LoadTypes(ctx context.Context, typeNames []string) ([]*pgtype.Type, error) {
derived_types.go#L243: func serverVersion(c *Conn) (int64, error) {
named_args.go#L24: func (na NamedArgs) RewriteQuery(ctx context.Context, conn *Conn, sql string, args []any) (newSQL string, newArgs []any, err error) {
named_args.go#L33: func (sna StrictNamedArgs) RewriteQuery(ctx context.Context, conn *Conn, sql string, args []any) (newSQL string, newArgs []any, err error) {
rows.go#L70: Conn() *Conn
rows.go#L135: conn *Conn
rows.go#L339: func (rows *baseRows) Conn() *Conn {
tracer.go#L13: TraceQueryStart(ctx context.Context, conn *Conn, data TraceQueryStartData) context.Context
tracer.go#L15: TraceQueryEnd(ctx context.Context, conn *Conn, data TraceQueryEndData)
tracer.go#L32: TraceBatchStart(ctx context.Context, conn *Conn, data TraceBatchStartData) context.Context
tracer.go#L34: TraceBatchQuery(ctx context.Context, conn *Conn, data TraceBatchQueryData)
tracer.go#L35: TraceBatchEnd(ctx context.Context, conn *Conn, data TraceBatchEndData)
tracer.go#L57: TraceCopyFromStart(ctx context.Context, conn *Conn, data TraceCopyFromStartData) context.Context
tracer.go#L59: TraceCopyFromEnd(ctx context.Context, conn *Conn, data TraceCopyFromEndData)
tracer.go#L76: TracePrepareStart(ctx context.Context, conn *Conn, data TracePrepareStartData) context.Context
tracer.go#L78: TracePrepareEnd(ctx context.Context, conn *Conn, data TracePrepareEndData)
tracer.go#L105: Conn *Conn
tx.go#L94: func (c *Conn) Begin(ctx context.Context) (Tx, error) {
tx.go#L100: func (c *Conn) BeginTx(ctx context.Context, txOptions TxOptions) (Tx, error) {
tx.go#L150: Conn() *Conn
tx.go#L158: conn *Conn
tx.go#L283: func (tx *dbTx) Conn() *Conn {
tx.go#L384: func (sp *dbSimulatedNestedTx) Conn() *Conn {
github.com/jackc/pgx/v5/pgxpool
conn.go#L72: func (c *Conn) Hijack() *pgx.Conn {
conn.go#L120: func (c *Conn) Conn() *pgx.Conn {
pool.go#L28: conn *pgx.Conn
pool.go#L88: afterConnect func(context.Context, *pgx.Conn) error
pool.go#L89: prepareConn func(context.Context, *pgx.Conn) (bool, error)
pool.go#L90: afterRelease func(*pgx.Conn) bool
pool.go#L91: beforeClose func(*pgx.Conn)
pool.go#L116: Conn *pgx.Conn
pool.go#L130: AfterConnect func(context.Context, *pgx.Conn) error
pool.go#L138: BeforeAcquire func(context.Context, *pgx.Conn) bool
pool.go#L150: PrepareConn func(context.Context, *pgx.Conn) (bool, error)
pool.go#L154: AfterRelease func(*pgx.Conn) bool
pool.go#L157: BeforeClose func(*pgx.Conn)
pool.go#L231: prepareConn = func(ctx context.Context, conn *pgx.Conn) (bool, error) {
pool.go#L603: var conn *pgx.Conn
rows.go#L20: func (e errRows) Conn() *pgx.Conn { return nil }
rows.go#L89: func (rows *poolRows) Conn() *pgx.Conn {
tracer.go#L21: Conn *pgx.Conn
tracer.go#L32: Conn *pgx.Conn
tx.go#L81: func (tx *Tx) Conn() *pgx.Conn {
github.com/jackc/pgx/v5/tracelog
tracelog.go#L174: func (tl *TraceLog) TraceQueryStart(ctx context.Context, conn *pgx.Conn, data pgx.TraceQueryStartData) context.Context {
tracelog.go#L182: func (tl *TraceLog) TraceQueryEnd(ctx context.Context, conn *pgx.Conn, data pgx.TraceQueryEndData) {
tracelog.go#L205: func (tl *TraceLog) TraceBatchStart(ctx context.Context, conn *pgx.Conn, data pgx.TraceBatchStartData) context.Context {
tracelog.go#L211: func (tl *TraceLog) TraceBatchQuery(ctx context.Context, conn *pgx.Conn, data pgx.TraceBatchQueryData) {
tracelog.go#L224: func (tl *TraceLog) TraceBatchEnd(ctx context.Context, conn *pgx.Conn, data pgx.TraceBatchEndData) {
tracelog.go#L249: func (tl *TraceLog) TraceCopyFromStart(ctx context.Context, conn *pgx.Conn, data pgx.TraceCopyFromStartData) context.Context {
tracelog.go#L257: func (tl *TraceLog) TraceCopyFromEnd(ctx context.Context, conn *pgx.Conn, data pgx.TraceCopyFromEndData) {
tracelog.go#L326: func (tl *TraceLog) TracePrepareStart(ctx context.Context, _ *pgx.Conn, data pgx.TracePrepareStartData) context.Context {
tracelog.go#L334: func (tl *TraceLog) TracePrepareEnd(ctx context.Context, conn *pgx.Conn, data pgx.TracePrepareEndData) {
tracelog.go#L395: func (tl *TraceLog) log(ctx context.Context, conn *pgx.Conn, lvl LogLevel, msg string, data map[string]any) {
go.pact.im/x/pgxprocess
conn.go#L17: handle[pgx.Conn, *pgx.Conn]
errors.go#L52: func (errRows) Conn() *pgx.Conn {