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

<?php
declare(strict_types=1);
require __DIR__.'/sr129-helper.php';
$settings=sr129Settings();$database=$settings['database'];
$manager=new MongoDB\Driver\Manager($settings['uri'],['serverSelectionTimeoutMS'=>1500,'connectTimeoutMS'=>500,'socketTimeoutMS'=>2000,'retryReads'=>false]);
$owned=[];
try{
$version=sr129Command($manager,$database,['buildInfo'=>1])[0]['version'];
if(version_compare($version,'8.0','<')){throw new RuntimeException('MongoDB8.0+ required');}
$server=$manager->selectServer(new MongoDB\Driver\ReadPreference(MongoDB\Driver\ReadPreference::PRIMARY));
if($server->getType()!==MongoDB\Driver\Server::TYPE_STANDALONE){throw new RuntimeException('Separate standalone lab required');}
$runtime=['php'=>PHP_VERSION,'extension'=>phpversion('mongodb'),'server'=>$version,'execution'=>'database','observed_host'=>$server->getHost(),'observed_port'=>$server->getPort()];
$namespace=sr129Create($manager,$database,$owned);$collection=$owned[0];
sr129Insert($manager,$namespace,[['_id'=>1,'sku'=>'MUG','title'=>'Кружка']]);
$cursor=$server->executeQuery($namespace,new MongoDB\Driver\Query(['_id'=>1],['projection'=>['_id'=>1,'sku'=>1],'limit'=>1,'batchSize'=>2,'maxTimeMS'=>1500]));
$docs=sr129Rows($cursor);$actual=$cursor->getServer();$parts=parse_url($settings['uri']);
$private=false;try{new MongoDB\Driver\Server();}catch(Error){$private=true;}
$same=$actual->getHost()===$server->getHost()&&$actual->getPort()===$server->getPort();
$rows=[['Полученный товар',$docs[0]['sku']],['Ответил выбранный Server',$same],['Порт совпадает с URI',$actual->getPort()===$parts['port']],['new Server недоступен',$private]];
$checks=['exact_doc'=>$docs===[['_id'=>1,'sku'=>'MUG']],'same_server'=>$same,'port_checked_against_uri'=>$actual->getPort()===$parts['port'],'host_is_loopback'=>$actual->getHost()==='127.0.0.1','private_constructor'=>$private,'standalone_not_replica'=>$server->getType()===MongoDB\Driver\Server::TYPE_STANDALONE];
}finally{
    foreach(array_reverse($owned) as $name){sr129Command($manager,$database,['drop'=>$name],true);}
}
$removed=true;foreach($owned as $name){if(sr129Exists($manager,$database,$name)){$removed=false;}}
$checks['only_owned_collections_removed']=$removed && count($owned)===1;
sr129Report('mongodb129-server-selected-server', ['Проверка', 'Результат'], $rows, $checks, $runtime);
echo 'mongodb129-server-selected-server: saved result.html and result.json
';

mongodb129-server-selected-server: saved result.html and result.json

Реальный запуск в собственной учебной MongoDB-коллекции. Результат показан в HTML и JSON. Helper и README входят в архив; неожиданные отказы не подменяются успешными строками.

<?php
declare(strict_types=1);
require __DIR__.'/sr129-helper.php';
$settings=sr129Settings();$database=$settings['database'];
$manager=new MongoDB\Driver\Manager($settings['uri'],['serverSelectionTimeoutMS'=>1500,'connectTimeoutMS'=>500,'socketTimeoutMS'=>2000,'retryReads'=>false]);
$owned=[];
try{
$version=sr129Command($manager,$database,['buildInfo'=>1])[0]['version'];
if(version_compare($version,'8.0','<')){throw new RuntimeException('MongoDB8.0+ required');}
$server=$manager->selectServer(new MongoDB\Driver\ReadPreference(MongoDB\Driver\ReadPreference::PRIMARY));
if($server->getType()!==MongoDB\Driver\Server::TYPE_STANDALONE){throw new RuntimeException('Separate standalone lab required');}
$runtime=['php'=>PHP_VERSION,'extension'=>phpversion('mongodb'),'server'=>$version,'execution'=>'database','observed_host'=>$server->getHost(),'observed_port'=>$server->getPort()];
$namespace=sr129Create($manager,$database,$owned);$collection=$owned[0];
sr129Insert($manager,$namespace,[['_id'=>1,'tenant'=>'A','active'=>true,'title'=>'Чайник','price'=>300,'internal'=>'hidden'],['_id'=>2,'tenant'=>'A','active'=>true,'title'=>'Кружка','price'=>100,'internal'=>'hidden'],['_id'=>3,'tenant'=>'A','active'=>true,'title'=>'Тарелка','price'=>200,'internal'=>'hidden'],['_id'=>4,'tenant'=>'B','active'=>true,'title'=>'Чужой товар','price'=>10],['_id'=>5,'tenant'=>'A','active'=>false,'title'=>'Черновик','price'=>50]]);
$filter=['tenant'=>'A','active'=>true];$projection=['_id'=>1,'title'=>1,'price'=>1];
$first=sr129Query($server,$namespace,$filter,$projection,2,['price'=>1,'_id'=>1]);
$last=$first[count($first)-1];
$nextFilter=$filter+['$or'=>[['price'=>['$gt'=>$last['price']]],['price'=>$last['price'],'_id'=>['$gt'=>$last['_id']]]]];
$second=sr129Query($server,$namespace,$nextFilter,$projection,2,['price'=>1,'_id'=>1]);
$rows=[];foreach([1=>$first,2=>$second] as $page=>$docs){foreach($docs as $doc){$rows[]=[$page,$doc['_id'],$doc['title'],$doc['price']];}}
$checks=['page_one_ids'=>array_column($first,'_id')===[2,3],'page_two_id'=>array_column($second,'_id')===[1],'only_requested_fields'=>array_keys($first[0])===['_id','title','price'],'no_unrelated_or_draft'=>array_column(array_merge($first,$second),'_id')===[2,3,1],'page_bound'=>count($first)<=2&&count($second)<=2];
}finally{
    foreach(array_reverse($owned) as $name){sr129Command($manager,$database,['drop'=>$name],true);}
}
$removed=true;foreach($owned as $name){if(sr129Exists($manager,$database,$name)){$removed=false;}}
$checks['only_owned_collections_removed']=$removed && count($owned)===1;
sr129Report('mongodb129-server-query-page', ['Страница', 'ID', 'Название', 'Цена, условные единицы'], $rows, $checks, $runtime);
echo 'mongodb129-server-query-page: saved result.html and result.json
';

mongodb129-server-query-page: saved result.html and result.json

Реальный запуск в собственной учебной MongoDB-коллекции. Результат показан в HTML и JSON. Helper и README входят в архив; неожиданные отказы не подменяются успешными строками.

<?php
declare(strict_types=1);
require __DIR__.'/sr129-helper.php';
$settings=sr129Settings();$database=$settings['database'];
$manager=new MongoDB\Driver\Manager($settings['uri'],['serverSelectionTimeoutMS'=>1500,'connectTimeoutMS'=>500,'socketTimeoutMS'=>2000,'retryReads'=>false]);
$owned=[];
try{
$version=sr129Command($manager,$database,['buildInfo'=>1])[0]['version'];
if(version_compare($version,'8.0','<')){throw new RuntimeException('MongoDB8.0+ required');}
$server=$manager->selectServer(new MongoDB\Driver\ReadPreference(MongoDB\Driver\ReadPreference::PRIMARY));
if($server->getType()!==MongoDB\Driver\Server::TYPE_STANDALONE){throw new RuntimeException('Separate standalone lab required');}
$runtime=['php'=>PHP_VERSION,'extension'=>phpversion('mongodb'),'server'=>$version,'execution'=>'database','observed_host'=>$server->getHost(),'observed_port'=>$server->getPort()];
$namespace=sr129Create($manager,$database,$owned);$collection=$owned[0];
sr129Insert($manager,$namespace,[['_id'=>1,'sku'=>'MUG','qty'=>5],['_id'=>2,'sku'=>'DRAFT','qty'=>0]]);
$bulk=new MongoDB\Driver\BulkWrite(['ordered'=>true]);
$bulk->update(['_id'=>1,'qty'=>['$gte'=>2]],['$inc'=>['qty'=>-2]],['multi'=>false,'upsert'=>false]);
$bulk->insert(['_id'=>3,'sku'=>'PLATE','qty'=>7]);$bulk->delete(['_id'=>2],['limit'=>1]);
$result=$server->executeBulkWrite($namespace,$bulk,['writeConcern'=>new MongoDB\Driver\WriteConcern(1,3000)]);
$docs=sr129Query($server,$namespace,[],['_id'=>1,'sku'=>1,'qty'=>1],3);
$rows=[];foreach($docs as $doc){$rows[]=[$doc['sku'],$doc['qty']];}
$empty=false;try{$server->executeBulkWrite($namespace,new MongoDB\Driver\BulkWrite);}catch(MongoDB\Driver\Exception\InvalidArgumentException){$empty=true;}
$checks=['one_insert'=>$result->getInsertedCount()===1,'one_update'=>$result->getMatchedCount()===1&&$result->getModifiedCount()===1,'one_delete'=>$result->getDeletedCount()===1,'stock_result'=>array_column($docs,'qty')===[3,7],'deleted_draft'=>array_column($docs,'_id')===[1,3],'empty_batch_rejected'=>$empty];
}finally{
    foreach(array_reverse($owned) as $name){sr129Command($manager,$database,['drop'=>$name],true);}
}
$removed=true;foreach($owned as $name){if(sr129Exists($manager,$database,$name)){$removed=false;}}
$checks['only_owned_collections_removed']=$removed && count($owned)===1;
sr129Report('mongodb129-server-bulk-stock', ['Артикул после пакета', 'Остаток'], $rows, $checks, $runtime);
echo 'mongodb129-server-bulk-stock: saved result.html and result.json
';

mongodb129-server-bulk-stock: saved result.html and result.json

Реальный запуск в собственной учебной MongoDB-коллекции. Результат показан в HTML и JSON. Helper и README входят в архив; неожиданные отказы не подменяются успешными строками.

<?php
declare(strict_types=1);
require __DIR__.'/sr129-helper.php';
$settings=sr129Settings();$database=$settings['database'];
$manager=new MongoDB\Driver\Manager($settings['uri'],['serverSelectionTimeoutMS'=>1500,'connectTimeoutMS'=>500,'socketTimeoutMS'=>2000,'retryReads'=>false]);
$owned=[];
try{
$version=sr129Command($manager,$database,['buildInfo'=>1])[0]['version'];
if(version_compare($version,'8.0','<')){throw new RuntimeException('MongoDB8.0+ required');}
$server=$manager->selectServer(new MongoDB\Driver\ReadPreference(MongoDB\Driver\ReadPreference::PRIMARY));
if($server->getType()!==MongoDB\Driver\Server::TYPE_STANDALONE){throw new RuntimeException('Separate standalone lab required');}
$runtime=['php'=>PHP_VERSION,'extension'=>phpversion('mongodb'),'server'=>$version,'execution'=>'database','observed_host'=>$server->getHost(),'observed_port'=>$server->getPort()];
$namespace=sr129Create($manager,$database,$owned);$collection=$owned[0];
$journalNs=sr129Create($manager,$database,$owned);
$bulk=new MongoDB\Driver\BulkWriteCommand;
$bulk->insertOne($namespace,['_id'=>1,'sku'=>'MUG','qty'=>4]);
$bulk->insertOne($journalNs,['_id'=>1,'event'=>'catalog-import','sku'=>'MUG']);
$result=$server->executeBulkWriteCommand($bulk,['writeConcern'=>new MongoDB\Driver\WriteConcern(1,3000)]);
$product=sr129Query($server,$namespace,['_id'=>1],['_id'=>0,'sku'=>1,'qty'=>1],1)[0];
$entry=sr129Query($server,$journalNs,['_id'=>1],['_id'=>0,'event'=>1,'sku'=>1],1)[0];
$rows=[['Каталог',$product['sku'],'qty='.$product['qty']],['Журнал',$entry['sku'],$entry['event']]];
$checks=['inserted_two'=>$result->getInsertedCount()===2,'two_own_namespaces'=>$namespace!==$journalNs&&count($owned)===2,'catalog_document'=>$product===['sku'=>'MUG','qty'=>4],'journal_document'=>$entry===['event'=>'catalog-import','sku'=>'MUG']];
}finally{
    foreach(array_reverse($owned) as $name){sr129Command($manager,$database,['drop'=>$name],true);}
}
$removed=true;foreach($owned as $name){if(sr129Exists($manager,$database,$name)){$removed=false;}}
$checks['only_owned_collections_removed']=$removed && count($owned)===2;
sr129Report('mongodb129-server-bulk-command', ['Назначение коллекции', 'Артикул', 'Сохранено'], $rows, $checks, $runtime);
echo 'mongodb129-server-bulk-command: saved result.html and result.json
';

mongodb129-server-bulk-command: saved result.html and result.json

Реальный запуск в собственной учебной MongoDB-коллекции. Результат показан в HTML и JSON. Helper и README входят в архив; неожиданные отказы не подменяются успешными строками.

<?php
declare(strict_types=1);
require __DIR__.'/sr129-helper.php';
$settings=sr129Settings();$database=$settings['database'];
$manager=new MongoDB\Driver\Manager($settings['uri'],['serverSelectionTimeoutMS'=>1500,'connectTimeoutMS'=>500,'socketTimeoutMS'=>2000,'retryReads'=>false]);
$owned=[];
try{
$version=sr129Command($manager,$database,['buildInfo'=>1])[0]['version'];
if(version_compare($version,'8.0','<')){throw new RuntimeException('MongoDB8.0+ required');}
$server=$manager->selectServer(new MongoDB\Driver\ReadPreference(MongoDB\Driver\ReadPreference::PRIMARY));
if($server->getType()!==MongoDB\Driver\Server::TYPE_STANDALONE){throw new RuntimeException('Separate standalone lab required');}
$runtime=['php'=>PHP_VERSION,'extension'=>phpversion('mongodb'),'server'=>$version,'execution'=>'database','observed_host'=>$server->getHost(),'observed_port'=>$server->getPort()];
$namespace=sr129Create($manager,$database,$owned);$collection=$owned[0];
sr129Insert($manager,$namespace,[['_id'=>1,'shop'=>'A','status'=>'paid','amount'=>100],['_id'=>2,'shop'=>'A','status'=>'paid','amount'=>250],['_id'=>3,'shop'=>'A','status'=>'draft','amount'=>900],['_id'=>4,'shop'=>'B','status'=>'paid','amount'=>800]]);
$ping=sr129Rows($server->executeCommand($database,new MongoDB\Driver\Command(['ping'=>1])))[0];
$command=new MongoDB\Driver\Command(['aggregate'=>$collection,'pipeline'=>[['$match'=>['shop'=>'A','status'=>'paid']],['$group'=>['_id'=>'$shop','orders'=>['$sum'=>1],'total'=>['$sum'=>'$amount']]],['$limit'=>1]],'cursor'=>['batchSize'=>2],'maxTimeMS'=>1500]);
$report=sr129Rows($server->executeReadCommand($database,$command,['readConcern'=>new MongoDB\Driver\ReadConcern('local')]))[0];
$rows=[['Узел доступен',(bool)$ping['ok']],['Оплаченных заказов магазина A',$report['orders']],['Сумма магазина A',$report['total']]];
$checks=['ping_ok'=>(bool)$ping['ok']===true,'selected_only_shop_a'=>$report['_id']==='A','paid_count'=>$report['orders']===2,'paid_total'=>$report['total']===350,'source_intact'=>count(sr129Query($server,$namespace,[],['_id'=>1],5))===4];
}finally{
    foreach(array_reverse($owned) as $name){sr129Command($manager,$database,['drop'=>$name],true);}
}
$removed=true;foreach($owned as $name){if(sr129Exists($manager,$database,$name)){$removed=false;}}
$checks['only_owned_collections_removed']=$removed && count($owned)===1;
sr129Report('mongodb129-server-read-command', ['Показатель', 'Результат'], $rows, $checks, $runtime);
echo 'mongodb129-server-read-command: saved result.html and result.json
';

mongodb129-server-read-command: saved result.html and result.json

Реальный запуск в собственной учебной MongoDB-коллекции. Результат показан в HTML и JSON. Helper и README входят в архив; неожиданные отказы не подменяются успешными строками.

<?php
declare(strict_types=1);
require __DIR__.'/sr129-helper.php';
$settings=sr129Settings();$database=$settings['database'];
$manager=new MongoDB\Driver\Manager($settings['uri'],['serverSelectionTimeoutMS'=>1500,'connectTimeoutMS'=>500,'socketTimeoutMS'=>2000,'retryReads'=>false]);
$owned=[];
try{
$version=sr129Command($manager,$database,['buildInfo'=>1])[0]['version'];
if(version_compare($version,'8.0','<')){throw new RuntimeException('MongoDB8.0+ required');}
$server=$manager->selectServer(new MongoDB\Driver\ReadPreference(MongoDB\Driver\ReadPreference::PRIMARY));
if($server->getType()!==MongoDB\Driver\Server::TYPE_STANDALONE){throw new RuntimeException('Separate standalone lab required');}
$runtime=['php'=>PHP_VERSION,'extension'=>phpversion('mongodb'),'server'=>$version,'execution'=>'database','observed_host'=>$server->getHost(),'observed_port'=>$server->getPort()];
$namespace=sr129Create($manager,$database,$owned);$collection=$owned[0];
sr129Insert($manager,$namespace,[['_id'=>1,'sku'=>'MUG','qty'=>4],['_id'=>2,'sku'=>'PLATE','qty'=>7]]);
$command=new MongoDB\Driver\Command(['createIndexes'=>$collection,'indexes'=>[['key'=>['sku'=>1],'name'=>'sku_unique','unique'=>true]],'maxTimeMS'=>1500]);
$first=sr129Rows($server->executeWriteCommand($database,$command,['writeConcern'=>new MongoDB\Driver\WriteConcern(1,3000)]))[0];
$second=sr129Rows($server->executeWriteCommand($database,$command,['writeConcern'=>new MongoDB\Driver\WriteConcern(1,3000)]))[0];
$indexes=sr129Rows($server->executeReadCommand($database,new MongoDB\Driver\Command(['listIndexes'=>$collection,'cursor'=>['batchSize'=>10],'maxTimeMS'=>1500])));
$found=null;foreach($indexes as $index){if($index['name']==='sku_unique'){$found=$index;}}
$duplicate=false;$bulk=new MongoDB\Driver\BulkWrite;$bulk->insert(['_id'=>3,'sku'=>'MUG','qty'=>1]);
try{$server->executeBulkWrite($namespace,$bulk);}catch(MongoDB\Driver\Exception\BulkWriteException $error){$duplicate=$error->getCode()===11000;if(!$duplicate){throw $error;}}
$docs=sr129Query($server,$namespace,[],['_id'=>1,'sku'=>1],3);
$rows=[['Индекс',$found['name']],['Правило unique',$found['unique']],['Повтор подготовки успешен',(bool)$second['ok']],['Повторный MUG отклонён',$duplicate],['Товаров осталось',count($docs)]];
$checks=['write_command_ok'=>(bool)$first['ok']===true,'unique_index'=>$found!==null&&$found['key']===['sku'=>1]&&$found['unique']===true,'repeat_is_safe'=>(bool)$second['ok']===true,'duplicate_rejected'=>$duplicate,'catalog_intact'=>array_column($docs,'_id')===[1,2]];
}finally{
    foreach(array_reverse($owned) as $name){sr129Command($manager,$database,['drop'=>$name],true);}
}
$removed=true;foreach($owned as $name){if(sr129Exists($manager,$database,$name)){$removed=false;}}
$checks['only_owned_collections_removed']=$removed && count($owned)===1;
sr129Report('mongodb129-server-write-command', ['Действие', 'Результат'], $rows, $checks, $runtime);
echo 'mongodb129-server-write-command: saved result.html and result.json
';

mongodb129-server-write-command: saved result.html and result.json

Реальный запуск в собственной учебной MongoDB-коллекции. Результат показан в HTML и JSON. Helper и README входят в архив; неожиданные отказы не подменяются успешными строками.

<?php
declare(strict_types=1);
require __DIR__.'/sr129-helper.php';
$settings=sr129Settings();$database=$settings['database'];
$manager=new MongoDB\Driver\Manager($settings['uri'],['serverSelectionTimeoutMS'=>1500,'connectTimeoutMS'=>500,'socketTimeoutMS'=>2000,'retryReads'=>false]);
$owned=[];
try{
$version=sr129Command($manager,$database,['buildInfo'=>1])[0]['version'];
if(version_compare($version,'8.0','<')){throw new RuntimeException('MongoDB8.0+ required');}
$server=$manager->selectServer(new MongoDB\Driver\ReadPreference(MongoDB\Driver\ReadPreference::PRIMARY));
if($server->getType()!==MongoDB\Driver\Server::TYPE_STANDALONE){throw new RuntimeException('Separate standalone lab required');}
$runtime=['php'=>PHP_VERSION,'extension'=>phpversion('mongodb'),'server'=>$version,'execution'=>'database','observed_host'=>$server->getHost(),'observed_port'=>$server->getPort()];
$namespace=sr129Create($manager,$database,$owned);$collection=$owned[0];
$reportNs=sr129Create($manager,$database,$owned);$reportName=$owned[1];
sr129Insert($manager,$namespace,[['_id'=>1,'shop'=>'A','amount'=>100],['_id'=>2,'shop'=>'A','amount'=>250],['_id'=>3,'shop'=>'B','amount'=>800]]);
$command=new MongoDB\Driver\Command(['aggregate'=>$collection,'pipeline'=>[['$match'=>['shop'=>'A']],['$group'=>['_id'=>'$shop','total'=>['$sum'=>'$amount'],'orders'=>['$sum'=>1]]],['$limit'=>1],['$merge'=>['into'=>$reportName,'on'=>'_id','whenMatched'=>'replace','whenNotMatched'=>'insert']]],'cursor'=>['batchSize'=>2],'maxTimeMS'=>1500]);
$firstCursor=sr129Rows($server->executeReadWriteCommand($database,$command,['writeConcern'=>new MongoDB\Driver\WriteConcern(1,3000)]));
$before=sr129Query($server,$reportNs,['_id'=>'A'],['_id'=>1,'total'=>1,'orders'=>1],1)[0];
$bulk=new MongoDB\Driver\BulkWrite;$bulk->update(['_id'=>2],['$set'=>['amount'=>300]],['multi'=>false,'upsert'=>false]);$server->executeBulkWrite($namespace,$bulk);
$nextCursor=sr129Rows($server->executeReadWriteCommand($database,$command,['writeConcern'=>new MongoDB\Driver\WriteConcern(1,3000)]));
$after=sr129Query($server,$reportNs,[],['_id'=>1,'total'=>1,'orders'=>1],2);
$rows=[['Первое сохранение',$before['_id'],$before['orders'],$before['total']],['После изменения исходной суммы',$after[0]['_id'],$after[0]['orders'],$after[0]['total']]];
$checks=['merge_no_document_cursor'=>$firstCursor===[]&&$nextCursor===[],'initial_report'=>$before['total']===350&&$before['orders']===2,'refreshed_report'=>$after[0]['total']===400&&$after[0]['orders']===2,'one_report_not_duplicate'=>count($after)===1&&$after[0]['_id']==='A','only_own_targets'=>count($owned)===2&&$namespace!==$reportNs];
}finally{
    foreach(array_reverse($owned) as $name){sr129Command($manager,$database,['drop'=>$name],true);}
}
$removed=true;foreach($owned as $name){if(sr129Exists($manager,$database,$name)){$removed=false;}}
$checks['only_owned_collections_removed']=$removed && count($owned)===2;
sr129Report('mongodb129-server-readwrite-command', ['Этап', 'Магазин', 'Заказов', 'Сумма'], $rows, $checks, $runtime);
echo 'mongodb129-server-readwrite-command: saved result.html and result.json
';

mongodb129-server-readwrite-command: saved result.html and result.json

Реальный запуск в собственной учебной MongoDB-коллекции. Результат показан в HTML и JSON. Helper и README входят в архив; неожиданные отказы не подменяются успешными строками.

<?php
declare(strict_types=1);
require __DIR__.'/sr129-helper.php';
$settings=sr129Settings();$database=$settings['database'];
$manager=new MongoDB\Driver\Manager($settings['uri'],['serverSelectionTimeoutMS'=>1500,'connectTimeoutMS'=>500,'socketTimeoutMS'=>2000,'retryReads'=>false]);
$owned=[];
try{
$version=sr129Command($manager,$database,['buildInfo'=>1])[0]['version'];
if(version_compare($version,'8.0','<')){throw new RuntimeException('MongoDB8.0+ required');}
$server=$manager->selectServer(new MongoDB\Driver\ReadPreference(MongoDB\Driver\ReadPreference::PRIMARY));
if($server->getType()!==MongoDB\Driver\Server::TYPE_STANDALONE){throw new RuntimeException('Separate standalone lab required');}
$runtime=['php'=>PHP_VERSION,'extension'=>phpversion('mongodb'),'server'=>$version,'execution'=>'database','observed_host'=>$server->getHost(),'observed_port'=>$server->getPort()];
$namespace=sr129Create($manager,$database,$owned);$collection=$owned[0];
sr129Insert($manager,$namespace,[['_id'=>1,'sku'=>'MUG']]);
$default=new MongoDB\Driver\ServerApi(MongoDB\Driver\ServerApi::V1);
$explicit=new MongoDB\Driver\ServerApi(MongoDB\Driver\ServerApi::V1,false,false);
$strict=new MongoDB\Driver\ServerApi(MongoDB\Driver\ServerApi::V1,true,true);
$shapes=[];$rows=[];foreach(['По умолчанию'=>$default,'Явное false'=>$explicit,'Строгий API'=>$strict] as $label=>$api){$object=$api->bsonSerialize();$shapes[$label]=(array)$object;$rows[]=[$label,json_encode($object,JSON_THROW_ON_ERROR)];}
$apiManager=sr129ApiManager($settings,$strict);$apiServer=$apiManager->selectServer(new MongoDB\Driver\ReadPreference(MongoDB\Driver\ReadPreference::PRIMARY));
$docs=sr129Query($apiServer,$namespace,['_id'=>1],['_id'=>0,'sku'=>1],1);$rows[]=['Чтение строгим клиентом',$docs[0]['sku']];
$invalid=false;try{new MongoDB\Driver\ServerApi('2');}catch(MongoDB\Driver\Exception\InvalidArgumentException){$invalid=true;}
$checks=['defaults_omit_null'=>$shapes['По умолчанию']===['version'=>'1'],'false_is_explicit'=>$shapes['Явное false']===['version'=>'1','strict'=>false,'deprecationErrors'=>false],'true_is_explicit'=>$shapes['Строгий API']===['version'=>'1','strict'=>true,'deprecationErrors'=>true],'returns_stdclass'=>$strict->bsonSerialize() instanceof stdClass,'typed_api_reads'=>$docs===[['sku'=>'MUG']],'unknown_version_rejected'=>$invalid];
}finally{
    foreach(array_reverse($owned) as $name){sr129Command($manager,$database,['drop'=>$name],true);}
}
$removed=true;foreach($owned as $name){if(sr129Exists($manager,$database,$name)){$removed=false;}}
$checks['only_owned_collections_removed']=$removed && count($owned)===1;
sr129Report('mongodb129-server-stable-config', ['Настройка / операция', 'Наблюдаемое представление'], $rows, $checks, $runtime);
echo 'mongodb129-server-stable-config: saved result.html and result.json
';

mongodb129-server-stable-config: saved result.html and result.json

Реальный запуск в собственной учебной MongoDB-коллекции. Результат показан в HTML и JSON. Helper и README входят в архив; неожиданные отказы не подменяются успешными строками.

<?php
declare(strict_types=1);
require __DIR__.'/sr129-helper.php';
$settings=sr129Settings();$database=$settings['database'];
$manager=new MongoDB\Driver\Manager($settings['uri'],['serverSelectionTimeoutMS'=>1500,'connectTimeoutMS'=>500,'socketTimeoutMS'=>2000,'retryReads'=>false]);
$owned=[];
try{
$version=sr129Command($manager,$database,['buildInfo'=>1])[0]['version'];
if(version_compare($version,'8.0','<')){throw new RuntimeException('MongoDB8.0+ required');}
$server=$manager->selectServer(new MongoDB\Driver\ReadPreference(MongoDB\Driver\ReadPreference::PRIMARY));
if($server->getType()!==MongoDB\Driver\Server::TYPE_STANDALONE){throw new RuntimeException('Separate standalone lab required');}
$runtime=['php'=>PHP_VERSION,'extension'=>phpversion('mongodb'),'server'=>$version,'execution'=>'database','observed_host'=>$server->getHost(),'observed_port'=>$server->getPort()];
$namespace=sr129Create($manager,$database,$owned);$collection=$owned[0];
sr129Insert($manager,$namespace,[['_id'=>1,'sku'=>'MUG','qty'=>4]]);
$api=new MongoDB\Driver\ServerApi(MongoDB\Driver\ServerApi::V1,true,true);
$apiManager=sr129ApiManager($settings,$api);$apiServer=$apiManager->selectServer(new MongoDB\Driver\ReadPreference(MongoDB\Driver\ReadPreference::PRIMARY));
$product=sr129Query($apiServer,$namespace,['_id'=>1],['_id'=>0,'sku'=>1,'qty'=>1],1)[0];
$count=sr129Rows($apiServer->executeReadCommand($database,new MongoDB\Driver\Command(['count'=>$collection,'query'=>['_id'=>1],'maxTimeMS'=>1500])))[0];
$errorCode=0;try{sr129Rows($apiServer->executeCommand($database,new MongoDB\Driver\Command(['buildInfo'=>1])));}catch(MongoDB\Driver\Exception\CommandException $error){$errorCode=$error->getCode();if($errorCode!==323){throw $error;}}
$normal=sr129Rows($server->executeCommand($database,new MongoDB\Driver\Command(['buildInfo'=>1])))[0];
$after=sr129Query($apiServer,$namespace,['_id'=>1],['_id'=>0,'sku'=>1,'qty'=>1],1)[0];
$rows=[['find через строгий клиент',$product['sku']],['count через строгий клиент',(int)$count['n']],['buildInfo через строгий клиент','APIStrictError '.$errorCode],['buildInfo через обычный клиент',isset($normal['version'])],['Данные после отказа сохранены',$after===$product]];
$checks=['stable_find_succeeds'=>$product===['sku'=>'MUG','qty'=>4],'stable_count_succeeds'=>(int)$count['n']===1,'strict_rejects_outside_api'=>$errorCode===323,'normal_diagnostics_allowed'=>isset($normal['version'])&&$normal['version']===$version,'data_unchanged'=>$after===$product];
}finally{
    foreach(array_reverse($owned) as $name){sr129Command($manager,$database,['drop'=>$name],true);}
}
$removed=true;foreach($owned as $name){if(sr129Exists($manager,$database,$name)){$removed=false;}}
$checks['only_owned_collections_removed']=$removed && count($owned)===1;
sr129Report('mongodb129-server-strict-api', ['Команда / проверка', 'Результат'], $rows, $checks, $runtime);
echo 'mongodb129-server-strict-api: saved result.html and result.json
';

mongodb129-server-strict-api: saved result.html and result.json

Реальный запуск в собственной учебной MongoDB-коллекции. Результат показан в HTML и JSON. Helper и README входят в архив; неожиданные отказы не подменяются успешными строками.