Trait ExecuteBlocking

pub trait ExecuteBlocking<'c, C>
where
    Self: Sized,
{
    type ExecuteOutput;
    type QueryOutput;

    // Required methods
    fn execute_blocking(self, cli: &'c C) -> Self::ExecuteOutput;
    fn query_blocking(self, cli: &'c C) -> Self::QueryOutput;
}

blocking version of Execute for synchronous environment

Required Associated Types

type ExecuteOutput

type QueryOutput

Required Methods

fn execute_blocking(self, cli: &'c C) -> Self::ExecuteOutput

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

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl<'c, C> ExecuteBlocking<'c, C> for &Path

where C: Query + 'c,

type ExecuteOutput = Result<u64, Error>

type QueryOutput = Result<GenericRowStream<Vec<Column>, NoTyped>, Error>

fn execute_blocking(self, cli: &'c C) -> Self::ExecuteOutput

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

impl<C> ExecuteBlocking<'_, C> for &str

where C: Query,

type ExecuteOutput = Result<u64, Error>

type QueryOutput = Result<GenericRowStream<Vec<Column>, NoTyped>, Error>

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

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

Implementors

impl<'c, 's, C> ExecuteBlocking<'c, C> for StatementNamed<'s>

where C: Prepare + 'c, 's: 'c,

type ExecuteOutput = Result<StatementGuarded<'c, C>, Error>

type QueryOutput = <StatementNamed<'s> as ExecuteBlocking<'c, C>>::ExecuteOutput

impl<'p, C, B, const SYNC_MODE: bool> ExecuteBlocking<'_, C> for Pipeline<'p, B, SYNC_MODE>

where C: Query, B: DerefMut<Target = BytesMut>,

type ExecuteOutput = Result<u64, Error>

type QueryOutput = Result<PipelineStream<'p>, Error>

impl<'s, 'c, C, P> ExecuteBlocking<'c, C> for StatementUnnamedBind<'s, P>

where C: Prepare + 'c, P: AsParams + 'c, 's: 'c,

type ExecuteOutput = Result<u64, Error>

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

impl<'s, C> ExecuteBlocking<'_, C> for &'s Statement

where C: Query,

type ExecuteOutput = Result<u64, Error>

type QueryOutput = Result<GenericRowStream<&'s [Column], Typed>, Error>

impl<'s, C, P> ExecuteBlocking<'_, C> for StatementQuery<'s, P>

where C: Query, P: AsParams + 's,

type ExecuteOutput = Result<u64, Error>

type QueryOutput = Result<GenericRowStream<&'s [Column], Typed>, Error>