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

<?php
declare(strict_types=1);

require __DIR__.'/ms130-helper.php';
use MongoDB\Driver\{Manager, Session};
use MongoDB\BSON\{Binary, Timestamp};

[$uri, $db] = ms130Config();
$manager = new Manager($uri, [
    'serverSelectionTimeoutMS' => 2000,
    'socketTimeoutMS' => 4500,
    'retryReads' => false,
]);
$hello = ms130RequireLab($manager, $db);
$runtime = [
    'php' => PHP_VERSION, 'extension' => phpversion('mongodb'),
    'server' => ms130Command($manager, $db, ['buildInfo' => 1])[0]['version'],
    'execution' => 'database', 'replica_set' => $hello['setName'], 'members' => count($hello['hosts']),
];
$checks = [];
$details = [];
$rows = ms130WithCollection($manager, $db, function (string $ns) use ($manager, &$checks, &$details): array {
    $session = $manager->startSession(['causalConsistency' => true]);
    $initial = $session->getOperationTime();
    $before = $session->getLogicalSessionId();
    $count = addEvent($manager, $ns, $session, 'A-17', 'готов');
    $state = readEvent($manager, $ns, $session, 'A-17');
    $after = $session->getLogicalSessionId();
    $timed = $session->getOperationTime() instanceof Timestamp;
    $checks = [
        'new_clock_empty' => $initial === null,
        'session_created' => $session instanceof Session,
        'inserted_one' => $count === 1,
        'saved_state' => $state === 'готов',
        'same_id' => $before->id == $after->id,
        'clock_observed' => $timed,
    ];
    $details = ['order' => 'A-17', 'writeConcern' => 'majority', 'readConcern' => 'majority'];
    $session->endSession();
    return [['Начальная метка', $initial], ['Добавлено', $count], ['Статус заказа', $state], ['Получена метка операции', $timed]];
});
$checks['owned_collection_removed'] = true;
ms130Report('mongodb130-session-first-order', ['Что проверили', 'Результат'], $rows, $checks, $runtime, $details);
echo 'mongodb130-session-first-order: OK', PHP_EOL;

mongodb130-session-first-order: OK

Запустите полный файл в отдельной учебной реплике. В HTML и JSON появятся значения, полученные из собственной коллекции примера.

<?php
declare(strict_types=1);

require __DIR__.'/ms130-helper.php';
use MongoDB\Driver\{Manager, Session};
use MongoDB\BSON\{Binary, Timestamp};

[$uri, $db] = ms130Config();
$manager = new Manager($uri, [
    'serverSelectionTimeoutMS' => 2000,
    'socketTimeoutMS' => 4500,
    'retryReads' => false,
]);
$hello = ms130RequireLab($manager, $db);
$runtime = [
    'php' => PHP_VERSION, 'extension' => phpversion('mongodb'),
    'server' => ms130Command($manager, $db, ['buildInfo' => 1])[0]['version'],
    'execution' => 'database', 'replica_set' => $hello['setName'], 'members' => count($hello['hosts']),
];
$checks = [];
$details = [];
$rows = ms130WithCollection($manager, $db, function (string $ns) use ($manager, &$checks, &$details): array {
    $desk = $manager->startSession();
    $mobile = $manager->startSession();
    $deskId = $desk->getLogicalSessionId()->id;
    $mobileId = $mobile->getLogicalSessionId()->id;
    $a = addEvent($manager, $ns, $desk, 'D-31', 'принят в кассе');
    $b = addEvent($manager, $ns, $mobile, 'M-42', 'принят в приложении');
    $first = readEvent($manager, $ns, $desk, 'D-31');
    $second = readEvent($manager, $ns, $mobile, 'M-42');
    $different = $deskId->getData() !== $mobileId->getData();
    $checks = [
        'two_inserts' => $a === 1 && $b === 1,
        'uuid_type' => $deskId instanceof Binary && $deskId->getType() === Binary::TYPE_UUID,
        'uuid_width' => strlen($deskId->getData()) === 16,
        'distinct_active_sessions' => $different,
        'desk_order' => $first === 'принят в кассе',
        'app_order' => $second === 'принят в приложении',
        'identity_stable' => $mobileId == $mobile->getLogicalSessionId()->id,
    ];
    $details = ['business_ids' => ['D-31','M-42'], 'uuid_bytes' => strlen($deskId->getData())];
    $desk->endSession();
    $mobile->endSession();
    return [['Заказ D-31', $first], ['Заказ M-42', $second], ['Разные активные lsid', $different], ['Байт в id сессии', strlen($deskId->getData())]];
});
$checks['owned_collection_removed'] = true;
ms130Report('mongodb130-session-request-identities', ['Что проверили', 'Результат'], $rows, $checks, $runtime, $details);
echo 'mongodb130-session-request-identities: OK', PHP_EOL;

mongodb130-session-request-identities: OK

Запустите полный файл в отдельной учебной реплике. В HTML и JSON появятся значения, полученные из собственной коллекции примера.

<?php
declare(strict_types=1);

require __DIR__.'/ms130-helper.php';
use MongoDB\Driver\{Manager, Session};
use MongoDB\BSON\{Binary, Timestamp};

[$uri, $db] = ms130Config();
$manager = new Manager($uri, [
    'serverSelectionTimeoutMS' => 2000,
    'socketTimeoutMS' => 4500,
    'retryReads' => false,
]);
$hello = ms130RequireLab($manager, $db);
$runtime = [
    'php' => PHP_VERSION, 'extension' => phpversion('mongodb'),
    'server' => ms130Command($manager, $db, ['buildInfo' => 1])[0]['version'],
    'execution' => 'database', 'replica_set' => $hello['setName'], 'members' => count($hello['hosts']),
];
$checks = [];
$details = [];
$rows = ms130WithCollection($manager, $db, function (string $ns) use ($manager, &$checks, &$details): array {
    $session = $manager->startSession(['causalConsistency' => true]);
    $initial = $session->getOperationTime();
    $a = addEvent($manager, $ns, $session, 'P-1', 'упаковано');
    $packed = $session->getOperationTime();
    $b = addEvent($manager, $ns, $session, 'P-2', 'отправлено');
    $sent = $session->getOperationTime();
    $later = clockParts($sent) > clockParts($packed);
    $first = readEvent($manager, $ns, $session, 'P-1');
    $last = readEvent($manager, $ns, $session, 'P-2');
    $checks = [
        'empty_before' => $initial === null, 'two_events' => $a === 1 && $b === 1,
        'valid_timestamps' => $packed instanceof Timestamp && $sent instanceof Timestamp,
        'forward_order' => $later, 'packed' => $first === 'упаковано',
        'dispatched' => $last === 'отправлено',
    ];
    $details = ['event_ids' => ['P-1','P-2'], 'order_comparison' => $later];
    return [['Первое событие', $first], ['Второе событие', $last], ['Метка второй записи больше', $later]];
});
$checks['owned_collection_removed'] = true;
ms130Report('mongodb130-session-operation-order', ['Что проверили', 'Результат'], $rows, $checks, $runtime, $details);
echo 'mongodb130-session-operation-order: OK', PHP_EOL;

mongodb130-session-operation-order: OK

Запустите полный файл в отдельной учебной реплике. В HTML и JSON появятся значения, полученные из собственной коллекции примера.

<?php
declare(strict_types=1);

require __DIR__.'/ms130-helper.php';
use MongoDB\Driver\{Manager, Session};
use MongoDB\BSON\{Binary, Timestamp};

[$uri, $db] = ms130Config();
$manager = new Manager($uri, [
    'serverSelectionTimeoutMS' => 2000,
    'socketTimeoutMS' => 4500,
    'retryReads' => false,
]);
$hello = ms130RequireLab($manager, $db);
$runtime = [
    'php' => PHP_VERSION, 'extension' => phpversion('mongodb'),
    'server' => ms130Command($manager, $db, ['buildInfo' => 1])[0]['version'],
    'execution' => 'database', 'replica_set' => $hello['setName'], 'members' => count($hello['hosts']),
];
$checks = [];
$details = [];
$rows = ms130WithCollection($manager, $db, function (string $ns) use ($manager, &$checks, &$details): array {
    $source = $manager->startSession();
    $receiver = $manager->startSession();
    $empty = $source->getClusterTime();
    $count = addEvent($manager, $ns, $source, 'R-9', 'приёмка закрыта');
    $envelope = $source->getClusterTime();
    $receiver->advanceClusterTime($envelope);
    $accepted = $receiver->getClusterTime();
    $same = clockParts($accepted->clusterTime) === clockParts($envelope->clusterTime);
    $state = readEvent($manager, $ns, $source, 'R-9');
    $checks = [
        'initially_empty' => $empty === null, 'one_receipt' => $count === 1,
        'envelope_object' => is_object($envelope),
        'bson_clock' => $envelope->clusterTime instanceof Timestamp,
        'same_cluster_clock' => $same, 'receipt_state' => $state === 'приёмка закрыта',
    ];
    $details = ['receipt' => 'R-9', 'copied_full_document' => $same];
    return [['До операции', $empty], ['Приёмка R-9', $state], ['Вложена метка BSON', $envelope->clusterTime instanceof Timestamp], ['Метка принята', $same]];
});
$checks['owned_collection_removed'] = true;
ms130Report('mongodb130-session-cluster-envelope', ['Что проверили', 'Результат'], $rows, $checks, $runtime, $details);
echo 'mongodb130-session-cluster-envelope: OK', PHP_EOL;

mongodb130-session-cluster-envelope: OK

Запустите полный файл в отдельной учебной реплике. В HTML и JSON появятся значения, полученные из собственной коллекции примера.

<?php
declare(strict_types=1);

require __DIR__.'/ms130-helper.php';
use MongoDB\Driver\{Manager, Session};
use MongoDB\BSON\{Binary, Timestamp};

[$uri, $db] = ms130Config();
$manager = new Manager($uri, [
    'serverSelectionTimeoutMS' => 2000,
    'socketTimeoutMS' => 4500,
    'retryReads' => false,
]);
$hello = ms130RequireLab($manager, $db);
$runtime = [
    'php' => PHP_VERSION, 'extension' => phpversion('mongodb'),
    'server' => ms130Command($manager, $db, ['buildInfo' => 1])[0]['version'],
    'execution' => 'database', 'replica_set' => $hello['setName'], 'members' => count($hello['hosts']),
];
$checks = [];
$details = [];
$rows = ms130WithCollection($manager, $db, function (string $ns) use ($manager, &$checks, &$details): array {
    $reservations = $manager->startSession(['causalConsistency' => true]);
    $packing = $manager->startSession(['causalConsistency' => true]);
    $count = addEvent($manager, $ns, $reservations, 'K-71', 'зарезервирован');
    $operation = $reservations->getOperationTime();
    $cluster = $reservations->getClusterTime();
    $fresh = $packing->getOperationTime() === null && $packing->getClusterTime() === null;
    $packing->advanceOperationTime($operation);
    $packing->advanceClusterTime($cluster);
    $gotOperation = clockParts($operation) === clockParts($packing->getOperationTime());
    $gotCluster = clockParts($cluster->clusterTime) === clockParts($packing->getClusterTime()->clusterTime);
    $wire = new class($ns, $operation) implements MongoDB\Driver\Monitoring\CommandSubscriber {
        public int $finds = 0;
        public ?string $level = null;
        public bool $boundaryMatches = false;

        public function __construct(private string $ns, private Timestamp $boundary) {}

        public function commandStarted(MongoDB\Driver\Monitoring\CommandStartedEvent $event): void
        {
            if ($event->getCommandName() !== 'find') {
                return;
            }
            $command = $event->getCommand();
            if ($event->getDatabaseName().'.'.$command->find !== $this->ns) {
                return;
            }
            $this->finds++;
            $concern = $command->readConcern ?? null;
            $this->level = $concern->level ?? null;
            $sentTime = $concern->afterClusterTime ?? null;
            $this->boundaryMatches = $sentTime instanceof Timestamp
                && clockParts($sentTime) === clockParts($this->boundary);
        }

        public function commandSucceeded(MongoDB\Driver\Monitoring\CommandSucceededEvent $event): void {}
        public function commandFailed(MongoDB\Driver\Monitoring\CommandFailedEvent $event): void {}
    };
    $manager->addSubscriber($wire);
    try {
        $state = readEvent($manager, $ns, $packing, 'K-71');
    } finally {
        $manager->removeSubscriber($wire);
    }
    $checks = [
        'inserted' => $count === 1, 'receiver_empty' => $fresh,
        'operation_handed_over' => $gotOperation, 'cluster_handed_over' => $gotCluster,
        'separate_sessions' => $reservations->getLogicalSessionId()->id != $packing->getLogicalSessionId()->id,
        'packing_sees_reservation' => $state === 'зарезервирован',
        'one_observed_find' => $wire->finds === 1,
        'read_concern_on_wire' => $wire->level === 'majority',
        'after_cluster_time_on_wire' => $wire->boundaryMatches,
    ];
    $details = ['document' => 'K-71', 'read_and_write_concern' => 'majority', 'reader_is_independent' => $checks['separate_sessions']];
    return [['Указана граница операции', $gotOperation], ['Указано время кластера', $gotCluster],
        ['Уровень чтения в команде find', $wire->level], ['afterClusterTime совпал с меткой операции', $wire->boundaryMatches],
        ['Склад видит K-71', $state]];
});
$checks['owned_collection_removed'] = true;
ms130Report('mongodb130-session-handoff', ['Что проверили', 'Результат'], $rows, $checks, $runtime, $details);
echo 'mongodb130-session-handoff: OK', PHP_EOL;

mongodb130-session-handoff: OK

Запустите полный файл в отдельной учебной реплике. В HTML и JSON появятся значения, полученные из собственной коллекции примера.

<?php
declare(strict_types=1);

require __DIR__.'/ms130-helper.php';
use MongoDB\Driver\{Manager, Session};
use MongoDB\BSON\{Binary, Timestamp};

[$uri, $db] = ms130Config();
$manager = new Manager($uri, [
    'serverSelectionTimeoutMS' => 2000,
    'socketTimeoutMS' => 4500,
    'retryReads' => false,
]);
$hello = ms130RequireLab($manager, $db);
$runtime = [
    'php' => PHP_VERSION, 'extension' => phpversion('mongodb'),
    'server' => ms130Command($manager, $db, ['buildInfo' => 1])[0]['version'],
    'execution' => 'database', 'replica_set' => $hello['setName'], 'members' => count($hello['hosts']),
];
$checks = [];
$details = [];
$rows = ms130WithCollection($manager, $db, function (string $ns) use ($manager, &$checks, &$details): array {
    $writer = $manager->startSession();
    $reader = $manager->startSession(['causalConsistency' => true]);
    addEvent($manager, $ns, $writer, 'S-1', 'проверен');
    $firstOp = $writer->getOperationTime();
    $firstCluster = $writer->getClusterTime();
    addEvent($manager, $ns, $writer, 'S-2', 'передан курьеру');
    $secondOp = $writer->getOperationTime();
    $secondCluster = $writer->getClusterTime();
    $reader->advanceOperationTime($secondOp);
    $reader->advanceClusterTime($secondCluster);
    $reader->advanceOperationTime($firstOp);
    $reader->advanceClusterTime($firstCluster);
    $opRetained = clockParts($reader->getOperationTime()) === clockParts($secondOp);
    $clusterRetained = clockParts($reader->getClusterTime()->clusterTime) === clockParts($secondCluster->clusterTime);
    $a = readEvent($manager, $ns, $reader, 'S-1');
    $b = readEvent($manager, $ns, $reader, 'S-2');
    $checks = [
        'newer_operation' => clockParts($secondOp) > clockParts($firstOp),
        'ordered_cluster_times' => clockParts($secondCluster->clusterTime) >= clockParts($firstCluster->clusterTime),
        'retained_operation' => $opRetained, 'retained_cluster' => $clusterRetained,
        'first_saved' => $a === 'проверен', 'latest_saved' => $b === 'передан курьеру',
    ];
    $details = ['delivery_order' => ['S-2', 'S-1'], 'same_newest_operation' => $opRetained];
    return [['Метка операции осталась новой', $opRetained], ['Граница кластера сохранена', $clusterRetained], ['Событие S-1', $a], ['Событие S-2', $b]];
});
$checks['owned_collection_removed'] = true;
ms130Report('mongodb130-session-older-message', ['Что проверили', 'Результат'], $rows, $checks, $runtime, $details);
echo 'mongodb130-session-older-message: OK', PHP_EOL;

mongodb130-session-older-message: OK

Запустите полный файл в отдельной учебной реплике. В HTML и JSON появятся значения, полученные из собственной коллекции примера.

<?php
declare(strict_types=1);

require __DIR__.'/ms130-helper.php';
use MongoDB\Driver\{Manager, Session};
use MongoDB\BSON\{Binary, Timestamp};

[$uri, $db] = ms130Config();
$manager = new Manager($uri, [
    'serverSelectionTimeoutMS' => 2000,
    'socketTimeoutMS' => 4500,
    'retryReads' => false,
]);
$hello = ms130RequireLab($manager, $db);
$runtime = [
    'php' => PHP_VERSION, 'extension' => phpversion('mongodb'),
    'server' => ms130Command($manager, $db, ['buildInfo' => 1])[0]['version'],
    'execution' => 'database', 'replica_set' => $hello['setName'], 'members' => count($hello['hosts']),
];
$checks = [];
$details = [];
$rows = ms130WithCollection($manager, $db, function (string $ns) use ($manager, &$checks, &$details): array {
    $session = $manager->startSession();
    $before = $session->getServer();
    $count = addEvent($manager, $ns, $session, 'T-8', 'на выдаче');
    $cursor = eventCursor($manager, $ns, $session, 'T-8');
    $selected = $cursor->getServer();
    $documents = $cursor->toArray();
    $pinned = $session->getServer();
    $isPrimary = $selected->getType() === MongoDB\Driver\Server::TYPE_RS_PRIMARY;
    $state = $documents[0]->state;
    $checks = [
        'no_initial_pin' => $before === null, 'one_insert' => $count === 1,
        'served_by_primary' => $isPrimary, 'one_document' => count($documents) === 1,
        'correct_state' => $state === 'на выдаче', 'no_final_pin' => $pinned === null,
    ];
    $details = ['topology' => 'один узел replica set', 'read_from_primary' => $isPrimary];
    return [['Сервер закреплён до чтения', $before !== null], ['Чтение выполнил primary', $isPrimary], ['Статус T-8', $state], ['Сервер закреплён после чтения', $pinned !== null]];
});
$checks['owned_collection_removed'] = true;
ms130Report('mongodb130-session-actual-server', ['Что проверили', 'Результат'], $rows, $checks, $runtime, $details);
echo 'mongodb130-session-actual-server: OK', PHP_EOL;

mongodb130-session-actual-server: OK

Запустите полный файл в отдельной учебной реплике. В HTML и JSON появятся значения, полученные из собственной коллекции примера.

<?php
declare(strict_types=1);

require __DIR__.'/ms130-helper.php';
use MongoDB\Driver\{Manager, Session};
use MongoDB\BSON\{Binary, Timestamp};

[$uri, $db] = ms130Config();
$manager = new Manager($uri, [
    'serverSelectionTimeoutMS' => 2000,
    'socketTimeoutMS' => 4500,
    'retryReads' => false,
]);
$hello = ms130RequireLab($manager, $db);
$runtime = [
    'php' => PHP_VERSION, 'extension' => phpversion('mongodb'),
    'server' => ms130Command($manager, $db, ['buildInfo' => 1])[0]['version'],
    'execution' => 'database', 'replica_set' => $hello['setName'], 'members' => count($hello['hosts']),
];
$checks = [];
$details = [];
$rows = ms130WithCollection($manager, $db, function (string $ns) use ($manager, &$checks, &$details): array {
    $session = $manager->startSession();
    $initialDirty = $session->isDirty();
    $count = addEvent($manager, $ns, $session, 'R-12', 'получен');
    $code = null;
    try {
        addEvent($manager, $ns, $session, 'R-12', 'дубликат');
    } catch (MongoDB\Driver\Exception\BulkWriteException $error) {
        $errors = $error->getWriteResult()->getWriteErrors();
        $code = $errors[0]->getCode() ?? null;
    }
    $afterError = $session->isDirty();
    $state = readEvent($manager, $ns, $session, 'R-12');
    $checks = [
        'clean_start' => $initialDirty === false, 'first_insert' => $count === 1,
        'duplicate_conflict' => $code === 11000, 'no_network_mark' => $afterError === false,
        'stored_original' => $state === 'получен',
        'usable_session' => $session->getOperationTime() instanceof Timestamp,
    ];
    $details = ['order' => 'R-12', 'duplicate_error_code' => $code, 'dirty' => $afterError];
    return [['Первый документ', $state], ['Код повторной вставки', $code], ['Сессия dirty после конфликта', $afterError]];
});
$checks['owned_collection_removed'] = true;
ms130Report('mongodb130-session-duplicate', ['Что проверили', 'Результат'], $rows, $checks, $runtime, $details);
echo 'mongodb130-session-duplicate: OK', PHP_EOL;

mongodb130-session-duplicate: OK

Запустите полный файл в отдельной учебной реплике. В HTML и JSON появятся значения, полученные из собственной коллекции примера.