Method commit_transaction

graphlite/src/txn/manager.rs:191–242

Commit a transaction

(&self, transaction_id: TransactionId)

    /// Commit a transaction
    pub fn commit_transaction(&self, transaction_id: TransactionId) -> Result<(), ExecutionError> {
        let active_txns = self.active_transactions.read().map_err(|_| {
            ExecutionError::RuntimeError("Failed to acquire transactions lock".to_string())
        })?;

        if let Some(txn_arc) = active_txns.get(&transaction_id) {
            let mut transaction = txn_arc.lock().map_err(|_| {
                ExecutionError::RuntimeError("Failed to acquire transaction lock".to_string())
            })?;

            if !transaction.is_active() {
                return Err(ExecutionError::RuntimeError(format!(
                    "Transaction {} is not active",
                    transaction_id
                )));
            }

            let final_sequence = transaction.get_sequence_number();
            let commit_description = format!(
                "COMMIT TRANSACTION - final sequence number: {}",
                final_sequence
            );

            // Write COMMIT entry to WAL
            let wal_entry = WALEntry::new(
                WALEntryType::Commit,
                transaction_id,
                self.wal.next_global_sequence(),
                final_sequence,
                None,
                commit_description.clone(),
            );

            if let Err(e) = self.wal.write_entry(wal_entry) {
                return Err(ExecutionError::RuntimeError(format!(
                    "Failed to write COMMIT to WAL: {}",
                    e
                )));
            }

            // Also log to in-memory transaction log
            transaction.add_operation(OperationType::Other, commit_description);
            transaction.commit();

            Ok(())
        } else {
            Err(ExecutionError::RuntimeError(format!(
                "Transaction {} not found",
                transaction_id
            )))
        }
    }

    /// Rollback a transaction
    pub fn rollback_transaction(