Struct PooledConnection 

pub struct PooledConnection { /* private fields */ }

A connection checked out of a Pool.

Dereferences to Connection. When dropped, the connection is returned to the pool rather than closed — but only once any RowStream taken from it has also been dropped, so the connection is never handed out twice while a query is still streaming.

Implementations

impl PooledConnection

pub async fn begin(self) -> Result<Transaction, Error>

Starts a transaction on this connection.

Methods from Deref<Target = Connection>

pub fn is_closed(&self) -> bool

Returns true if the connection has been closed or hit an I/O error.

pub fn notifications(&self) -> Receiver<Notification>

Subscribes to LISTEN / NOTIFY notifications.

The returned receiver yields notifications delivered on this connection (after LISTEN). Multiple subscribers are supported.

pub fn cancel_token(&self) -> CancelToken

Returns a token that can cancel the currently running query.

pub async fn ping(&self) -> Result<(), Error>

Verifies the connection is usable with a trivial round trip.

Trait Implementations

impl Deref for PooledConnection

type Target = Connection

The resulting type after dereferencing.

fn deref(&self) -> &Connection

Dereferences the value.

impl Drop for PooledConnection

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl ScriptExecutor for PooledConnection

fn execute_script<'a>( &'a self, sql: &'a str, ) -> impl Future<Output = Result<u64, Error>> + Send + 'a

Runs one or more statements and returns the affected-row count of the last command.