Struct PooledConnection 

pub struct PooledConnection { /* private fields */ }

A connection managed by a pool.

This struct is thread-safe (Sync) because the return callback is protected by a Mutex.

Implementations

impl PooledConnection

pub fn new<F>(connection: Arc<Connection>, on_return: F) -> Self

where F: FnOnce(Arc<Connection>) + Send + 'static,

Create a new pooled connection.

pub fn connection(&self) -> &Connection

Get a reference to the underlying connection.

pub fn inner(&self) -> &Connection

Get the underlying connection (alias for connection()).

pub async fn query(&self, sql: &str) -> Result<QueryResult, ClientError>

Execute a query.

pub async fn execute(&self, sql: &str) -> Result<u64, ClientError>

Execute a statement.

Methods from Deref<Target = Connection>

pub fn id(&self) -> u64

Get the connection ID.

pub fn is_connected(&self) -> bool

Check if connected.

pub fn in_transaction(&self) -> bool

Check if in a transaction.

pub fn age(&self) -> Duration

Get connection age.

pub fn idle_time(&self) -> Duration

Get idle time.

pub async fn query(&self, sql: &str) -> Result<QueryResult, ClientError>

Execute a query.

pub async fn query_with_params( &self, sql: &str, params: Vec<Value>, ) -> Result<QueryResult, ClientError>

Execute a query with parameters.

pub async fn execute(&self, sql: &str) -> Result<u64, ClientError>

Execute a statement (INSERT, UPDATE, DELETE).

pub async fn execute_with_params( &self, sql: &str, params: Vec<Value>, ) -> Result<u64, ClientError>

Execute a statement with parameters.

pub async fn begin_transaction(&self) -> Result<(), ClientError>

Begin a transaction.

pub async fn commit(&self) -> Result<(), ClientError>

Commit a transaction.

pub async fn rollback(&self) -> Result<(), ClientError>

Rollback a transaction.

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

Ping the connection.

pub async fn close(&self)

Close the connection.

pub fn stats(&self) -> ConnectionStats

Get connection statistics.

pub fn base_url(&self) -> &str

Get the base URL of the server.

Trait Implementations

impl Deref for PooledConnection

type Target = Connection

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl Drop for PooledConnection

fn drop(&mut self)

Executes the destructor for this type.