icydb-core 0.69.0

IcyDB — A type-safe, embedded ORM and schema system for the Internet Computer
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

//! Module: query::plan::grouped_layout
//! Responsibility: planner-owned grouped projection layout invariant checks.
//! Does not own: grouped execution routing or fold/runtime mechanics.
//! Boundary: validates grouped projection structural contracts before executor handoff.

use crate::{db::query::plan::PlannedProjectionLayout, error::InternalError};

/// Validate grouped projection layout invariants for one grouped handoff shape.
pub(in crate::db) fn validate_grouped_projection_layout(
    projection_layout: &PlannedProjectionLayout,
    group_fields_len: usize,
    aggregate_exprs_len: usize,
) -> Result<(), InternalError> {
    let group_positions = projection_layout.group_field_positions();
    let aggregate_positions = projection_layout.aggregate_positions();
    if group_positions.len() != group_fields_len {
        return Err(PlannedProjectionLayout::group_field_count_mismatch(
            group_positions.len(),
            group_fields_len,
        ));
    }
    if aggregate_positions.len() != aggregate_exprs_len {
        return Err(PlannedProjectionLayout::aggregate_count_mismatch(
            aggregate_positions.len(),
            aggregate_exprs_len,
        ));
    }

    if !group_positions
        .windows(2)
        .all(|window| window[0] < window[1])
    {
        return Err(PlannedProjectionLayout::group_field_positions_not_strictly_increasing());
    }
    if !aggregate_positions
        .windows(2)
        .all(|window| window[0] < window[1])
    {
        return Err(PlannedProjectionLayout::aggregate_positions_not_strictly_increasing());
    }
    if let (Some(last_group_position), Some(first_aggregate_position)) =
        (group_positions.last(), aggregate_positions.first())
        && last_group_position >= first_aggregate_position
    {
        return Err(PlannedProjectionLayout::group_fields_must_precede_aggregates());
    }

    Ok(())
}