selene-db-gql 1.3.0

ISO/IEC 39075:2024 GQL parser, planner, optimizer, and executor for selene-db.
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

use selene_core::Value;

use crate::{
    FilterPredicate,
    runtime::{BindingTable, EvalCtx, ExecutorError, evaluator},
};

pub(super) fn execute(
    predicate: &FilterPredicate,
    table: BindingTable,
    ctx: &EvalCtx<'_, '_, '_, '_>,
) -> Result<BindingTable, ExecutorError> {
    if predicate.index_consumed {
        return Err(ExecutorError::ImplementationDefined {
            detail: "index-consumed predicate emitted into pipeline",
        });
    }

    let (schema, input_rows) = table.into_parts();
    let mut rows = Vec::new();
    let mut rows_since_check = 0;
    for row in input_rows {
        ctx.tx.check_cancellation_stride(&mut rows_since_check, 1)?;
        match evaluator::evaluate(&predicate.expr, &row, &schema, ctx)? {
            Value::Bool(true) => rows.push(row),
            Value::Bool(false) | Value::Null => {}
            _ => {}
        }
    }
    Ok(BindingTable::new(schema, rows))
}