uqa-engine 0.2.3

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

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

//! Procedural transaction boundaries for nonatomic `CALL` and `DO` execution.

use super::{routine::routine_transaction_control_allowed, Flow, Interpreter, SQLError};

impl Interpreter<'_> {
    pub(super) fn exec_procedural_transaction(
        &mut self,
        commit: bool,
        chain: bool,
    ) -> Result<Flow, SQLError> {
        if !routine_transaction_control_allowed(self.engine) {
            return Err(invalid_transaction_termination());
        }
        self.engine
            .finish_procedural_transaction(commit, chain)
            .map(|()| Flow::Normal)
    }
}

fn invalid_transaction_termination() -> SQLError {
    SQLError::Routine {
        sqlstate: "2D000".into(),
        message: "invalid transaction termination".into(),
    }
}