Struct mysql_async::Stmt

pub struct Stmt<T> { /* fields omitted */ }

Prepared statement.

Methods

impl<T> Stmt<T> where
    T: ConnectionLike + Sized + 'static, 

pub fn id(&self) -> u32

Returns statement identifier.

pub fn columns(&self) -> &[Column]

Returns statement columns.

use mysql_async::{consts::{ColumnFlags, ColumnType}, Pool};
use mysql_async::prelude::*;

#[tokio::main]
async fn main() -> Result<(), mysql_async::error::Error> {
    let pool = Pool::new(get_opts());
    let conn = pool.get_conn().await?;

    let stmt = conn.prepare("SELECT 'foo', CAST(42 AS UNSIGNED)").await?;

    let columns = stmt.columns();

    assert_eq!(columns.len(), 2);
    assert_eq!(columns[0].column_type(), ColumnType::MYSQL_TYPE_VAR_STRING);
    assert!(columns[1].flags().contains(ColumnFlags::UNSIGNED_FLAG));

    Ok(())
}

pub fn params(&self) -> &[Column]

Returns statement parameters.

use mysql_async::{consts::{ColumnFlags, ColumnType}, Pool};
use mysql_async::prelude::*;

#[tokio::main]
async fn main() -> Result<(), mysql_async::error::Error> {
    let pool = Pool::new(get_opts());
    let conn = pool.get_conn().await?;

    let stmt = conn.prepare("SELECT ?, ?").await?;

    assert_eq!(stmt.params().len(), 2);

    Ok(())
}

pub async fn execute<P>(
    self,
    params: P
) -> Result<QueryResult<Self, BinaryProtocol>> where
    P: Into<Params>, 

See Queryable::execute

pub async fn first<P, R>(self, params: P) -> Result<(Self, Option<R>)> where
    P: Into<Params> + 'static,
    R: FromRow, 

See Queryable::first

pub async fn batch<I, P>(self, params_iter: I) -> Result<Self> where
    I: IntoIterator<Item = P>,
    I::IntoIter: Send + 'static,
    Params: From<P>,
    P: 'static, 

See Queryable::batch

pub async fn close(__arg0: Self) -> Result<T>

This will close statement (if it's not in the cache) and resolve to a wrapped queryable.

Trait Implementations

impl<T: Debug> Debug for Stmt<T>

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

Formats the value using the given formatter.