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

<?php
declare(strict_types=1);
require __DIR__.'/policy-lab.php';
use MongoDB\Driver\{Manager, ReadConcern, ReadPreference, WriteConcern, Server};
use MongoDB\Driver\Exception\{ConnectionTimeoutException, InvalidArgumentException};

runLesson('mongodb130-policy-visibility-document', ['Настройка', 'Описание в JSON', 'Версия материала'], function (Manager $manager, string $namespace): array {
    insertDocuments($manager, $namespace, [['_id' => 'notice', 'edition' => 7, 'internalNote' => 'draft']]);
    $inherited = new ReadConcern();
    $explicit = new ReadConcern(ReadConcern::LOCAL);
    $rows = [];
    foreach (['По умолчанию' => $inherited, 'Явно задано' => $explicit] as $label => $policy) {
        $description = $policy->bsonSerialize();
        [$docs] = readPage($manager, $namespace, ['_id' => 'notice'], ['_id' => 0, 'edition' => 1], $policy);
        $rows[] = [$label, json_encode($description, JSON_THROW_ON_ERROR), $docs[0]['edition']];
        $checks['only_public_field'] = ($checks['only_public_field'] ?? true) && array_keys($docs[0]) === ['edition'];
    }
    $checks['default_has_no_level'] = !property_exists($inherited->bsonSerialize(), 'level');
    $checks['default_is_object'] = $inherited->bsonSerialize() instanceof stdClass;
    $checks['explicit_local'] = $explicit->bsonSerialize()->level === 'local';
    $checks['both_edition_seven'] = array_column($rows, 2) === [7, 7];
    return [$rows, $checks, ['default_level' => $inherited->getLevel(), 'explicit_level' => $explicit->getLevel()]];
});
echo 'mongodb130-policy-visibility-document' . ": OK\n";

mongodb130-policy-visibility-document: OK

Запускайте example.php из распакованного архива с policy-lab.php. Фактическую таблицу программа сохраняет в result.html и result.json.

<?php
declare(strict_types=1);
require __DIR__.'/policy-lab.php';
use MongoDB\Driver\{Manager, ReadConcern, ReadPreference, WriteConcern, Server};
use MongoDB\Driver\Exception\{ConnectionTimeoutException, InvalidArgumentException};

runLesson('mongodb130-policy-committed-feed', ['Выпуск', 'Версия', 'Уровень чтения'], function (Manager $manager, string $namespace): array {
    $write = new WriteConcern(WriteConcern::MAJORITY, 2000);
    $receipt = insertDocuments($manager, $namespace, [
        ['_id' => 'issue-41', 'state' => 'published', 'edition' => 3],
        ['_id' => 'issue-42', 'state' => 'draft', 'edition' => 8],
        ['_id' => 'issue-43', 'state' => 'published', 'edition' => 1],
    ], $write);
    $read = new ReadConcern(ReadConcern::MAJORITY);
    [$docs, $server] = readPage($manager, $namespace, ['state' => 'published'], ['_id' => 1, 'edition' => 1], $read);
    $rows = [];
    foreach ($docs as $doc) {
        $rows[] = [$doc['_id'], $doc['edition'], $read->bsonSerialize()->level];
    }
    $checks['three_written'] = $receipt->getInsertedCount() === 3;
    $checks['write_w_majority'] = $write->bsonSerialize()->w === 'majority';
    $checks['published_only'] = array_column($docs, '_id') === ['issue-41', 'issue-43'];
    $checks['projected_fields'] = !array_key_exists('state', $docs[0]);
    $checks['editions'] = array_column($docs, 'edition') === [3, 1];
    return [$rows, $checks, ['acknowledged' => $receipt->isAcknowledged(), 'read_options' => $read->bsonSerialize(), 'primary' => $server->getType() === Server::TYPE_RS_PRIMARY]];
});
echo 'mongodb130-policy-committed-feed' . ": OK\n";

mongodb130-policy-committed-feed: OK

Запускайте example.php из распакованного архива с policy-lab.php. Фактическую таблицу программа сохраняет в result.html и result.json.

<?php
declare(strict_types=1);
require __DIR__.'/policy-lab.php';
use MongoDB\Driver\{Manager, ReadConcern, ReadPreference, WriteConcern, Server};
use MongoDB\Driver\Exception\{ConnectionTimeoutException, InvalidArgumentException};

runLesson('mongodb130-policy-single-record', ['Ключ', 'Редакция', 'Уровень'], function (Manager $manager, string $namespace): array {
    $receipt = insertDocuments($manager, $namespace, [
        ['_id' => 'active-release', 'revision' => 18, 'recipientList' => 'private'],
    ], new WriteConcern('majority', 2000));
    $visibility = new ReadConcern(ReadConcern::LINEARIZABLE);
    $route = new ReadPreference(ReadPreference::PRIMARY);
    [$docs, $server] = readPage($manager, $namespace, ['_id' => 'active-release'], ['_id' => 0, 'revision' => 1], $visibility, $route);
    $checks['one_insert'] = $receipt->getInsertedCount() === 1;
    $checks['one_record'] = count($docs) === 1;
    $checks['selected_primary'] = $server->getType() === Server::TYPE_RS_PRIMARY;
    $checks['level'] = $visibility->bsonSerialize()->level === 'linearizable';
    $checks['only_revision'] = $docs === [['revision' => 18]];
    return [[['active-release', $docs[0]['revision'], $visibility->getLevel()]], $checks, [
        'maxTimeMS' => 2000, 'requested_route' => $route->bsonSerialize(), 'acknowledged_writes' => $receipt->getInsertedCount(),
    ]];
});
echo 'mongodb130-policy-single-record' . ": OK\n";

mongodb130-policy-single-record: OK

Запускайте example.php из распакованного архива с policy-lab.php. Фактическую таблицу программа сохраняет в result.html и result.json.

<?php
declare(strict_types=1);
require __DIR__.'/policy-lab.php';
use MongoDB\Driver\{Manager, ReadConcern, ReadPreference, WriteConcern, Server};
use MongoDB\Driver\Exception\{ConnectionTimeoutException, InvalidArgumentException};

runLesson('mongodb130-policy-preferred-route', ['Запрошено', 'Ответил', 'На странице'], function (Manager $manager, string $namespace): array {
    insertDocuments($manager, $namespace, [['_id' => 'press', 'headline' => 'Итоги недели', 'privateMemo' => 99]]);
    $route = new ReadPreference(ReadPreference::SECONDARY_PREFERRED);
    [$docs, $server] = readPage($manager, $namespace, ['_id' => 'press'], ['_id' => 0, 'headline' => 1], null, $route);
    $isPrimary = $server->getType() === Server::TYPE_RS_PRIMARY;
    $checks['preferred_mode'] = $route->getModeString() === 'secondaryPreferred';
    $checks['serialized_mode'] = $route->bsonSerialize()->mode === $route->getModeString();
    $checks['fallback_primary'] = $isPrimary;
    $checks['exact_card'] = $docs === [['headline' => 'Итоги недели']];
    $checks['no_route_tags'] = $route->getTagSets() === [];
    return [[[$route->getModeString(), $isPrimary ? 'primary' : 'other', $docs[0]['headline']]], $checks,
        ['requested' => $route->bsonSerialize(), 'served_by' => $server->getHost(), 'type' => $server->getType()]];
});
echo 'mongodb130-policy-preferred-route' . ": OK\n";

mongodb130-policy-preferred-route: OK

Запускайте example.php из распакованного архива с policy-lab.php. Фактическую таблицу программа сохраняет в result.html и result.json.

<?php
declare(strict_types=1);
require __DIR__.'/policy-lab.php';
use MongoDB\Driver\{Manager, ReadConcern, ReadPreference, WriteConcern, Server};
use MongoDB\Driver\Exception\{ConnectionTimeoutException, InvalidArgumentException};

runLesson('mongodb130-policy-region-fallback', ['Правило', 'Исход запроса', 'Записей в выпуске'], function (Manager $manager, string $namespace): array {
    insertDocuments($manager, $namespace, [['_id' => 'east-news', 'items' => 12]]);
    $strict = new ReadPreference('nearest', [['dc' => 'east']]);
    $withFallback = new ReadPreference('nearest', [['dc' => 'east'], []]);
    $selectionFailed = false;
    try {
        readPage($manager, $namespace, ['_id' => 'east-news'], ['items' => 1], null, $strict);
    } catch (ConnectionTimeoutException $error) {
        $selectionFailed = true;
    }
    [$docs, $server] = readPage($manager, $namespace, ['_id' => 'east-news'], ['_id' => 0, 'items' => 1], null, $withFallback);
    $tags = $withFallback->bsonSerialize()->tags;
    $checks['strict_tag_unavailable'] = $selectionFailed;
    $checks['two_tag_documents'] = count($tags) === 2 && $tags[1] instanceof stdClass;
    $checks['first_tag_east'] = $tags[0]->dc === 'east';
    $checks['last_tag_any'] = get_object_vars($tags[1]) === [];
    $checks['secondary_not_required'] = $server->getType() === Server::TYPE_RS_PRIMARY;
    $checks['read_count'] = $docs === [['items' => 12]];
    return [[['Только east', $selectionFailed ? 'нет подходящего узла' : 'ответ', null],
             ['east, затем любой', 'ответ', $docs[0]['items']]], $checks, ['requested' => $withFallback->bsonSerialize()]];
});
echo 'mongodb130-policy-region-fallback' . ": OK\n";

mongodb130-policy-region-fallback: OK

Запускайте example.php из распакованного архива с policy-lab.php. Фактическую таблицу программа сохраняет в result.html и result.json.

<?php
declare(strict_types=1);
require __DIR__.'/policy-lab.php';
use MongoDB\Driver\{Manager, ReadConcern, ReadPreference, WriteConcern, Server};
use MongoDB\Driver\Exception\{ConnectionTimeoutException, InvalidArgumentException};

runLesson('mongodb130-policy-write-profile', ['Материал', 'w', 'j', 'wtimeout, мс', 'Вставлено'], function (Manager $manager, string $namespace): array {
    $policies = [
        'Черновик' => new WriteConcern(1),
        'Выпуск' => new WriteConcern(WriteConcern::MAJORITY, 2500, true),
    ];
    $rows = [];
    $profiles = [];
    foreach ($policies as $kind => $policy) {
        $document = $policy->bsonSerialize();
        $receipt = insertDocuments($manager, $namespace, [['_id' => $kind, 'stage' => $kind]], $policy);
        $profiles[$kind] = $document;
        $rows[] = [$kind, $document->w, $document->j ?? null, $document->wtimeout ?? null, $receipt->getInsertedCount()];
        $checks['both_acknowledged'] = ($checks['both_acknowledged'] ?? true) && $receipt->isAcknowledged();
    }
    [$persisted] = readPage($manager, $namespace, [], ['_id' => 0, 'stage' => 1], new ReadConcern('majority'));
    $checks['two_stored'] = count($persisted) === 2;
    $checks['draft_fields'] = array_keys(get_object_vars($profiles['Черновик'])) === ['w'];
    $checks['release_journal'] = $profiles['Выпуск']->j === true;
    $checks['release_wait'] = $profiles['Выпуск']->wtimeout === 2500;
    $checks['release_majority'] = $profiles['Выпуск']->w === 'majority';
    return [$rows, $checks, ['requested' => $profiles, 'stored_stages' => array_column($persisted, 'stage')]];
});
echo 'mongodb130-policy-write-profile' . ": OK\n";

mongodb130-policy-write-profile: OK

Запускайте example.php из распакованного архива с policy-lab.php. Фактическую таблицу программа сохраняет в result.html и result.json.

<?php
declare(strict_types=1);
require __DIR__.'/policy-lab.php';
use MongoDB\Driver\{Manager, ReadConcern, ReadPreference, WriteConcern, Server};
use MongoDB\Driver\Exception\{ConnectionTimeoutException, InvalidArgumentException};

runLesson('mongodb130-policy-legacy-mode', ['Старое число', 'Решение', 'Версия прочитанной страницы'], function (Manager $manager, string $namespace): array {
    insertDocuments($manager, $namespace, [
        ['_id' => 'route-cache', 'oldMode' => 6],
        ['_id' => 'route-unknown', 'oldMode' => 77],
        ['_id' => 'daily-page', 'edition' => 4],
    ]);
    [$settings] = readPage($manager, $namespace, ['oldMode' => ['$exists' => true]], ['_id' => 1, 'oldMode' => 1]);
    $oldModes = [1 => 'primary', 5 => 'primaryPreferred', 2 => 'secondary', 6 => 'secondaryPreferred', 10 => 'nearest'];
    $rows = [];
    foreach ($settings as $setting) {
        $old = $setting['oldMode'];
        if (!is_int($old) || !isset($oldModes[$old])) {
            $rows[] = [$old, 'нужен разбор', null];
            continue;
        }
        $route = new ReadPreference($oldModes[$old]);
        [$page] = readPage($manager, $namespace, ['_id' => 'daily-page'], ['_id' => 0, 'edition' => 1], null, $route);
        $rows[] = [$old, $route->getModeString(), $page[0]['edition']];
    }
    $checks['old_getter_removed'] = !method_exists(ReadPreference::class, 'getMode');
    $checks['modern_getter_exists'] = method_exists(ReadPreference::class, 'getModeString');
    $checks['two_profiles'] = count($settings) === 2;
    $checks['known_mode_read'] = $rows[0] === [6, 'secondaryPreferred', 4];
    $checks['unknown_quarantined'] = $rows[1] === [77, 'нужен разбор', null];
    return [$rows, $checks, ['known_old_values' => $oldModes, 'old_getter_present' => method_exists(ReadPreference::class, 'getMode')]];
});
echo 'mongodb130-policy-legacy-mode' . ": OK\n";

mongodb130-policy-legacy-mode: OK

Запускайте example.php из распакованного архива с policy-lab.php. Фактическую таблицу программа сохраняет в result.html и result.json.

<?php
declare(strict_types=1);
require __DIR__.'/policy-lab.php';
use MongoDB\Driver\{Manager, ReadConcern, ReadPreference, WriteConcern, Server};
use MongoDB\Driver\Exception\{ConnectionTimeoutException, InvalidArgumentException};

runLesson('mongodb130-policy-hedge-audit', ['Профиль', 'Значение enabled', 'Режим'], function (Manager $manager, string $namespace): array {
    insertDocuments($manager, $namespace, [
        ['_id' => 'reader-profile', 'mode' => 'nearest', 'hedge' => ['enabled' => false]],
        ['_id' => 'edition-card', 'title' => 'Вечерний выпуск'],
    ]);
    [$settings] = readPage($manager, $namespace, ['_id' => 'reader-profile'], ['_id' => 0, 'mode' => 1, 'hedge' => 1]);
    $profile = $settings[0];
    $warnings = [];
    set_error_handler(static function (int $severity, string $message) use (&$warnings): bool {
        if ($severity !== E_DEPRECATED || stripos($message, 'hedge') === false) {
            return false;
        }
        $warnings[] = $message;
        return true;
    }, E_DEPRECATED);
    try {
        $historical = new ReadPreference($profile['mode'], null, ['hedge' => $profile['hedge']]);
        $explicit = $historical->getHedge();
        $clean = new ReadPreference($profile['mode']);
        $omitted = $clean->getHedge();
    } finally {
        restore_error_handler();
    }
    [$page, $server] = readPage($manager, $namespace, ['_id' => 'edition-card'], ['_id' => 0, 'title' => 1], null, $clean);
    $checks['old_explicit_false'] = $explicit instanceof stdClass && $explicit->enabled === false;
    $checks['clean_omitted'] = $omitted === null;
    $checks['warnings_recorded'] = count($warnings) > 0;
    $checks['same_mode'] = $historical->getModeString() === $clean->getModeString();
    $checks['field_removed'] = !property_exists($clean->bsonSerialize(), 'hedge');
    $checks['served_card'] = $page === [['title' => 'Вечерний выпуск']] && $server->getType() === Server::TYPE_RS_PRIMARY;
    return [[['До переноса', $explicit->enabled, $historical->getModeString()],
             ['После переноса', $omitted, $clean->getModeString()]], $checks,
            ['php_deprecations' => $warnings, 'queried_title' => $page[0]['title'], 'used_route' => $clean->bsonSerialize()]];
});
echo 'mongodb130-policy-hedge-audit' . ": OK\n";

mongodb130-policy-hedge-audit: OK

Запускайте example.php из распакованного архива с policy-lab.php. Фактическую таблицу программа сохраняет в result.html и result.json.