Struct QueryResult

pub struct QueryResult { /* private fields */ }

Result of a query or statement execution.

Implementations

impl QueryResult

pub fn fold<F, T, Fut>( self, init: T, f: F, ) -> impl Future<Item = (ClientHandle, T), Error = Error>

where F: Fn(T, Row<'_, Simple>) -> Fut + Send + Sync + 'static, Fut: IntoFuture<Item = T, Error = Error> + Send + 'static, Fut::Future: Send, T: Send + 'static,

Method that applies a function to each row, producing a single, final value.

example:

pool.get_handle()
    .and_then(|c| {
        c.query("SELECT number FROM system.numbers LIMIT 10000000")
            .fold(0, |acc, row| {
                let number: u64 = row.get("number")?;
                Ok(acc + number)
            })
    })

pub fn fetch_all( self, ) -> Box<dyn Future<Item = (ClientHandle, Block<Complex>), Error = Error> + Send>

Fetch data from table. It returns a block that contains all rows.

pub fn fold_blocks<F, T, Fut>( self, init: T, f: F, ) -> impl Future<Item = (ClientHandle, T), Error = Error>

where F: Fn(T, Block) -> Fut + Send + 'static, Fut: IntoFuture<Item = T, Error = Error> + Send + 'static, Fut::Future: Send, T: Send + 'static,

Method that applies a function to each block, producing a single, final value.

pub fn stream_blocks( self, ) -> Box<dyn Stream<Item = Block, Error = Error> + Send>

Method that produces a stream of blocks containing rows

example:

 pool.get_handle()
     .and_then(|c| {
         c.query(sql_query)
             .stream_blocks()
             .for_each(|block| {
                 println!("{:?}\nblock counts: {} rows", block, block.row_count());
             })
     })

pub fn stream_rows( self, ) -> Box<dyn Stream<Item = Row<'static, Simple>, Error = Error> + Send>

Method that produces a stream of rows