Struct PgPool 

pub struct PgPool { /* private fields */ }

PostgreSQL connection pool.

Example

let config = PoolConfig::new("localhost", 5432, "user", "db")
    .password("secret")
    .max_connections(20);

let pool = PgPool::connect(config).await?;

// Get a connection from the pool
let mut conn = pool.acquire().await?;
conn.simple_query("SELECT 1").await?;
// Connection automatically returned when dropped

Implementations

impl PgPool

pub async fn connect(config: PoolConfig) -> PgResult<Self>

Create a new connection pool.

pub async fn acquire(&self) -> PgResult<PooledConnection>

Acquire a connection from the pool.

Waits if all connections are in use (up to acquire_timeout). Stale connections (idle > idle_timeout) are automatically discarded. Connection is automatically returned when dropped.

pub async fn idle_count(&self) -> usize

Get the current number of idle connections.

pub fn active_count(&self) -> usize

Get the number of connections currently in use.

pub fn max_connections(&self) -> usize

Get the maximum number of connections.

pub async fn stats(&self) -> PoolStats

Get comprehensive pool statistics.

pub fn is_closed(&self) -> bool

Check if the pool is closed.

pub async fn close(&self)

Close the pool gracefully.

Prevents new connections from being acquired. Existing checked-out connections will be dropped when returned.

Trait Implementations

impl Clone for PgPool

fn clone(&self) -> PgPool

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.