uqa-engine 0.3.0

Engine: schema-aware table store, catalog restore, transactions
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

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

//! Bind sequence inspection to live registry guards and existing catalog resolution.

use crate::Engine;
use uqa_core::RelationIdentity;
use uqa_execution::catalog::{
    security::SequenceSecurity,
    sequence::SequenceState,
    sequence_introspection::{
        SequenceIntrospectionCatalog, SequenceIntrospectionContext, SequenceObjectIdsRead,
        SequenceStatesRead,
    },
};
use uqa_sql::ast::RelationPersistence;
use uqa_storage::StorageBackendResult;

impl Engine {
    pub(crate) fn sequence_introspection_context(&self) -> SequenceIntrospectionContext<'_> {
        SequenceIntrospectionContext {
            catalog: self.catalog_execution(),
            sequences: self,
            owners: self,
            roles: self,
        }
    }
}
impl SequenceIntrospectionCatalog for Engine {
    fn refresh_sequences(&self) -> StorageBackendResult<()> {
        self.refresh_sequences_from_catalog()
    }
    fn object_ids(&self) -> SequenceObjectIdsRead<'_> {
        Box::new(self.durable.sequence_object_ids.read())
    }
    fn states(&self) -> SequenceStatesRead<'_> {
        Box::new(self.durable.sequences.read())
    }
    fn sequence_state(&self, relation: &RelationIdentity) -> Option<SequenceState> {
        self.durable.sequences.read().get(relation).copied()
    }
    fn sequence_security(&self, relation: &RelationIdentity) -> Option<SequenceSecurity> {
        self.durable.sequence_security.read().get(relation).cloned()
    }
    fn sequence_persistence(&self, relation: &RelationIdentity) -> Option<RelationPersistence> {
        self.durable
            .sequence_persistence
            .read()
            .get(relation)
            .copied()
    }
}