transaction.php

<?php

namespace ArangoDBClient;

require __DIR__ . '/init.php';

try {
    $connection         = new Connection($connectionOptions);
    $collectionHandler  = new CollectionHandler($connection);
    $documentHandler    = new DocumentHandler($connection);
    $transactionHandler = new StreamingTransactionHandler($connection);

    // set up a document collection "users"
    $collection = new Collection('users');
    try {
        $collectionHandler->create($collection);
    } catch (\Exception $e) {
        // collection may already exist - ignore this error for now
    }

    // clear everything, so we can start with a clean state
    $collectionHandler->truncate($collection);

    // creates a transaction object
    $trx = new StreamingTransaction($connection, [
         TransactionBase::ENTRY_COLLECTIONS => [
             TransactionBase::ENTRY_WRITE => 'users'
         ]
    ]);

    // starts the transaction
    $trx = $transactionHandler->create($trx);
       
    // get a StreamingTransactionCollection object. this is used to execute operations
    // in a transaction context
    $trxCollection = $trx->getCollection('users');
        
    // pass the StreamingTransactionCollection into the document operations instead of
    // a regular Collection object - this will make the operations execute in the context
    // of the currently running transaction
    $documentHandler->insert($trxCollection, [ '_key' => 'test1', 'value' => 'test1' ]);
    
    $documentHandler->insert($trxCollection, [ '_key' => 'test2', 'value' => 'test2' ]);

    echo "BEFORE COMMIT" . PHP_EOL;
    echo "COLLECTION COUNT OUTSIDE OF TRANSACTION IS: ", $collectionHandler->count($collection) . PHP_EOL;
    echo "COLLECTION COUNT INSIDE OF TRANSACTION IS: ", $collectionHandler->count($trxCollection) . PHP_EOL;

    // commits the transaction
    $transactionHandler->commit($trx);

    echo PHP_EOL;
    echo "AFTER COMMIT" . PHP_EOL;
    echo "COLLECTION COUNT IS: ", $collectionHandler->count($collection) . PHP_EOL;
} catch (ConnectException $e) {
    print $e . PHP_EOL;
} catch (ServerException $e) {
    print $e . PHP_EOL;
} catch (ClientException $e) {
    print $e . PHP_EOL;
}