icydb-core 0.74.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
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
119
120
121
122
123
124
125
126
127
128
129
130
131
132

//! Module: db::executor::route::hints::aggregate
//! Responsibility: module-local ownership and contracts for db::executor::route::hints::aggregate.
//! Does not own: cross-module orchestration outside this module.
//! Boundary: exposes this module API while keeping implementation details internal.

use crate::{
    db::{
        direction::Direction,
        executor::{
            aggregate::field_target_is_tie_free_probe_target_for_model,
            route::{
                AccessWindow, AggregateRouteShape, AggregateSeekSpec, RouteCapabilities,
                aggregate_bounded_probe_fetch_hint, aggregate_supports_bounded_probe_hint,
                direction_allows_physical_fetch_hint,
            },
        },
        query::plan::{AccessPlannedQuery, AggregateKind},
    },
    model::entity::EntityModel,
};

pub(in crate::db::executor::route) const fn count_pushdown_fetch_hint(
    access_window: AccessWindow,
    capabilities: RouteCapabilities,
) -> Option<usize> {
    if capabilities.bounded_probe_hint_safe {
        crate::db::executor::route::hints::load::bounded_window_fetch_hint(access_window)
    } else {
        None
    }
}

pub(in crate::db::executor::route) fn aggregate_probe_fetch_hint_for_model(
    model: &EntityModel,
    plan: &AccessPlannedQuery,
    aggregate: AggregateRouteShape<'_>,
    direction: Direction,
    capabilities: RouteCapabilities,
    access_window: AccessWindow,
) -> Option<usize> {
    let kind = aggregate.kind();
    aggregate_probe_shape_supported_for_model(model, plan, aggregate, direction, capabilities)
        .then_some(())?;

    (aggregate_supports_bounded_probe_hint(kind)
        && direction_allows_physical_fetch_hint(
            direction,
            capabilities.desc_physical_reverse_supported,
        )
        && capabilities.bounded_probe_hint_safe)
        .then_some(())?;

    aggregate_probe_window_fetch_hint(kind, direction, access_window)
}

pub(in crate::db::executor::route) fn aggregate_seek_spec_for_model(
    model: &EntityModel,
    plan: &AccessPlannedQuery,
    aggregate: AggregateRouteShape<'_>,
    direction: Direction,
    capabilities: RouteCapabilities,
    access_window: AccessWindow,
) -> Option<AggregateSeekSpec> {
    aggregate.kind().is_extrema().then_some(())?;
    let fetch = aggregate_probe_fetch_hint_for_model(
        model,
        plan,
        aggregate,
        direction,
        capabilities,
        access_window,
    )?;

    Some(match direction {
        Direction::Asc => AggregateSeekSpec::First { fetch },
        Direction::Desc => AggregateSeekSpec::Last { fetch },
    })
}

// Apply the route capability snapshot to the aggregate probe shape before the
// bounded fetch-hint layer interprets the access window.
fn aggregate_probe_shape_supported_for_model(
    model: &EntityModel,
    plan: &AccessPlannedQuery,
    aggregate: AggregateRouteShape<'_>,
    direction: Direction,
    capabilities: RouteCapabilities,
) -> bool {
    match (aggregate.target_field(), aggregate.kind(), direction) {
        (Some(_), AggregateKind::Min, Direction::Asc) => capabilities.field_min_fast_path_eligible,
        (Some(_), AggregateKind::Max, Direction::Desc) => {
            capabilities.field_max_fast_path_eligible
                && field_target_max_probe_shape_is_tie_free_for_model(model, plan, aggregate)
        }
        (Some(_), _, _) => false,
        (None, _, _) => true,
    }
}

// Convert one route access window into the bounded aggregate probe fetch hint.
fn aggregate_probe_window_fetch_hint(
    kind: AggregateKind,
    direction: Direction,
    access_window: AccessWindow,
) -> Option<usize> {
    if access_window.is_zero_window() {
        return Some(0);
    }

    let offset = access_window.lower_bound();
    let page_limit = access_window
        .page_limit()
        .map(|limit| usize::try_from(limit).unwrap_or(usize::MAX));

    aggregate_bounded_probe_fetch_hint(kind, direction, offset, page_limit)
}

fn field_target_max_probe_shape_is_tie_free_for_model(
    model: &EntityModel,
    plan: &AccessPlannedQuery,
    aggregate: AggregateRouteShape<'_>,
) -> bool {
    aggregate.target_field().is_some_and(|target_field| {
        let access_class = plan.access_strategy().class();
        let index_model = access_class
            .single_path_index_prefix_details()
            .or_else(|| access_class.single_path_index_range_details())
            .map(|(index, _)| index);

        field_target_is_tie_free_probe_target_for_model(model, target_field, index_model)
    })
}