uqa-execution 0.4.0

Volcano physical operators with row-batch pipelines
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

//
// Unified Query Algebra
//
// Copyright (c) 2023-2026 Cognica, Inc.
//

//! Constraint-owned index identities in catalog snapshots.

use super::{CatalogReadView, SQLError};

impl CatalogReadView {
    pub fn has_constraint_index(&self, relation: &uqa_core::RelationIdentity) -> bool {
        self.snapshot
            .definitions
            .catalog_indexes
            .get(relation)
            .is_some_and(|row| {
                crate::catalog::index::index_definition(row)
                    .is_ok_and(|definition| definition.relationships.owning_constraint.is_some())
            })
    }

    pub fn constraint_index(
        &self,
        relation: &uqa_core::RelationIdentity,
    ) -> Result<Option<uqa_storage::CatalogIndexRow>, SQLError> {
        let Some(row) = self.snapshot.definitions.catalog_indexes.get(relation) else {
            return Ok(None);
        };
        let definition = crate::catalog::index::index_definition(row)
            .map_err(|error| SQLError::Internal(error.to_string()))?;
        Ok(definition
            .relationships
            .owning_constraint
            .map(|_| row.clone()))
    }
}