uqa-execution 0.3.5

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
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

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

//! Immutable catalog inputs and runtime catalog projections.

pub mod foreign;
pub mod identity;
pub mod security;
pub mod sequence;
pub mod view;

use security::{DatabaseSecurity, SchemaSecurity, SequenceSecurity, TableSecurity};
use sequence::SequenceState;
use std::collections::BTreeMap;
use std::sync::Arc;
use uqa_core::RelationIdentity;
pub use uqa_sql::catalog::resolution::{RelationLookupMode, RelationNameResolution};
use view::StoredView;
mod analysis;
pub mod graph;
mod read;
pub mod schema;

/// Read-only access to catalog-owned state. This view cannot mutate transactions, acquire locks, publish caches, or recover the enclosing engine.
#[derive(Clone)]
pub struct CatalogReadView {
    snapshot: Arc<CatalogReadSnapshot>,
}

/// Immutable catalog names and durable registries captured at one statement boundary.
#[derive(Clone)]
pub struct CatalogReadSnapshot {
    pub tables: BTreeMap<uqa_core::RelationIdentity, CatalogTableSnapshot>,
    pub definitions: CatalogDefinitionSnapshot,
}

/// Immutable table-definition fields used by binding and catalog projection.
#[derive(Clone)]
pub struct CatalogTableSnapshot {
    pub object_id: [u8; 16],
    pub security: Arc<crate::catalog::security::TableSecurity>,
    pub columns: Arc<Vec<uqa_sql::ast::ColumnDef>>,
    pub columns_declared: bool,
    pub checks: Arc<Vec<uqa_sql::ast::TableCheck>>,
    pub foreign_keys: Arc<Vec<uqa_sql::ast::ForeignKey>>,
    pub keys: Arc<Vec<uqa_sql::ast::TableKeyConstraint>>,
    pub hierarchy: Arc<uqa_sql::ast::TableHierarchy>,
    pub persistence: uqa_sql::ast::RelationPersistence,
}

/// Immutable state for one sequence selected through the statement's relation namespace.
#[derive(Clone)]
pub struct CatalogSequenceSnapshot {
    pub relation: uqa_core::RelationIdentity,
    pub state: crate::catalog::sequence::SequenceState,
    pub security: crate::catalog::security::SequenceSecurity,
}

pub use uqa_sql::catalog::resolution::RelationResolution;

/// Shared immutable definition maps captured from one catalog generation.
#[derive(Clone)]
pub struct CatalogDefinitionSnapshot {
    pub sequence_persistence: Arc<BTreeMap<RelationIdentity, uqa_sql::ast::RelationPersistence>>,
    pub foreign_tables: Arc<BTreeMap<RelationIdentity, foreign::StoredForeignTable>>,
    pub sql_user_functions: Arc<BTreeMap<String, Vec<Arc<uqa_sql::routines::SQLUserFunction>>>>,
    pub role_memberships: Arc<
        BTreeMap<
            uqa_sql::catalog::roles::RoleMembershipKey,
            uqa_sql::catalog::roles::RoleMembership,
        >,
    >,

    pub domains: Arc<BTreeMap<String, uqa_sql::catalog::domain::StoredDomain>>,
    pub graphs: Arc<BTreeMap<String, Arc<uqa_graph::GraphStoreHandle>>>,
    pub views: Arc<BTreeMap<RelationIdentity, StoredView>>,
    pub catalog_indexes: Arc<BTreeMap<RelationIdentity, uqa_storage::CatalogIndexRow>>,
    pub database_security: Arc<DatabaseSecurity>,
    pub schemas: Arc<BTreeMap<String, SchemaSecurity>>,
    pub sequences: Arc<BTreeMap<RelationIdentity, SequenceState>>,
    pub sequence_object_ids: Arc<BTreeMap<RelationIdentity, [u8; 16]>>,
    pub sequence_security: Arc<BTreeMap<RelationIdentity, SequenceSecurity>>,
    pub foreign_table_security: Arc<BTreeMap<RelationIdentity, TableSecurity>>,
    pub roles: Arc<BTreeMap<String, uqa_sql::catalog::roles::RoleDefinition>>,
    pub triggers: Arc<
        BTreeMap<
            uqa_storage::RelationIdentity,
            BTreeMap<String, uqa_sql::catalog::events::StoredTrigger>,
        >,
    >,
    pub rules: Arc<
        BTreeMap<
            uqa_storage::RelationIdentity,
            BTreeMap<String, uqa_sql::catalog::events::StoredRule>,
        >,
    >,
}

impl CatalogReadView {
    pub fn new(snapshot: CatalogReadSnapshot) -> Self {
        Self {
            snapshot: Arc::new(snapshot),
        }
    }
    pub fn snapshot(&self) -> &CatalogReadSnapshot {
        &self.snapshot
    }
}

pub mod cache;
pub mod context;
pub mod index;
pub mod projection;
pub mod services;

pub mod sequence_introspection;

#[cfg(test)]
pub(crate) mod test_support;

pub mod notices;