Struct MySQLConnection

pub struct MySQLConnection {
    pub conn: Arc<Mutex<Conn>>,
}

Available on crate feature mysql only.

Fields

conn: Arc<Mutex<Conn>>

Trait Implementations

impl<'a> AsyncDbConnection<Conn, &'a (dyn ToValue + Sync)> for MySQLConnection

fn new(conn: Conn) -> Self

fn tables<'life0, 'life1, 'async_trait>( &'life0 self, schema: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, Error>> + Send + 'async_trait>>

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

fn schemas<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, Error>> + Send + 'async_trait>>

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

fn get_schema<'life0, 'life1, 'async_trait>( &'life0 self, table_reference: &'life1 TableReference, ) -> Pin<Box<dyn Future<Output = Result<SchemaRef, Error>> + Send + 'async_trait>>

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

Get the schema for a table reference.

fn query_arrow<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, sql: &'life1 str, params: &'life2 [&'a (dyn ToValue + Sync)], projected_schema: Option<SchemaRef>, ) -> Pin<Box<dyn Future<Output = Result<SendableRecordBatchStream, GenericError>> + Send + 'async_trait>>

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

Query the database with the given SQL statement and parameters, returning a Result of SendableRecordBatchStream.

fn execute<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, query: &'life1 str, params: &'life2 [&'a (dyn ToValue + Sync)], ) -> Pin<Box<dyn Future<Output = Result<u64, GenericError>> + Send + 'async_trait>>

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

Execute the given SQL statement with parameters, returning the number of affected rows.

impl<'a> DbConnection<Conn, &'a (dyn ToValue + Sync)> for MySQLConnection

fn as_any(&self) -> &dyn Any

fn as_any_mut(&mut self) -> &mut dyn Any

fn as_async( &self, ) -> Option<&dyn AsyncDbConnection<Conn, &'a (dyn ToValue + Sync)>>

fn as_sync(&self) -> Option<&dyn SyncDbConnection<T, P>>