summaryrefslogtreecommitdiff
path: root/vendor/github.com/jackc/pgx/v5/pgxpool/conn.go
diff options
context:
space:
mode:
Diffstat (limited to 'vendor/github.com/jackc/pgx/v5/pgxpool/conn.go')
-rw-r--r--vendor/github.com/jackc/pgx/v5/pgxpool/conn.go134
1 files changed, 0 insertions, 134 deletions
diff --git a/vendor/github.com/jackc/pgx/v5/pgxpool/conn.go b/vendor/github.com/jackc/pgx/v5/pgxpool/conn.go
deleted file mode 100644
index 38c90f3da..000000000
--- a/vendor/github.com/jackc/pgx/v5/pgxpool/conn.go
+++ /dev/null
@@ -1,134 +0,0 @@
-package pgxpool
-
-import (
- "context"
- "sync/atomic"
-
- "github.com/jackc/pgx/v5"
- "github.com/jackc/pgx/v5/pgconn"
- "github.com/jackc/puddle/v2"
-)
-
-// Conn is an acquired *pgx.Conn from a Pool.
-type Conn struct {
- res *puddle.Resource[*connResource]
- p *Pool
-}
-
-// Release returns c to the pool it was acquired from. Once Release has been called, other methods must not be called.
-// However, it is safe to call Release multiple times. Subsequent calls after the first will be ignored.
-func (c *Conn) Release() {
- if c.res == nil {
- return
- }
-
- conn := c.Conn()
- res := c.res
- c.res = nil
-
- if c.p.releaseTracer != nil {
- c.p.releaseTracer.TraceRelease(c.p, TraceReleaseData{Conn: conn})
- }
-
- if conn.IsClosed() || conn.PgConn().IsBusy() || conn.PgConn().TxStatus() != 'I' {
- res.Destroy()
- // Signal to the health check to run since we just destroyed a connections
- // and we might be below minConns now
- c.p.triggerHealthCheck()
- return
- }
-
- // If the pool is consistently being used, we might never get to check the
- // lifetime of a connection since we only check idle connections in checkConnsHealth
- // so we also check the lifetime here and force a health check
- if c.p.isExpired(res) {
- atomic.AddInt64(&c.p.lifetimeDestroyCount, 1)
- res.Destroy()
- // Signal to the health check to run since we just destroyed a connections
- // and we might be below minConns now
- c.p.triggerHealthCheck()
- return
- }
-
- if c.p.afterRelease == nil {
- res.Release()
- return
- }
-
- go func() {
- if c.p.afterRelease(conn) {
- res.Release()
- } else {
- res.Destroy()
- // Signal to the health check to run since we just destroyed a connections
- // and we might be below minConns now
- c.p.triggerHealthCheck()
- }
- }()
-}
-
-// Hijack assumes ownership of the connection from the pool. Caller is responsible for closing the connection. Hijack
-// will panic if called on an already released or hijacked connection.
-func (c *Conn) Hijack() *pgx.Conn {
- if c.res == nil {
- panic("cannot hijack already released or hijacked connection")
- }
-
- conn := c.Conn()
- res := c.res
- c.res = nil
-
- res.Hijack()
-
- return conn
-}
-
-func (c *Conn) Exec(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error) {
- return c.Conn().Exec(ctx, sql, arguments...)
-}
-
-func (c *Conn) Query(ctx context.Context, sql string, args ...any) (pgx.Rows, error) {
- return c.Conn().Query(ctx, sql, args...)
-}
-
-func (c *Conn) QueryRow(ctx context.Context, sql string, args ...any) pgx.Row {
- return c.Conn().QueryRow(ctx, sql, args...)
-}
-
-func (c *Conn) SendBatch(ctx context.Context, b *pgx.Batch) pgx.BatchResults {
- return c.Conn().SendBatch(ctx, b)
-}
-
-func (c *Conn) CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int64, error) {
- return c.Conn().CopyFrom(ctx, tableName, columnNames, rowSrc)
-}
-
-// Begin starts a transaction block from the *Conn without explicitly setting a transaction mode (see BeginTx with TxOptions if transaction mode is required).
-func (c *Conn) Begin(ctx context.Context) (pgx.Tx, error) {
- return c.Conn().Begin(ctx)
-}
-
-// BeginTx starts a transaction block from the *Conn with txOptions determining the transaction mode.
-func (c *Conn) BeginTx(ctx context.Context, txOptions pgx.TxOptions) (pgx.Tx, error) {
- return c.Conn().BeginTx(ctx, txOptions)
-}
-
-func (c *Conn) Ping(ctx context.Context) error {
- return c.Conn().Ping(ctx)
-}
-
-func (c *Conn) Conn() *pgx.Conn {
- return c.connResource().conn
-}
-
-func (c *Conn) connResource() *connResource {
- return c.res.Value()
-}
-
-func (c *Conn) getPoolRow(r pgx.Row) *poolRow {
- return c.connResource().getPoolRow(c, r)
-}
-
-func (c *Conn) getPoolRows(r pgx.Rows) *poolRows {
- return c.connResource().getPoolRows(c, r)
-}