Struct rbdc_mysql::connection::MySqlConnection

pub struct MySqlConnection {
    pub stream: MySqlStream,
    pub cache_statement: StatementCache<(u32, MySqlStatementMetadata)>,
}

A connection to a MySQL database.

Fields

stream: MySqlStream

cache_statement: StatementCache<(u32, MySqlStatementMetadata)>

Implementations

impl MySqlConnection

pub async fn execute(&mut self, sql: &str) -> Result<Option<MySqlRow>, Error>

pub fn fetch_many(
    &mut self,
    query: MysqlQuery
) -> BoxStream<'_, Result<Either<MySqlQueryResult, MySqlRow>, Error>>

pub fn fetch_optional(
    &mut self,
    query: MysqlQuery
) -> BoxFuture<'_, Result<Option<MySqlRow>, Error>>

pub fn prepare_with<'e>(
    &'e mut self,
    sql: &'e str,
    parameters: &'e [MySqlTypeInfo]
) -> BoxFuture<'e, Result<MySqlStatement, Error>>

Trait Implementations

impl Connection for MySqlConnection

fn get_rows(
    &mut self,
    sql: &str,
    params: Vec<Value>
) -> BoxFuture<'_, Result<Vec<Box<dyn Row>>, Error>>

Execute a query that is expected to return a result set, such as a SELECT statement

fn exec(
    &mut self,
    sql: &str,
    params: Vec<Value>
) -> BoxFuture<'_, Result<ExecResult, Error>>

Execute a query that is expected to update some rows.

fn close(&mut self) -> BoxFuture<'static, Result<(), Error>>

close connection

fn ping(&mut self) -> BoxFuture<'_, Result<(), Error>>

ping

fn get_values(
    &mut self,
    sql: &str,
    params: Vec<Value, Global>
) -> Pin<Box<dyn Future<Output = Result<Vec<Value, Global>, Error>> + Send, Global>>

Execute a query that is expected to return a result set, such as a SELECT statement

impl Debug for MySqlConnection

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.