Struct rbdc_mysql::connection::MySqlConnection

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

A connection to a MySQL database.

Fields

stream: DropBox<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, _: &'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<'_, Result<(), Error>>

close connection Normally conn is dropped when the link is dropped, but it is recommended to actively close this function so that the database does not report errors. If &mut self is not satisfied close, when you need mut self, It is recommended to use Option and then call take to take ownership and then if let Some(v) = self.inner.take() {v.lose ().await; }

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.