toasty 0.11.0

An async ORM for Rust supporting SQL and NoSQL databases
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

use crate::{
    Result,
    engine::{exec::Exec, mir},
};
use toasty_core::{
    driver::{ExecResponse, Rows},
    stmt,
};

impl Exec<'_> {
    pub(super) async fn exec_repeat(&mut self, action: &mir::Repeat) -> Result<ExecResponse> {
        let ExecResponse {
            values,
            next_cursor,
            prev_cursor,
        } = self.vars.load(action.input).await?;

        // Only the input's cardinality is observed; a count-only driver
        // response works the same as one that returned rows.
        let count = match values {
            Rows::Count(count) => count as usize,
            Rows::Value(stmt::Value::List(items)) => items.len(),
            Rows::Value(value) => todo!("value={value:#?}"),
            Rows::Stream(mut value_stream) => {
                let mut count = 0;
                while let Some(res) = value_stream.next().await {
                    res?;
                    count += 1;
                }
                count
            }
        };

        let rows = vec![action.value.clone(); count];

        // The output has one item for each input row. Its cursors must match
        // the input cursors so the caller can fetch the next or previous page.
        Ok(ExecResponse {
            values: Rows::value_stream(rows),
            next_cursor,
            prev_cursor,
        })
    }
}