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

<?php
declare(strict_types=1);
require __DIR__.'/mi116-helper.php';
[$manager, $database] = mi116Environment();
$server = mi116Command($manager, $database, ['buildInfo' => 1])[0]['version'];
$runtime = ['php' => PHP_VERSION, 'extension' => phpversion('mongodb'), 'server' => $server];
$collection = 'mongodb116_index_' . bin2hex(random_bytes(8));
$namespace = $database . '.' . $collection;
$owned = false; $details = [];
try {
    if (mi116Exists($manager, $database, $collection)) { throw new RuntimeException('Fixture already exists'); }
    mi116Command($manager, $database, ['create' => $collection], true);
    $owned = true;
$documents = [];
    for ($i = 1; $i <= 120; $i++) {
        $documents[] = ['_id' => $i, 'tenant' => $i <= 80 ? 'A' : 'B',
            'status' => $i % 3 === 0 ? 'draft' : 'active',
            'title' => 'Товар ' . $i, 'price' => 100 + ($i % 10) * 50];
    }
    mi116Insert($manager, $namespace, $documents);
    $index = ['name' => 'catalog_screen', 'key' => ['tenant' => 1, 'status' => 1, 'price' => 1, '_id' => 1]];
    $createCursor = $manager->executeWriteCommand($database, new MongoDB\Driver\Command([
        'createIndexes' => $collection, 'indexes' => [$index], 'maxTimeMS' => 2000,
    ]));
    $createCursor->setTypeMap(['root' => 'array', 'document' => 'array', 'array' => 'array']);
    $created = $createCursor->toArray()[0];
    $filter = ['tenant' => 'A', 'status' => 'active', 'price' => ['$gte' => 200]];
    $options = ['projection' => ['_id' => 1, 'title' => 1, 'price' => 1],
        'sort' => ['price' => 1, '_id' => 1], 'limit' => 4];
    $products = mi116Read($manager, $namespace, $filter, $options);
    $hintedProducts = mi116Read($manager, $namespace, $filter, $options + ['hint' => 'catalog_screen']);
    $find = ['find' => $collection, 'filter' => $filter, 'projection' => $options['projection'],
        'sort' => $options['sort'], 'limit' => 4, 'maxTimeMS' => 1000];
    $naturalPlan = mi116Command($manager, $database, ['explain' => $find, 'verbosity' => 'executionStats'])[0];
    $hintedPlan = mi116Command($manager, $database, ['explain' => $find + ['hint' => 'catalog_screen'], 'verbosity' => 'executionStats'])[0];
    $rows = array_map(fn($d) => [$d['_id'], $d['title'], $d['price']], $products);
    $checks = ['screen_rows' => $rows === [[2,'Товар 2',200],[22,'Товар 22',200],[32,'Товар 32',200],[52,'Товар 52',200]],
        'same_rows_with_hint' => $products === $hintedProducts,
        'index_created' => (int)$created['numIndexesBefore'] === 1 && (int)$created['numIndexesAfter'] === 2,
        'hinted_index_applicable' => mi116PlanContains($hintedPlan['queryPlanner'], 'indexName', 'catalog_screen'),
        'both_plans_return_four' => $naturalPlan['executionStats']['nReturned'] === 4 && $hintedPlan['executionStats']['nReturned'] === 4];
    $details = ['Создание индекса' => $created, 'Обычный выбор оптимизатора' => $naturalPlan,
        'Проверка заданного индекса через hint' => $hintedPlan,
        'Что измерено' => ['fixture_documents' => 120, 'performance_claim' => false, 'screen_limit' => 4]];
} finally {
    if ($owned) { mi116Command($manager, $database, ['drop' => $collection], true); }
}
$checks['owned_collection_removed'] = !mi116Exists($manager, $database, $collection);
$details = mi116Public($details, $collection, $database);
mi116Report('mongodb116-index-compound-screen', ['ID', 'Товар', 'Цена, руб.'], $rows, $checks, $runtime, $details);
echo 'mongodb116-index-compound-screen: saved result.html and result.json
';

mongodb116-index-compound-screen: saved result.html and result.json

Запустите php example.php из распакованного каталога и откройте result.html. Архив содержит исходные данные, mi116-helper.php и README.txt. result.json повторяет итоговую таблицу; metrics.json хранит проверки и диагностику.

<?php
declare(strict_types=1);
require __DIR__.'/mi116-helper.php';
[$manager, $database] = mi116Environment();
$server = mi116Command($manager, $database, ['buildInfo' => 1])[0]['version'];
$runtime = ['php' => PHP_VERSION, 'extension' => phpversion('mongodb'), 'server' => $server];
$collection = 'mongodb116_index_' . bin2hex(random_bytes(8));
$namespace = $database . '.' . $collection;
$owned = false; $details = [];
try {
    if (mi116Exists($manager, $database, $collection)) { throw new RuntimeException('Fixture already exists'); }
    mi116Command($manager, $database, ['create' => $collection], true);
    $owned = true;
mi116Command($manager, $database, ['createIndexes' => $collection, 'indexes' => [[
        'name' => 'tenant_sku_unique', 'key' => ['tenant' => 1, 'sku' => 1], 'unique' => true,
    ]]], true);
    mi116Insert($manager, $namespace, [
        ['_id' => 101, 'tenant' => 'A', 'sku' => 'LAMP', 'title' => 'Лампа A'],
        ['_id' => 102, 'tenant' => 'B', 'sku' => 'LAMP', 'title' => 'Лампа B'],
        ['_id' => 103, 'tenant' => 'A', 'sku' => 'CUP', 'title' => 'Кружка'],
    ]);
    $duplicate = false; $errorCode = null;
    try {
        mi116Insert($manager, $namespace, [['_id' => 104, 'tenant' => 'A', 'sku' => 'LAMP', 'title' => 'Повтор']]);
    } catch (MongoDB\Driver\Exception\BulkWriteException $error) {
        if ($error->getCode() !== 11000) { throw $error; }
        $duplicate = true; $errorCode = $error->getCode();
    }
    $saved = mi116Read($manager, $namespace, [], ['sort' => ['_id' => 1], 'limit' => 10]);
    $rows = array_map(fn($d) => [$d['_id'], $d['tenant'], $d['sku'], $d['title']], $saved);
    $checks = ['duplicate_11000' => $duplicate && $errorCode === 11000,
        'same_sku_different_tenants' => array_column($saved, '_id') === [101,102,103],
        'original_not_replaced' => $saved[0]['title'] === 'Лампа A',
        'unique_spec_saved' => mi116PlanContains(mi116Command($manager, $database, ['listIndexes' => $collection]), 'unique', true)];
    $details = ['Отказ повторной записи' => ['attempt_id' => 104, 'tenant' => 'A', 'sku' => 'LAMP', 'code' => $errorCode, 'inserted' => false],
        'Сохранённые документы' => $saved];
} finally {
    if ($owned) { mi116Command($manager, $database, ['drop' => $collection], true); }
}
$checks['owned_collection_removed'] = !mi116Exists($manager, $database, $collection);
$details = mi116Public($details, $collection, $database);
mi116Report('mongodb116-index-tenant-unique', ['ID', 'Магазин', 'Артикул', 'Название'], $rows, $checks, $runtime, $details);
echo 'mongodb116-index-tenant-unique: saved result.html and result.json
';

mongodb116-index-tenant-unique: saved result.html and result.json

Запустите php example.php из распакованного каталога и откройте result.html. Архив содержит исходные данные, mi116-helper.php и README.txt. result.json повторяет итоговую таблицу; metrics.json хранит проверки и диагностику.

<?php
declare(strict_types=1);
require __DIR__.'/mi116-helper.php';
[$manager, $database] = mi116Environment();
$server = mi116Command($manager, $database, ['buildInfo' => 1])[0]['version'];
$runtime = ['php' => PHP_VERSION, 'extension' => phpversion('mongodb'), 'server' => $server];
$collection = 'mongodb116_index_' . bin2hex(random_bytes(8));
$namespace = $database . '.' . $collection;
$owned = false; $details = [];
try {
    if (mi116Exists($manager, $database, $collection)) { throw new RuntimeException('Fixture already exists'); }
    mi116Command($manager, $database, ['create' => $collection], true);
    $owned = true;
mi116Insert($manager, $namespace, [
        ['_id' => 11, 'title' => 'Кружка A', 'variants' => [['color' => 'red', 'stock' => 0], ['color' => 'blue', 'stock' => 4]]],
        ['_id' => 12, 'title' => 'Кружка B', 'variants' => [['color' => 'red', 'stock' => 5], ['color' => 'blue', 'stock' => 0]]],
        ['_id' => 13, 'title' => 'Кружка C', 'variants' => [['color' => 'blue', 'stock' => 7]]],
    ]);
    mi116Command($manager, $database, ['createIndexes' => $collection, 'indexes' => [[
        'name' => 'variant_stock', 'key' => ['variants.color' => 1, 'variants.stock' => 1],
    ]]], true);
    $options = ['projection' => ['_id' => 1, 'title' => 1], 'sort' => ['_id' => 1], 'limit' => 10];
    $separate = mi116Read($manager, $namespace, ['variants.color' => 'red', 'variants.stock' => ['$gt' => 0]], $options);
    $filter = ['variants' => ['$elemMatch' => ['color' => 'red', 'stock' => ['$gt' => 0]]]];
    $same = mi116Read($manager, $namespace, $filter, $options);
    $hinted = mi116Read($manager, $namespace, $filter, $options + ['hint' => 'variant_stock']);
    $plan = mi116Command($manager, $database, ['explain' => ['find' => $collection, 'filter' => $filter,
        'hint' => 'variant_stock', 'limit' => 10, 'maxTimeMS' => 1000], 'verbosity' => 'executionStats'])[0];
    $rows = [['Раздельные условия', implode(', ', array_column($separate, '_id'))],
        ['Один элемент через $elemMatch', implode(', ', array_column($same, '_id'))],
        ['Название подходящего товара', $same[0]['title']]];
    $checks = ['separate_conditions_include_false_positive' => array_column($separate, '_id') === [11,12],
        'same_variant_only' => array_column($same, '_id') === [12], 'hint_preserves_semantics' => $same === $hinted,
        'index_is_multikey' => mi116PlanContains($plan['queryPlanner'], 'isMultiKey', true),
        'one_matched_document' => $plan['executionStats']['nReturned'] === 1];
    $details = ['Документы с вариантами' => mi116Read($manager, $namespace, [], ['sort' => ['_id' => 1], 'limit' => 10]),
        'План заданного multikey-индекса' => $plan];
} finally {
    if ($owned) { mi116Command($manager, $database, ['drop' => $collection], true); }
}
$checks['owned_collection_removed'] = !mi116Exists($manager, $database, $collection);
$details = mi116Public($details, $collection, $database);
mi116Report('mongodb116-index-same-variant', ['Условие', 'Фактический результат'], $rows, $checks, $runtime, $details);
echo 'mongodb116-index-same-variant: saved result.html and result.json
';

mongodb116-index-same-variant: saved result.html and result.json

Запустите php example.php из распакованного каталога и откройте result.html. Архив содержит исходные данные, mi116-helper.php и README.txt. result.json повторяет итоговую таблицу; metrics.json хранит проверки и диагностику.

<?php
declare(strict_types=1);
require __DIR__.'/mi116-helper.php';
[$manager, $database] = mi116Environment();
$server = mi116Command($manager, $database, ['buildInfo' => 1])[0]['version'];
$runtime = ['php' => PHP_VERSION, 'extension' => phpversion('mongodb'), 'server' => $server];
$collection = 'mongodb116_index_' . bin2hex(random_bytes(8));
$namespace = $database . '.' . $collection;
$owned = false; $details = [];
try {
    if (mi116Exists($manager, $database, $collection)) { throw new RuntimeException('Fixture already exists'); }
    mi116Command($manager, $database, ['create' => $collection], true);
    $owned = true;
mi116Command($manager, $database, ['createIndexes' => $collection, 'indexes' => [[
        'name' => 'active_sku_unique', 'key' => ['tenant' => 1, 'sku' => 1],
        'unique' => true, 'partialFilterExpression' => ['status' => 'active'],
    ]]], true);
    mi116Insert($manager, $namespace, [
        ['_id' => 201, 'tenant' => 'A', 'sku' => 'LAMP', 'status' => 'active'],
        ['_id' => 202, 'tenant' => 'A', 'sku' => 'LAMP', 'status' => 'archived'],
        ['_id' => 203, 'tenant' => 'A', 'sku' => 'LAMP', 'status' => 'draft'],
        ['_id' => 204, 'tenant' => 'B', 'sku' => 'LAMP', 'status' => 'active'],
    ]);
    $duplicate = false;
    try {
        $activation = new MongoDB\Driver\BulkWrite;
        $activation->update(['_id' => 203], ['$set' => ['status' => 'active']], ['multi' => false]);
        $manager->executeBulkWrite($namespace, $activation);
    } catch (MongoDB\Driver\Exception\BulkWriteException $error) {
        if ($error->getCode() !== 11000) { throw $error; }
        $duplicate = true;
    }
    $archived = mi116Insert($manager, $namespace, [['_id' => 205, 'tenant' => 'A', 'sku' => 'LAMP', 'status' => 'archived']]);
    $saved = mi116Read($manager, $namespace, [], ['sort' => ['_id' => 1], 'limit' => 10]);
    $active = mi116Read($manager, $namespace, ['status' => 'active'], ['projection' => ['_id' => 1], 'sort' => ['_id' => 1], 'limit' => 10]);
    $rows = array_map(fn($d) => [$d['_id'], $d['tenant'], $d['sku'], $d['status']], $saved);
    $checks = ['activation_rejected_11000' => $duplicate, 'failed_document_still_draft' => $saved[2]['status'] === 'draft',
        'archive_duplicate_accepted' => $archived->getInsertedCount() === 1 && count($saved) === 5,
        'active_ids_preserved' => array_column($active, '_id') === [201,204],
        'partial_spec_saved' => mi116PlanContains(mi116Command($manager, $database, ['listIndexes' => $collection]), 'partialFilterExpression', ['status' => ['$eq' => 'active']])
            || mi116PlanContains(mi116Command($manager, $database, ['listIndexes' => $collection]), 'partialFilterExpression', ['status' => 'active'])];
    $details = ['Попытка активации' => ['id' => 203, 'error_code' => 11000, 'status_after_error' => $saved[2]['status']],
        'Активные ID' => array_column($active, '_id'), 'Архивная вставка' => $archived->getInsertedCount()];
} finally {
    if ($owned) { mi116Command($manager, $database, ['drop' => $collection], true); }
}
$checks['owned_collection_removed'] = !mi116Exists($manager, $database, $collection);
$details = mi116Public($details, $collection, $database);
mi116Report('mongodb116-index-partial-active', ['ID', 'Магазин', 'Артикул', 'Статус'], $rows, $checks, $runtime, $details);
echo 'mongodb116-index-partial-active: saved result.html and result.json
';

mongodb116-index-partial-active: saved result.html and result.json

Запустите php example.php из распакованного каталога и откройте result.html. Архив содержит исходные данные, mi116-helper.php и README.txt. result.json повторяет итоговую таблицу; metrics.json хранит проверки и диагностику.

<?php
declare(strict_types=1);
require __DIR__.'/mi116-helper.php';
[$manager, $database] = mi116Environment();
$server = mi116Command($manager, $database, ['buildInfo' => 1])[0]['version'];
$runtime = ['php' => PHP_VERSION, 'extension' => phpversion('mongodb'), 'server' => $server];
$collection = 'mongodb116_index_' . bin2hex(random_bytes(8));
$namespace = $database . '.' . $collection;
$owned = false; $details = [];
try {
    if (mi116Exists($manager, $database, $collection)) { throw new RuntimeException('Fixture already exists'); }
    mi116Command($manager, $database, ['create' => $collection], true);
    $owned = true;
mi116Insert($manager, $namespace, [
        ['_id'=>11,'title'=>'Чашка A','price'=>100,'status'=>'active'],
        ['_id'=>12,'title'=>'Чашка B','price'=>100,'status'=>'active'],
        ['_id'=>21,'title'=>'Блюдце A','price'=>150,'status'=>'active'],
        ['_id'=>22,'title'=>'Блюдце B','price'=>150,'status'=>'active'],
        ['_id'=>23,'title'=>'Блюдце C','price'=>150,'status'=>'active'],
        ['_id'=>31,'title'=>'Тарелка','price'=>220,'status'=>'active'],
        ['_id'=>99,'title'=>'Черновик','price'=>50,'status'=>'draft'],
    ]);
    mi116Command($manager, $database, ['createIndexes'=>$collection, 'indexes'=>[[
        'name'=>'page_price_id', 'key'=>['status'=>1,'price'=>1,'_id'=>1],
    ]]], true);
    $last = null; $rows = []; $seen = []; $pageSizes = []; $emptyEnd = false;
    for ($page = 1; $page <= 10; $page++) {
        $filter = ['status'=>'active'];
        if ($last !== null) {
            $filter['$or'] = [
                ['price'=>['$gt'=>$last['price']]],
                ['price'=>$last['price'], '_id'=>['$gt'=>$last['_id']]],
            ];
        }
        $products = mi116Read($manager, $namespace, $filter, [
            'projection'=>['_id'=>1,'title'=>1,'price'=>1], 'sort'=>['price'=>1,'_id'=>1], 'limit'=>2,
        ]);
        if ($products === []) { $emptyEnd = true; break; }
        $pageSizes[] = count($products);
        foreach ($products as $product) {
            $rows[] = [$page,$product['_id'],$product['title'],$product['price']];
            $seen[] = $product['_id'];
        }
        $last = $products[array_key_last($products)];
    }
    $priceOnly = mi116Read($manager, $namespace, ['status'=>'active','price'=>['$gt'=>150]], [
        'projection'=>['_id'=>1], 'sort'=>['price'=>1,'_id'=>1], 'limit'=>2,
    ]);
    $checks = ['no_missing_ids' => $seen === [11,12,21,22,23,31],
        'no_duplicate_ids' => count($seen) === count(array_unique($seen)),
        'bounded_pages' => $pageSizes === [2,2,2] && $emptyEnd,
        'tie_continues_on_page_three' => $rows[4] === [3,23,'Блюдце C',150],
        'price_only_loses_tied_item' => array_column($priceOnly, '_id') === [31]];
    $details = ['Курсор после второй страницы' => ['price'=>150,'_id'=>22],
        'Следующий правильный экран' => array_slice($rows,4),
        'Неполный фильтр price > 150' => ['returned_ids'=>array_column($priceOnly,'_id'),'missing_id'=>23],
        'Конец списка' => ['empty_page'=>$page,'page_sizes'=>$pageSizes,'dataset_changed_during_run'=>false]];
} finally {
    if ($owned) { mi116Command($manager, $database, ['drop' => $collection], true); }
}
$checks['owned_collection_removed'] = !mi116Exists($manager, $database, $collection);
$details = mi116Public($details, $collection, $database);
mi116Report('mongodb116-index-keyset-pages', ['Страница', 'ID', 'Товар', 'Цена, руб.'], $rows, $checks, $runtime, $details);
echo 'mongodb116-index-keyset-pages: saved result.html and result.json
';

mongodb116-index-keyset-pages: saved result.html and result.json

Запустите php example.php из распакованного каталога и откройте result.html. Архив содержит исходные данные, mi116-helper.php и README.txt. result.json повторяет итоговую таблицу; metrics.json хранит проверки и диагностику.

<?php
declare(strict_types=1);
require __DIR__.'/mi116-helper.php';
[$manager, $database] = mi116Environment();
$server = mi116Command($manager, $database, ['buildInfo' => 1])[0]['version'];
$runtime = ['php' => PHP_VERSION, 'extension' => phpversion('mongodb'), 'server' => $server];
$collection = 'mongodb116_index_' . bin2hex(random_bytes(8));
$namespace = $database . '.' . $collection;
$owned = false; $details = [];
try {
    if (mi116Exists($manager, $database, $collection)) { throw new RuntimeException('Fixture already exists'); }
    mi116Command($manager, $database, ['create' => $collection], true);
    $owned = true;
mi116Insert($manager, $namespace, [['_id'=>301,'title'=>'Кружка','price'=>500],
        ['_id'=>302,'title'=>'Лампа','price'=>900],['_id'=>303,'title'=>'Блюдце','price'=>250]]);
    mi116Command($manager, $database, ['createIndexes'=>$collection, 'indexes'=>[
        ['name'=>'catalog_price','key'=>['price'=>1]], ['name'=>'catalog_title','key'=>['title'=>1]],
    ]], true);
    $readIndexes = function() use ($manager, $database, $collection): array {
        $cursor = $manager->executeReadCommand($database, new MongoDB\Driver\Command([
            'listIndexes'=>$collection, 'cursor'=>['batchSize'=>1],
        ]));
        $cursor->setTypeMap(['root'=>'array','document'=>'array','array'=>'array']);
        $indexes = []; $positions = [];
        $cursor->rewind();
        while ($cursor->valid()) {
            $positions[] = $cursor->key();
            $index = $cursor->current();
            $indexes[$index['name']] = $index['key'];
            $cursor->next();
        }
        ksort($indexes);
        return [$indexes, $positions];
    };
    $beforeDocuments = mi116Read($manager, $namespace, [], ['sort'=>['_id'=>1],'limit'=>10]);
    [$beforeIndexes, $beforePositions] = $readIndexes();
    $dropCursor = $manager->executeWriteCommand($database, new MongoDB\Driver\Command([
        'dropIndexes'=>$collection, 'index'=>'catalog_title',
    ]));
    $dropCursor->setTypeMap(['root'=>'array','document'=>'array','array'=>'array']);
    $dropped = $dropCursor->toArray()[0];
    [$afterIndexes, $afterPositions] = $readIndexes();
    $afterDocuments = mi116Read($manager, $namespace, [], ['sort'=>['_id'=>1],'limit'=>10]);
    $rows = [];
    foreach (['До удаления'=>$beforeIndexes,'После удаления'=>$afterIndexes] as $stage=>$indexes) {
        foreach ($indexes as $name=>$key) {
            $rows[] = [$stage,$name,json_encode($key, JSON_THROW_ON_ERROR)];
        }
    }
    $checks = ['three_indexes_before' => array_keys($beforeIndexes) === ['_id_','catalog_price','catalog_title'],
        'only_named_index_removed' => array_keys($afterIndexes) === ['_id_','catalog_price'],
        'documents_unchanged' => $beforeDocuments === $afterDocuments && count($afterDocuments) === 3,
        'cursor_positions' => $beforePositions === [0,1,2] && $afterPositions === [0,1],
        'drop_acknowledged' => (float)$dropped['ok'] === 1.0];
    $details = ['Ответ dropIndexes' => $dropped, 'Документы после удаления индекса' => $afterDocuments,
        'Позиции курсора до и после' => [$beforePositions,$afterPositions], 'batchSize' => 1];
} finally {
    if ($owned) { mi116Command($manager, $database, ['drop' => $collection], true); }
}
$checks['owned_collection_removed'] = !mi116Exists($manager, $database, $collection);
$details = mi116Public($details, $collection, $database);
mi116Report('mongodb116-index-index-lifecycle', ['Этап', 'Имя индекса', 'Ключ'], $rows, $checks, $runtime, $details);
echo 'mongodb116-index-index-lifecycle: saved result.html and result.json
';

mongodb116-index-index-lifecycle: saved result.html and result.json

Запустите php example.php из распакованного каталога и откройте result.html. Архив содержит исходные данные, mi116-helper.php и README.txt. result.json повторяет итоговую таблицу; metrics.json хранит проверки и диагностику.