icydb-core 0.67.2

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
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118

//! Module: executor::route::fast_path
//! Responsibility: route-owned fast-path verification/dispatch scaffolding.
//! Does not own: route capability derivation or stream materialization behavior.
//! Boundary: precedence runner and fast-path eligibility helpers for route planning.

use crate::{
    db::{executor::ExecutionPreparation, query::plan::AccessPlannedQuery},
    error::InternalError,
    model::entity::EntityModel,
};

use crate::db::executor::route::FastPathOrder;

///
/// PkStreamFastPathAccessContract
///
/// Route-owned invariant contract for PK stream fast-path access verification.
/// This keeps path-shape guard construction local to the route fast-path
/// boundary instead of rebuilding internal errors inline in the verifier.
/// Iterate route-owned fast-path precedence through a shared verify+execute gate.
///
/// Verification runs first for each route; execution is attempted only when
/// verification returns a marker. Returns the first successful execution hit.
pub(in crate::db::executor) fn try_first_verified_fast_path_hit<T, M, V, E>(
    fast_path_order: &[FastPathOrder],
    mut verify_route: V,
    mut execute_verified_route: E,
) -> Result<Option<T>, InternalError>
where
    V: FnMut(FastPathOrder) -> Result<Option<M>, InternalError>,
    E: FnMut(M) -> Result<Option<T>, InternalError>,
{
    for route in fast_path_order.iter().copied() {
        let Some(marker) = verify_route(route)? else {
            continue;
        };
        let Some(hit) = execute_verified_route(marker)? else {
            continue;
        };

        return Ok(Some(hit));
    }

    Ok(None)
}

/// Validate routed access-path shape for PK stream fast-path execution.
pub(in crate::db::executor) fn verify_pk_stream_fast_path_access(
    plan: &AccessPlannedQuery,
) -> Result<(), InternalError> {
    let access_strategy = plan.access_strategy();
    let access_class = access_strategy.class();
    access_class.single_path().then_some(()).ok_or_else(|| {
        InternalError::query_executor_invariant(
            "pk stream fast-path requires direct access-path execution",
        )
    })?;
    access_class
        .single_path_supports_pk_stream_access()
        .then_some(())
        .ok_or_else(|| {
            InternalError::query_executor_invariant(
                "pk stream fast-path requires full-scan/key-range access path",
            )
        })?;

    let access = access_strategy.as_path().ok_or_else(|| {
        InternalError::query_executor_invariant(
            "pk stream fast-path requires direct access-path execution",
        )
    })?;
    debug_assert_eq!(
        access.capabilities().supports_pk_stream_access(),
        access_class.single_path_supports_pk_stream_access(),
        "route invariant: descriptor and path capability snapshots must stay aligned",
    );

    Ok(())
}

/// Return whether aggregate routing must force materialized mode due to predicate uncertainty.
#[must_use]
pub(in crate::db::executor::route) const fn aggregate_force_materialized_due_to_predicate_uncertainty_with_preparation(
    execution_preparation: &ExecutionPreparation,
) -> bool {
    execution_preparation.compiled_predicate().is_some()
        &&
        // Route strict-mode uncertainty must remain aligned with the shared
        // kernel predicate compiler boundary.
        execution_preparation.strict_mode().is_none()
}

/// Return whether one plan shape supports primary-key ordered stream execution.
#[must_use]
pub(in crate::db::executor::route) fn pk_order_stream_fast_path_shape_supported_for_model(
    model: &EntityModel,
    plan: &AccessPlannedQuery,
) -> bool {
    let logical = plan.scalar_plan();
    let access_strategy = plan.access_strategy();
    let access_class = access_strategy.class();
    let supports_pk_stream_access = access_strategy
        .as_path()
        .is_some_and(|path| path.capabilities().supports_pk_stream_access());
    debug_assert_eq!(
        supports_pk_stream_access,
        access_class.single_path_supports_pk_stream_access(),
        "route invariant: path and access-class PK stream capability projections must stay aligned",
    );

    let Some(order) = logical.order.as_ref() else {
        return false;
    };

    logical.mode.is_load()
        && supports_pk_stream_access
        && order.is_primary_key_only(model.primary_key.name)
}