PHP: полный мануал с примерами, функциями и ООП

<?php
declare(strict_types=1);
require __DIR__.'/tx118-helper.php';
[$manager,$database]=tx118Environment();
$runtime=['php'=>PHP_VERSION,'extension'=>phpversion('mongodb'),'server'=>tx118Command($manager,'admin',['buildInfo'=>1])[0]['version']];
$prefix='mongodb118_txn_'.bin2hex(random_bytes(8));
$collections=[];$owned=[];$session=null;$sessionEnded=false;$details=[];
try {
    foreach(['stock', 'orders'] as $role){
        $name=$prefix.'_'.$role;
        if(tx118Exists($manager,$database,$name)){throw new RuntimeException('Owned fixture collision');}
        tx118Command($manager,$database,['create'=>$name],true);
        $owned[]=$name;$collections[$role]=$name;
    }
$stock=$database.'.'.$collections['stock'];$orders=$database.'.'.$collections['orders'];
    tx118Insert($manager,$stock,[['_id'=>'mug','title'=>'Кружка','available'=>5]]);
    $stockOptions=['projection'=>['_id'=>0,'available'=>1],'limit'=>1];
    $orderOptions=['projection'=>['_id'=>1,'quantity'=>1],'limit'=>10];
    $session=tx118Session($manager);
    $before=tx118Read($manager,$stock,['_id'=>'mug'],$stockOptions)[0]['available'];
    $none=$session->getTransactionState();
    $session->startTransaction();
    $starting=$session->getTransactionState();$options=$session->getTransactionOptions();
    $write=tx118Update($manager,$stock,['_id'=>'mug','available'=>['$gte'=>2]],['$inc'=>['available'=>-2]],$session);
    if($write->getMatchedCount()!==1){throw new DomainException('Insufficient stock');}
    $insert=tx118Insert($manager,$orders,[['_id'=>'order-118','sku'=>'mug','quantity'=>2]],$session);
    $inside=tx118Read($manager,$stock,['_id'=>'mug'],$stockOptions,$session)[0]['available'];
    $outside=tx118Read($manager,$stock,['_id'=>'mug'],$stockOptions)[0]['available'];
    $insideOrders=count(tx118Read($manager,$orders,[],$orderOptions,$session));
    $outsideOrders=count(tx118Read($manager,$orders,[],$orderOptions));
    $inProgress=$session->getTransactionState();$active=$session->isInTransaction();
    $session->commitTransaction();
    $committed=$session->getTransactionState();
    $after=tx118Read($manager,$stock,['_id'=>'mug'],$stockOptions)[0]['available'];
    $afterOrders=count(tx118Read($manager,$orders,[],$orderOptions));
    $rows=[['До начала',$before,0,$none],['Внутри транзакции',$inside,$insideOrders,$inProgress],
        ['Снаружи до commit',$outside,$outsideOrders,'отдельное чтение'],['После commit',$after,$afterOrders,$committed]];
    $checks=['conditional_decrement'=>$write->getMatchedCount()===1 && $write->getModifiedCount()===1,
        'order_inserted'=>$insert->getInsertedCount()===1,'inside_changes_visible'=>$inside===3 && $insideOrders===1,
        'outside_uncommitted_hidden'=>$outside===5 && $outsideOrders===0,
        'committed_pair'=>$after===3 && $afterOrders===1,
        'session_lifecycle'=>$none==='none' && $starting==='starting' && $inProgress==='in_progress' && $committed==='committed',
        'active_only_before_commit'=>$active && !$session->isInTransaction(),
        'transaction_option_inherited'=>is_array($options) && $options['maxCommitTimeMS']===1000];
    $details=['starting_state'=>$starting,'maxCommitTimeMS'=>$options['maxCommitTimeMS']];
} finally {
    try {
        if($session!==null && !$sessionEnded){
            try{if($session->isInTransaction()){$session->abortTransaction();}}
            finally{$session->endSession();$sessionEnded=true;}
        }
    } finally {
        foreach(array_reverse($owned) as $name){tx118Command($manager,$database,['drop'=>$name],true);}
    }
}
$removed=true;foreach($owned as $name){$removed=$removed && !tx118Exists($manager,$database,$name);}
$checks['owned_collections_removed']=$removed;
$checks['session_closed']=$sessionEnded;
tx118Report('mongodb118-transactions-order-stock', ['Наблюдение', 'Остаток, шт.', 'Заказов', 'Состояние'], $rows, $checks, $runtime, $details);
echo 'mongodb118-transactions-order-stock: saved result.html and result.json
';

mongodb118-transactions-order-stock: saved result.html and result.json

Запустите php example.php на отдельном локальном replica set и откройте result.html. В архиве есть tx118-helper.php и README с подготовкой сервера, расширения и переменных окружения. Программа создаёт и убирает только собственные учебные коллекции.

<?php
declare(strict_types=1);
require __DIR__.'/tx118-helper.php';
[$manager,$database]=tx118Environment();
$runtime=['php'=>PHP_VERSION,'extension'=>phpversion('mongodb'),'server'=>tx118Command($manager,'admin',['buildInfo'=>1])[0]['version']];
$prefix='mongodb118_txn_'.bin2hex(random_bytes(8));
$collections=[];$owned=[];$session=null;$sessionEnded=false;$details=[];
try {
    foreach(['stock', 'orders'] as $role){
        $name=$prefix.'_'.$role;
        if(tx118Exists($manager,$database,$name)){throw new RuntimeException('Owned fixture collision');}
        tx118Command($manager,$database,['create'=>$name],true);
        $owned[]=$name;$collections[$role]=$name;
    }
$stock=$database.'.'.$collections['stock'];$orders=$database.'.'.$collections['orders'];
    tx118Insert($manager,$stock,[['_id'=>'mug','available'=>1]]);
    $session=tx118Session($manager);$reason='';$insideCount=0;$matched=-1;
    $session->startTransaction();
    try{
        tx118Insert($manager,$orders,[['_id'=>'draft-118','sku'=>'mug','quantity'=>3]],$session);
        $insideCount=count(tx118Read($manager,$orders,[],['projection'=>['_id'=>1],'limit'=>10],$session));
        $result=tx118Update($manager,$stock,['_id'=>'mug','available'=>['$gte'=>3]],['$inc'=>['available'=>-3]],$session);
        $matched=$result->getMatchedCount();
        if($matched!==1){throw new DomainException('Недостаточно товара');}
        $session->commitTransaction();
    }catch(DomainException $failure){
        $reason=$failure->getMessage();$session->abortTransaction();
    }
    $state=$session->getTransactionState();
    $left=tx118Read($manager,$stock,['_id'=>'mug'],['projection'=>['available'=>1],'limit'=>1])[0]['available'];
    $count=count(tx118Read($manager,$orders,[],['projection'=>['_id'=>1],'limit'=>10]));
    $rows=[['Черновик внутри',1,$insideCount,'ещё не сохранён'],['Условное списание',1,$matched,'совпавших товаров'],
        ['После abort',$left,$count,$reason],['Session',null,null,$state]];
    $checks=['draft_existed_inside'=>$insideCount===1,'condition_matched_zero'=>$matched===0,
        'reason_is_business'=>$reason==='Недостаточно товара','stock_unchanged'=>$left===1,
        'draft_rolled_back'=>$count===0,'transaction_aborted'=>$state==='aborted' && !$session->isInTransaction()];
} finally {
    try {
        if($session!==null && !$sessionEnded){
            try{if($session->isInTransaction()){$session->abortTransaction();}}
            finally{$session->endSession();$sessionEnded=true;}
        }
    } finally {
        foreach(array_reverse($owned) as $name){tx118Command($manager,$database,['drop'=>$name],true);}
    }
}
$removed=true;foreach($owned as $name){$removed=$removed && !tx118Exists($manager,$database,$name);}
$checks['owned_collections_removed']=$removed;
$checks['session_closed']=$sessionEnded;
tx118Report('mongodb118-transactions-business-abort', ['Шаг', 'Остаток', 'Количество', 'Результат'], $rows, $checks, $runtime, $details);
echo 'mongodb118-transactions-business-abort: saved result.html and result.json
';

mongodb118-transactions-business-abort: saved result.html and result.json

Запустите php example.php на отдельном локальном replica set и откройте result.html. В архиве есть tx118-helper.php и README с подготовкой сервера, расширения и переменных окружения. Программа создаёт и убирает только собственные учебные коллекции.

<?php
declare(strict_types=1);
require __DIR__.'/tx118-helper.php';
[$manager,$database]=tx118Environment();
$runtime=['php'=>PHP_VERSION,'extension'=>phpversion('mongodb'),'server'=>tx118Command($manager,'admin',['buildInfo'=>1])[0]['version']];
$prefix='mongodb118_txn_'.bin2hex(random_bytes(8));
$collections=[];$owned=[];$session=null;$sessionEnded=false;$details=[];
try {
    foreach(['stock', 'orders'] as $role){
        $name=$prefix.'_'.$role;
        if(tx118Exists($manager,$database,$name)){throw new RuntimeException('Owned fixture collision');}
        tx118Command($manager,$database,['create'=>$name],true);
        $owned[]=$name;$collections[$role]=$name;
    }
$stock=$database.'.'.$collections['stock'];$orders=$database.'.'.$collections['orders'];
    tx118Command($manager,$database,['createIndexes'=>$collections['orders'],
        'indexes'=>[['key'=>['request_key'=>1],'name'=>'request_key_unique','unique'=>true]]],true);
    tx118Insert($manager,$stock,[['_id'=>'mug','available'=>5]]);
    tx118Insert($manager,$orders,[['_id'=>900,'request_key'=>'used-request','quantity'=>1]]);
    $session=tx118Session($manager);$codes=[];$changedInside=-1;
    $session->startTransaction();
    try{
        $change=tx118Update($manager,$stock,['_id'=>'mug','available'=>['$gte'=>1]],['$inc'=>['available'=>-1]],$session);
        if($change->getMatchedCount()!==1){throw new RuntimeException('Fixture stock mismatch');}
        $changedInside=tx118Read($manager,$stock,['_id'=>'mug'],['projection'=>['available'=>1],'limit'=>1],$session)[0]['available'];
        tx118Insert($manager,$orders,[['_id'=>901,'request_key'=>'used-request','quantity'=>1]],$session);
        throw new RuntimeException('Expected duplicate key did not occur');
    }catch(MongoDB\Driver\Exception\BulkWriteException $failure){
        $codes=array_map(fn($error)=>$error->getCode(),$failure->getWriteResult()->getWriteErrors());
        if($codes!==[11000]){throw $failure;}
        if($session->isInTransaction()){$session->abortTransaction();}
    }
    $left=tx118Read($manager,$stock,['_id'=>'mug'],['projection'=>['available'=>1],'limit'=>1])[0]['available'];
    $saved=tx118Read($manager,$orders,[],['projection'=>['_id'=>1],'sort'=>['_id'=>1],'limit'=>10]);
    $rows=[['До транзакции',5,'900'],['После списания внутри',$changedInside,'новый заказ ещё не записан'],
        ['Сервер отклонил дубликат',null,(string)$codes[0]],['После отказа',$left,implode(', ',array_column($saved,'_id'))]];
    $checks=['decrement_was_inside'=>$changedInside===4,'duplicate_code'=>$codes===[11000],
        'decrement_rolled_back'=>$left===5,'only_original_order'=>array_column($saved,'_id')===[900],
        'no_active_transaction'=>!$session->isInTransaction()];
} finally {
    try {
        if($session!==null && !$sessionEnded){
            try{if($session->isInTransaction()){$session->abortTransaction();}}
            finally{$session->endSession();$sessionEnded=true;}
        }
    } finally {
        foreach(array_reverse($owned) as $name){tx118Command($manager,$database,['drop'=>$name],true);}
    }
}
$removed=true;foreach($owned as $name){$removed=$removed && !tx118Exists($manager,$database,$name);}
$checks['owned_collections_removed']=$removed;
$checks['session_closed']=$sessionEnded;
tx118Report('mongodb118-transactions-duplicate-rollback', ['Этап', 'Остаток', 'Заказ/код'], $rows, $checks, $runtime, $details);
echo 'mongodb118-transactions-duplicate-rollback: saved result.html and result.json
';

mongodb118-transactions-duplicate-rollback: saved result.html and result.json

Запустите php example.php на отдельном локальном replica set и откройте result.html. В архиве есть tx118-helper.php и README с подготовкой сервера, расширения и переменных окружения. Программа создаёт и убирает только собственные учебные коллекции.

<?php
declare(strict_types=1);
require __DIR__.'/tx118-helper.php';
[$manager,$database]=tx118Environment();
$runtime=['php'=>PHP_VERSION,'extension'=>phpversion('mongodb'),'server'=>tx118Command($manager,'admin',['buildInfo'=>1])[0]['version']];
$prefix='mongodb118_txn_'.bin2hex(random_bytes(8));
$collections=[];$owned=[];$session=null;$sessionEnded=false;$details=[];
try {
    foreach(['wallets', 'receipts'] as $role){
        $name=$prefix.'_'.$role;
        if(tx118Exists($manager,$database,$name)){throw new RuntimeException('Owned fixture collision');}
        tx118Command($manager,$database,['create'=>$name],true);
        $owned[]=$name;$collections[$role]=$name;
    }
$wallets=$database.'.'.$collections['wallets'];$receipts=$database.'.'.$collections['receipts'];
    tx118Insert($manager,$wallets,[['_id'=>'A','balance_kopecks'=>10000],['_id'=>'B','balance_kopecks'=>3000]]);
    $session=tx118Session($manager);
    $transfer=function(string $to,int $amount,string $receiptId) use($manager,$wallets,$receipts,$session): void {
        if($amount<=0 || $amount>10000 || $to==='A'){throw new DomainException('Недопустимый перевод');}
        $session->startTransaction();
        $commitStarted=false;
        try{
            $debit=tx118Update($manager,$wallets,['_id'=>'A','balance_kopecks'=>['$gte'=>$amount]],['$inc'=>['balance_kopecks'=>-$amount]],$session);
            if($debit->getMatchedCount()!==1){throw new DomainException('Недостаточно средств');}
            $credit=tx118Update($manager,$wallets,['_id'=>$to],['$inc'=>['balance_kopecks'=>$amount]],$session);
            if($credit->getMatchedCount()!==1){throw new DomainException('Получатель отсутствует');}
            tx118Insert($manager,$receipts,[['_id'=>$receiptId,'from'=>'A','to'=>$to,'kopecks'=>$amount]],$session);
            $commitStarted=true;$session->commitTransaction();
        }catch(Throwable $failure){
            if(!$commitStarted && $session->isInTransaction()){$session->abortTransaction();}
            throw $failure;
        }
    };
    $transfer('B',2500,'transfer-1');
    $committed=$session->getTransactionState();
    $afterSuccess=tx118Read($manager,$wallets,[],['projection'=>['_id'=>1,'balance_kopecks'=>1],'sort'=>['_id'=>1],'limit'=>10]);
    $refused='';
    try{$transfer('missing',1000,'transfer-2');}
    catch(DomainException $failure){$refused=$failure->getMessage();}
    $afterFailure=tx118Read($manager,$wallets,[],['projection'=>['_id'=>1,'balance_kopecks'=>1],'sort'=>['_id'=>1],'limit'=>10]);
    $records=tx118Read($manager,$receipts,[],['projection'=>['_id'=>1],'limit'=>10]);
    $rows=[['До перевода',10000,3000,13000,0],
        ['Переведено 2500',$afterSuccess[0]['balance_kopecks'],$afterSuccess[1]['balance_kopecks'],array_sum(array_column($afterSuccess,'balance_kopecks')),1],
        ['Отказ: получатель отсутствует',$afterFailure[0]['balance_kopecks'],$afterFailure[1]['balance_kopecks'],array_sum(array_column($afterFailure,'balance_kopecks')),count($records)]];
    $checks=['success_balances'=>array_column($afterSuccess,'balance_kopecks')===[7500,5500],
        'sum_preserved'=>array_sum(array_column($afterSuccess,'balance_kopecks'))===13000,
        'success_committed'=>$committed==='committed','failed_recipient'=>$refused==='Получатель отсутствует',
        'failed_debit_rolled_back'=>$afterSuccess===$afterFailure,
        'only_one_receipt'=>array_column($records,'_id')===['transfer-1'],
        'second_transaction_aborted'=>$session->getTransactionState()==='aborted'];
} finally {
    try {
        if($session!==null && !$sessionEnded){
            try{if($session->isInTransaction()){$session->abortTransaction();}}
            finally{$session->endSession();$sessionEnded=true;}
        }
    } finally {
        foreach(array_reverse($owned) as $name){tx118Command($manager,$database,['drop'=>$name],true);}
    }
}
$removed=true;foreach($owned as $name){$removed=$removed && !tx118Exists($manager,$database,$name);}
$checks['owned_collections_removed']=$removed;
$checks['session_closed']=$sessionEnded;
tx118Report('mongodb118-transactions-wallet-transfer', ['Операция', 'Кошелёк A, коп.', 'Кошелёк B, коп.', 'Всего, коп.', 'Квитанций'], $rows, $checks, $runtime, $details);
echo 'mongodb118-transactions-wallet-transfer: saved result.html and result.json
';

mongodb118-transactions-wallet-transfer: saved result.html and result.json

Запустите php example.php на отдельном локальном replica set и откройте result.html. В архиве есть tx118-helper.php и README с подготовкой сервера, расширения и переменных окружения. Программа создаёт и убирает только собственные учебные коллекции.

<?php
declare(strict_types=1);
require __DIR__.'/tx118-helper.php';
[$manager,$database]=tx118Environment();
$runtime=['php'=>PHP_VERSION,'extension'=>phpversion('mongodb'),'server'=>tx118Command($manager,'admin',['buildInfo'=>1])[0]['version']];
$prefix='mongodb118_txn_'.bin2hex(random_bytes(8));
$collections=[];$owned=[];$session=null;$sessionEnded=false;$details=[];
try {
    foreach(['stock'] as $role){
        $name=$prefix.'_'.$role;
        if(tx118Exists($manager,$database,$name)){throw new RuntimeException('Owned fixture collision');}
        tx118Command($manager,$database,['create'=>$name],true);
        $owned[]=$name;$collections[$role]=$name;
    }
$stock=$database.'.'.$collections['stock'];
    tx118Insert($manager,$stock,[['_id'=>'mug','available'=>8]]);
    $session=$manager->startSession(['causalConsistency'=>false]);
    $none=$session->getTransactionState();$noTransaction=!$session->isInTransaction();
    $beforeOptions=$session->getTransactionOptions();
    $session->startTransaction(tx118Options());
    $starting=$session->getTransactionState();$currentOptions=$session->getTransactionOptions();
    $active=$session->isInTransaction();
    tx118Update($manager,$stock,['_id'=>'mug','available'=>['$gte'=>3]],['$inc'=>['available'=>-3]],$session);
    $preview=tx118Read($manager,$stock,['_id'=>'mug'],['projection'=>['available'=>1],'limit'=>1],$session)[0]['available'];
    $inProgress=$session->getTransactionState();
    $session->endSession();$sessionEnded=true;
    // После endSession методы этой Session больше не вызываем.
    $outside=tx118Read($manager,$stock,['_id'=>'mug'],['projection'=>['available'=>1],'limit'=>1])[0]['available'];
    $rows=[['До startTransaction',$none,'false','NULL',8],
        ['После startTransaction',$starting,$active?'true':'false',(string)$currentOptions['maxCommitTimeMS'],8],
        ['Предварительное списание',$inProgress,'true',(string)$currentOptions['maxCommitTimeMS'],$preview],
        ['После endSession','Session закрыта','не вызываем','не вызываем',$outside]];
    $checks=['initial_state'=>$none==='none' && $noTransaction,'initial_options_null'=>$beforeOptions===null,
        'starting_and_active'=>$starting==='starting' && $active,'in_progress_after_write'=>$inProgress==='in_progress',
        'option_contract'=>$currentOptions['maxCommitTimeMS']===1000
            && $currentOptions['readConcern'] instanceof MongoDB\Driver\ReadConcern
            && $currentOptions['writeConcern'] instanceof MongoDB\Driver\WriteConcern
            && $currentOptions['readPreference'] instanceof MongoDB\Driver\ReadPreference,
        'preview_changed'=>$preview===5,'end_session_aborted'=>$outside===8];
} finally {
    try {
        if($session!==null && !$sessionEnded){
            try{if($session->isInTransaction()){$session->abortTransaction();}}
            finally{$session->endSession();$sessionEnded=true;}
        }
    } finally {
        foreach(array_reverse($owned) as $name){tx118Command($manager,$database,['drop'=>$name],true);}
    }
}
$removed=true;foreach($owned as $name){$removed=$removed && !tx118Exists($manager,$database,$name);}
$checks['owned_collections_removed']=$removed;
$checks['session_closed']=$sessionEnded;
tx118Report('mongodb118-transactions-checkout-preview', ['Шаг', 'getTransactionState', 'isInTransaction', 'maxCommitTimeMS', 'Остаток'], $rows, $checks, $runtime, $details);
echo 'mongodb118-transactions-checkout-preview: saved result.html and result.json
';

mongodb118-transactions-checkout-preview: saved result.html and result.json

Запустите php example.php на отдельном локальном replica set и откройте result.html. В архиве есть tx118-helper.php и README с подготовкой сервера, расширения и переменных окружения. Программа создаёт и убирает только собственные учебные коллекции.

<?php
declare(strict_types=1);
require __DIR__.'/tx118-helper.php';
[$manager,$database]=tx118Environment();
$runtime=['php'=>PHP_VERSION,'extension'=>phpversion('mongodb'),'server'=>tx118Command($manager,'admin',['buildInfo'=>1])[0]['version']];
$prefix='mongodb118_txn_'.bin2hex(random_bytes(8));
$collections=[];$owned=[];$session=null;$sessionEnded=false;$details=[];
try {
    foreach(['stock', 'orders'] as $role){
        $name=$prefix.'_'.$role;
        if(tx118Exists($manager,$database,$name)){throw new RuntimeException('Owned fixture collision');}
        tx118Command($manager,$database,['create'=>$name],true);
        $owned[]=$name;$collections[$role]=$name;
    }
$stock=$database.'.'.$collections['stock'];$orders=$database.'.'.$collections['orders'];
    tx118Insert($manager,$stock,[['_id'=>'mug','available'=>5]]);
    $session=tx118Session($manager);
    $place=function(string $key,int $quantity) use($manager,$stock,$orders,$session): array {
        if(!preg_match('/\Arequest-[A-Za-z0-9-]{1,40}\z/D',$key) || $quantity<1 || $quantity>10){throw new DomainException('Неверный запрос');}
        $session->startTransaction();$commitStarted=false;
        try{
            $existing=tx118Read($manager,$orders,['_id'=>$key],['projection'=>['_id'=>1,'order_id'=>1,'sku'=>1,'quantity'=>1],'limit'=>1],$session);
            if($existing!==[]){
                if($existing[0]['sku']!=='mug' || $existing[0]['quantity']!==$quantity){throw new DomainException('Ключ уже связан с другим составом');}
                $session->abortTransaction(); // В этой попытке записей нет.
                return ['status'=>'повтор: существующий заказ','order_id'=>$existing[0]['order_id']];
            }
            // _id уникален: request key не может стать двумя заказами.
            tx118Insert($manager,$orders,[['_id'=>$key,'order_id'=>'order-4001','sku'=>'mug','quantity'=>$quantity]],$session);
            $debit=tx118Update($manager,$stock,['_id'=>'mug','available'=>['$gte'=>$quantity]],['$inc'=>['available'=>-$quantity]],$session);
            if($debit->getMatchedCount()!==1){throw new DomainException('Недостаточно товара');}
            $commitStarted=true;$session->commitTransaction();
            return ['status'=>'создан','order_id'=>'order-4001'];
        }catch(Throwable $failure){
            if(!$commitStarted && $session->isInTransaction()){$session->abortTransaction();}
            throw $failure;
        }
    };
    $first=$place('request-118-001',2);
    $firstStock=tx118Read($manager,$stock,['_id'=>'mug'],['projection'=>['available'=>1],'limit'=>1])[0]['available'];
    $second=$place('request-118-001',2);
    $secondStock=tx118Read($manager,$stock,['_id'=>'mug'],['projection'=>['available'=>1],'limit'=>1])[0]['available'];
    $refused='';
    try{$place('request-118-001',3);}catch(DomainException $failure){$refused=$failure->getMessage();}
    $finalStock=tx118Read($manager,$stock,['_id'=>'mug'],['projection'=>['available'=>1],'limit'=>1])[0]['available'];
    $saved=tx118Read($manager,$orders,[],['projection'=>['_id'=>1,'quantity'=>1],'limit'=>10]);
    $rows=[['Первый запрос, 2 шт.',$first['status'],$first['order_id'],$firstStock],
        ['Тот же ключ, 2 шт.',$second['status'],$second['order_id'],$secondStock],
        ['Тот же ключ, 3 шт.',$refused,'не создан',$finalStock]];
    $checks=['first_committed'=>$first['status']==='создан' && $firstStock===3,
        'repeated_result'=>$second['status']==='повтор: существующий заказ' && $second['order_id']===$first['order_id'],
        'no_second_debit'=>$secondStock===3 && $finalStock===3,
        'payload_conflict'=>$refused==='Ключ уже связан с другим составом',
        'single_order'=>count($saved)===1 && $saved[0]['_id']==='request-118-001' && $saved[0]['quantity']===2,
        'no_active_after_resolution'=>!$session->isInTransaction()];
} finally {
    try {
        if($session!==null && !$sessionEnded){
            try{if($session->isInTransaction()){$session->abortTransaction();}}
            finally{$session->endSession();$sessionEnded=true;}
        }
    } finally {
        foreach(array_reverse($owned) as $name){tx118Command($manager,$database,['drop'=>$name],true);}
    }
}
$removed=true;foreach($owned as $name){$removed=$removed && !tx118Exists($manager,$database,$name);}
$checks['owned_collections_removed']=$removed;
$checks['session_closed']=$sessionEnded;
tx118Report('mongodb118-transactions-idempotent-order', ['Попытка', 'Ответ', 'Заказ', 'Остаток'], $rows, $checks, $runtime, $details);
echo 'mongodb118-transactions-idempotent-order: saved result.html and result.json
';

mongodb118-transactions-idempotent-order: saved result.html and result.json

Запустите php example.php на отдельном локальном replica set и откройте result.html. В архиве есть tx118-helper.php и README с подготовкой сервера, расширения и переменных окружения. Программа создаёт и убирает только собственные учебные коллекции.