uqa-execution 0.3.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
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

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

//! Catalog, routine, and transaction capabilities for trigger execution.
use super::DeferredConstraintTriggerEvent;
use crate::{
    catalog::context::CatalogContext,
    query::runtime::QueryRuntimeView,
    routines::{context::RoutineExpressions, TriggerRoutineContext},
};
use std::sync::Arc;
use uqa_core::Value;
use uqa_sql::{
    ast::{ColumnType, TriggerEvent, TriggerTiming},
    catalog::events::StoredTrigger,
    routines::SQLUserFunction,
    semantics::{partition::PartitionCatalog, referential::ReferentialCatalog},
    SQLError,
};

/// Trigger definitions and relation row types observed by the active command.
pub trait TriggerCatalog {
    fn has_row_triggers(&self, table: &str, event: TriggerEvent) -> Result<bool, SQLError>;
    fn rule_relation_columns(&self, table: &str) -> Result<Vec<(String, ColumnType)>, SQLError>;
    fn triggers_for(
        &self,
        table: &str,
        timing: TriggerTiming,
        event: TriggerEvent,
        row: bool,
        updated_columns: &[String],
    ) -> Result<Vec<StoredTrigger>, SQLError>;
    fn has_trigger_definition(
        &self,
        table: &str,
        timing: TriggerTiming,
        event: TriggerEvent,
        row: bool,
    ) -> Result<bool, SQLError>;
    fn hierarchy_scan_tables(
        &self,
        table: &str,
        include_descendants: bool,
    ) -> Result<Vec<String>, SQLError>;
}
/// Enter a stored routine using its bound identity and the caller's security context.
pub trait TriggerRoutineInvoker {
    fn resolve_bound_trigger_function(
        &self,
        name: &str,
        object_id: Option<[u8; 16]>,
    ) -> Result<Arc<SQLUserFunction>, SQLError>;
    fn execute_trigger_routine(
        &self,
        function: &SQLUserFunction,
        context: &TriggerRoutineContext,
    ) -> Result<Value, SQLError>;
}
/// Transaction-owned deferred constraint-trigger queue.
pub trait ConstraintTriggerQueue {
    fn constraint_trigger_is_deferred(&self, trigger: &StoredTrigger) -> Result<bool, SQLError>;
    fn defer_constraint_trigger_event(
        &self,
        event: DeferredConstraintTriggerEvent,
    ) -> Result<(), SQLError>;
}
#[derive(Clone, Copy)]
pub struct TriggerContext<'a> {
    pub catalog: &'a dyn TriggerCatalog,
    pub relations: &'a dyn PartitionCatalog,
    pub routines: &'a dyn TriggerRoutineInvoker,
    pub deferrals: &'a dyn ConstraintTriggerQueue,
    pub referrers: &'a dyn ReferentialCatalog,
    pub expressions: &'a dyn RoutineExpressions,
    pub projection: CatalogContext<'a>,
    pub runtime: QueryRuntimeView<'a>,
}