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

<?php
declare(strict_types=1);
require __DIR__.'/ma117-helper.php';
[$manager, $database] = ma117Environment();
$server = ma117Command($manager, $database, ['buildInfo' => 1])[0]['version'];
$runtime = ['php' => PHP_VERSION, 'extension' => phpversion('mongodb'), 'server' => $server];
$collection = 'mongodb117_atomic_' . bin2hex(random_bytes(8));
$namespace = $database . '.' . $collection;
$owned = false; $details = [];
try {
    if (ma117Exists($manager, $database, $collection)) { throw new RuntimeException('Fixture already exists'); }
    $createOptions = [
        'validator' => ['$jsonSchema' => [
            'bsonType' => 'object', 'required' => ['sku', 'title', 'stock'],
            'additionalProperties' => false,
            'properties' => [
                '_id' => ['bsonType' => ['int', 'long']],
                'sku' => ['bsonType' => 'string', 'minLength' => 1],
                'title' => ['bsonType' => 'string', 'minLength' => 1],
                'stock' => ['bsonType' => ['int', 'long'], 'minimum' => 0],
            ],
        ]], 'validationLevel' => 'strict', 'validationAction' => 'error',
    ];
    ma117Command($manager, $database, ['create' => $collection] + $createOptions, true);
    $owned = true;
$input = [
        ['_id' => 101, 'sku' => 'CUP', 'title' => 'Кружка', 'stock' => 4],
        ['_id' => 102, 'sku' => 'LAMP', 'title' => 'Лампа', 'stock' => '4'],
        ['_id' => 103, 'sku' => 'PLATE', 'title' => 'Тарелка', 'stock' => 1, 'discount' => 10],
    ];
    $bulk = new MongoDB\Driver\BulkWrite(['ordered' => false]);
    foreach ($input as $document) { $bulk->insert($document); }
    $caught = false;
    try { $result = $manager->executeBulkWrite($namespace, $bulk); }
    catch (MongoDB\Driver\Exception\BulkWriteException $error) {
        $result = $error->getWriteResult(); $caught = true;
        if ($result->getWriteConcernError() !== null || $result->getWriteErrors() === []) { throw $error; }
        foreach ($result->getWriteErrors() as $writeError) {
            if ($writeError->getCode() !== 121) { throw $error; }
        }
    }
    $errorsByInput = []; $diagnostics = [];
    foreach ($result->getWriteErrors() as $writeError) {
        $position = $writeError->getIndex();
        $errorsByInput[$position] = $writeError->getCode();
        $diagnostics[] = ['position' => $position, 'sku' => $input[$position]['sku'],
            'code' => $writeError->getCode(), 'message' => $writeError->getMessage(),
            'info' => $writeError->getInfo()];
    }
    ksort($errorsByInput);
    $saved = ma117Read($manager, $namespace, [], ['sort' => ['_id' => 1], 'limit' => 10]);
    $rows = [];
    foreach ($input as $position => $document) {
        $rows[] = [$position, $document['sku'], isset($errorsByInput[$position]) ? 'отклонено' : 'сохранено', $errorsByInput[$position] ?? null];
    }
    $checks = ['expected_validation_errors' => $caught && $errorsByInput === [1 => 121, 2 => 121],
        'one_insert_confirmed' => $result->isAcknowledged() && $result->getInsertedCount() === 1,
        'only_valid_document_saved' => $saved === [$input[0]],
        'diagnostics_present' => count($diagnostics) === 2 && $diagnostics[0]['message'] !== '' && $diagnostics[1]['message'] !== ''];
    $details = ['Входные документы: число и строка различаются' => $input,
        'Серверные причины двух отказов' => $diagnostics, 'Сохранённый документ' => $saved];
} finally {
    if ($owned) { ma117Command($manager, $database, ['drop' => $collection], true); }
}
$checks['owned_collection_removed'] = !ma117Exists($manager, $database, $collection);
$details = ma117Public($details, $collection, $database);
ma117Report('mongodb117-atomic-validation', ['Позиция операции', 'SKU', 'Результат', 'Код ошибки'], $rows, $checks, $runtime, $details);
echo 'mongodb117-atomic-validation: saved result.html and result.json
';

mongodb117-atomic-validation: saved result.html and result.json

Запустите php example.php и откройте result.html. result.json повторяет таблицу; metrics.json хранит проверки, версии, ответы команд и диагностику. Все файлы для локального сценария и точная инструкция включены в архив.

<?php
declare(strict_types=1);
require __DIR__.'/ma117-helper.php';
[$manager, $database] = ma117Environment();
$server = ma117Command($manager, $database, ['buildInfo' => 1])[0]['version'];
$runtime = ['php' => PHP_VERSION, 'extension' => phpversion('mongodb'), 'server' => $server];
$collection = 'mongodb117_atomic_' . bin2hex(random_bytes(8));
$namespace = $database . '.' . $collection;
$owned = false; $details = [];
try {
    if (ma117Exists($manager, $database, $collection)) { throw new RuntimeException('Fixture already exists'); }
    $createOptions = [];
    ma117Command($manager, $database, ['create' => $collection] + $createOptions, true);
    $owned = true;
ma117Insert($manager, $namespace, [['_id' => 201, 'sku' => 'CUP', 'available' => 5, 'reserved' => 0]]);
    $requests = [['name' => 'Q1', 'quantity' => 3], ['name' => 'Q2', 'quantity' => 3]];
    $rows = []; $allAcknowledged = true; $noUpserts = true; $snapshots = [];
    foreach ($requests as $request) {
        $qty = $request['quantity'];
        if (!is_int($qty) || $qty <= 0) { throw new InvalidArgumentException('Positive integer quantity required'); }
        $bulk = new MongoDB\Driver\BulkWrite();
        $bulk->update(['_id' => 201, 'available' => ['$gte' => $qty]],
            ['$inc' => ['available' => -$qty, 'reserved' => $qty]], ['multi' => false, 'upsert' => false]);
        $result = $manager->executeBulkWrite($namespace, $bulk);
        $allAcknowledged = $allAcknowledged && $result->isAcknowledged();
        $noUpserts = $noUpserts && $result->getUpsertedCount() === 0 && $result->getUpsertedIds() === [];
        $after = ma117Read($manager, $namespace, ['_id' => 201], ['limit' => 1])[0];
        $rows[] = [$request['name'], $qty, $result->getMatchedCount(), $result->getModifiedCount(), $after['available'], $after['reserved']];
        $snapshots[] = $after;
    }
    $checks = ['conditional_results' => $rows === [['Q1',3,1,1,2,3],['Q2',3,0,0,2,3]],
        'all_writes_acknowledged' => $allAcknowledged,
        'reserve_never_creates_product' => $noUpserts,
        'second_request_unchanged' => $snapshots[0] === $snapshots[1],
        'stock_conserved_nonnegative' => $snapshots[1]['available'] >= 0 && $snapshots[1]['available'] + $snapshots[1]['reserved'] === 5];
    $details = ['Начальный остаток' => ['available' => 5, 'reserved' => 0], 'После каждого запроса' => $snapshots,
        'Границы проверки' => ['requests_are_sequential' => true, 'concurrency_load_test' => false, 'http_idempotency_implemented' => false]];
} finally {
    if ($owned) { ma117Command($manager, $database, ['drop' => $collection], true); }
}
$checks['owned_collection_removed'] = !ma117Exists($manager, $database, $collection);
$details = ma117Public($details, $collection, $database);
ma117Report('mongodb117-atomic-reserve-stock', ['Запрос', 'Количество', 'Matched', 'Modified', 'Доступно', 'Резерв'], $rows, $checks, $runtime, $details);
echo 'mongodb117-atomic-reserve-stock: saved result.html and result.json
';

mongodb117-atomic-reserve-stock: saved result.html and result.json

Запустите php example.php и откройте result.html. result.json повторяет таблицу; metrics.json хранит проверки, версии, ответы команд и диагностику. Все файлы для локального сценария и точная инструкция включены в архив.

<?php
declare(strict_types=1);
require __DIR__.'/ma117-helper.php';
[$manager, $database] = ma117Environment();
$server = ma117Command($manager, $database, ['buildInfo' => 1])[0]['version'];
$runtime = ['php' => PHP_VERSION, 'extension' => phpversion('mongodb'), 'server' => $server];
$collection = 'mongodb117_atomic_' . bin2hex(random_bytes(8));
$namespace = $database . '.' . $collection;
$owned = false; $details = [];
try {
    if (ma117Exists($manager, $database, $collection)) { throw new RuntimeException('Fixture already exists'); }
    $createOptions = [];
    ma117Command($manager, $database, ['create' => $collection] + $createOptions, true);
    $owned = true;
ma117Insert($manager, $namespace, [['_id' => 301, 'title' => 'Синяя кружка', 'price' => 500, 'version' => 7]]);
    $forms = [
        ['name' => 'A', 'expectedVersion' => 7, 'changes' => ['price' => 550]],
        ['name' => 'B', 'expectedVersion' => 7, 'changes' => ['title' => 'Красная кружка']],
    ];
    $rows = []; $replies = []; $snapshots = [];
    foreach ($forms as $form) {
        $command = new MongoDB\Driver\Command([
            'findAndModify' => $collection,
            'query' => ['_id' => 301, 'version' => $form['expectedVersion']],
            'update' => ['$set' => $form['changes'], '$inc' => ['version' => 1]],
            'new' => true, 'upsert' => false, 'maxTimeMS' => 1000,
            'fields' => ['_id' => 1, 'title' => 1, 'price' => 1, 'version' => 1],
        ]);
        $cursor = $manager->executeReadWriteCommand($database, $command);
        $cursor->setTypeMap(['root' => 'array', 'document' => 'array', 'array' => 'array']);
        $reply = $cursor->toArray()[0]; $replies[] = $reply;
        $after = ma117Read($manager, $namespace, ['_id' => 301], ['limit' => 1])[0]; $snapshots[] = $after;
        $rows[] = [$form['name'], $form['expectedVersion'], (int)$reply['lastErrorObject']['n'], $after['price'], $after['title'], $after['version']];
    }
    $checks = ['first_form_saved' => $replies[0]['value']['price'] === 550 && $replies[0]['value']['version'] === 8,
        'stale_form_no_match' => $replies[1]['value'] === null && (int)$replies[1]['lastErrorObject']['n'] === 0,
        'stale_form_did_not_overwrite' => $snapshots[0] === $snapshots[1] && $snapshots[1]['title'] === 'Синяя кружка',
        'both_commands_successful' => (float)$replies[0]['ok'] === 1.0 && (float)$replies[1]['ok'] === 1.0];
    $details = ['Две формы читали версию 7' => $forms, 'Ответы findAndModify' => $replies, 'Состояние после каждого сохранения' => $snapshots];
} finally {
    if ($owned) { ma117Command($manager, $database, ['drop' => $collection], true); }
}
$checks['owned_collection_removed'] = !ma117Exists($manager, $database, $collection);
$details = ma117Public($details, $collection, $database);
ma117Report('mongodb117-atomic-optimistic-version', ['Форма', 'Ожидаемая версия', 'Изменено', 'Цена, руб.', 'Название', 'Текущая версия'], $rows, $checks, $runtime, $details);
echo 'mongodb117-atomic-optimistic-version: saved result.html and result.json
';

mongodb117-atomic-optimistic-version: saved result.html and result.json

Запустите php example.php и откройте result.html. result.json повторяет таблицу; metrics.json хранит проверки, версии, ответы команд и диагностику. Все файлы для локального сценария и точная инструкция включены в архив.

<?php
declare(strict_types=1);
require __DIR__.'/ma117-helper.php';
[$manager, $database] = ma117Environment();
$server = ma117Command($manager, $database, ['buildInfo' => 1])[0]['version'];
$runtime = ['php' => PHP_VERSION, 'extension' => phpversion('mongodb'), 'server' => $server];
$collection = 'mongodb117_atomic_' . bin2hex(random_bytes(8));
$namespace = $database . '.' . $collection;
$owned = false; $details = [];
try {
    if (ma117Exists($manager, $database, $collection)) { throw new RuntimeException('Fixture already exists'); }
    $createOptions = [];
    ma117Command($manager, $database, ['create' => $collection] + $createOptions, true);
    $owned = true;
ma117Command($manager, $database, ['createIndexes' => $collection, 'indexes' => [[
        'name' => 'supplier_sku_unique', 'key' => ['supplier' => 1, 'sku' => 1], 'unique' => true,
    ]]], true);
    $first = new MongoDB\Driver\BulkWrite();
    $first->update(['supplier' => 'S1', 'sku' => 'CUP'],
        ['$set' => ['title' => 'Кружка', 'price' => 500], '$setOnInsert' => ['_id' => 401, 'createdTag' => 'first']], ['upsert' => true, 'multi' => false]);
    $r1 = $manager->executeBulkWrite($namespace, $first);
    $mixed = new MongoDB\Driver\BulkWrite();
    $mixed->update(['supplier' => 'S1', 'sku' => 'CUP'],
        ['$set' => ['title' => 'Кружка', 'price' => 550], '$setOnInsert' => ['_id' => 401, 'createdTag' => 'second']], ['upsert' => true, 'multi' => false]);
    $mixed->update(['supplier' => 'S1', 'sku' => 'LAMP'],
        ['$set' => ['title' => 'Лампа', 'price' => 900], '$setOnInsert' => ['_id' => 402, 'createdTag' => 'initial']], ['upsert' => true, 'multi' => false]);
    $r2 = $manager->executeBulkWrite($namespace, $mixed);
    $repeat = new MongoDB\Driver\BulkWrite();
    $repeat->update(['supplier' => 'S1', 'sku' => 'CUP'],
        ['$set' => ['title' => 'Кружка', 'price' => 550]], ['upsert' => true, 'multi' => false]);
    $r3 = $manager->executeBulkWrite($namespace, $repeat);
    $rows = [];
    foreach ([['Первый импорт', $r1], ['Смешанный пакет', $r2], ['Повтор без изменений', $r3]] as [$label, $result]) {
        $idLabels = [];
        foreach ($result->getUpsertedIds() as $operationIndex => $id) { $idLabels[] = $operationIndex . ' → ' . $id; }
        $rows[] = [$label, $result->getMatchedCount(), $result->getModifiedCount(), $result->getUpsertedCount(), implode(', ', $idLabels) ?: 'нет'];
    }
    $saved = ma117Read($manager, $namespace, [], ['sort' => ['_id' => 1], 'limit' => 10]);
    $checks = ['first_upsert_id' => $r1->getUpsertedCount() === 1 && $r1->getUpsertedIds() === [0 => 401],
        'mixed_keeps_operation_index' => $r2->getUpsertedIds() === [1 => 402] && $r2->getMatchedCount() === 1 && $r2->getModifiedCount() === 1,
        'repeat_is_not_new_insert' => $r3->getUpsertedCount() === 0 && $r3->getUpsertedIds() === [] && $r3->getMatchedCount() === 1 && $r3->getModifiedCount() === 0,
        'creation_fields_preserved' => count($saved) === 2 && $saved[0]['_id'] === 401 && $saved[0]['price'] === 550 && $saved[0]['createdTag'] === 'first' && $saved[1]['_id'] === 402 && $saved[1]['price'] === 900,
        'all_acknowledged' => $r1->isAcknowledged() && $r2->isAcknowledged() && $r3->isAcknowledged()];
    $details = ['Соответствие операции новому ID' => ['first' => $r1->getUpsertedIds(), 'mixed' => $r2->getUpsertedIds(), 'repeat' => $r3->getUpsertedIds()],
        'Итоговые товары' => $saved, 'Различие счётчиков' => ['first_inserted_count' => $r1->getInsertedCount(), 'first_upserted_count' => $r1->getUpsertedCount()]];
} finally {
    if ($owned) { ma117Command($manager, $database, ['drop' => $collection], true); }
}
$checks['owned_collection_removed'] = !ma117Exists($manager, $database, $collection);
$details = ma117Public($details, $collection, $database);
ma117Report('mongodb117-atomic-upsert-result', ['Запуск', 'Matched', 'Modified', 'Upserted', 'Позиция → новый ID'], $rows, $checks, $runtime, $details);
echo 'mongodb117-atomic-upsert-result: saved result.html and result.json
';

mongodb117-atomic-upsert-result: saved result.html and result.json

Запустите php example.php и откройте result.html. result.json повторяет таблицу; metrics.json хранит проверки, версии, ответы команд и диагностику. Все файлы для локального сценария и точная инструкция включены в архив.

<?php
declare(strict_types=1);
require __DIR__.'/ma117-helper.php';
[$manager, $database] = ma117Environment();
$server = ma117Command($manager, $database, ['buildInfo' => 1])[0]['version'];
$runtime = ['php' => PHP_VERSION, 'extension' => phpversion('mongodb'), 'server' => $server];
$collection = 'mongodb117_atomic_' . bin2hex(random_bytes(8));
$namespace = $database . '.' . $collection;
$owned = false; $details = [];
try {
    if (ma117Exists($manager, $database, $collection)) { throw new RuntimeException('Fixture already exists'); }
    $createOptions = [];
    ma117Command($manager, $database, ['create' => $collection] + $createOptions, true);
    $owned = true;
ma117Command($manager, $database, ['createIndexes' => $collection, 'indexes' => [[
        'name' => 'batch_sku_unique', 'key' => ['batch' => 1, 'sku' => 1], 'unique' => true,
    ]]], true);
    $rows = []; $details = []; $results = [];
    foreach ([['ordered', true, 500], ['unordered', false, 600]] as [$mode, $ordered, $base]) {
        ma117Insert($manager, $namespace, [['_id' => $base, 'batch' => $mode, 'sku' => 'BUSY']]);
        $input = [
            ['_id' => $base + 1, 'batch' => $mode, 'sku' => 'A'],
            ['_id' => $base + 2, 'batch' => $mode, 'sku' => 'BUSY'],
            ['_id' => $base + 3, 'batch' => $mode, 'sku' => 'B'],
            ['_id' => $base + 4, 'batch' => $mode, 'sku' => 'BUSY'],
        ];
        $bulk = new MongoDB\Driver\BulkWrite(['ordered' => $ordered]);
        foreach ($input as $document) { $bulk->insert($document); }
        $caught = false;
        try { $result = $manager->executeBulkWrite($namespace, $bulk); }
        catch (MongoDB\Driver\Exception\BulkWriteException $error) {
            $result = $error->getWriteResult(); $caught = true;
            if ($result->getWriteConcernError() !== null || $result->getWriteErrors() === []) { throw $error; }
            foreach ($result->getWriteErrors() as $writeError) { if ($writeError->getCode() !== 11000) { throw $error; } }
        }
        $positions = []; $errors = [];
        foreach ($result->getWriteErrors() as $writeError) {
            $position = $writeError->getIndex(); $positions[] = $position;
            $errors[] = ['operation_index' => $position, 'input' => $input[$position],
                'code' => $writeError->getCode(), 'message' => $writeError->getMessage(), 'info' => $writeError->getInfo()];
        }
        sort($positions);
        $saved = ma117Read($manager, $namespace, ['batch' => $mode], ['sort' => ['sku' => 1], 'limit' => 10]);
        $skus = array_column($saved, 'sku');
        $rows[] = [$mode, $result->getInsertedCount(), implode(', ', $positions), implode(', ', $skus), $result->isAcknowledged() ? 'да' : 'нет'];
        $results[$mode] = ['caught' => $caught, 'positions' => $positions, 'saved' => $skus, 'ack' => $result->isAcknowledged()];
        $details[$mode] = ['input' => $input, 'errors' => $errors, 'saved' => $saved,
            'not_attempted_indices' => $ordered ? [2,3] : []];
    }
    $checks = ['ordered_stops_after_first_error' => $results['ordered']['caught'] && $results['ordered']['positions'] === [1] && $results['ordered']['saved'] === ['A','BUSY'],
        'unordered_reports_both_errors' => $results['unordered']['caught'] && $results['unordered']['positions'] === [1,3] && $results['unordered']['saved'] === ['A','B','BUSY'],
        'confirmed_partial_success' => $results['ordered']['ack'] && $results['unordered']['ack'] && $rows[0][1] === 1 && $rows[1][1] === 2,
        'all_originals_still_exist' => count(ma117Read($manager, $namespace, ['_id' => ['$in' => [500,600]]], ['limit' => 2])) === 2];
} finally {
    if ($owned) { ma117Command($manager, $database, ['drop' => $collection], true); }
}
$checks['owned_collection_removed'] = !ma117Exists($manager, $database, $collection);
$details = ma117Public($details, $collection, $database);
ma117Report('mongodb117-atomic-partial-bulk', ['Режим', 'Новых документов', 'Ошибочные позиции', 'Сохранённые SKU', 'Acknowledged'], $rows, $checks, $runtime, $details);
echo 'mongodb117-atomic-partial-bulk: saved result.html and result.json
';

mongodb117-atomic-partial-bulk: saved result.html and result.json

Запустите php example.php и откройте result.html. result.json повторяет таблицу; metrics.json хранит проверки, версии, ответы команд и диагностику. Все файлы для локального сценария и точная инструкция включены в архив.

<?php
declare(strict_types=1);
require __DIR__.'/ma117-helper.php';
[$manager, $database] = ma117Environment();
$server = ma117Command($manager, $database, ['buildInfo' => 1])[0]['version'];
$runtime = ['php' => PHP_VERSION, 'extension' => phpversion('mongodb'), 'server' => $server];
$collection = 'mongodb117_atomic_' . bin2hex(random_bytes(8));
$namespace = $database . '.' . $collection;
$owned = false; $details = [];
try {
    if (ma117Exists($manager, $database, $collection)) { throw new RuntimeException('Fixture already exists'); }
    $createOptions = [];
    ma117Command($manager, $database, ['create' => $collection] + $createOptions, true);
    $owned = true;
ma117Insert($manager, $namespace, [['_id' => 701, 'title' => 'Лампа', 'available' => 4, 'reserved' => 0]]);
    $rows = []; $replies = [];
    foreach ([2,3] as $qty) {
        $command = new MongoDB\Driver\Command([
            'findAndModify' => $collection, 'query' => ['_id' => 701, 'available' => ['$gte' => $qty]],
            'update' => ['$inc' => ['available' => -$qty, 'reserved' => $qty]],
            'new' => true, 'upsert' => false, 'maxTimeMS' => 1000,
            'fields' => ['_id' => 1, 'title' => 1, 'available' => 1, 'reserved' => 1],
        ]);
        $cursor = $manager->executeReadWriteCommand($database, $command);
        $cursor->setTypeMap(['root' => 'array', 'document' => 'array', 'array' => 'array']);
        $reply = $cursor->toArray()[0]; $replies[] = $reply;
        $value = $reply['value'];
        $rows[] = [$qty, $value === null ? 'нет подходящего документа' : 'резерв создан', $value['available'] ?? null, $value['reserved'] ?? null];
    }
    $after = ma117Read($manager, $namespace, ['_id' => 701], ['limit' => 1])[0];
    $checks = ['new_value_returned' => $replies[0]['value']['available'] === 2 && $replies[0]['value']['reserved'] === 2 && (int)$replies[0]['lastErrorObject']['n'] === 1,
        'no_match_returns_null' => $replies[1]['value'] === null && (int)$replies[1]['lastErrorObject']['n'] === 0,
        'successful_command_not_business_success' => (float)$replies[1]['ok'] === 1.0,
        'failed_condition_did_not_change_stock' => $after['available'] === 2 && $after['reserved'] === 2];
    $details = ['Ответы команды: value, lastErrorObject, ok' => $replies, 'Итоговый документ' => $after];
} finally {
    if ($owned) { ma117Command($manager, $database, ['drop' => $collection], true); }
}
$checks['owned_collection_removed'] = !ma117Exists($manager, $database, $collection);
$details = ma117Public($details, $collection, $database);
ma117Report('mongodb117-atomic-find-and-modify', ['Запрошено', 'Результат', 'Доступно в value', 'Резерв в value'], $rows, $checks, $runtime, $details);
echo 'mongodb117-atomic-find-and-modify: saved result.html and result.json
';

mongodb117-atomic-find-and-modify: saved result.html and result.json

Запустите php example.php и откройте result.html. result.json повторяет таблицу; metrics.json хранит проверки, версии, ответы команд и диагностику. Все файлы для локального сценария и точная инструкция включены в архив.