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,'factory_catalog',
        '(id INT AUTO_INCREMENT PRIMARY KEY, sku VARCHAR(20) NOT NULL UNIQUE, stock INT NOT NULL) ENGINE=InnoDB');
    $catalog=$schema->getTable($name);
    $insert=$catalog->insert('sku','stock')->values(['LED',5],['BOX',3]);
    $insertResult=$insert->execute();
    $temporary=$catalog->insert('sku','stock')->values(['DRAFT',0])->execute();
    $draftId=$temporary->getAutoIncrementValue();
    $update=$catalog->update()->set('stock',7)->where('sku = :sku')->bind(['sku'=>'LED']);
    $updateResult=$update->execute();
    $delete=$catalog->delete()->where('id = :id')->bind(['id'=>$draftId]);
    $deleteResult=$delete->execute();
    $select=$catalog->select('sku','stock')->orderby('id');
    $result=$select->execute();
    $saved=$result->fetchAll();
    $types=['table'=>get_debug_type($catalog),'insert'=>get_debug_type($insert),
        'update'=>get_debug_type($update),'delete'=>get_debug_type($delete),
        'select'=>get_debug_type($select),'write_result'=>get_debug_type($updateResult),
        'rows'=>get_debug_type($result)];
    $rows=[['Сохранённый LED',$saved[0]['stock']],['Сохранённый BOX',$saved[1]['stock']],
        ['Удалено временных строк',$deleteResult->getAffectedItemsCount()],
        ['Команда обновления',$types['update']],['Квитанция записи',$types['write_result']],
        ['Результат чтения',$types['rows']]];
    $checks=['saved_catalog_exact'=>$saved===[['sku'=>'LED','stock'=>7],['sku'=>'BOX','stock'=>3]],
        'write_receipts'=>$insertResult->getAffectedItemsCount()===2 && $updateResult->getAffectedItemsCount()===1 && $deleteResult->getAffectedItemsCount()===1,
        'factory_types'=>$catalog instanceof mysql_xdevapi\Table && $insert instanceof mysql_xdevapi\TableInsert && $update instanceof mysql_xdevapi\TableUpdate && $delete instanceof mysql_xdevapi\TableDelete && $select instanceof mysql_xdevapi\TableSelect && $updateResult instanceof mysql_xdevapi\Result && $result instanceof mysql_xdevapi\RowResult];
    $observations=['types'=>$types,'saved_rows'=>$saved,'temporary_id'=>$draftId,
        'inserted'=>$insertResult->getAffectedItemsCount(),'updated'=>$updateResult->getAffectedItemsCount(),'deleted'=>$deleteResult->getAffectedItemsCount()];

} finally {
    try {
        if ($schema instanceof mysql_xdevapi\Schema) {
            $removed = x144Cleanup($schema, $owned);
        }
    } finally {
        $session->close();
    }
}

x144Report('mysql144-x-factory-table-workflow', 'Получить товар, команду и результат через их фабрики', $rows, $checks, $observations, $runtime, $owned, $removed);

Сохранённый LED — 7
Сохранённый BOX — 3
Удалено временных строк — 1
Команда обновления — mysql_xdevapi\TableUpdate
Квитанция записи — mysql_xdevapi\Result
Результат чтения — mysql_xdevapi\RowResult

CLI-программа создаёт одну собственную таблицу InnoDB в подготовленной учебной схеме, выполняет запросы, сохраняет данные readback и удаляет только свой объект. Новые участники используют отдельные соединения; все транзакции завершаются до уборки. Это не HTTP-обработчик.

<?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,'factory_report',
        '(id INT PRIMARY KEY, sku VARCHAR(20) NOT NULL, qty INT NOT NULL, price_kopecks INT NOT NULL) ENGINE=InnoDB');
    $sales=$schema->getTable($name);
    $sales->insert('id','sku','qty','price_kopecks')->values([1,'LED',2,1200],[2,'BOX',3,400],[3,'TAPE',1,350])->execute();
    $statement=$session->sql('SELECT sku AS product, qty, qty * price_kopecks AS total_kopecks FROM '
        .x144Qualified($schema,$name).' WHERE qty >= ? ORDER BY id')->bind(2);
    $result=$statement->execute();
    $columns=$result->getColumns();
    $metadata=[];
    foreach ($columns as $column) {
        $metadata[]=['class'=>get_debug_type($column),'label'=>$column->getColumnLabel(),
            'name'=>$column->getColumnName(),'type'=>$column->getType()];
    }
    $saved=$result->fetchAll();
    $labels=array_column($metadata,'label');
    $rows=[['Товары отчёта',implode(', ',array_column($saved,'product'))],
        ['LED: сумма в копейках',$saved[0]['total_kopecks']],['BOX: сумма в копейках',$saved[1]['total_kopecks']],
        ['Подписи полей',implode(', ',$labels)],['SQL-команда',get_debug_type($statement)],
        ['SQL-результат',get_debug_type($result)],['Объект столбца',get_debug_type($columns[0])]];
    $checks=['report_rows_exact'=>$saved===[['product'=>'LED','qty'=>2,'total_kopecks'=>2400],['product'=>'BOX','qty'=>3,'total_kopecks'=>1200]],
        'metadata_matches_projection'=>$labels===['product','qty','total_kopecks'] && count($columns)===3,
        'sql_factory_types'=>$statement instanceof mysql_xdevapi\SqlStatement && $result instanceof mysql_xdevapi\SqlStatementResult && $columns[0] instanceof mysql_xdevapi\ColumnResult];
    $observations=['rows'=>$saved,'metadata'=>$metadata,'statement_type'=>get_debug_type($statement),'result_type'=>get_debug_type($result)];

} finally {
    try {
        if ($schema instanceof mysql_xdevapi\Schema) {
            $removed = x144Cleanup($schema, $owned);
        }
    } finally {
        $session->close();
    }
}

x144Report('mysql144-x-factory-sql-report', 'Получить заполненный SQL-отчёт и описание его полей', $rows, $checks, $observations, $runtime, $owned, $removed);

Товары отчёта — LED, BOX
LED: сумма в копейках — 2400
BOX: сумма в копейках — 1200
Подписи полей — product, qty, total_kopecks
SQL-команда — mysql_xdevapi\SqlStatement
SQL-результат — mysql_xdevapi\SqlStatementResult
Объект столбца — mysql_xdevapi\ColumnResult

CLI-программа создаёт одну собственную таблицу InnoDB в подготовленной учебной схеме, выполняет запросы, сохраняет данные readback и удаляет только свой объект. Новые участники используют отдельные соединения; все транзакции завершаются до уборки. Это не HTTP-обработчик.

<?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,'exclusive_stock',
        '(id INT PRIMARY KEY, sku VARCHAR(20) NOT NULL, stock INT NOT NULL, reserved_by VARCHAR(20) NULL) ENGINE=InnoDB');
    $catalog=$schema->getTable($name);
    $catalog->insert('id','sku','stock','reserved_by')->values([1,'LED',1,null])->execute();
    $other=mysql_xdevapi\getSession($config['uri']);
    $otherSchema=$other->getSchema($config['schema']);
    $otherCatalog=$otherSchema->getTable($name);
    $aOpen=$bOpen=false;
    try {
        $connectionA=$session->sql('SELECT CONNECTION_ID() AS id')->execute()->fetchOne()['id'];
        $connectionB=$other->sql('SELECT CONNECTION_ID() AS id')->execute()->fetchOne()['id'];
        $session->startTransaction(); $aOpen=true;
        $command=$catalog->select('id','stock')->where('id = 1')->lockExclusive();
        $lockedResult=$command->execute(); $first=$lockedResult->fetchOne();
        $ordinary=$otherCatalog->select('stock')->where('id = 1')->execute()->fetchOne();
        $other->startTransaction(); $bOpen=true;
        $conflict=x144Failure(static function () use ($otherCatalog): void {
            $otherCatalog->select('id','stock')->where('id = 1')->lockExclusive(MYSQLX_LOCK_NOWAIT)->execute()->fetchAll();
        });
        $other->rollback(); $bOpen=false;
        if ($first['stock'] < 1) {throw new RuntimeException('Нет остатка для первого резерва.');}
        $receipt=$catalog->update()->set('stock',$first['stock']-1)->set('reserved_by','ORDER-A')->where('id = 1')->execute();
        if ($receipt->getAffectedItemsCount()!==1) {throw new RuntimeException('Первый резерв не записан.');}
        $session->commit(); $aOpen=false;
        $other->startTransaction(); $bOpen=true;
        $second=$otherCatalog->select('id','stock','reserved_by')->where('id = 1')->lockExclusive(MYSQLX_LOCK_NOWAIT)->execute()->fetchOne();
        $secondReserved=false;
        if ($second['stock'] >= 1) {
            $change=$otherCatalog->update()->set('stock',$second['stock']-1)->set('reserved_by','ORDER-B')->where('id = 1')->execute();
            if ($change->getAffectedItemsCount()!==1) {throw new RuntimeException('Второй резерв не записан.');}
            $secondReserved=true;
        }
        $other->commit(); $bOpen=false;
        $saved=$catalog->select('sku','stock','reserved_by')->where('id = 1')->execute()->fetchOne();
        $codes=array_column($conflict ?? [],'code');
        $rows=[['Первый прочитал остаток',$first['stock']],['Обычное чтение до записи',$ordinary['stock']],
            ['NOWAIT нашёл конфликт',in_array(3572,$codes,true) ? 'да' : 'нет'],
            ['Второй прочитал после commit',$second['stock']],['Второй создал резерв',$secondReserved ? 'да' : 'нет'],
            ['Финальный остаток',$saved['stock']],['Владелец резерва',$saved['reserved_by']]];
        $checks=['independent_connections'=>$connectionA!==$connectionB,
            'nowait_conflict_observed'=>in_array(3572,$codes,true),
            'ordinary_read_is_not_blocked'=>$ordinary===['stock'=>1],
            'last_item_reserved_once'=>$saved===['sku'=>'LED','stock'=>0,'reserved_by'=>'ORDER-A'] && $second['stock']===0 && !$secondReserved,
            'lock_builder_and_result'=>$command instanceof mysql_xdevapi\TableSelect && $lockedResult instanceof mysql_xdevapi\RowResult];
        $observations=['connection_ids'=>[$connectionA,$connectionB],'first'=>$first,'ordinary'=>$ordinary,'nowait_error_chain'=>$conflict,
            'second'=>$second,'saved'=>$saved,'builder_type'=>get_debug_type($command),'result_type'=>get_debug_type($lockedResult)];
    } finally {
        try {if ($bOpen) {$other->rollback();}} finally {
            try {if ($aOpen) {$session->rollback();}} finally {$other->close();}
        }
    }

} finally {
    try {
        if ($schema instanceof mysql_xdevapi\Schema) {
            $removed = x144Cleanup($schema, $owned);
        }
    } finally {
        $session->close();
    }
}

x144Report('mysql144-x-table-exclusive-reservation', 'Зарезервировать последнюю единицу без второго владельца', $rows, $checks, $observations, $runtime, $owned, $removed);

Первый прочитал остаток — 1
Обычное чтение до записи — 1
NOWAIT нашёл конфликт — да
Второй прочитал после commit — 0
Второй создал резерв — нет
Финальный остаток — 0
Владелец резерва — ORDER-A

CLI-программа создаёт одну собственную таблицу InnoDB в подготовленной учебной схеме, выполняет запросы, сохраняет данные readback и удаляет только свой объект. Новые участники используют отдельные соединения; все транзакции завершаются до уборки. Это не HTTP-обработчик.

<?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,'shared_price',
        '(id INT PRIMARY KEY, price_kopecks INT NOT NULL) ENGINE=InnoDB');
    $prices=$schema->getTable($name);
    $prices->insert('id','price_kopecks')->values([1,1200])->execute();
    $reader=mysql_xdevapi\getSession($config['uri']);
    $editor=null; $aOpen=$bOpen=$cOpen=false;
    try {
        $editor=mysql_xdevapi\getSession($config['uri']);
        $readerSchema=$reader->getSchema($config['schema']); $readerPrices=$readerSchema->getTable($name);
        $editorSchema=$editor->getSchema($config['schema']); $editorPrices=$editorSchema->getTable($name);
        $ids=[$session->sql('SELECT CONNECTION_ID() AS id')->execute()->fetchOne()['id'],
            $reader->sql('SELECT CONNECTION_ID() AS id')->execute()->fetchOne()['id'],
            $editor->sql('SELECT CONNECTION_ID() AS id')->execute()->fetchOne()['id']];
        $session->startTransaction(); $aOpen=true;
        $a=$prices->select('price_kopecks')->where('id = 1')->lockShared()->execute()->fetchOne();
        $reader->startTransaction(); $bOpen=true;
        $b=$readerPrices->select('price_kopecks')->where('id = 1')->lockShared(MYSQLX_LOCK_NOWAIT)->execute()->fetchOne();
        $editor->startTransaction(); $cOpen=true;
        $conflict=x144Failure(static function () use ($editorPrices): void {
            $editorPrices->select('id')->where('id = 1')->lockExclusive(MYSQLX_LOCK_NOWAIT)->execute()->fetchAll();
        });
        $editor->rollback(); $cOpen=false;
        $session->commit(); $aOpen=false;
        $reader->commit(); $bOpen=false;
        $editor->startTransaction(); $cOpen=true;
        $available=$editorPrices->select('price_kopecks')->where('id = 1')->lockExclusive(MYSQLX_LOCK_NOWAIT)->execute()->fetchOne();
        $receipt=$editorPrices->update()->set('price_kopecks',1350)->where('id = 1')->execute();
        if ($receipt->getAffectedItemsCount()!==1) {throw new RuntimeException('Новая цена не записана.');}
        $editor->commit(); $cOpen=false;
        $saved=$prices->select('price_kopecks')->where('id = 1')->execute()->fetchOne();
        $codes=array_column($conflict ?? [],'code');
        $rows=[['Первый проверяющий',$a['price_kopecks']],['Второй проверяющий',$b['price_kopecks']],
            ['Изменение во время проверки',in_array(3572,$codes,true) ? 'отложено' : 'не защищено'],
            ['Цена перед разрешённым изменением',$available['price_kopecks']],['Сохранённая новая цена',$saved['price_kopecks']]];
        $checks=['three_independent_sessions'=>count(array_unique($ids))===3,
            'shared_readers_compatible'=>$a===['price_kopecks'=>1200] && $b===$a,
            'exclusive_conflicts_with_readers'=>in_array(3572,$codes,true),
            'write_after_readers_finish'=>$available===$a && $saved===['price_kopecks'=>1350]];
        $observations=['connection_ids'=>$ids,'reader_a'=>$a,'reader_b'=>$b,'nowait_error_chain'=>$conflict,'after_release'=>$available,'saved'=>$saved];
    } finally {
        try {if ($cOpen && $editor instanceof mysql_xdevapi\Session) {$editor->rollback();}} finally {
            try {if ($bOpen) {$reader->rollback();}} finally {
                try {if ($aOpen) {$session->rollback();}} finally {
                    try {if ($editor instanceof mysql_xdevapi\Session) {$editor->close();}} finally {$reader->close();}
                }
            }
        }
    }

} finally {
    try {
        if ($schema instanceof mysql_xdevapi\Schema) {
            $removed = x144Cleanup($schema, $owned);
        }
    } finally {
        $session->close();
    }
}

x144Report('mysql144-x-table-shared-review', 'Дать двум проверяющим прочитать цену и отложить её изменение', $rows, $checks, $observations, $runtime, $owned, $removed);

Первый проверяющий — 1200
Второй проверяющий — 1200
Изменение во время проверки — отложено
Цена перед разрешённым изменением — 1200
Сохранённая новая цена — 1350

CLI-программа создаёт одну собственную таблицу InnoDB в подготовленной учебной схеме, выполняет запросы, сохраняет данные readback и удаляет только свой объект. Новые участники используют отдельные соединения; все транзакции завершаются до уборки. Это не HTTP-обработчик.

<?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,'worker_queue',
        '(id INT PRIMARY KEY, task VARCHAR(40) NOT NULL, status VARCHAR(20) NOT NULL, claimed_by VARCHAR(20) NULL, INDEX queue_state (status,id)) ENGINE=InnoDB');
    $queue=$schema->getTable($name);
    $queue->insert('id','task','status','claimed_by')->values(
        [1,'preview_LED','pending',null],[2,'preview_BOX','pending',null],[3,'preview_TAPE','pending',null])->execute();
    $workerB=mysql_xdevapi\getSession($config['uri']);
    $schemaB=$workerB->getSchema($config['schema']); $queueB=$schemaB->getTable($name);
    $aOpen=$bOpen=false;
    try {
        $ids=[$session->sql('SELECT CONNECTION_ID() AS id')->execute()->fetchOne()['id'],
            $workerB->sql('SELECT CONNECTION_ID() AS id')->execute()->fetchOne()['id']];
        $session->startTransaction(); $aOpen=true;
        // Worker A has been assigned candidate 1 and claims that exact existing row.
        $first=$queue->select('id','task')->where('id = 1 AND status = :state')->bind(['state'=>'pending'])->lockExclusive()->execute()->fetchOne();
        if (!$first) {throw new RuntimeException('Первое задание недоступно.');}
        $workerB->startTransaction(); $bOpen=true;
        $available=$queueB->select('id','task')->where('status = :state')->bind(['state'=>'pending'])
            ->orderby('id')->limit(1)->lockExclusive(MYSQLX_LOCK_SKIP_LOCKED)->execute()->fetchAll();
        if (count($available)!==1) {throw new RuntimeException('Не найдено ожидаемое свободное задание.');}
        $second=$available[0];
        $bReceipt=$queueB->update()->set('status','processing')->set('claimed_by','worker-B')->where('id = :id')->bind(['id'=>$second['id']])->execute();
        if ($bReceipt->getAffectedItemsCount()!==1) {throw new RuntimeException('Задание B не закреплено.');}
        $workerB->commit(); $bOpen=false;
        $aReceipt=$queue->update()->set('status','processing')->set('claimed_by','worker-A')->where('id = :id')->bind(['id'=>$first['id']])->execute();
        if ($aReceipt->getAffectedItemsCount()!==1) {throw new RuntimeException('Задание A не закреплено.');}
        $session->commit(); $aOpen=false;
        $saved=$queue->select('id','status','claimed_by')->orderby('id')->execute()->fetchAll();
        $rows=[['Задание worker-A',$first['id']],['Задание worker-B',$second['id']],
            ['Владелец задания 1',$saved[0]['claimed_by']],['Владелец задания 2',$saved[1]['claimed_by']],
            ['Задание 3 осталось',$saved[2]['status']]];
        $checks=['independent_workers'=>$ids[0]!==$ids[1],
            'locked_candidate_skipped'=>$first['id']===1 && $second['id']===2 && $first['id']!==$second['id'],
            'claims_saved_exactly'=>$saved===[['id'=>1,'status'=>'processing','claimed_by'=>'worker-A'],['id'=>2,'status'=>'processing','claimed_by'=>'worker-B'],['id'=>3,'status'=>'pending','claimed_by'=>null]]];
        $observations=['connection_ids'=>$ids,'held_candidate'=>$first,'available_candidates'=>$available,'saved_rows'=>$saved];
    } finally {
        try {if ($bOpen) {$workerB->rollback();}} finally {
            try {if ($aOpen) {$session->rollback();}} finally {$workerB->close();}
        }
    }

} finally {
    try {
        if ($schema instanceof mysql_xdevapi\Schema) {
            $removed = x144Cleanup($schema, $owned);
        }
    } finally {
        $session->close();
    }
}

x144Report('mysql144-x-table-skip-locked-queue', 'Выдать свободное задание, пока первое уже занято', $rows, $checks, $observations, $runtime, $owned, $removed);

Задание worker-A — 1
Задание worker-B — 2
Владелец задания 1 — worker-A
Владелец задания 2 — worker-B
Задание 3 осталось — pending

CLI-программа создаёт одну собственную таблицу InnoDB в подготовленной учебной схеме, выполняет запросы, сохраняет данные readback и удаляет только свой объект. Новые участники используют отдельные соединения; все транзакции завершаются до уборки. Это не HTTP-обработчик.

<?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,'rollback_stock',
        '(id INT PRIMARY KEY, stock INT NOT NULL, reserved_by VARCHAR(20) NULL) ENGINE=InnoDB');
    $stock=$schema->getTable($name);
    $stock->insert('id','stock','reserved_by')->values([1,2,null])->execute();
    $next=mysql_xdevapi\getSession($config['uri']);
    $nextSchema=$next->getSchema($config['schema']); $nextStock=$nextSchema->getTable($name);
    $aOpen=$bOpen=false;
    try {
        $ids=[$session->sql('SELECT CONNECTION_ID() AS id')->execute()->fetchOne()['id'],
            $next->sql('SELECT CONNECTION_ID() AS id')->execute()->fetchOne()['id']];
        $rejection=null;
        try {
            $session->startTransaction(); $aOpen=true;
            $before=$stock->select('stock')->where('id = 1')->lockExclusive()->execute()->fetchOne();
            if ($before['stock']<1) {throw new RuntimeException('Нет остатка.');}
            $change=$stock->update()->set('stock',$before['stock']-1)->set('reserved_by','REJECTED')->where('id = 1')->execute();
            if ($change->getAffectedItemsCount()!==1) {throw new RuntimeException('Пробный резерв не записан.');}
            $inside=$stock->select('stock','reserved_by')->where('id = 1')->execute()->fetchOne();
            $deliveryAllowed=false; // Fixed local business condition; no external call.
            if (!$deliveryAllowed) {throw new DomainException('Доставка в выбранную зону недоступна.');}
            $session->commit(); $aOpen=false;
        } catch (DomainException $error) {
            $rejection=$error->getMessage();
        } finally {
            if ($aOpen) {$session->rollback(); $aOpen=false;}
        }
        $restored=$stock->select('stock','reserved_by')->where('id = 1')->execute()->fetchOne();
        $next->startTransaction(); $bOpen=true;
        $unlocked=$nextStock->select('stock','reserved_by')->where('id = 1')->lockExclusive(MYSQLX_LOCK_NOWAIT)->execute()->fetchOne();
        if ($unlocked['stock']<1) {throw new RuntimeException('Нет остатка для следующего заказа.');}
        $receipt=$nextStock->update()->set('stock',$unlocked['stock']-1)->set('reserved_by','ORDER-B')->where('id = 1')->execute();
        if ($receipt->getAffectedItemsCount()!==1) {throw new RuntimeException('Следующий резерв не записан.');}
        $next->commit(); $bOpen=false;
        $saved=$stock->select('stock','reserved_by')->where('id = 1')->execute()->fetchOne();
        $rows=[['Остаток внутри отклонённого заказа',$inside['stock']],['Остаток после rollback',$restored['stock']],
            ['Старый резерв отменён',$restored['reserved_by']===null ? 'да' : 'нет'],
            ['Следующий получил строку через NOWAIT','да'],['Новый остаток',$saved['stock']],['Новый владелец',$saved['reserved_by']]];
        $checks=['independent_sessions'=>$ids[0]!==$ids[1],
            'business_rejection_observed'=>$rejection==='Доставка в выбранную зону недоступна.' && $inside===['stock'=>1,'reserved_by'=>'REJECTED'],
            'rollback_restores_entire_row'=>$restored===['stock'=>2,'reserved_by'=>null],
            'rollback_releases_lock'=>$unlocked===$restored,
            'next_reservation_saved'=>$saved===['stock'=>1,'reserved_by'=>'ORDER-B']];
        $observations=['connection_ids'=>$ids,'before'=>$before,'inside'=>$inside,'rejection'=>$rejection,'after_rollback'=>$restored,'next_locked_read'=>$unlocked,'saved'=>$saved];
    } finally {
        try {if ($bOpen) {$next->rollback();}} finally {
            try {if ($aOpen) {$session->rollback();}} finally {$next->close();}
        }
    }

} finally {
    try {
        if ($schema instanceof mysql_xdevapi\Schema) {
            $removed = x144Cleanup($schema, $owned);
        }
    } finally {
        $session->close();
    }
}

x144Report('mysql144-x-table-rollback-release', 'Отменить отклонённый резерв и освободить строку', $rows, $checks, $observations, $runtime, $owned, $removed);

Остаток внутри отклонённого заказа — 1
Остаток после rollback — 2
Старый резерв отменён — да
Следующий получил строку через NOWAIT — да
Новый остаток — 1
Новый владелец — ORDER-B

CLI-программа создаёт одну собственную таблицу InnoDB в подготовленной учебной схеме, выполняет запросы, сохраняет данные readback и удаляет только свой объект. Новые участники используют отдельные соединения; все транзакции завершаются до уборки. Это не HTTP-обработчик.