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

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

$config = x140Config();
$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 = x140Name('computed');
    $handle = $schema->getCollection($name);
    $existed = $handle->existsInDatabase();
    if ($existed) {throw new RuntimeException('Случайное имя уже занято.');}
    $collection = $schema->createCollection($name);
    $owned[] = $name;

    $collection->add(['_id'=>'LAMP','sku'=>'LAMP','price'=>1200,'stock'=>4])->execute();
    $minimal = $collection->find('_id = :id')->bind(['id'=>'LAMP'])
        ->fields(['sku','price * stock AS inventory'])->execute()->fetchOne();
    $before = $collection->getOne('LAMP');
    $collection->modify('_id = :id')->bind(['id'=>'LAMP'])->set('note','price * stock')->execute();
    $literal = $collection->getOne('LAMP');
    $constructed = new mysql_xdevapi\Expression('stock + :extra');
    $collection->modify('_id = :id')->set('stock',$constructed)->bind(['id'=>'LAMP','extra'=>2])->execute();
    $afterConstructor = $collection->getOne('LAMP');
    $formula = mysql_xdevapi\expression('stock + :extra');
    $collection->modify('_id = :id')->set('stock',$formula)->bind(['id'=>'LAMP','extra'=>3])->execute();
    $after = $collection->getOne('LAMP');
    $minimalCorrect = (is_int($minimal['inventory']) || is_float($minimal['inventory']))
        && (float)$minimal['inventory'] === 4800.0;
    $constructorCorrect = (is_int($afterConstructor['stock']) || is_float($afterConstructor['stock']))
        && (float)$afterConstructor['stock'] === 6.0;
    $incrementCorrect = (is_int($after['stock']) || is_float($after['stock']))
        && (float)$after['stock'] === 9.0;
    $rows = [['Стоимость четырёх ламп', $minimalCorrect ? (int)$minimal['inventory'] : 'Неожиданное число'],
        ['В исходном документе появился inventory', array_key_exists('inventory',$before)],
        ['Обычная строка сохранена буквально', $literal['note']],
        ['После new Expression: поступило 2 лампы', $constructorCorrect ? (int)$afterConstructor['stock'] : 'Неожиданное число'],
        ['После expression: поступило ещё 3 лампы', $incrementCorrect ? (int)$after['stock'] : 'Неожиданное число']];
    $checks = ['minimal_value'=>$minimalCorrect,
        'projection_sku'=>$minimal['sku'] === 'LAMP',
        'projection_read_only'=>!array_key_exists('inventory',$before) && $before['stock'] === 4,
        'literal_preserved'=>$literal['note'] === 'price * stock',
        'function_expression'=>$formula instanceof mysql_xdevapi\Expression,
        'constructor_expression'=>$constructed instanceof mysql_xdevapi\Expression,
        'constructor_readback'=>$constructorCorrect,
        'increment_readback'=>$incrementCorrect && $after['price'] === 1200];
    $observations = ['minimal_projection'=>$minimal,
        'before_write'=>$before,'literal_readback'=>$literal,'after_constructor'=>$afterConstructor,'after_function_expression'=>$after,
        'expression_name_property'=>$constructed->name,
        'numeric_types'=>['inventory'=>get_debug_type($minimal['inventory']),
            'after_constructor_stock'=>get_debug_type($afterConstructor['stock']),
            'after_function_stock'=>get_debug_type($after['stock'])]];
} finally {
    try {
        if ($schema instanceof mysql_xdevapi\Schema) {
            $removed = x140Cleanup($schema, $owned);
        }
    } finally {
        $session->close();
    }
}
x140Report('mysql140-x-computed-stock', 'Вычислить стоимость остатка без лишнего поля в документе', $rows, $checks, $observations, $runtime, $owned, $removed);

Стоимость четырёх ламп — 4800
В исходном документе появился inventory — нет
Обычная строка сохранена буквально — price * stock
После new Expression: поступило 2 лампы — 6
После expression: поступило ещё 3 лампы — 9

Откройте result.html после запуска: строки получены из реальных ответов MySQL. result.json сохраняет документы и цепочки отказов; metrics.json — результаты проверок и очистки.

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

$config = x140Config();
$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 = x140Name('totals');
    $handle = $schema->getCollection($name);
    $existed = $handle->existsInDatabase();
    if ($existed) {throw new RuntimeException('Случайное имя уже занято.');}
    $collection = $schema->createCollection($name);
    $owned[] = $name;

    $collection->add(
        ['_id'=>'LAMP','sku'=>'LAMP','category'=>'lighting','warehouse'=>'central','price'=>1200,'stock'=>4,'active'=>true],
        ['_id'=>'STRIP','sku'=>'STRIP','category'=>'lighting','warehouse'=>'annex','price'=>1500,'stock'=>2,'active'=>true],
        ['_id'=>'CABLE','sku'=>'CABLE','category'=>'cable','warehouse'=>'central','price'=>300,'stock'=>10,'active'=>true],
        ['_id'=>'OLD','sku'=>'OLD','category'=>'lighting','warehouse'=>'central','price'=>99,'stock'=>100,'active'=>false]
    )->execute();

    $byCategory = $collection->find('active = true')
        ->fields(['category','COUNT(*) AS skus','SUM(stock) AS units','SUM(price * stock) AS amount'])
        ->groupBy('category')->sort('category ASC')->execute()->fetchAll();
    $byWarehouse = $collection->find('active = true')
        ->fields(['category','warehouse','SUM(stock) AS units'])
        ->groupBy(['category','warehouse'])->sort('category ASC','warehouse ASC')->execute()->fetchAll();
    $rows = [];
    foreach ($byCategory as $group) {
        $rows[] = [$group['category'], (int)$group['skus'].' SKU / '.(int)$group['units'].' шт. / '.(int)$group['amount'].' руб.'];
    }
    $rows[] = ['Групп категория + склад',count($byWarehouse)];
    $rows[] = ['Исходных документов в базе',$collection->count()];
    $checks = ['two_categories'=>count($byCategory) === 2,
        'cable_totals'=>$byCategory[0]['category'] === 'cable' && (float)$byCategory[0]['skus'] === 1.0 && (float)$byCategory[0]['units'] === 10.0 && (float)$byCategory[0]['amount'] === 3000.0,
        'lighting_totals'=>$byCategory[1]['category'] === 'lighting' && (float)$byCategory[1]['skus'] === 2.0 && (float)$byCategory[1]['units'] === 6.0 && (float)$byCategory[1]['amount'] === 7800.0,
        'two_key_grouping'=>count($byWarehouse) === 3 && $byWarehouse[1]['warehouse'] === 'annex' && (float)$byWarehouse[1]['units'] === 2.0,
        'documents_preserved'=>$collection->count() === 4];
    $observations = ['category_rows'=>$byCategory,'category_warehouse_rows'=>$byWarehouse,
        'all_documents'=>$collection->find()->sort('_id ASC')->execute()->fetchAll()];
} finally {
    try {
        if ($schema instanceof mysql_xdevapi\Schema) {
            $removed = x140Cleanup($schema, $owned);
        }
    } finally {
        $session->close();
    }
}
x140Report('mysql140-x-category-totals', 'Получить ведомость по категориям и складам', $rows, $checks, $observations, $runtime, $owned, $removed);

cable — 1 SKU / 10 шт. / 3000 руб.
lighting — 2 SKU / 6 шт. / 7800 руб.
Групп категория + склад — 3
Исходных документов в базе — 4

Откройте result.html после запуска: строки получены из реальных ответов MySQL. result.json сохраняет документы и цепочки отказов; metrics.json — результаты проверок и очистки.

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

$config = x140Config();
$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 = x140Name('threshold');
    $handle = $schema->getCollection($name);
    $existed = $handle->existsInDatabase();
    if ($existed) {throw new RuntimeException('Случайное имя уже занято.');}
    $collection = $schema->createCollection($name);
    $owned[] = $name;

    $collection->add(
        ['_id'=>'LAMP','sku'=>'LAMP','category'=>'lighting','warehouse'=>'central','price'=>1200,'stock'=>4,'active'=>true],
        ['_id'=>'STRIP','sku'=>'STRIP','category'=>'lighting','warehouse'=>'annex','price'=>1500,'stock'=>2,'active'=>true],
        ['_id'=>'CABLE','sku'=>'CABLE','category'=>'cable','warehouse'=>'central','price'=>300,'stock'=>10,'active'=>true],
        ['_id'=>'OLD','sku'=>'OLD','category'=>'lighting','warehouse'=>'central','price'=>99,'stock'=>100,'active'=>false]
    )->execute();

    $over = $collection->find('active = true')
        ->fields(['category','SUM(price * stock) AS amount'])
        ->groupBy('category')->having('SUM(price * stock) >= :minimum')->bind(['minimum'=>5000])
        ->sort('category ASC')->execute()->fetchAll();
    $early = $collection->find('active = true AND stock >= :stock')->bind(['stock'=>3])
        ->fields(['category','SUM(price * stock) AS amount'])->groupBy('category')
        ->sort('category ASC')->execute()->fetchAll();
    $none = $collection->find('active = true')
        ->fields(['category','SUM(price * stock) AS amount'])->groupBy('category')
        ->having('SUM(price * stock) >= :minimum')->bind(['minimum'=>10000])->execute()->fetchAll();
    $rows = [['Категория с суммой от 5000',$over[0]['category']],['Сумма всей категории',(int)$over[0]['amount']],
        ['lighting после раннего отбора stock >=3',(int)$early[1]['amount']], ['Групп с суммой от 10000',count($none)]];
    $checks = ['having_one_group'=>count($over) === 1 && $over[0]['category'] === 'lighting',
        'complete_group_amount'=>(float)$over[0]['amount'] === 7800.0,
        'different_population'=>count($early) === 2 && $early[1]['category'] === 'lighting' && (float)$early[1]['amount'] === 4800.0,
        'empty_is_array'=>$none === [],'documents_not_deleted'=>$collection->count() === 4];
    $observations = ['after_group_filter'=>$over,'before_group_filter'=>$early,'no_matching_groups'=>$none];
} finally {
    try {
        if ($schema instanceof mysql_xdevapi\Schema) {
            $removed = x140Cleanup($schema, $owned);
        }
    } finally {
        $session->close();
    }
}
x140Report('mysql140-x-group-threshold', 'Отобрать дорогие запасы после подсчёта групп', $rows, $checks, $observations, $runtime, $owned, $removed);

Категория с суммой от 5000 — lighting
Сумма всей категории — 7800
lighting после раннего отбора stock >=3 — 4800
Групп с суммой от 10000 — 0

Откройте result.html после запуска: строки получены из реальных ответов MySQL. result.json сохраняет документы и цепочки отказов; metrics.json — результаты проверок и очистки.

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

$config = x140Config();
$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 = x140Name('indexes');
    $handle = $schema->getCollection($name);
    $existed = $handle->existsInDatabase();
    if ($existed) {throw new RuntimeException('Случайное имя уже занято.');}
    $collection = $schema->createCollection($name);
    $owned[] = $name;

    $collection->add(
        ['_id'=>'LAMP','sku'=>'LAMP','category'=>'lighting','warehouse'=>'central','price'=>1200,'stock'=>4,'active'=>true],
        ['_id'=>'STRIP','sku'=>'STRIP','category'=>'lighting','warehouse'=>'annex','price'=>1500,'stock'=>2,'active'=>true],
        ['_id'=>'CABLE','sku'=>'CABLE','category'=>'cable','warehouse'=>'central','price'=>300,'stock'=>10,'active'=>true],
        ['_id'=>'OLD','sku'=>'OLD','category'=>'lighting','warehouse'=>'central','price'=>99,'stock'=>100,'active'=>false]
    )->execute();

    $before = $collection->find('category = :category AND price <= :price')
        ->bind(['category'=>'lighting','price'=>1300])->fields(['sku','price'])->sort('sku ASC')->execute()->fetchAll();
    $description = json_encode(['fields'=>[
        ['field'=>'$.category','type'=>'TEXT(40)','required'=>true],
        ['field'=>'$.price','type'=>'INT UNSIGNED','required'=>true]
    ]], JSON_THROW_ON_ERROR);
    $creation = $collection->createIndex('category_price',$description);
    $duplicate = x140Failure(static fn()=>$collection->createIndex('category_price',$description));
    $after = $collection->find('category = :category AND price <= :price')
        ->bind(['category'=>'lighting','price'=>1300])->fields(['sku','price'])->sort('sku ASC')->execute()->fetchAll();
    $dropped = $collection->dropIndex('category_price');
    $dropWarnings = [];
    set_error_handler(static function(int $severity, string $message) use (&$dropWarnings): bool {
        if ($severity === E_WARNING && str_contains($message,'Collection::dropIndex()')
            && str_contains($message,'[1091][42000]') && str_contains($message,"'category_price'")) {
            $dropWarnings[] = $message;
            return true;
        }
        return false;
    });
    try {$absent = $collection->dropIndex('category_price');}
    finally {restore_error_handler();}
    $rows = [['Артикулы выбранной страницы',implode(', ',array_column($after,'sku'))],
        ['Выдача до и после индекса совпадает',$before === $after],
        ['Повторное имя отклонено',$duplicate !== null],['Свой индекс удалён',$dropped],['Повторное удаление',$absent],
        ['Предупреждений отсутствующего индекса',count($dropWarnings)],
        ['Документов после удаления индекса',$collection->count()]];
    $checks = ['same_result'=>$before === $after && array_column($after,'sku') === ['LAMP','OLD'],
        'duplicate_failed'=>is_array($duplicate) && count($duplicate)>0,
        'create_return_observed'=>$creation === true,
        'drop_existing'=>$dropped === true,'drop_absent'=>$absent === false,
        'specific_absence_warning'=>count($dropWarnings) === 1,'documents_intact'=>$collection->count() === 4];
    $observations = ['index_description'=>json_decode($description,true,512,JSON_THROW_ON_ERROR),
        'before'=>$before,'after'=>$after,'create_return_type'=>get_debug_type($creation),
        'duplicate_exception_chain'=>$duplicate,'dropped'=>$dropped,'drop_absent'=>$absent,'drop_absent_warnings'=>$dropWarnings];
} finally {
    try {
        if ($schema instanceof mysql_xdevapi\Schema) {
            $removed = x140Cleanup($schema, $owned);
        }
    } finally {
        $session->close();
    }
}
x140Report('mysql140-x-index-lifecycle', 'Создать индекс каталога и удалить только его', $rows, $checks, $observations, $runtime, $owned, $removed);

Артикулы выбранной страницы — LAMP, OLD
Выдача до и после индекса совпадает — да
Повторное имя отклонено — да
Свой индекс удалён — да
Повторное удаление — нет
Предупреждений отсутствующего индекса — 1
Документов после удаления индекса — 4

Откройте result.html после запуска: строки получены из реальных ответов MySQL. result.json сохраняет документы и цепочки отказов; metrics.json — результаты проверок и очистки.

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

$config = x140Config();
$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 = x140Name('contract');
    $handle = $schema->getCollection($name);
    $existed = $handle->existsInDatabase();
    if ($existed) {throw new RuntimeException('Случайное имя уже занято.');}
    $collection = $schema->createCollection($name);
    $owned[] = $name;

    $collection->add(['_id'=>'BOX','sku'=>'BOX','weight'=>2],['_id'=>'BAG','sku'=>'BAG'])->execute();
    $optional = '{"fields":[{"field":"$.weight","type":"INT","required":false}]}';
    $required = '{"fields":[{"field":"$.weight","type":"INT","required":true}]}';
    $collection->createIndex('weight_optional',$optional);
    $optionalRead = $collection->getOne('BAG');
    $collection->dropIndex('weight_optional');
    $missingAtBuild = x140Failure(static fn()=>$collection->createIndex('weight_required',$required));
    $collection->modify('_id = :id')->bind(['id'=>'BAG'])->set('weight',1)->execute();
    $collection->createIndex('weight_required',$required);
    $missingAtInsert = x140Failure(static fn()=>$collection->add(['_id'=>'EMPTY','sku'=>'EMPTY'])->execute());
    $badJson = x140Failure(static fn()=>$collection->createIndex('bad_json','{"fields":['));
    $unknownField = x140Failure(static fn()=>$collection->createIndex('unknown_option',
        '{"fields":[{"field":"$.weight","type":"INT","unsupported_option":true}]}'));
    $badType = x140Failure(static fn()=>$collection->createIndex('bad_type','{"fields":[{"field":"$.weight","type":"NOT_A_SQL_TYPE"}]}'));
    $uniqueCreated = $collection->createIndex('unique_sku',
        '{"fields":[{"field":"$.sku","type":"TEXT(40)","required":true}],"unique":true}');
    $duplicateSku = x140Failure(static fn()=>$collection->add(['_id'=>'DUP','sku'=>'BOX','weight'=>3])->execute());
    $indexRows = $session->sql('SHOW INDEX FROM `'.$config['schema'].'`.`'.$name.'`')->execute()->fetchAll();
    $skuNonUnique = null;
    foreach ($indexRows as $indexRow) {
        if ($indexRow['Key_name'] === 'unique_sku') {$skuNonUnique = (int)$indexRow['Non_unique'];}
    }
    $bag = $collection->getOne('BAG');
    $empty = $collection->getOne('EMPTY') ?? null;
    $duplicate = $collection->getOne('DUP') ?? null;
    $rows = [['Optional сохранил документ без weight',!array_key_exists('weight',$optionalRead)],
        ['Required отклонён на старых неполных данных',$missingAtBuild !== null],
        ['Вес после исправления исходного документа',$bag['weight']],
        ['Новая запись без weight отклонена',$missingAtInsert !== null],
        ['Ошибочный JSON отклонён',$badJson !== null],['Неизвестная опция отклонена',$unknownField !== null],
        ['Неизвестный тип отклонён',$badType !== null],['Вызов с unique:true принят',$uniqueCreated === true],
        ['SHOW INDEX: Non_unique для unique_sku',$skuNonUnique],
        ['Повторный артикул с новым _id записался',$duplicateSku === null && $duplicate !== null],
        ['Сохранённых документов',$collection->count()]];
    $checks = ['optional_missing'=>!array_key_exists('weight',$optionalRead),
        'required_existing_missing_failed'=>$missingAtBuild !== null,
        'repaired_document'=>$bag['weight'] === 1,'required_new_missing_failed'=>$missingAtInsert !== null && $empty === null,
        'malformed_json_failed'=>$badJson !== null,'unknown_field_failed'=>$unknownField !== null,'unknown_type_failed'=>$badType !== null,
        'index_request_accepted'=>$uniqueCreated === true,
        'unique_flag_not_enforced'=>$skuNonUnique === 1,
        'duplicate_value_persisted'=>$duplicateSku === null && $duplicate !== null && $duplicate['sku'] === 'BOX' && $duplicate['weight'] === 3,
        'expected_document_count'=>$collection->count() === 3];
    $observations = ['optional_document'=>$optionalRead,'repaired_document'=>$bag,'absent_failed_insert'=>$empty,
        'missing_at_build'=>$missingAtBuild,'missing_at_insert'=>$missingAtInsert,
        'bad_json'=>$badJson,'unknown_option'=>$unknownField,'bad_type'=>$badType,
        'index_return_type'=>get_debug_type($uniqueCreated),'indexes'=>$indexRows,
        'duplicate_sku_exception'=>$duplicateSku,'duplicate_readback'=>$duplicate,
        'documents'=>$collection->find()->sort('_id ASC')->execute()->fetchAll()];
} finally {
    try {
        if ($schema instanceof mysql_xdevapi\Schema) {
            $removed = x140Cleanup($schema, $owned);
        }
    } finally {
        $session->close();
    }
}
x140Report('mysql140-x-index-data-contract', 'Проверить отсутствующее поле и ошибочное описание индекса', $rows, $checks, $observations, $runtime, $owned, $removed);

Optional сохранил документ без weight — да
Required отклонён на старых неполных данных — да
Вес после исправления исходного документа — 1
Новая запись без weight отклонена — да
Ошибочный JSON отклонён — да
Неизвестная опция отклонена — да
Неизвестный тип отклонён — да
Вызов с unique:true принят — да
SHOW INDEX: Non_unique для unique_sku — 1
Повторный артикул с новым _id записался — да
Сохранённых документов — 3

Откройте result.html после запуска: строки получены из реальных ответов MySQL. result.json сохраняет документы и цепочки отказов; metrics.json — результаты проверок и очистки.