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

<?php
declare(strict_types=1);
require __DIR__.'/lab.php';

$config = x144Config();
$session = mysql_xdevapi\getSession($config['uri']);
$schema = null;
$owned = [];
$removed = [];
$rows = $checks = $observations = [];
try {
    $schema = $session->getSchema($config['schema']);
    if (!$schema->existsInDatabase()) {
        throw new RuntimeException('Учебная схема не существует: подготовьте её отдельно.');
    }
    $runtime = ['php'=>PHP_VERSION, 'extension'=>phpversion('mysql_xdevapi'),
        'server_version'=>$session->getServerVersion(), 'schema'=>$config['schema'],
        'host'=>$config['host'], 'port'=>$config['port']];
    $name = x144OwnTable($session, $schema, $owned, 'sequential_jobs',
        '(id INT PRIMARY KEY, task_name VARCHAR(40) NOT NULL, items INT NOT NULL, state VARCHAR(12) NOT NULL) ENGINE=InnoDB');
    $qualified = x144Qualified($schema, $name);
    $options = ['enabled'=>true, 'maxSize'=>1, 'maxIdleTime'=>10000, 'queueTimeOut'=>250];
    $client = mysql_xdevapi\getClient($config['uri'], json_encode($options, JSON_THROW_ON_ERROR));
    $jobs = [[1, 'catalog-export', 2], [2, 'receipt-export', 3]];
    $receipts = $connectionIds = $releaseResults = [];
    try {
        foreach ($jobs as [$id, $taskName, $items]) {
            $worker = $client->getSession();
            try {
                $connectionIds[] = $worker->sql('SELECT CONNECTION_ID() AS id')->execute()->fetchOne()['id'];
                $worker->sql('INSERT INTO '.$qualified.' (id, task_name, items, state) VALUES (?, ?, ?, ?)')
                    ->bind($id)->bind($taskName)->bind($items)->bind('done')->execute();
                $receipts[] = $worker->sql('SELECT id, task_name, items, state FROM '.$qualified.' WHERE id = ?')
                    ->bind($id)->execute()->fetchOne();
            } finally {
                $releaseResults[] = $worker->close();
            }
        }
    } finally {
        $client->close();
    }
    $saved = $session->sql('SELECT id, task_name, items, state FROM '.$qualified.' ORDER BY id')->execute()->fetchAll();
    $rows = [['Первое задание', $saved[0]['task_name']], ['Позиций первого задания', $saved[0]['items']],
        ['Второе задание', $saved[1]['task_name']], ['Позиций второго задания', $saved[1]['items']],
        ['Сохранено квитанций', count($saved)], ['Оба задания завершены', array_column($saved, 'state') === ['done', 'done']],
        ['Session возвращены после каждого задания', $releaseResults === [true, true]]];
    $checks = ['saved_tasks'=>array_column($saved, 'task_name') === ['catalog-export', 'receipt-export'],
        'item_counts'=>array_column($saved, 'items') === [2, 3], 'states'=>array_column($saved, 'state') === ['done', 'done'],
        'receipt_readback'=>$receipts === $saved, 'released'=>$releaseResults === [true, true],
        'two_checkouts'=>count($connectionIds) === 2 && $connectionIds[0] > 0 && $connectionIds[1] > 0,
        'client_class'=>$client instanceof mysql_xdevapi\Client];
    $observations = ['options'=>$options, 'jobs'=>$jobs, 'receipts'=>$receipts, 'saved_rows'=>$saved,
        'connection_ids'=>$connectionIds, 'same_connection_observed'=>$connectionIds[0] === $connectionIds[1],
        'release_results'=>$releaseResults, 'client_class'=>get_debug_type($client)];
} finally {
    try {
        if ($schema instanceof mysql_xdevapi\Schema) {
            $removed = x144Cleanup($schema, $owned);
        }
    } finally {
        $session->close();
    }
}
x144Report('mysql144-x-pool-first-checkout', 'Взять соединение для двух последовательных заданий', $rows, $checks, $observations, $runtime, $owned, $removed);

Первое задание — catalog-export
Позиций первого задания — 2
Второе задание — receipt-export
Позиций второго задания — 3
Сохранено квитанций — 2
Оба задания завершены — да
Session возвращены после каждого задания — да

Запустите отдельным процессом PHP по README. lab.php создаёт одну собственную таблицу; программа сохраняет и перечитывает строки, освобождает Session/Client и удаляет свою таблицу. result.html показывает результат, result.json — реальные данные и безопасную диагностику, metrics.json — проверки.

<?php
declare(strict_types=1);
require __DIR__.'/lab.php';

$config = x144Config();
$session = mysql_xdevapi\getSession($config['uri']);
$schema = null;
$owned = [];
$removed = [];
$rows = $checks = $observations = [];
try {
    $schema = $session->getSchema($config['schema']);
    if (!$schema->existsInDatabase()) {
        throw new RuntimeException('Учебная схема не существует: подготовьте её отдельно.');
    }
    $runtime = ['php'=>PHP_VERSION, 'extension'=>phpversion('mysql_xdevapi'),
        'server_version'=>$session->getServerVersion(), 'schema'=>$config['schema'],
        'host'=>$config['host'], 'port'=>$config['port']];
    $name = x144OwnTable($session, $schema, $owned, 'independent_stock',
        '(id INT PRIMARY KEY, sku VARCHAR(20) NOT NULL, stock INT NOT NULL) ENGINE=InnoDB');
    $qualified = x144Qualified($schema, $name);
    $session->sql('INSERT INTO '.$qualified." (id, sku, stock) VALUES (1, 'LAMP', 4)")->execute();
    $options = ['enabled'=>true, 'maxSize'=>2, 'queueTimeOut'=>250];
    $client = mysql_xdevapi\getClient($config['uri'], json_encode($options, JSON_THROW_ON_ERROR));
    $first = $second = null;
    $active = false;
    try {
        $first = $client->getSession();
        $second = $client->getSession();
        $ids = [$first->sql('SELECT CONNECTION_ID() AS id')->execute()->fetchOne()['id'],
            $second->sql('SELECT CONNECTION_ID() AS id')->execute()->fetchOne()['id']];
        $second->sql('SET autocommit = 1')->execute();
        $initial = $second->sql('SELECT sku, stock FROM '.$qualified.' WHERE id = 1')->execute()->fetchOne();
        $first->startTransaction();
        $active = true;
        $first->sql('UPDATE '.$qualified.' SET stock = ? WHERE id = ?')->bind(9)->bind(1)->execute();
        $own = $first->sql('SELECT sku, stock FROM '.$qualified.' WHERE id = 1')->execute()->fetchOne();
        $otherBefore = $second->sql('SELECT sku, stock FROM '.$qualified.' WHERE id = 1')->execute()->fetchOne();
        $first->commit();
        $active = false;
        $otherAfter = $second->sql('SELECT sku, stock FROM '.$qualified.' WHERE id = 1')->execute()->fetchOne();
    } finally {
        try { if ($active && $first !== null) { $first->rollback(); } }
        finally {
            try { if ($second !== null) { $second->close(); } }
            finally { try { if ($first !== null) { $first->close(); } } finally { $client->close(); } }
        }
    }
    $saved = $session->sql('SELECT sku, stock FROM '.$qualified.' WHERE id = 1')->execute()->fetchOne();
    $rows = [['Товар', $saved['sku']], ['Исходный остаток', $initial['stock']], ['Своё изменение до commit', $own['stock']],
        ['Другой участник до commit', $otherBefore['stock']], ['Новый запрос другого участника после commit', $otherAfter['stock']],
        ['Сохранённый остаток', $saved['stock']], ['Два одновременно выданных соединения различаются', $ids[0] !== $ids[1]]];
    $checks = ['initial_stock'=>$initial === ['sku'=>'LAMP','stock'=>4], 'own_write'=>$own['stock'] === 9,
        'uncommitted_hidden'=>$otherBefore['stock'] === 4, 'commit_visible'=>$otherAfter['stock'] === 9,
        'persistent_readback'=>$saved === $otherAfter, 'independent_connections'=>$ids[0] !== $ids[1]];
    $observations = ['options'=>$options, 'connection_ids'=>$ids, 'initial'=>$initial, 'own_uncommitted'=>$own,
        'other_before_commit'=>$otherBefore, 'other_after_commit'=>$otherAfter, 'saved_row'=>$saved,
        'second_session_autocommit'=>true];
} finally {
    try {
        if ($schema instanceof mysql_xdevapi\Schema) {
            $removed = x144Cleanup($schema, $owned);
        }
    } finally {
        $session->close();
    }
}
x144Report('mysql144-x-pool-independent-transactions', 'Увидеть две независимые транзакционные Session', $rows, $checks, $observations, $runtime, $owned, $removed);

Товар — LAMP
Исходный остаток — 4
Своё изменение до commit — 9
Другой участник до commit — 4
Новый запрос другого участника после commit — 9
Сохранённый остаток — 9
Два одновременно выданных соединения различаются — да

Запустите отдельным процессом PHP по README. lab.php создаёт одну собственную таблицу; программа сохраняет и перечитывает строки, освобождает Session/Client и удаляет свою таблицу. result.html показывает результат, result.json — реальные данные и безопасную диагностику, metrics.json — проверки.

<?php
declare(strict_types=1);
require __DIR__.'/lab.php';

$config = x144Config();
$session = mysql_xdevapi\getSession($config['uri']);
$schema = null;
$owned = [];
$removed = [];
$rows = $checks = $observations = [];
try {
    $schema = $session->getSchema($config['schema']);
    if (!$schema->existsInDatabase()) {
        throw new RuntimeException('Учебная схема не существует: подготовьте её отдельно.');
    }
    $runtime = ['php'=>PHP_VERSION, 'extension'=>phpversion('mysql_xdevapi'),
        'server_version'=>$session->getServerVersion(), 'schema'=>$config['schema'],
        'host'=>$config['host'], 'port'=>$config['port']];
    $name = x144OwnTable($session, $schema, $owned, 'bounded_queue',
        '(id INT PRIMARY KEY, task_name VARCHAR(40) NOT NULL, state VARCHAR(12) NOT NULL) ENGINE=InnoDB');
    $qualified = x144Qualified($schema, $name);
    $options = ['enabled'=>true, 'maxSize'=>1, 'queueTimeOut'=>250];
    $client = mysql_xdevapi\getClient($config['uri'], json_encode($options, JSON_THROW_ON_ERROR));
    $held = $next = null;
    try {
        $held = $client->getSession();
        $held->sql('INSERT INTO '.$qualified." (id, task_name, state) VALUES (1, 'catalog', 'working')")->execute();
        $started = hrtime(true);
        $failure = x144Failure(static function () use ($client): void {
            $unexpected = $client->getSession();
            try { $unexpected->sql('SELECT 1 AS alive')->execute()->fetchOne(); }
            finally { $unexpected->close(); }
        });
        $elapsedMs = (hrtime(true) - $started) / 1000000;
        $held->sql('UPDATE '.$qualified." SET state = 'done' WHERE id = 1")->execute();
        $released = $held->close();
        $held = null;
        $next = $client->getSession();
        $next->sql('INSERT INTO '.$qualified." (id, task_name, state) VALUES (2, 'receipts', 'done')")->execute();
        $saved = $next->sql('SELECT id, task_name, state FROM '.$qualified.' ORDER BY id')->execute()->fetchAll();
    } finally {
        try { if ($next !== null) { $next->close(); } }
        finally { try { if ($held !== null) { $held->close(); } } finally { $client->close(); } }
    }
    $codes = array_column($failure ?? [], 'code');
    $messages = array_column($failure ?? [], 'message');
    $redacted = count($messages) > 0;
    foreach ($messages as $message) {
        $redacted = $redacted && !str_contains($message, $config['uri']) && !str_contains($message, 'mysqlx://');
    }
    $rows = [['Лимит одновременных Session', $options['maxSize']], ['Отказ занятого пула распознан', in_array(10055, $codes, true)],
        ['Первый слот возвращён', $released], ['Первое задание', $saved[0]['state']], ['Следующее задание', $saved[1]['state']],
        ['Сохранено завершённых заданий', count($saved)], ['URI исключён из диагностики', $redacted]];
    $checks = ['queue_rejected'=>in_array(10055, $codes, true), 'session_returned'=>$released === true,
        'recovered_work'=>$saved === [['id'=>1,'task_name'=>'catalog','state'=>'done'],['id'=>2,'task_name'=>'receipts','state'=>'done']],
        'diagnostic_redacted'=>$redacted, 'finite_measurement'=>is_finite($elapsedMs) && $elapsedMs >= 0];
    $observations = ['options'=>$options, 'failure_chain'=>$failure, 'elapsed_ms'=>$elapsedMs, 'release_result'=>$released, 'saved_rows'=>$saved];
} finally {
    try {
        if ($schema instanceof mysql_xdevapi\Schema) {
            $removed = x144Cleanup($schema, $owned);
        }
    } finally {
        $session->close();
    }
}
x144Report('mysql144-x-pool-bounded-queue', 'Освободить единственный слот после конечного отказа', $rows, $checks, $observations, $runtime, $owned, $removed);

Лимит одновременных Session — 1
Отказ занятого пула распознан — да
Первый слот возвращён — да
Первое задание — done
Следующее задание — done
Сохранено завершённых заданий — 2
URI исключён из диагностики — да

Запустите отдельным процессом PHP по README. lab.php создаёт одну собственную таблицу; программа сохраняет и перечитывает строки, освобождает Session/Client и удаляет свою таблицу. result.html показывает результат, result.json — реальные данные и безопасную диагностику, metrics.json — проверки.

<?php
declare(strict_types=1);
require __DIR__.'/lab.php';

$config = x144Config();
$session = mysql_xdevapi\getSession($config['uri']);
$schema = null;
$owned = [];
$removed = [];
$rows = $checks = $observations = [];
try {
    $schema = $session->getSchema($config['schema']);
    if (!$schema->existsInDatabase()) {
        throw new RuntimeException('Учебная схема не существует: подготовьте её отдельно.');
    }
    $runtime = ['php'=>PHP_VERSION, 'extension'=>phpversion('mysql_xdevapi'),
        'server_version'=>$session->getServerVersion(), 'schema'=>$config['schema'],
        'host'=>$config['host'], 'port'=>$config['port']];
    $name = x144OwnTable($session, $schema, $owned, 'failed_job',
        '(id INT PRIMARY KEY, task_name VARCHAR(40) NOT NULL, state VARCHAR(12) NOT NULL) ENGINE=InnoDB');
    $qualified = x144Qualified($schema, $name);
    $session->sql('INSERT INTO '.$qualified." (id, task_name, state) VALUES (1, 'existing', 'done')")->execute();
    $options = ['enabled'=>true, 'maxSize'=>1, 'queueTimeOut'=>250];
    $client = mysql_xdevapi\getClient($config['uri'], json_encode($options, JSON_THROW_ON_ERROR));
    $worker = $next = null;
    $active = false;
    try {
        $worker = $client->getSession();
        $worker->startTransaction();
        $active = true;
        try {
            $worker->sql('INSERT INTO '.$qualified." (id, task_name, state) VALUES (2, 'partial', 'working')")->execute();
            $inside = $worker->sql('SELECT id, state FROM '.$qualified.' WHERE id = 2')->execute()->fetchOne();
            $failure = x144Failure(static function () use ($worker, $qualified): void {
                $worker->sql('INSERT INTO '.$qualified." (id, task_name, state) VALUES (1, 'duplicate', 'working')")->execute();
            });
        } finally {
            try { if ($active) { $worker->rollback(); $active = false; } }
            finally { $released = $worker->close(); $worker = null; }
        }
        $next = $client->getSession();
        $missing = $next->sql('SELECT id, state FROM '.$qualified.' WHERE id = 2')->execute()->fetchOne();
        $next->sql('INSERT INTO '.$qualified." (id, task_name, state) VALUES (3, 'next-job', 'done')")->execute();
        $saved = $next->sql('SELECT id, task_name, state FROM '.$qualified.' ORDER BY id')->execute()->fetchAll();
    } finally {
        try { if ($next !== null) { $next->close(); } }
        finally { try { if ($worker !== null) { $worker->close(); } } finally { $client->close(); } }
    }
    $codes = array_column($failure ?? [], 'code');
    $rows = [['Частичная строка была видна внутри задания', $inside === ['id'=>2,'state'=>'working']],
        ['Конфликт первичного ключа распознан', in_array(1062, $codes, true)],
        ['Частичная строка исчезла после rollback', $missing === null], ['Session возвращена', $released],
        ['Исходная запись сохранена', $saved[0]['task_name']], ['Следующее задание сохранено', $saved[1]['task_name']],
        ['Строк в итоговом журнале', count($saved)]];
    $checks = ['partial_existed'=>$inside === ['id'=>2,'state'=>'working'], 'duplicate_detected'=>in_array(1062, $codes, true),
        'partial_rolled_back'=>$missing === null, 'slot_returned'=>$released === true,
        'final_records'=>$saved === [['id'=>1,'task_name'=>'existing','state'=>'done'],['id'=>3,'task_name'=>'next-job','state'=>'done']]];
    $observations = ['options'=>$options, 'partial_inside_transaction'=>$inside, 'failure_chain'=>$failure,
        'partial_after_rollback'=>$missing, 'release_result'=>$released, 'saved_rows'=>$saved];
} finally {
    try {
        if ($schema instanceof mysql_xdevapi\Schema) {
            $removed = x144Cleanup($schema, $owned);
        }
    } finally {
        $session->close();
    }
}
x144Report('mysql144-x-pool-failure-release', 'Откатить частичное задание и вернуть Session следующему', $rows, $checks, $observations, $runtime, $owned, $removed);

Частичная строка была видна внутри задания — да
Конфликт первичного ключа распознан — да
Частичная строка исчезла после rollback — да
Session возвращена — да
Исходная запись сохранена — existing
Следующее задание сохранено — next-job
Строк в итоговом журнале — 2

Запустите отдельным процессом PHP по README. lab.php создаёт одну собственную таблицу; программа сохраняет и перечитывает строки, освобождает Session/Client и удаляет свою таблицу. result.html показывает результат, result.json — реальные данные и безопасную диагностику, metrics.json — проверки.

<?php
declare(strict_types=1);
require __DIR__.'/lab.php';

$config = x144Config();
$session = mysql_xdevapi\getSession($config['uri']);
$schema = null;
$owned = [];
$removed = [];
$rows = $checks = $observations = [];
try {
    $schema = $session->getSchema($config['schema']);
    if (!$schema->existsInDatabase()) {
        throw new RuntimeException('Учебная схема не существует: подготовьте её отдельно.');
    }
    $runtime = ['php'=>PHP_VERSION, 'extension'=>phpversion('mysql_xdevapi'),
        'server_version'=>$session->getServerVersion(), 'schema'=>$config['schema'],
        'host'=>$config['host'], 'port'=>$config['port']];
    $name = x144OwnTable($session, $schema, $owned, 'operation_receipt',
        '(operation_id CHAR(32) CHARACTER SET ascii COLLATE ascii_bin PRIMARY KEY, task_name VARCHAR(40) NOT NULL, items INT NOT NULL, state VARCHAR(12) NOT NULL) ENGINE=InnoDB');
    $qualified = x144Qualified($schema, $name);
    $options = ['enabled'=>true, 'maxSize'=>1, 'queueTimeOut'=>250];
    $client = mysql_xdevapi\getClient($config['uri'], json_encode($options, JSON_THROW_ON_ERROR));
    $worker = $reader = null;
    try {
        $worker = $client->getSession();
        $operationId = $worker->generateUUID();
        $request = ['operation_id'=>$operationId, 'task_name'=>'catalog-sync', 'items'=>7];
        $worker->sql('INSERT INTO '.$qualified.' (operation_id, task_name, items, state) VALUES (?, ?, ?, ?)')
            ->bind($request['operation_id'])->bind($request['task_name'])->bind($request['items'])->bind('done')->execute();
        $worker->close();
        $worker = null;
        $reader = $client->getSession();
        $receipt = $reader->sql('SELECT operation_id, task_name, items, state FROM '.$qualified.' WHERE operation_id = ?')
            ->bind($operationId)->execute()->fetchOne();
    } finally {
        try { if ($reader !== null) { $reader->close(); } }
        finally { try { if ($worker !== null) { $worker->close(); } } finally { $client->close(); } }
    }
    $same = $receipt !== null && $receipt['operation_id'] === $request['operation_id'];
    $format = is_string($operationId) && preg_match('/^[0-9A-F]{32}$/D', $operationId) === 1;
    $rows = [['UUID получен до записи', $request['operation_id'] === $operationId], ['Длина UUID', strlen($operationId)],
        ['Формат текущего генератора: 32 заглавных hex-символа', $format], ['Найдена квитанция той же операции', $same],
        ['Задание', $receipt['task_name']], ['Позиций синхронизации', $receipt['items']], ['Состояние', $receipt['state']]];
    $checks = ['uuid_format'=>$format, 'correlated_receipt'=>$same, 'saved_task'=>$receipt['task_name'] === 'catalog-sync',
        'saved_items'=>$receipt['items'] === 7, 'saved_state'=>$receipt['state'] === 'done'];
    $observations = ['options'=>$options, 'request'=>$request, 'actual_uuid'=>$operationId,
        'uuid_type'=>get_debug_type($operationId), 'uuid_length'=>strlen($operationId), 'saved_receipt'=>$receipt];
} finally {
    try {
        if ($schema instanceof mysql_xdevapi\Schema) {
            $removed = x144Cleanup($schema, $owned);
        }
    } finally {
        $session->close();
    }
}
x144Report('mysql144-x-session-correlation-uuid', 'Найти квитанцию по UUID, созданному до записи', $rows, $checks, $observations, $runtime, $owned, $removed);

UUID получен до записи — да
Длина UUID — 32
Формат текущего генератора: 32 заглавных hex-символа — да
Найдена квитанция той же операции — да
Задание — catalog-sync
Позиций синхронизации — 7
Состояние — done

Запустите отдельным процессом PHP по README. lab.php создаёт одну собственную таблицу; программа сохраняет и перечитывает строки, освобождает Session/Client и удаляет свою таблицу. result.html показывает результат, result.json — реальные данные и безопасную диагностику, metrics.json — проверки.

<?php
declare(strict_types=1);
require __DIR__.'/lab.php';

$config = x144Config();
$session = mysql_xdevapi\getSession($config['uri']);
$schema = null;
$owned = [];
$removed = [];
$rows = $checks = $observations = [];
try {
    $schema = $session->getSchema($config['schema']);
    if (!$schema->existsInDatabase()) {
        throw new RuntimeException('Учебная схема не существует: подготовьте её отдельно.');
    }
    $runtime = ['php'=>PHP_VERSION, 'extension'=>phpversion('mysql_xdevapi'),
        'server_version'=>$session->getServerVersion(), 'schema'=>$config['schema'],
        'host'=>$config['host'], 'port'=>$config['port']];
    $name = x144OwnTable($session, $schema, $owned, 'shutdown_receipt',
        '(id INT PRIMARY KEY, task_name VARCHAR(40) NOT NULL, items INT NOT NULL, state VARCHAR(12) NOT NULL) ENGINE=InnoDB');
    $qualified = x144Qualified($schema, $name);
    $options = ['enabled'=>true, 'maxSize'=>1, 'queueTimeOut'=>250];
    $client = mysql_xdevapi\getClient($config['uri'], json_encode($options, JSON_THROW_ON_ERROR));
    $worker = $fresh = null;
    $acceptingJobs = true;
    $blockedNewJob = false;
    try {
        $worker = $client->getSession();
        if ($acceptingJobs) {
            $worker->sql('INSERT INTO '.$qualified." (id, task_name, items, state) VALUES (1, 'catalog-export', 2, 'done')")->execute();
        }
        $completed = $worker->sql('SELECT task_name, items, state FROM '.$qualified.' WHERE id = 1')->execute()->fetchOne();
        $acceptingJobs = false;
        $closeResult = $client->close();
        $oldFailure = x144Failure(static function () use ($worker, $qualified): void {
            $worker->sql('SELECT state FROM '.$qualified.' WHERE id = 1')->execute()->fetchOne();
        });
        // Диагностика фактического контракта: тот же Client способен выдать новую Session.
        $fresh = $client->getSession();
        $saved = $fresh->sql('SELECT task_name, items, state FROM '.$qualified.' WHERE id = 1')->execute()->fetchOne();
        if ($acceptingJobs) {
            $fresh->sql('INSERT INTO '.$qualified." (id, task_name, items, state) VALUES (2, 'unexpected', 1, 'done')")->execute();
        } else {
            $blockedNewJob = true;
        }
        $newJob = $fresh->sql('SELECT id FROM '.$qualified.' WHERE id = 2')->execute()->fetchOne();
    } finally {
        try { if ($fresh !== null) { $fresh->close(); } }
        finally { $client->close(); }
    }
    $codes = array_column($oldFailure ?? [], 'code');
    $rows = [['Завершённое задание', $saved['task_name']], ['Сохранённых позиций', $saved['items']], ['Состояние квитанции', $saved['state']],
        ['Фактический тип возврата Client::close', get_debug_type($closeResult)],
        ['Старая Session отклоняет запрос с 10056', in_array(10056, $codes, true)],
        ['Новая Session того же Client прочитала квитанцию', $saved === $completed],
        ['Приложение прекратило приём новых заданий', !$acceptingJobs && $blockedNewJob],
        ['Лишняя запись не создана', $newJob === null]];
    $checks = ['completed_receipt'=>$saved === ['task_name'=>'catalog-export','items'=>2,'state'=>'done'],
        'close_actual_null'=>$closeResult === null, 'old_session_closed'=>in_array(10056, $codes, true),
        'client_reopens'=>$saved === $completed, 'application_stopped'=>!$acceptingJobs && $blockedNewJob,
        'no_new_work'=>$newJob === null];
    $observations = ['options'=>$options, 'completed_before_close'=>$completed, 'client_close_return'=>$closeResult,
        'client_close_type'=>get_debug_type($closeResult), 'old_session_failure'=>$oldFailure, 'fresh_session_receipt'=>$saved,
        'accepting_jobs'=>$acceptingJobs, 'new_job'=>$newJob];
} finally {
    try {
        if ($schema instanceof mysql_xdevapi\Schema) {
            $removed = x144Cleanup($schema, $owned);
        }
    } finally {
        $session->close();
    }
}
x144Report('mysql144-x-client-shutdown', 'Завершить worker и различить close пула и запрет новой работы', $rows, $checks, $observations, $runtime, $owned, $removed);

Завершённое задание — catalog-export
Сохранённых позиций — 2
Состояние квитанции — done
Фактический тип возврата Client::close — null
Старая Session отклоняет запрос с 10056 — да
Новая Session того же Client прочитала квитанцию — да
Приложение прекратило приём новых заданий — да
Лишняя запись не создана — да

Запустите отдельным процессом PHP по README. lab.php создаёт одну собственную таблицу; программа сохраняет и перечитывает строки, освобождает Session/Client и удаляет свою таблицу. result.html показывает результат, result.json — реальные данные и безопасную диагностику, metrics.json — проверки.