Struct PooledDatabase 

pub struct PooledDatabase { /* private fields */ }

Implementations

impl PooledDatabase

pub fn new( id: u32, inner: Arc<dyn DMSCDatabase>, pool: Arc<DMSCDatabasePool>, ) -> Self

pub fn id(&self) -> u32

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

pub async fn query(&self, sql: &str) -> DMSCResult<DMSCDBResult>

pub async fn query_one(&self, sql: &str) -> DMSCResult<Option<DMSCDBRow>>

pub async fn ping(&self) -> DMSCResult<bool>

pub fn is_connected(&self) -> bool

pub fn pool_metrics(&self) -> DatabaseMetrics

Trait Implementations

impl Clone for PooledDatabase

fn clone(&self) -> PooledDatabase

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl DMSCDatabase for PooledDatabase

fn database_type(&self) -> DatabaseType

Returns the type of database this instance connects to.

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, sql: &'life1 str, ) -> Pin<Box<dyn Future<Output = DMSCResult<u64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Executes a SQL statement without returning results.

fn query<'life0, 'life1, 'async_trait>( &'life0 self, sql: &'life1 str, ) -> Pin<Box<dyn Future<Output = DMSCResult<DMSCDBResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Executes a SQL query and returns all matching rows.

fn query_one<'life0, 'life1, 'async_trait>( &'life0 self, sql: &'life1 str, ) -> Pin<Box<dyn Future<Output = DMSCResult<Option<DMSCDBRow>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Executes a SQL query and returns at most one row.

fn ping<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = DMSCResult<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Checks if the database connection is alive.

fn is_connected(&self) -> bool

Checks if the database connection is currently connected.

fn close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = DMSCResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Closes the database connection.

fn batch_execute<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, sql: &'life1 str, params: &'life2 [Vec<Value>], ) -> Pin<Box<dyn Future<Output = DMSCResult<Vec<u64>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Executes the same SQL statement multiple times with different parameters.

fn batch_query<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, sql: &'life1 str, params: &'life2 [Vec<Value>], ) -> Pin<Box<dyn Future<Output = DMSCResult<Vec<DMSCDBResult>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Executes the same query multiple times with different parameters.

fn execute_with_params<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, sql: &'life1 str, params: &'life2 [Value], ) -> Pin<Box<dyn Future<Output = DMSCResult<u64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Executes a SQL statement with parameters.

fn query_with_params<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, sql: &'life1 str, params: &'life2 [Value], ) -> Pin<Box<dyn Future<Output = DMSCResult<DMSCDBResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Executes a SQL query with parameters.

fn transaction<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = DMSCResult<Box<dyn DMSCDatabaseTransaction>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Starts a new database transaction.