icydb_core/db/query/
expr.rs

1//! Module: query::expr
2//! Responsibility: schema-agnostic filter/sort expression wrappers and lowering.
3//! Does not own: planner route selection or executor evaluation.
4//! Boundary: intent boundary lowers these to validated predicate/order forms.
5
6use crate::db::query::plan::{OrderDirection, PlanError, validate::validate_order};
7use crate::db::{
8    predicate::{
9        Predicate, SchemaInfo, ValidateError, normalize, normalize_enum_literals,
10        reject_unsupported_query_features, validate,
11    },
12    query::plan::OrderSpec,
13};
14use thiserror::Error as ThisError;
15
16///
17/// FilterExpr
18/// Schema-agnostic filter expression for dynamic query input.
19/// Lowered into a validated predicate at the intent boundary.
20///
21
22#[derive(Clone, Debug)]
23pub struct FilterExpr(pub Predicate);
24
25impl FilterExpr {
26    /// Lower the filter expression into a validated predicate for the provided schema.
27    pub(crate) fn lower_with(&self, schema: &SchemaInfo) -> Result<Predicate, ValidateError> {
28        // Phase 1: normalize enum literals using schema enum metadata.
29        let normalized_enum_literals = normalize_enum_literals(schema, &self.0)?;
30
31        // Phase 2: reject unsupported query features and validate against schema.
32        reject_unsupported_query_features(&normalized_enum_literals)?;
33        validate(schema, &normalized_enum_literals)?;
34
35        // Phase 3: normalize structural predicate shape for deterministic planning.
36        Ok(normalize(&normalized_enum_literals))
37    }
38}
39
40///
41/// SortExpr
42/// Schema-agnostic sort expression for dynamic query input.
43/// Lowered into a validated order spec at the intent boundary.
44///
45
46#[derive(Clone, Debug)]
47pub struct SortExpr {
48    fields: Vec<(String, OrderDirection)>,
49}
50
51impl SortExpr {
52    /// Construct one schema-agnostic sort expression.
53    #[must_use]
54    pub const fn new(fields: Vec<(String, OrderDirection)>) -> Self {
55        Self { fields }
56    }
57
58    /// Borrow the declared sort fields in declaration order.
59    #[must_use]
60    pub fn fields(&self) -> &[(String, OrderDirection)] {
61        &self.fields
62    }
63
64    /// Lower the sort expression into a validated order spec for the provided schema.
65    pub(crate) fn lower_with(&self, schema: &SchemaInfo) -> Result<OrderSpec, SortLowerError> {
66        let spec = OrderSpec {
67            fields: self.fields.clone(),
68        };
69
70        validate_order(schema, &spec)?;
71
72        Ok(spec)
73    }
74}
75
76///
77/// SortLowerError
78/// Errors returned when lowering sort expressions into order specs.
79///
80
81#[derive(Debug, ThisError)]
82pub(crate) enum SortLowerError {
83    #[error("{0}")]
84    Validate(#[from] ValidateError),
85
86    #[error("{0}")]
87    Plan(Box<PlanError>),
88}
89
90impl From<PlanError> for SortLowerError {
91    fn from(err: PlanError) -> Self {
92        Self::Plan(Box::new(err))
93    }
94}
icydb_core/db/query/expr.rs

icydb_core/db/query/
expr.rs
