Struct StatementQuery 

pub struct StatementQuery<'a, P> { /* private fields */ }

an unprepared statement with it’s query params

Certain executor can make use of unprepared statement and offer addtional functionality

Examples

async fn execute_with_pool(pool: &Pool) {
    // connection pool can execute unprepared statement directly where statement preparing
    // execution and caching happens internally
    let rows = Statement::named("SELECT * FROM user WHERE id = $1", &[Type::INT4])
        .bind([9527])
        .query(pool)
        .await;
}

Implementations

impl<'a, P> StatementQuery<'a, P>

pub fn into_single_rtt(self) -> StatementSingleRTTQuery<'a, P>

transform self to a single use of statement query with given executor

See StatementSingleRTTQuery for explaination

Trait Implementations

impl<'c, C, P> Execute<&'c C> for StatementQuery<'_, P>

where C: Prepare, P: AsParams,

type ExecuteOutput = ResultFuture<RowAffected>

outcome of execute. used for single time database response: number of rows affected by execution for example.

type QueryOutput = Ready<Result<RowStreamGuarded<'c, C>, Error>>

outcome of query. used for repeated database response: database rows for example

fn execute(self, cli: &C) -> Self::ExecuteOutput

define how a statement is executed with single time response

fn query(self, cli: &'c C) -> Self::QueryOutput

define how a statement is queried with repeated response

impl<'c, 's, P> Execute<&'c Pool> for StatementQuery<'s, P>

where P: AsParams + Send + 'c, 's: 'c,

Available on non-crate feature nightly only.

type ExecuteOutput = Pin<Box<dyn Future<Output = Result<u64, Error>> + Send + 'c>>

outcome of execute. used for single time database response: number of rows affected by execution for example.

type QueryOutput = Pin<Box<dyn Future<Output = Result<GenericRowStream<Arc<[Column]>, Typed>, Error>> + Send + 'c>>

outcome of query. used for repeated database response: database rows for example

fn execute(self, pool: &'c Pool) -> Self::ExecuteOutput

define how a statement is executed with single time response

fn query(self, pool: &'c Pool) -> Self::QueryOutput

define how a statement is queried with repeated response

impl<'c, 's, P> Execute<&'c mut PoolConnection<'_>> for StatementQuery<'s, P>

where P: AsParams + Send + 'c, 's: 'c,

Available on non-crate feature nightly only.

type ExecuteOutput = Pin<Box<dyn Future<Output = Result<RowAffected, Error>> + Send + 'c>>

outcome of execute. used for single time database response: number of rows affected by execution for example.

type QueryOutput = Pin<Box<dyn Future<Output = Result<GenericRowStream<Arc<[Column]>, Typed>, Error>> + Send + 'c>>

outcome of query. used for repeated database response: database rows for example

fn execute(self, conn: &'c mut PoolConnection<'_>) -> Self::ExecuteOutput

define how a statement is executed with single time response

fn query(self, conn: &'c mut PoolConnection<'_>) -> Self::QueryOutput

define how a statement is queried with repeated response

impl<'c, C, P> ExecuteBlocking<&'c C> for StatementQuery<'_, P>

where C: Prepare, P: AsParams,

type ExecuteOutput = Result<u64, Error>

type QueryOutput = Result<RowStreamGuarded<'c, C>, Error>

fn execute_blocking(self, cli: &C) -> Result<u64, Error>

fn query_blocking(self, cli: &'c C) -> Self::QueryOutput