graphlite 0.0.1

GraphLite - A lightweight ISO GQL Graph Database
Documentation 
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

// Copyright (c) 2024-2025 DeepGraph Inc.
// SPDX-License-Identifier: Apache-2.0
//
use crate::ast::ast::TransactionStatement;
use crate::exec::write_stmt::{ExecutionContext, TransactionStatementExecutor};
use crate::exec::{ExecutionError, QueryExecutor, QueryResult};

use super::{
    commit::CommitExecutor, rollback::RollbackExecutor,
    set_characteristics::SetTransactionCharacteristicsExecutor, start::StartTransactionExecutor,
};

pub struct TransactionCoordinator;

impl TransactionCoordinator {
    pub fn execute_transaction_statement(
        statement: &TransactionStatement,
        context: &ExecutionContext,
        _executor: &QueryExecutor,
    ) -> Result<QueryResult, ExecutionError> {
        // Pre-execute: WAL logging and permissions
        let stmt_executor: Box<dyn TransactionStatementExecutor> = match statement {
            TransactionStatement::StartTransaction(start_stmt) => {
                Box::new(StartTransactionExecutor::new(start_stmt.clone()))
            }
            TransactionStatement::Commit(commit_stmt) => {
                Box::new(CommitExecutor::new(commit_stmt.clone()))
            }
            TransactionStatement::Rollback(rollback_stmt) => {
                Box::new(RollbackExecutor::new(rollback_stmt.clone()))
            }
            TransactionStatement::SetTransactionCharacteristics(set_stmt) => {
                Box::new(SetTransactionCharacteristicsExecutor::new(set_stmt.clone()))
            }
        };
        stmt_executor.pre_execute(context)?;
        stmt_executor.execute_transaction_operation(context)
    }
}