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

<?php
declare(strict_types=1);
require __DIR__.'/mr121-helper.php';
$runtime=mr121Runtime(); [$manager,$database]=mr121Database();
$runtime['server']=mr121Command($manager,'admin',['buildInfo'=>1])[0]['version'];
if (version_compare($runtime['server'],'8.0.0','<')) { throw new RuntimeException('MongoDB 8.0+ is required'); }
$collection='mongodb121_results_'.bin2hex(random_bytes(8)); $namespace=$database.'.'.$collection; $owned=false;
if (mr121Exists($manager,$database,$collection)) { throw new RuntimeException('Unexpected collection collision'); }
try {
    mr121Command($manager,$database,['create'=>$collection],true); $owned=true;
$source=[101=>['sku'=>'CUP','_id'=>501,'price'=>500],102=>['sku'=>'LAMP','_id'=>502,'price'=>1200]];
$bulk=new MongoDB\Driver\BulkWriteCommand(['verboseResults'=>true]);
$ids=[]; $ids[0]=$bulk->insertOne($namespace,$source[101]);
$bulk->updateOne($namespace,['_id'=>501],['$set'=>['price'=>550]]); // index 1 is not an insert
$ids[2]=$bulk->insertOne($namespace,$source[102]);
$result=mr121Run($manager,$bulk); $insert=mr121Plain($result->getInsertResults());
$operationToLine=[0=>101,2=>102]; $rows=[];
foreach ($operationToLine as $operation=>$line) {
    $rows[]=[$line,$operation,$source[$line]['sku'],$insert[$operation]['insertedId'],'подтверждено'];
}
$saved=mr121Find($manager,$namespace);
$checks=['acknowledged'=>$result->isAcknowledged(),'inserted_two'=>$result->getInsertedCount()===2,
    'global_indices'=>array_keys($insert)===[0,2],
    'ids_match_enqueue'=>$insert[0]['insertedId']===$ids[0] && $insert[2]['insertedId']===$ids[2],
    'actual_documents'=>$saved===[['_id'=>501,'sku'=>'CUP','price'=>550],['_id'=>502,'sku'=>'LAMP','price'=>1200]],
    'no_upserts'=>$result->getUpsertedCount()===0];
$details=['Строки прайса'=>$source,'Операции вставки'=>$insert,'После пакета'=>$saved,
    'Отдельная операция 1'=>mr121Plain($result->getUpdateResults())];
} finally {
    if ($owned) { mr121Command($manager,$database,['drop'=>$collection],true); }
}
$checks['owned_collection_removed']=!mr121Exists($manager,$database,$collection);
$details['Собственная удалённая коллекция']=$collection;
mr121Report('mongodb121-results-import-ledger',['Строка прайса', 'Индекс операции', 'Артикул', 'Вставленный _id', 'Статус'],$rows,$checks,$runtime,$details);
echo 'mongodb121-results-import-ledger: saved result.html and result.json
';

mongodb121-results-import-ledger: saved result.html and result.json

Запустите php example.php на отдельном локальном MongoDB 8.0+. Все данные, helper и README входят в ZIP; результат читается из настоящего ответа и контрольного запроса. Собственная коллекция удаляется в finally.

<?php
declare(strict_types=1);
require __DIR__.'/mr121-helper.php';
$runtime=mr121Runtime(); [$manager,$database]=mr121Database();
$runtime['server']=mr121Command($manager,'admin',['buildInfo'=>1])[0]['version'];
if (version_compare($runtime['server'],'8.0.0','<')) { throw new RuntimeException('MongoDB 8.0+ is required'); }
$collection='mongodb121_results_'.bin2hex(random_bytes(8)); $namespace=$database.'.'.$collection; $owned=false;
if (mr121Exists($manager,$database,$collection)) { throw new RuntimeException('Unexpected collection collision'); }
try {
    mr121Command($manager,$database,['create'=>$collection],true); $owned=true;
mr121Seed($manager,$namespace,[['_id'=>1,'sku'=>'CUP','price'=>500],['_id'=>2,'sku'=>'LAMP','price'=>1000]]);
$requests=[['sku'=>'CUP','price'=>500],['sku'=>'LAMP','price'=>1200],['sku'=>'MISSING','price'=>900]];
$bulk=new MongoDB\Driver\BulkWriteCommand(['verboseResults'=>true]);
foreach ($requests as $request) { $bulk->updateOne($namespace,['sku'=>$request['sku']],['$set'=>['price'=>$request['price']]]); }
$result=mr121Run($manager,$bulk); $updates=mr121Plain($result->getUpdateResults()); $rows=[];
foreach ($requests as $index=>$request) {
    $matched=mr121Number($updates[$index]['matchedCount']); $modified=mr121Number($updates[$index]['modifiedCount']);
    $status=$matched===0?'товар не найден':($modified===0?'цена уже такая':'цена изменена');
    $rows[]=[$index,$request['sku'],$request['price'],$matched,$modified,$status];
}
$saved=mr121Find($manager,$namespace);
$checks=['matched_two'=>$result->getMatchedCount()===2,'modified_one'=>$result->getModifiedCount()===1,
    'all_successful_operations'=>array_keys($updates)===[0,1,2],
    'zero_match_not_error'=>mr121Number($updates[2]['matchedCount'])===0,
    'actual_prices'=>$saved===[['_id'=>1,'sku'=>'CUP','price'=>500],['_id'=>2,'sku'=>'LAMP','price'=>1200]],
    'no_upserts'=>$result->getUpsertedCount()===0];
$details=['Запрошенные цены'=>$requests,'Подробные результаты'=>$updates,'Фактические товары'=>$saved];
} finally {
    if ($owned) { mr121Command($manager,$database,['drop'=>$collection],true); }
}
$checks['owned_collection_removed']=!mr121Exists($manager,$database,$collection);
$details['Собственная удалённая коллекция']=$collection;
mr121Report('mongodb121-results-price-noop',['Операция', 'Артикул', 'Желаемая цена', 'Matched', 'Modified', 'Вывод'],$rows,$checks,$runtime,$details);
echo 'mongodb121-results-price-noop: saved result.html and result.json
';

mongodb121-results-price-noop: saved result.html and result.json

Запустите php example.php на отдельном локальном MongoDB 8.0+. Все данные, helper и README входят в ZIP; результат читается из настоящего ответа и контрольного запроса. Собственная коллекция удаляется в finally.

<?php
declare(strict_types=1);
require __DIR__.'/mr121-helper.php';
$runtime=mr121Runtime(); [$manager,$database]=mr121Database();
$runtime['server']=mr121Command($manager,'admin',['buildInfo'=>1])[0]['version'];
if (version_compare($runtime['server'],'8.0.0','<')) { throw new RuntimeException('MongoDB 8.0+ is required'); }
$collection='mongodb121_results_'.bin2hex(random_bytes(8)); $namespace=$database.'.'.$collection; $owned=false;
if (mr121Exists($manager,$database,$collection)) { throw new RuntimeException('Unexpected collection collision'); }
try {
    mr121Command($manager,$database,['create'=>$collection],true); $owned=true;
mr121Seed($manager,$namespace,[['_id'=>601,'sku'=>'CUP','price'=>500]]);
mr121Command($manager,$database,['createIndexes'=>$collection,'indexes'=>[['key'=>['sku'=>1],'name'=>'sku_unique','unique'=>true]]],true);
$bulk=new MongoDB\Driver\BulkWriteCommand(['verboseResults'=>true]);
$bulk->updateOne($namespace,['sku'=>'CUP'],['$set'=>['price'=>550]],['upsert'=>true]);
$bulk->updateOne($namespace,['sku'=>'LAMP'],['$set'=>['price'=>1200],'$setOnInsert'=>['_id'=>602]],['upsert'=>true]);
$result=mr121Run($manager,$bulk); $updates=mr121Plain($result->getUpdateResults()); $rows=[];
foreach (['CUP','LAMP'] as $index=>$sku) {
    $created=array_key_exists('upsertedId',$updates[$index]);
    $rows[]=[$index,$sku,$created?'создан':'обновлён',$created?$updates[$index]['upsertedId']:null];
}
$saved=mr121Find($manager,$namespace);
$checks=['one_upsert'=>$result->getUpsertedCount()===1,'not_insert_count'=>$result->getInsertedCount()===0,
    'matched_existing'=>$result->getMatchedCount()===1,'modified_existing'=>$result->getModifiedCount()===1,
    'id_only_for_created'=>!array_key_exists('upsertedId',$updates[0]) && $updates[1]['upsertedId']===602,
    'actual_products'=>$saved===[['_id'=>601,'sku'=>'CUP','price'=>550],['_id'=>602,'sku'=>'LAMP','price'=>1200]]];
$details=['Результаты обновлений'=>$updates,'Сохранённые товары'=>$saved,
    'Сводка'=>['inserted'=>$result->getInsertedCount(),'upserted'=>$result->getUpsertedCount(),'matched'=>$result->getMatchedCount(),'modified'=>$result->getModifiedCount()]];
} finally {
    if ($owned) { mr121Command($manager,$database,['drop'=>$collection],true); }
}
$checks['owned_collection_removed']=!mr121Exists($manager,$database,$collection);
$details['Собственная удалённая коллекция']=$collection;
mr121Report('mongodb121-results-upsert-ids',['Операция', 'Артикул', 'Результат', 'Новый upsertedId'],$rows,$checks,$runtime,$details);
echo 'mongodb121-results-upsert-ids: saved result.html and result.json
';

mongodb121-results-upsert-ids: saved result.html and result.json

Запустите php example.php на отдельном локальном MongoDB 8.0+. Все данные, helper и README входят в ZIP; результат читается из настоящего ответа и контрольного запроса. Собственная коллекция удаляется в finally.

<?php
declare(strict_types=1);
require __DIR__.'/mr121-helper.php';
$runtime=mr121Runtime(); [$manager,$database]=mr121Database();
$runtime['server']=mr121Command($manager,'admin',['buildInfo'=>1])[0]['version'];
if (version_compare($runtime['server'],'8.0.0','<')) { throw new RuntimeException('MongoDB 8.0+ is required'); }
$collection='mongodb121_results_'.bin2hex(random_bytes(8)); $namespace=$database.'.'.$collection; $owned=false;
if (mr121Exists($manager,$database,$collection)) { throw new RuntimeException('Unexpected collection collision'); }
try {
    mr121Command($manager,$database,['create'=>$collection],true); $owned=true;
mr121Seed($manager,$namespace,[['_id'=>11,'sku'=>'CART-A','state'=>'expired'],['_id'=>12,'sku'=>'CART-B','state'=>'expired'],['_id'=>13,'sku'=>'CART-C','state'=>'active']]);
$bulk=new MongoDB\Driver\BulkWriteCommand(['verboseResults'=>true]);
$bulk->deleteOne($namespace,['_id'=>11,'state'=>'expired']);
$bulk->deleteMany($namespace,['state'=>'expired']);
$bulk->deleteOne($namespace,['_id'=>99]);
$result=mr121Run($manager,$bulk); $deleted=mr121Plain($result->getDeleteResults()); $rows=[];
foreach (['CART-A только expired','остальные expired','несуществующий _id=99'] as $index=>$reason) {
    $rows[]=[$index,$reason,mr121Number($deleted[$index]['deletedCount'])];
}
$saved=mr121Find($manager,$namespace);
$rows[]=['остаток',$saved[0]['sku'].' / '.$saved[0]['state'],count($saved)];
$checks=['deleted_two'=>$result->getDeletedCount()===2,'three_results'=>array_keys($deleted)===[0,1,2],
    'first_one'=>mr121Number($deleted[0]['deletedCount'])===1,'remaining_one'=>mr121Number($deleted[1]['deletedCount'])===1,
    'missing_zero'=>mr121Number($deleted[2]['deletedCount'])===0,
    'active_survives'=>$saved===[['_id'=>13,'sku'=>'CART-C','state'=>'active']]];
$details=['Результаты удаления'=>$deleted,'Фактический остаток'=>$saved];
} finally {
    if ($owned) { mr121Command($manager,$database,['drop'=>$collection],true); }
}
$checks['owned_collection_removed']=!mr121Exists($manager,$database,$collection);
$details['Собственная удалённая коллекция']=$collection;
mr121Report('mongodb121-results-delete-audit',['Операция', 'Критерий / сохранённая строка', 'Документов'],$rows,$checks,$runtime,$details);
echo 'mongodb121-results-delete-audit: saved result.html and result.json
';

mongodb121-results-delete-audit: saved result.html and result.json

Запустите php example.php на отдельном локальном MongoDB 8.0+. Все данные, helper и README входят в ZIP; результат читается из настоящего ответа и контрольного запроса. Собственная коллекция удаляется в finally.

<?php
declare(strict_types=1);
require __DIR__.'/mr121-helper.php';
$runtime=mr121Runtime(); [$manager,$database]=mr121Database();
$runtime['server']=mr121Command($manager,'admin',['buildInfo'=>1])[0]['version'];
if (version_compare($runtime['server'],'8.0.0','<')) { throw new RuntimeException('MongoDB 8.0+ is required'); }
$collection='mongodb121_results_'.bin2hex(random_bytes(8)); $namespace=$database.'.'.$collection; $owned=false;
if (mr121Exists($manager,$database,$collection)) { throw new RuntimeException('Unexpected collection collision'); }
try {
    mr121Command($manager,$database,['create'=>$collection],true); $owned=true;
$rows=[]; $details=[]; $mapsCorrect=true; $countsCorrect=true;
foreach ([false,true] as $verbose) {
    $bulk=new MongoDB\Driver\BulkWriteCommand(['verboseResults'=>$verbose]);
    $id=$verbose?702:701;
    $bulk->insertOne($namespace,['_id'=>$id,'sku'=>'TEMP','price'=>100]);
    $bulk->updateOne($namespace,['_id'=>$id],['$set'=>['price'=>150]]);
    $bulk->deleteOne($namespace,['_id'=>$id]);
    $result=mr121Run($manager,$bulk);
    $insert=mr121Plain($result->getInsertResults()); $update=mr121Plain($result->getUpdateResults()); $delete=mr121Plain($result->getDeleteResults());
    $mapsCorrect=$mapsCorrect && ($verbose
        ? array_keys($insert)===[0] && array_keys($update)===[1] && array_keys($delete)===[2]
        : $insert===null && $update===null && $delete===null);
    $countsCorrect=$countsCorrect && $result->isAcknowledged() && $result->getInsertedCount()===1
        && $result->getMatchedCount()===1 && $result->getModifiedCount()===1 && $result->getDeletedCount()===1;
    $rows[]=[$verbose?'true':'false',$result->getInsertedCount(),$result->getModifiedCount(),$result->getDeletedCount(),
        $verbose?'индексы: insert 0, update 1, delete 2':'три NULL: подробности не запрошены'];
    $details[$verbose?'verbose=true':'verbose=false']=['insert'=>$insert,'update'=>$update,'delete'=>$delete];
}
$saved=mr121Find($manager,$namespace);
$checks=['maps_follow_option'=>$mapsCorrect,'same_actual_counts'=>$countsCorrect,'no_documents_remain'=>$saved===[]];
$details['Конечные документы']=$saved;
} finally {
    if ($owned) { mr121Command($manager,$database,['drop'=>$collection],true); }
}
$checks['owned_collection_removed']=!mr121Exists($manager,$database,$collection);
$details['Собственная удалённая коллекция']=$collection;
mr121Report('mongodb121-results-verbose-switch',['verboseResults', 'Вставлено', 'Изменено', 'Удалено', 'Подробные результаты'],$rows,$checks,$runtime,$details);
echo 'mongodb121-results-verbose-switch: saved result.html and result.json
';

mongodb121-results-verbose-switch: saved result.html and result.json

Запустите php example.php на отдельном локальном MongoDB 8.0+. Все данные, helper и README входят в ZIP; результат читается из настоящего ответа и контрольного запроса. Собственная коллекция удаляется в finally.

<?php
declare(strict_types=1);
require __DIR__.'/mr121-helper.php';
$runtime=mr121Runtime(); [$manager,$database]=mr121Database();
$runtime['server']=mr121Command($manager,'admin',['buildInfo'=>1])[0]['version'];
if (version_compare($runtime['server'],'8.0.0','<')) { throw new RuntimeException('MongoDB 8.0+ is required'); }
$collection='mongodb121_results_'.bin2hex(random_bytes(8)); $namespace=$database.'.'.$collection; $owned=false;
if (mr121Exists($manager,$database,$collection)) { throw new RuntimeException('Unexpected collection collision'); }
try {
    mr121Command($manager,$database,['create'=>$collection],true); $owned=true;
mr121Seed($manager,$namespace,[['_id'=>900,'sku'=>'EXISTS','price'=>100]]);
$bulk=new MongoDB\Driver\BulkWriteCommand(['ordered'=>true,'verboseResults'=>true]);
$source=[['_id'=>901,'sku'=>'FIRST','price'=>200],['_id'=>900,'sku'=>'CONFLICT','price'=>300],['_id'=>902,'sku'=>'LATER','price'=>400]];
foreach ($source as $document) { $bulk->insertOne($namespace,$document); }
try { mr121Run($manager,$bulk); throw new RuntimeException('Expected duplicate write error'); }
catch (MongoDB\Driver\Exception\BulkWriteCommandException $error) {
    $errors=mr121Duplicate($error,[1]); $partial=$error->getPartialResult();
    if ($partial===null || !$partial->isAcknowledged()) { throw $error; }
    $success=mr121Plain($partial->getInsertResults());
    $topReply=$error->getErrorReply(); $concern=$error->getWriteConcernErrors();
}
$rows=[];
foreach ($source as $index=>$document) {
    $status=isset($success[$index])?'вставлен':(isset($errors[$index])?'отказ 11000':'не выполнялся после ошибки');
    $rows[]=[$index,$document['sku'],$document['_id'],$status];
}
$firstFailure=new MongoDB\Driver\BulkWriteCommand(['verboseResults'=>true]);
$firstFailure->insertOne($namespace,['_id'=>900,'sku'=>'AGAIN']); $noPartial=false;
try { mr121Run($manager,$firstFailure); throw new RuntimeException('Expected first-operation duplicate'); }
catch (MongoDB\Driver\Exception\BulkWriteCommandException $error) {
    mr121Duplicate($error,[0]); $noPartial=$error->getPartialResult()===null;
}
$rows[]=['отдельный пакет','AGAIN',900,$noPartial?'partialResult = NULL':'unexpected'];
$saved=mr121Find($manager,$namespace);
$checks=['only_first_inserted'=>$partial->getInsertedCount()===1 && array_keys($success)===[0],
    'one_indexed_error'=>array_keys($errors)===[1],'no_top_level_error'=>$topReply===null,
    'no_write_concern_errors'=>$concern===[],'null_when_no_success'=>$noPartial,
    'actual_partial_state'=>$saved===[['_id'=>900,'sku'=>'EXISTS','price'=>100],['_id'=>901,'sku'=>'FIRST','price'=>200]]];
$details=['Успешные индексы'=>$success,'Коды ошибок'=>[1=>$errors[1]->getCode()],
    'getErrorReply'=>$topReply,'getWriteConcernErrors'=>$concern,'Фактические документы'=>$saved];
} finally {
    if ($owned) { mr121Command($manager,$database,['drop'=>$collection],true); }
}
$checks['owned_collection_removed']=!mr121Exists($manager,$database,$collection);
$details['Собственная удалённая коллекция']=$collection;
mr121Report('mongodb121-results-ordered-stop',['Операция', 'Артикул входа', '_id', 'Решение по подтверждённому ответу'],$rows,$checks,$runtime,$details);
echo 'mongodb121-results-ordered-stop: saved result.html and result.json
';

mongodb121-results-ordered-stop: saved result.html and result.json

Запустите php example.php на отдельном локальном MongoDB 8.0+. Все данные, helper и README входят в ZIP; результат читается из настоящего ответа и контрольного запроса. Собственная коллекция удаляется в finally.

<?php
declare(strict_types=1);
require __DIR__.'/mr121-helper.php';
$runtime=mr121Runtime(); [$manager,$database]=mr121Database();
$runtime['server']=mr121Command($manager,'admin',['buildInfo'=>1])[0]['version'];
if (version_compare($runtime['server'],'8.0.0','<')) { throw new RuntimeException('MongoDB 8.0+ is required'); }
$collection='mongodb121_results_'.bin2hex(random_bytes(8)); $namespace=$database.'.'.$collection; $owned=false;
if (mr121Exists($manager,$database,$collection)) { throw new RuntimeException('Unexpected collection collision'); }
try {
    mr121Command($manager,$database,['create'=>$collection],true); $owned=true;
mr121Seed($manager,$namespace,[['_id'=>10,'sku'=>'LOCKED-A','price'=>100],['_id'=>20,'sku'=>'LOCKED-B','price'=>200]]);
$source=[['_id'=>30,'sku'=>'NEW-A','price'=>300],['_id'=>10,'sku'=>'BAD-A','price'=>999],['_id'=>40,'sku'=>'NEW-B','price'=>400],['_id'=>20,'sku'=>'BAD-B','price'=>999]];
$bulk=new MongoDB\Driver\BulkWriteCommand(['ordered'=>false,'verboseResults'=>true]);
foreach ($source as $document) { $bulk->insertOne($namespace,$document); }
try { mr121Run($manager,$bulk); throw new RuntimeException('Expected duplicates'); }
catch (MongoDB\Driver\Exception\BulkWriteCommandException $error) {
    $errors=mr121Duplicate($error,[1,3]); $partial=$error->getPartialResult();
    if ($partial===null || !$partial->isAcknowledged()) { throw $error; }
    $success=mr121Plain($partial->getInsertResults()); ksort($success);
    $topReply=$error->getErrorReply(); $concern=$error->getWriteConcernErrors();
}
$rows=[];
foreach ($source as $index=>$document) {
    $rows[]=[$index,$document['sku'],isset($success[$index])?'подтверждён insert':'отказ 11000',
        isset($success[$index])?$success[$index]['insertedId']:$errors[$index]->getIndex()];
}
$saved=mr121Find($manager,$namespace);
$checks=['two_successes'=>$partial->getInsertedCount()===2 && array_keys($success)===[0,2],
    'two_exact_errors'=>array_keys($errors)===[1,3],'top_level_reply_absent'=>$topReply===null,
    'concern_errors_empty'=>$concern===[],
    'failed_existing_unchanged'=>$saved===[['_id'=>10,'sku'=>'LOCKED-A','price'=>100],['_id'=>20,'sku'=>'LOCKED-B','price'=>200],['_id'=>30,'sku'=>'NEW-A','price'=>300],['_id'=>40,'sku'=>'NEW-B','price'=>400]]];
$details=['Вход по индексам'=>$source,'Успешные вставки'=>$success,'Ошибка индекс→код'=>[1=>$errors[1]->getCode(),3=>$errors[3]->getCode()],
    'Верхний ответ'=>$topReply,'Ошибки подтверждения'=>$concern,'Фактическое состояние'=>$saved];
} finally {
    if ($owned) { mr121Command($manager,$database,['drop'=>$collection],true); }
}
$checks['owned_collection_removed']=!mr121Exists($manager,$database,$collection);
$details['Собственная удалённая коллекция']=$collection;
mr121Report('mongodb121-results-unordered-ledger',['Индекс операции', 'Артикул входа', 'Подтверждённый исход', '_id успеха / индекс ошибки'],$rows,$checks,$runtime,$details);
echo 'mongodb121-results-unordered-ledger: saved result.html and result.json
';

mongodb121-results-unordered-ledger: saved result.html and result.json

Запустите php example.php на отдельном локальном MongoDB 8.0+. Все данные, helper и README входят в ZIP; результат читается из настоящего ответа и контрольного запроса. Собственная коллекция удаляется в finally.

<?php
declare(strict_types=1);
require __DIR__.'/mr121-helper.php';
$runtime=mr121Runtime(); [$manager,$database]=mr121Database();
$runtime['server']=mr121Command($manager,'admin',['buildInfo'=>1])[0]['version'];
if (version_compare($runtime['server'],'8.0.0','<')) { throw new RuntimeException('MongoDB 8.0+ is required'); }
$collection='mongodb121_results_'.bin2hex(random_bytes(8)); $namespace=$database.'.'.$collection; $owned=false;
if (mr121Exists($manager,$database,$collection)) { throw new RuntimeException('Unexpected collection collision'); }
try {
    mr121Command($manager,$database,['create'=>$collection],true); $owned=true;
mr121Seed($manager,$namespace,[['_id'=>801,'sku'=>'CUP','price'=>500]]);
mr121Command($manager,$database,['createIndexes'=>$collection,'indexes'=>[['key'=>['sku'=>1],'name'=>'sku_unique','unique'=>true]]],true);
$input=[['_id'=>803,'sku'=>'CUP','price'=>600],['_id'=>802,'sku'=>'LAMP','price'=>900]];
$first=new MongoDB\Driver\BulkWriteCommand(['ordered'=>false,'verboseResults'=>true]);
foreach ($input as $document) { $first->insertOne($namespace,$document); }
try { mr121Run($manager,$first); throw new RuntimeException('Expected SKU duplicate'); }
catch (MongoDB\Driver\Exception\BulkWriteCommandException $error) {
    mr121Duplicate($error,[0]); $partial=$error->getPartialResult();
    if ($partial===null || $partial->getInsertedCount()!==1) { throw $error; }
}
$before=mr121Find($manager,$namespace);
if ($before!==[['_id'=>801,'sku'=>'CUP','price'=>500],['_id'=>802,'sku'=>'LAMP','price'=>900]]) {
    throw new RuntimeException('Unexpected reconciliation state; stop and inspect');
}
// Explicit fixture policy: this checked supplier price list is authoritative for price only.
// Do not replay inserts or copy incoming _id=803 over the existing CUP identity.
$rows=[]; $passes=[];
foreach (['восстановление','тот же прайс повторно'] as $pass) {
    $bulk=new MongoDB\Driver\BulkWriteCommand(['verboseResults'=>true]);
    foreach ($input as $document) {
        $bulk->updateOne($namespace,['sku'=>$document['sku']],['$set'=>['price'=>$document['price']]],['upsert'=>true]);
    }
    $result=mr121Run($manager,$bulk); $updates=mr121Plain($result->getUpdateResults());
    foreach ($input as $index=>$document) {
        $rows[]=[$pass,$document['sku'],mr121Number($updates[$index]['matchedCount']),mr121Number($updates[$index]['modifiedCount']),$document['price']];
    }
    $passes[]=['matched'=>$result->getMatchedCount(),'modified'=>$result->getModifiedCount(),'upserted'=>$result->getUpsertedCount(),'updates'=>$updates];
}
$after=mr121Find($manager,$namespace);
$checks=['first_partial_insert'=>$partial->getInsertedCount()===1,
    'recovery_one_change'=>$passes[0]['matched']===2 && $passes[0]['modified']===1 && $passes[0]['upserted']===0,
    'replay_no_new_change'=>$passes[1]['matched']===2 && $passes[1]['modified']===0 && $passes[1]['upserted']===0,
    'same_business_entities'=>$after===[['_id'=>801,'sku'=>'CUP','price'=>600],['_id'=>802,'sku'=>'LAMP','price'=>900]]];
$details=['Проверенный вход'=>$input,'Перед решением конфликта'=>$before,'Ответы двух новых пакетов'=>$passes,'После восстановления'=>$after,
    'Граница'=>'Изолированный последовательный пример. Не тест гонки/сетевого retry и не обещание идемпотентности произвольного update.'];
} finally {
    if ($owned) { mr121Command($manager,$database,['drop'=>$collection],true); }
}
$checks['owned_collection_removed']=!mr121Exists($manager,$database,$collection);
$details['Собственная удалённая коллекция']=$collection;
mr121Report('mongodb121-results-controlled-retry',['Этап', 'Артикул', 'Matched', 'Modified', 'Цена после'],$rows,$checks,$runtime,$details);
echo 'mongodb121-results-controlled-retry: saved result.html and result.json
';

mongodb121-results-controlled-retry: saved result.html and result.json

Запустите php example.php на отдельном локальном MongoDB 8.0+. Все данные, helper и README входят в ZIP; результат читается из настоящего ответа и контрольного запроса. Собственная коллекция удаляется в finally.