iridium_core 0.1.0

SQL Server-compatible Rust engine core for Iridium SQL
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
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61

use crate::error::DbError;

use super::pagination_value::value_to_usize;
use crate::executor::context::ExecutionContext;
use crate::executor::projection::eval_top_n;
use crate::executor::query::plan::RelationalQuery;

use super::super::QueryExecutor;

pub(crate) fn apply_pagination(
    executor: &QueryExecutor<'_>,
    query: &RelationalQuery,
    mut final_rows: Vec<Vec<crate::types::Value>>,
    ctx: &mut ExecutionContext,
) -> Result<Vec<Vec<crate::types::Value>>, DbError> {
    if let Some(top) = query.pagination.top.clone() {
        let n = eval_top_n(
            &top,
            ctx,
            executor.catalog,
            executor.storage,
            executor.clock,
        )?;
        if final_rows.len() > n {
            final_rows.truncate(n);
        }
    }

    if let Some(offset_expr) = query.pagination.offset.clone() {
        let offset_val = crate::executor::evaluator::eval_expr(
            &offset_expr,
            &[],
            ctx,
            executor.catalog,
            executor.storage,
            executor.clock,
        )?;
        let offset_n = value_to_usize(offset_val);
        if offset_n < final_rows.len() {
            final_rows = final_rows[offset_n..].to_vec();
        } else {
            final_rows = vec![];
        }
        if let Some(fetch_expr) = query.pagination.fetch.clone() {
            let fetch_val = crate::executor::evaluator::eval_expr(
                &fetch_expr,
                &[],
                ctx,
                executor.catalog,
                executor.storage,
                executor.clock,
            )?;
            let fetch_n = value_to_usize(fetch_val);
            if final_rows.len() > fetch_n {
                final_rows.truncate(fetch_n);
            }
        }
    }

    Ok(final_rows)
}