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

<?php
declare(strict_types=1);
require __DIR__.'/recovery-lab.php';
use MongoDB\{Client, Collection};
use MongoDB\Driver\{Manager, Command, Query, ReadPreference, BulkWrite};
use MongoDB\Driver\Exception\{AuthenticationException, ConnectionException, ConnectionTimeoutException, ExecutionTimeoutException, ServerException, BulkWriteCommandException, BulkWriteException};

runRecovery('mongodb134-recovery-no-secondary', 'Отличить недоступный маршрут от пустой карточки', ['Что проверили', 'Наблюдение'],
    function (Client $client, Collection $orders, string $uri, string $dbName, string $name): array {
        $orders->insertOne(['_id'=>'R-101','status'=>'Готов']);
        $manager=freshManager($uri,['serverSelectionTimeoutMS'=>450]);
        try {
            $manager->executeQuery($dbName.'.'.$name,new Query(['_id'=>'R-101'],['limit'=>1]),
                ['readPreference'=>new ReadPreference(ReadPreference::SECONDARY)])->toArray();
            throw new RuntimeException('Expected no eligible secondary');
        } catch (ConnectionTimeoutException $error) {
            $info=diagnostic($error,'Выбор узла для чтения');
            $checks['connection_family']=$error instanceof ConnectionException;
            $checks['not_execution_timeout']=!($error instanceof ExecutionTimeoutException);
        }
        $actual=$orders->findOne(['_id'=>'R-101'],['projection'=>['_id'=>1,'status'=>1]]);
        $checks['status_from_primary']=$actual['status']==='Готов';
        $checks['order_present']=$actual['_id']==='R-101';
        $checks['reported_type']=$info['class']===ConnectionTimeoutException::class;
        return [[['Предписанный маршрут','secondary'],['Выбор узла','Подходящий узел отсутствует'],
                 ['При отдельном чтении с primary',$actual['status']]],$checks,'Карточку R-101 не удалось загрузить с выбранного узла',$info];
    }
);

Карточку R-101 не удалось загрузить с выбранного узла

Программа выполняет реальную операцию на loopback, сопоставляет отказ и наблюдаемое состояние и строит локальный HTML-отчёт.

<?php
declare(strict_types=1);
require __DIR__.'/recovery-lab.php';
use MongoDB\{Client, Collection};
use MongoDB\Driver\{Manager, Command, Query, ReadPreference, BulkWrite};
use MongoDB\Driver\Exception\{AuthenticationException, ConnectionException, ConnectionTimeoutException, ExecutionTimeoutException, ServerException, BulkWriteCommandException, BulkWriteException};

runRecovery('mongodb134-recovery-auth-rejected', 'Отделить вход приложения в базу от состояния заказа', ['Наблюдение', 'Данные'],
    function (Client $client, Collection $orders, string $uri, string $dbName, string $name): array {
        $orders->insertOne(['_id'=>'R-111','status'=>'Черновик']);
        $testManager=freshManager($uri,[
            'authSource'=>$dbName,'username'=>'unregistered_'.bin2hex(random_bytes(16)),
            'password'=>bin2hex(random_bytes(20)), 'serverSelectionTimeoutMS'=>800,
        ]);
        try {
            $testManager->executeWriteCommand($dbName,new Command(['update'=>$name,
                'updates'=>[['q'=>['_id'=>'R-111'],'u'=>['$set'=>['status'=>'Готов']]]]]))->toArray();
            throw new RuntimeException('Expected authentication failure');
        } catch (AuthenticationException $error) {
            $info=diagnostic($error,'Аутентификация приложения');
            $checks['connection_family']=$error instanceof ConnectionException;
            $checks['specific_auth']=$info['class']===AuthenticationException::class;
        }
        $actual=$orders->findOne(['_id'=>'R-111'],['projection'=>['_id'=>1,'status'=>1]]);
        $checks['draft_remains']=$actual['status']==='Черновик';
        $checks['one_order']=$orders->countDocuments([])===1;
        $checks['safe_diagnostic_keys']=array_keys($info)===['class','code','stage'];
        return [[['Запрос клиента','Перевести в готовые'],['После отказа',$actual['status']],
                 ['Следующий шаг','Проверить профиль доступа приложения']],$checks,'Статус R-111 не обновлён',$info];
    }
);

Статус R-111 не обновлён

Программа выполняет реальную операцию на loopback, сопоставляет отказ и наблюдаемое состояние и строит локальный HTML-отчёт.

<?php
declare(strict_types=1);
require __DIR__.'/recovery-lab.php';
use MongoDB\{Client, Collection};
use MongoDB\Driver\{Manager, Command, Query, ReadPreference, BulkWrite};
use MongoDB\Driver\Exception\{AuthenticationException, ConnectionException, ConnectionTimeoutException, ExecutionTimeoutException, ServerException, BulkWriteCommandException, BulkWriteException};

runRecovery('mongodb134-recovery-tls-mismatch', 'Прочитать старый обработчик SSL и распознать современный сбой', ['Наблюдение', 'Результат'],
    function (Client $client, Collection $orders, string $uri, string $dbName, string $name): array {
        $orders->insertOne(['_id'=>'R-121','stage'=>'Ожидает проверки']);
        $tlsClient=freshManager($uri,['tls'=>true,'connectTimeoutMS'=>300,'serverSelectionTimeoutMS'=>500]);
        try {
            $tlsClient->executeCommand($dbName,new Command(['ping'=>1]))->toArray();
            throw new RuntimeException('Expected incompatible TLS endpoint');
        } catch (ConnectionException $error) {
            $info=diagnostic($error,'Соединение с ожидаемым TLS');
            $checks['concrete_timeout']=$error instanceof ConnectionTimeoutException;
            $checks['modern_parent']=$error instanceof ConnectionException;
        }
        $legacy=class_exists('MongoDB\\Driver\\Exception\\SSLConnectionException');
        $actual=$orders->findOne(['_id'=>'R-121'],['projection'=>['_id'=>0,'stage'=>1]]);
        $checks['old_class_absent']=!$legacy;
        $checks['saved_state']=$actual===['stage'=>'Ожидает проверки'];
        $checks['type_recorded']=$info['class']===ConnectionTimeoutException::class;
        return [[['Старый класс в 2.5.5',$legacy],['Обработчик ветви','ConnectionException'],
                 ['Фактическое состояние R-121',$actual['stage']]],$checks,'Канал проверки R-121 недоступен',$info];
    }
);

Канал проверки R-121 недоступен

Программа выполняет реальную операцию на loopback, сопоставляет отказ и наблюдаемое состояние и строит локальный HTML-отчёт.

<?php
declare(strict_types=1);
require __DIR__.'/recovery-lab.php';
use MongoDB\{Client, Collection};
use MongoDB\Driver\{Manager, Command, Query, ReadPreference, BulkWrite};
use MongoDB\Driver\Exception\{AuthenticationException, ConnectionException, ConnectionTimeoutException, ExecutionTimeoutException, ServerException, BulkWriteCommandException, BulkWriteException};

runRecovery('mongodb134-recovery-locked-update', 'Сверить количество после серверного таймаута', ['Момент', 'Количество или код'],
    function (Client $client, Collection $orders, string $uri, string $dbName, string $name): array {
        $orders->insertOne(['_id'=>'R-131','reserved'=>4]);
        $session=$client->startSession();
        try {
            $session->startTransaction();
            try {
                $modified=$orders->updateOne(['_id'=>'R-131'],['$inc'=>['reserved'=>1]],['session'=>$session]);
                $inside=$orders->findOne(['_id'=>'R-131'],['session'=>$session])['reserved'];
                $contender=freshManager($uri,['socketTimeoutMS'=>3500]);
                try {
                    $update=new Command(['update'=>$name,'updates'=>[['q'=>['_id'=>'R-131'],'u'=>['$set'=>['reserved'=>9]]]],'maxTimeMS'=>150]);
                    $contender->executeWriteCommand($dbName,$update)->toArray();
                    throw new RuntimeException('Expected execution timeout');
                } catch (ExecutionTimeoutException $error) {
                    $info=diagnostic($error,'Исполнение update на сервере');
                    $checks['server_limit_50']=$info['code']===50;
                    $checks['server_family']=$error instanceof ServerException;
                }
            } finally {
                $session->abortTransaction();
            }
        } finally {
            $session->endSession();
        }
        $after=$orders->findOne(['_id'=>'R-131'])['reserved'];
        $checks['holder_modified_one']=$modified->getModifiedCount()===1;
        $checks['uncommitted_five']=$inside===5;
        $checks['after_abort_four']=$after===4;
        $checks['not_competing_value']=$after!==9;
        return [[['Начальное значение',4],['В первой транзакции',$inside],['Код конкурирующего update',$info['code']],
                 ['Независимое чтение после abort',$after]],$checks,'Резерв R-131 после проверки · '.$after,$info];
    }
);

Резерв R-131 после проверки · 4

Программа выполняет реальную операцию на loopback, сопоставляет отказ и наблюдаемое состояние и строит локальный HTML-отчёт.

<?php
declare(strict_types=1);
require __DIR__.'/recovery-lab.php';
use MongoDB\{Client, Collection};
use MongoDB\Driver\{Manager, Command, Query, ReadPreference, BulkWrite};
use MongoDB\Driver\Exception\{AuthenticationException, ConnectionException, ConnectionTimeoutException, ExecutionTimeoutException, ServerException, BulkWriteCommandException, BulkWriteException};

runRecovery('mongodb134-recovery-unknown-command', 'Отделить ошибку команды от потери данных', ['Что известно', 'Значение'],
    function (Client $client, Collection $orders, string $uri, string $dbName, string $name): array {
        $orders->insertOne(['_id'=>'R-141','state'=>'Подготовлен']);
        try {
            $client->getManager()->executeReadCommand($dbName,new Command(['manualRecoveryUnknown134'=>1]))->toArray();
            throw new RuntimeException('Expected unknown command');
        } catch (ServerException $error) {
            $info=diagnostic($error,'Проверка команды сервером');
            $checks['actual_command_exception']=$error instanceof MongoDB\Driver\Exception\CommandException;
            $checks['server_code_59']=$info['code']===59;
            $checks['not_connectivity']=!($error instanceof ConnectionException);
        }
        $actual=$orders->findOne(['_id'=>'R-141']);
        $checks['control_state']=$actual['state']==='Подготовлен';
        $checks['one_record']=$orders->countDocuments([])===1;
        return [[['Код ответа',$info['code']],['Состояние после проверки',$actual['state']],
                 ['Дальше','Исправить команду']],$checks,'Проверка не прошла · R-141 остаётся подготовленным',$info];
    }
);

Проверка не прошла · R-141 остаётся подготовленным

Программа выполняет реальную операцию на loopback, сопоставляет отказ и наблюдаемое состояние и строит локальный HTML-отчёт.

<?php
declare(strict_types=1);
require __DIR__.'/recovery-lab.php';
use MongoDB\{Client, Collection};
use MongoDB\Driver\{Manager, Command, Query, ReadPreference, BulkWrite};
use MongoDB\Driver\Exception\{AuthenticationException, ConnectionException, ConnectionTimeoutException, ExecutionTimeoutException, ServerException, BulkWriteCommandException, BulkWriteException};

runRecovery('mongodb134-recovery-ordered-import', 'Узнать судьбу каждой строки прерванного импорта', ['Номер', 'После чтения', 'Решение'],
    function (Client $client, Collection $orders, string $uri, string $dbName, string $name): array {
        $orders->insertOne(['_id'=>'R-302','item'=>'Штатив']);
        $input=[['_id'=>'R-301','item'=>'Лампа'],['_id'=>'R-302','item'=>'Кабель'],['_id'=>'R-303','item'=>'Чехол']];
        $error=packetFailure($client->getManager(),$dbName.'.'.$name,$input,true);
        $info=diagnostic($error,'Упорядоченная пакетная запись');
        $partial=$error->getPartialResult();
        $writeErrors=$error->getWriteErrors();
        if ($partial===null || !isset($writeErrors[1])) { throw new UnexpectedValueException('Unexpected partial receipt'); }
        $rows=[];
        foreach ($input as $position=>$expected) {
            $saved=$orders->findOne(['_id'=>$expected['_id']],['projection'=>['_id'=>1,'item'=>1]]);
            $action=match(true) {
                isset($writeErrors[$position]) => 'Разобрать конфликт',
                $saved===null => 'К отдельной отправке',
                $saved['item']===$expected['item'] => 'Уже сохранён',
                default => 'Разобрать расхождение',
            };
            $rows[]=[$expected['_id'],$saved['item']??'Нет записи',$action];
        }
        $checks['one_confirmed_insert']=$partial->getInsertedCount()===1;
        $checks['duplicate_index_one']=array_keys($writeErrors)===[1] && $writeErrors[1]->getCode()===11000;
        $checks['no_concern_errors']=$error->getWriteConcernErrors()===[];
        $checks['only_item_error']=$error->getErrorReply()===null;
        $checks['requested_content_preserved']=$rows[0][1]==='Лампа' && $rows[1][1]==='Штатив';
        $checks['remaining_absent']=$rows[2][1]==='Нет записи';
        $checks['actual_count_two']=$orders->countDocuments([])===2;
        return [$rows,$checks,'Импорт остановлен на R-302 · сохранён R-301, R-303 ожидает решения',$info];
    }
);

Импорт остановлен на R-302 · сохранён R-301, R-303 ожидает решения

Программа выполняет реальную операцию на loopback, сопоставляет отказ и наблюдаемое состояние и строит локальный HTML-отчёт.

<?php
declare(strict_types=1);
require __DIR__.'/recovery-lab.php';
use MongoDB\{Client, Collection};
use MongoDB\Driver\{Manager, Command, Query, ReadPreference, BulkWrite};
use MongoDB\Driver\Exception\{AuthenticationException, ConnectionException, ConnectionTimeoutException, ExecutionTimeoutException, ServerException, BulkWriteCommandException, BulkWriteException};

runRecovery('mongodb134-recovery-unordered-import', 'Сверить независимые позиции после ошибки в середине', ['Номер', 'Ответ операции', 'Сверка с базой'],
    function (Client $client, Collection $orders, string $uri, string $dbName, string $name): array {
        $orders->insertOne(['_id'=>'R-312','item'=>'Кабель','operation'=>'pack-312']);
        $input=[['_id'=>'R-311','item'=>'Чехол','operation'=>'pack-311'],['_id'=>'R-312','item'=>'Кабель','operation'=>'pack-312'],
                ['_id'=>'R-313','item'=>'Лампа','operation'=>'pack-313']];
        $error=packetFailure($client->getManager(),$dbName.'.'.$name,$input,false);
        $info=diagnostic($error,'Неупорядоченная пакетная запись');
        $partial=$error->getPartialResult();
        $errors=$error->getWriteErrors();
        if ($partial===null || !isset($errors[1])) { throw new UnexpectedValueException('Missing unordered receipt'); }
        $rows=[];
        foreach ($input as $i=>$original) {
            $saved=$orders->findOne(['_id'=>$original['_id']]);
            $same=$saved!==null && $saved['operation']===$original['operation'] && $saved['item']===$original['item'];
            $rows[]=[$original['_id'],isset($errors[$i])?'Дубликат':'Вставлен',$same?'Намерение подтверждено':'Нужен разбор'];
        }
        $checks['two_confirmed']=$partial->getInsertedCount()===2;
        $checks['item_duplicate']=array_keys($errors)===[1] && $errors[1]->getCode()===11000;
        $checks['final_three']=$orders->countDocuments([])===3;
        $checks['last_executed']=$rows[2][1]==='Вставлен';
        $checks['intent_matched']=array_column($rows,2)===array_fill(0,3,'Намерение подтверждено');
        return [$rows,$checks,'Все три намерения найдены · новых вставок '.$partial->getInsertedCount(),$info];
    }
);

Все три намерения найдены · новых вставок 2

Программа выполняет реальную операцию на loopback, сопоставляет отказ и наблюдаемое состояние и строит локальный HTML-отчёт.

<?php
declare(strict_types=1);
require __DIR__.'/recovery-lab.php';
use MongoDB\{Client, Collection};
use MongoDB\Driver\{Manager, Command, Query, ReadPreference, BulkWrite};
use MongoDB\Driver\Exception\{AuthenticationException, ConnectionException, ConnectionTimeoutException, ExecutionTimeoutException, ServerException, BulkWriteCommandException, BulkWriteException};

runRecovery('mongodb134-recovery-legacy-write', 'Обновить обработчик ошибки старого одиночного пакета', ['Наблюдение', 'Результат'],
    function (Client $client, Collection $orders, string $uri, string $dbName, string $name): array {
        $orders->insertOne(['_id'=>'R-321','amount'=>1400]);
        $bulk=new BulkWrite();
        $bulk->insert(['_id'=>'R-321','amount'=>1800]);
        try {
            $client->getManager()->executeBulkWrite($dbName.'.'.$name,$bulk);
            throw new RuntimeException('Expected a duplicate write');
        } catch (BulkWriteException $error) {
            $info=diagnostic($error,'Запись через executeBulkWrite');
            $result=$error->getWriteResult();
            $errors=$result->getWriteErrors();
            $checks['modern_server_branch']=$error instanceof ServerException;
            $checks['one_duplicate']=count($errors)===1 && $errors[0]->getCode()===11000;
            $checks['no_new_insert']=$result->getInsertedCount()===0;
        }
        $legacy=class_exists('MongoDB\\Driver\\Exception\\WriteException');
        $saved=$orders->findOne(['_id'=>'R-321']);
        $checks['removed_name_absent']=!$legacy;
        $checks['previous_amount']=$saved['amount']===1400;
        $checks['one_order']=$orders->countDocuments([])===1;
        return [[['Старый класс доступен',$legacy],['Код ошибки строки',$errors[0]->getCode()],['Фактическая сумма, ₽',$saved['amount']]],
                $checks,'Сумма R-321 сохранилась прежней · '.$saved['amount'].' ₽',$info];
    }
);

Сумма R-321 сохранилась прежней · 1400 ₽

Программа выполняет реальную операцию на loopback, сопоставляет отказ и наблюдаемое состояние и строит локальный HTML-отчёт.