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

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

//! Capabilities required to execute stored rewrite rules.
use crate::{PhysicalRow, RowSchema};
use uqa_core::Value;
use uqa_sql::{
    assignment::AssignmentContext,
    ast::{Expr, Statement},
    plan::ExpressionPlan,
    semantics::{returning::ReturningAnalysisContext, rules::analysis::RuleAnalysisContext},
    SQLError, SQLResult,
};
pub trait RuleSecurity {
    fn privilege_subject(&self, table: &str) -> Result<String, SQLError>;
}
pub trait RuleStatements {
    fn execute(&self, statement: Statement, privilege_subject: &str)
        -> Result<SQLResult, SQLError>;
}
pub trait RuleExpressions {
    fn evaluate(&self, expression: &Expr) -> Result<Value, SQLError>;
    fn evaluate_stored(
        &self,
        expression: &ExpressionPlan,
        schema: &RowSchema,
        row: &PhysicalRow,
        privilege_subject: &str,
    ) -> Result<Value, SQLError>;
}
#[derive(Clone, Copy)]
pub struct RuleContext<'a> {
    pub analysis: RuleAnalysisContext<'a>,
    pub security: &'a dyn RuleSecurity,
    pub statements: &'a dyn RuleStatements,
    pub expressions: &'a dyn RuleExpressions,
    pub returning: ReturningAnalysisContext<'a>,
    pub assignment: &'a dyn AssignmentContext,
}