use crate::{
db::{
access::AccessPlan,
predicate::{Predicate, normalize, normalize_enum_literals},
query::plan::{
OrderSpec, PlannedAccessSelection, PlannerError, canonicalize_order_spec_for_grouping,
plan_access_selection_with_order,
},
query::predicate::reject_unsupported_query_features,
schema::{SchemaInfo, ValidateError},
},
model::{entity::EntityModel, index::IndexModel},
value::Value,
};
#[derive(Debug)]
pub(in crate::db::query) struct AccessPlanningInputs<'a> {
predicate: Option<&'a Predicate>,
order: Option<&'a OrderSpec>,
key_access_override: Option<AccessPlan<Value>>,
}
impl<'a> AccessPlanningInputs<'a> {
#[must_use]
pub(in crate::db::query) const fn new(
predicate: Option<&'a Predicate>,
order: Option<&'a OrderSpec>,
key_access_override: Option<AccessPlan<Value>>,
) -> Self {
Self {
predicate,
order,
key_access_override,
}
}
#[must_use]
pub(in crate::db::query) const fn predicate(&self) -> Option<&'a Predicate> {
self.predicate
}
#[must_use]
pub(in crate::db::query) const fn order(&self) -> Option<&'a OrderSpec> {
self.order
}
#[must_use]
pub(in crate::db::query) fn into_key_access_override(self) -> Option<AccessPlan<Value>> {
self.key_access_override
}
}
pub(in crate::db::query) fn normalize_query_predicate(
schema_info: &SchemaInfo,
predicate: Option<&Predicate>,
) -> Result<Option<Predicate>, ValidateError> {
predicate
.map(|predicate| {
reject_unsupported_query_features(predicate).map_err(ValidateError::from)?;
let predicate = normalize_enum_literals(schema_info, predicate)?;
Ok::<Predicate, ValidateError>(normalize(&predicate))
})
.transpose()
}
pub(in crate::db::query) fn plan_query_access(
model: &EntityModel,
visible_indexes: &[&'static IndexModel],
schema_info: &SchemaInfo,
normalized_predicate: Option<&Predicate>,
order: Option<&OrderSpec>,
grouped: bool,
key_access_override: Option<AccessPlan<Value>>,
) -> Result<PlannedAccessSelection, PlannerError> {
if let Some(plan) = key_access_override {
Ok(PlannedAccessSelection::new(
plan,
Some(crate::db::query::plan::PlannedNonIndexAccessReason::IntentKeyAccessOverride),
))
} else {
let canonical_order = canonicalize_order_spec_for_grouping(model, order.cloned(), grouped);
plan_access_selection_with_order(
model,
visible_indexes,
schema_info,
normalized_predicate,
canonical_order.as_ref(),
grouped,
)
}
}