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

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

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

use super::{transaction::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.services.session) {
            return Err(invalid_transaction_termination());
        }
        self.services
            .transactions
            .finish_procedural_transaction(commit, chain)
            .map(|()| Flow::Normal)
    }
}

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