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

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

$config = x145Config();
$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']];

    $collectionName=x145OwnCollection($schema,$owned,'generated_ids');
    $documents=$schema->getCollection($collectionName);
    $documentReceipt=$documents->add(['sku'=>'LED','qty'=>2])->execute();
    $documentIds=$documentReceipt->getGeneratedIds();
    if (count($documentIds)!==1 || !is_string($documentIds[0]) || $documentIds[0]==='') {
        throw new RuntimeException('Сервер не вернул один строковый ID документа.');
    }
    $savedDocumentRows=$documents->find('_id = :id')->bind(['id'=>$documentIds[0]])->execute()->fetchAll();
    $name=x145OwnTable($session,$schema,$owned,'order_ids',
        '(id INT AUTO_INCREMENT PRIMARY KEY, order_ref VARCHAR(30) NOT NULL UNIQUE, qty INT NOT NULL) ENGINE=InnoDB');
    $qualified=x145Qualified($schema,$name);
    $sqlReceipt=$session->sql('INSERT INTO '.$qualified.' (order_ref,qty) VALUES (?,?)')
        ->bind('ORDER-101')->bind(2)->execute();
    $sqlGeneratedIds=$sqlReceipt->getGeneratedIds();
    $insertId=$sqlReceipt->getLastInsertId();
    $savedOrderRows=$session->sql('SELECT id,order_ref,qty FROM '.$qualified.' WHERE id = ?')
        ->bind($insertId)->execute()->fetchAll();
    $documentMatches=count($savedDocumentRows)===1
        && $savedDocumentRows[0]['_id']===$documentIds[0]
        && $savedDocumentRows[0]['sku']==='LED' && $savedDocumentRows[0]['qty']===2;
    $orderMatches=count($savedOrderRows)===1 && $savedOrderRows[0]['id']===$insertId
        && $savedOrderRows[0]['order_ref']==='ORDER-101' && $savedOrderRows[0]['qty']===2;
    $rows=[['Сгенерировано ID документов',count($documentIds)],
        ['Документ прочитан по полученному ID',$documentMatches],
        ['SQL getGeneratedIds: элементов',count($sqlGeneratedIds)],
        ['SQL-заказ прочитан по getLastInsertId',$orderMatches],
        ['Сохранённый заказ',$savedOrderRows[0]['order_ref']],
        ['Количество заказа',$savedOrderRows[0]['qty']]];
    $checks=['document_id_readback'=>$documentMatches,'sql_id_readback'=>$orderMatches && $insertId>0,
        'different_id_channels'=>$sqlGeneratedIds===[] && $sqlReceipt instanceof mysql_xdevapi\SqlStatementResult
            && $documentReceipt instanceof mysql_xdevapi\Result];
    $observations=['document_generated_ids'=>$documentIds,'document_rows'=>$savedDocumentRows,
        'sql_generated_ids'=>$sqlGeneratedIds,'sql_last_insert_id'=>$insertId,'sql_last_insert_id_type'=>get_debug_type($insertId),
        'order_rows'=>$savedOrderRows,'document_receipt_type'=>get_debug_type($documentReceipt),
        'sql_receipt_type'=>get_debug_type($sqlReceipt)];

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

x145Report('mysql145-x-generated-id-kinds', 'Связать созданный документ и SQL-заказ с их собственными ID', $rows, $checks, $observations, $runtime, $owned, $removed);

Сгенерировано ID документов — 1
Документ прочитан по полученному ID — да
SQL getGeneratedIds: элементов — 0
SQL-заказ прочитан по getLastInsertId — да
Сохранённый заказ — ORDER-101
Количество заказа — 2

CLI-программа создаёт собственные учебные объекты в подготовленной локальной схеме, сохраняет результат и настоящую диагностику, затем удаляет только эти объекты. Это самостоятельный пример, не обработчик формы.

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

$config = x145Config();
$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=x145OwnTable($session,$schema,$owned,'price_review',
        '(id INT PRIMARY KEY, sku VARCHAR(20) NOT NULL, price DECIMAL(8,2) NOT NULL) ENGINE=InnoDB');
    $qualified=x145Qualified($schema,$name);
    $inputPrice='12.345';
    $receipt=$session->sql('INSERT INTO '.$qualified.' (id,sku,price) VALUES (?,?,?)')
        ->bind(1)->bind('LED')->bind($inputPrice)->execute();
    $warnings=$receipt->getWarnings();
    $warningCount=$receipt->getWarningsCount();
    $warningRows=[];
    foreach ($warnings as $warning) {
        $warningRows[]=['type'=>get_debug_type($warning),'code'=>$warning->code,
            'level'=>$warning->level,'message'=>$warning->message];
    }
    $saved=$session->sql('SELECT sku,price FROM '.$qualified.' WHERE id = ?')->bind(1)->execute()->fetchAll();
    $rows=[['Переданная цена',$inputPrice],['Сохранённая цена',$saved[0]['price']],
        ['Вставлено строк',$receipt->getAffectedItemsCount()],['Предупреждений',$warningCount],
        ['Объект предупреждения',$warningRows[0]['type']],['Код',$warningRows[0]['code']],
        ['Уровень',$warningRows[0]['level']]];
    $checks=['warning_is_native'=>count($warnings)===1 && $warnings[0] instanceof mysql_xdevapi\Warning,
        'rounding_reported'=>$warningCount===1 && $warningRows[0]['code']===1265 && $warningRows[0]['level']===1,
        'price_readback'=>$saved===[['sku'=>'LED','price'=>'12.35']] && $receipt->getAffectedItemsCount()===1,
        'warning_message_present'=>is_string($warningRows[0]['message']) && $warningRows[0]['message']!==''];
    $observations=['input_price'=>$inputPrice,'warning_count'=>$warningCount,'warnings'=>$warningRows,
        'saved_rows'=>$saved,'saved_price_type'=>get_debug_type($saved[0]['price']),
        'affected'=>$receipt->getAffectedItemsCount(),'sql_mode'=>$session->sql('SELECT @@SESSION.sql_mode AS mode')->execute()->fetchAll()];

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

x145Report('mysql145-x-warning-object-review', 'Увидеть округление цены вместе с настоящим предупреждением', $rows, $checks, $observations, $runtime, $owned, $removed);

Переданная цена — 12.345
Сохранённая цена — 12.35
Вставлено строк — 1
Предупреждений — 1
Объект предупреждения — mysql_xdevapi\Warning
Код — 1265
Уровень — 1

CLI-программа создаёт собственные учебные объекты в подготовленной локальной схеме, сохраняет результат и настоящую диагностику, затем удаляет только эти объекты. Это самостоятельный пример, не обработчик формы.

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

$config = x145Config();
$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']];

    function readOperation(mysql_xdevapi\SqlStatement $statement): array {
        $context=(object)['events'=>[],'rows'=>[],'warnings'=>[],'errors'=>[],
            'ends'=>[],'ok_calls'=>[]];
        $onRow=static function ($ctx,array $row,array $columns) use ($context): void {
            $context->events[]='row';
            $context->rows[]=['same_context'=>$ctx===$context,'row'=>$row,
                'column_types'=>array_map(static fn($column)=>get_debug_type($column),$columns)];
        };
        $onWarning=static function ($ctx,int $code,string $message) use ($context): void {
            $context->events[]='warning';
            $context->warnings[]=['same_context'=>$ctx===$context,'code'=>$code,
                'message'=>x145SafeMessage($message)];
        };
        $onError=static function ($ctx,int $code,string $sqlstate,string $message) use ($context): void {
            $context->events[]='error';
            $context->errors[]=['same_context'=>$ctx===$context,'code'=>$code,
                'sqlstate'=>$sqlstate,'message'=>x145SafeMessage($message)];
        };
        $onEnd=static function ($ctx,bool $hasMore) use ($context): void {
            $context->events[]='resultset_end';
            $context->ends[]=['same_context'=>$ctx===$context,'has_more'=>$hasMore];
        };
        $onOk=static function (...$args) use ($context): void {
            $context->events[]='statement_ok';
            $types=array_map(static fn($value)=>get_debug_type($value),$args);
            $context->ok_calls[]=['argc'=>count($args),'types'=>$types,
                'same_context'=>isset($args[0]) && $args[0]===$context,
                'execution_status_received'=>in_array('mysql_xdevapi\ExecutionStatus',$types,true)];
        };
        $arguments=[$onRow,$onWarning,$onError,$onEnd,$onOk,$context];
        $sent=$statement->execute(mysql_xdevapi\SqlStatement::EXECUTE_ASYNC);
        if ($sent!==true) {throw new RuntimeException('Не удалось отправить команду.');}
        $reads=[['method'=>'getResult','value'=>$statement->getResult(...$arguments)]];
        $more=[$statement->hasMoreResults()];
        while ($more[array_key_last($more)]) {
            if (count($reads)>=4) {throw new RuntimeException('Ответ содержит больше четырёх ожидаемых частей.');}
            $reads[]=['method'=>'getNextResult','value'=>$statement->getNextResult(...$arguments)];
            $more[]=$statement->hasMoreResults();
        }
        return ['sent'=>$sent,'reads'=>$reads,'has_more'=>$more,'context'=>$context];
    }

    $name=x145OwnTable($session,$schema,$owned,'confirmed_orders',
        '(id INT AUTO_INCREMENT PRIMARY KEY, order_ref VARCHAR(30) NOT NULL UNIQUE, amount DECIMAL(8,2) NOT NULL) ENGINE=InnoDB');
    $qualified=x145Qualified($schema,$name);
    $normalReceipt=$session->sql('INSERT INTO '.$qualified.' (order_ref,amount) VALUES (?,?)')
        ->bind('ORDER-NORMAL')->bind('12.34')->execute();
    $normalId=$normalReceipt->getLastInsertId();
    $normalAffected=$normalReceipt->getAffectedItemsCount();
    $statement=$session->sql('INSERT INTO '.$qualified.' (order_ref,amount) VALUES (?,?)')
        ->bind('ORDER-CALLBACK')->bind('3.456');
    $outcome=readOperation($statement);
    $context=$outcome['context'];
    $saved=$session->sql('SELECT order_ref,amount FROM '.$qualified.' ORDER BY id')->execute()->fetchAll();
    $control=$session->sql('SELECT 1 AS ready')->execute()->fetchOne();
    $ok=$context->ok_calls[0] ?? null;
    if ($ok===null) {throw new RuntimeException('Не получено подтверждение успешного завершения.');}
    $rows=[['Команда отправлена',$outcome['sent']],
        ['Ответ записи прочитан',$outcome['reads'][0]['value']],
        ['События записи',implode(' → ',$context->events)],
        ['Аргументов callback успешного завершения',$ok['argc']],
        ['Объект ExecutionStatus передан',$ok['execution_status_received']],
        ['Сохранённая сумма ORDER-CALLBACK',$saved[1]['amount']],
        ['Обычный ответ: вставлено строк',$normalAffected],
        ['Следующий запрос выполнен',$control['ready']===1]];
    $checks=['callback_success_consumed'=>$outcome['sent']===true && $outcome['reads']===[['method'=>'getResult','value'=>true]]
            && $outcome['has_more']===[false] && $context->errors===[],
        'actual_callback_arguments'=>$ok!==null && $ok['argc']===1 && $ok['types']===['stdClass']
            && $ok['same_context']===true && $ok['execution_status_received']===false,
        'warning_and_completion'=>$context->events===['warning','statement_ok'] && count($context->warnings)===1
            && $context->warnings[0]['code']===1265 && $context->warnings[0]['same_context']===true,
        'normal_receipt_available'=>$normalReceipt instanceof mysql_xdevapi\SqlStatementResult && $normalAffected===1 && $normalId>0,
        'saved_amounts_exact'=>$saved===[['order_ref'=>'ORDER-NORMAL','amount'=>'12.34'],['order_ref'=>'ORDER-CALLBACK','amount'=>'3.46']],
        'session_ready'=>$control===['ready'=>1]];
    $observations=['callback_outcome'=>$outcome,'normal_receipt'=>['type'=>get_debug_type($normalReceipt),
        'affected'=>$normalAffected,'last_insert_id'=>$normalId],'saved_rows'=>$saved,'control'=>$control];

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

x145Report('mysql145-x-callback-write-receipt', 'Отделить отправку заказа от подтверждения и сохранённой суммы', $rows, $checks, $observations, $runtime, $owned, $removed);

Команда отправлена — да
Ответ записи прочитан — да
События записи — warning → statement_ok
Аргументов callback успешного завершения — 1
Объект ExecutionStatus передан — нет
Сохранённая сумма ORDER-CALLBACK — 3.46
Обычный ответ: вставлено строк — 1
Следующий запрос выполнен — да

CLI-программа создаёт собственные учебные объекты в подготовленной локальной схеме, сохраняет результат и настоящую диагностику, затем удаляет только эти объекты. Это самостоятельный пример, не обработчик формы.

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

$config = x145Config();
$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']];

    function readOperation(mysql_xdevapi\SqlStatement $statement): array {
        $context=(object)['events'=>[],'rows'=>[],'warnings'=>[],'errors'=>[],
            'ends'=>[],'ok_calls'=>[]];
        $onRow=static function ($ctx,array $row,array $columns) use ($context): void {
            $context->events[]='row';
            $context->rows[]=['same_context'=>$ctx===$context,'row'=>$row,
                'column_types'=>array_map(static fn($column)=>get_debug_type($column),$columns)];
        };
        $onWarning=static function ($ctx,int $code,string $message) use ($context): void {
            $context->events[]='warning';
            $context->warnings[]=['same_context'=>$ctx===$context,'code'=>$code,
                'message'=>x145SafeMessage($message)];
        };
        $onError=static function ($ctx,int $code,string $sqlstate,string $message) use ($context): void {
            $context->events[]='error';
            $context->errors[]=['same_context'=>$ctx===$context,'code'=>$code,
                'sqlstate'=>$sqlstate,'message'=>x145SafeMessage($message)];
        };
        $onEnd=static function ($ctx,bool $hasMore) use ($context): void {
            $context->events[]='resultset_end';
            $context->ends[]=['same_context'=>$ctx===$context,'has_more'=>$hasMore];
        };
        $onOk=static function (...$args) use ($context): void {
            $context->events[]='statement_ok';
            $types=array_map(static fn($value)=>get_debug_type($value),$args);
            $context->ok_calls[]=['argc'=>count($args),'types'=>$types,
                'same_context'=>isset($args[0]) && $args[0]===$context,
                'execution_status_received'=>in_array('mysql_xdevapi\ExecutionStatus',$types,true)];
        };
        $arguments=[$onRow,$onWarning,$onError,$onEnd,$onOk,$context];
        $sent=$statement->execute(mysql_xdevapi\SqlStatement::EXECUTE_ASYNC);
        if ($sent!==true) {throw new RuntimeException('Не удалось отправить команду.');}
        $reads=[['method'=>'getResult','value'=>$statement->getResult(...$arguments)]];
        $more=[$statement->hasMoreResults()];
        while ($more[array_key_last($more)]) {
            if (count($reads)>=4) {throw new RuntimeException('Ответ содержит больше четырёх ожидаемых частей.');}
            $reads[]=['method'=>'getNextResult','value'=>$statement->getNextResult(...$arguments)];
            $more[]=$statement->hasMoreResults();
        }
        return ['sent'=>$sent,'reads'=>$reads,'has_more'=>$more,'context'=>$context];
    }

    $name=x145OwnTable($session,$schema,$owned,'rejected_orders',
        '(id INT AUTO_INCREMENT PRIMARY KEY, order_ref VARCHAR(30) NOT NULL UNIQUE, amount DECIMAL(8,2) NOT NULL) ENGINE=InnoDB');
    $qualified=x145Qualified($schema,$name);
    $session->sql('INSERT INTO '.$qualified.' (order_ref,amount) VALUES (?,?)')
        ->bind('ORDER-A')->bind('12.34')->execute();
    $statement=$session->sql('INSERT INTO '.$qualified.' (order_ref,amount) VALUES (?,?)')
        ->bind('ORDER-A')->bind('99.99');
    $outcome=readOperation($statement);
    $context=$outcome['context'];
    $error=$context->errors[0] ?? null;
    if ($error===null) {throw new RuntimeException('Ожидаемый отказ повторной вставки не получен.');}
    $saved=$session->sql('SELECT order_ref,amount FROM '.$qualified.' WHERE order_ref = ?')
        ->bind('ORDER-A')->execute()->fetchAll();
    $control=$session->sql('SELECT 1 AS ready')->execute()->fetchOne();
    $rows=[['Команда отправлена',$outcome['sent']],['Ответ сообщает успех',$outcome['reads'][0]['value']],
        ['Код отказа',$error['code']],['SQLSTATE',$error['sqlstate']],
        ['Успешных callback завершения',count($context->ok_calls)],
        ['Сохранённых заказов ORDER-A',count($saved)],['Исходная сумма сохранена',$saved[0]['amount']],
        ['Следующий запрос выполнен',$control['ready']===1]];
    $checks=['sent_not_completed'=>$outcome['sent']===true && $outcome['reads']===[['method'=>'getResult','value'=>false]],
        'duplicate_received'=>$context->events===['error'] && count($context->errors)===1 && $error['code']===1062
            && $error['sqlstate']==='23000' && $error['same_context']===true && $error['message']!=='',
        'no_success_event'=>$context->ok_calls===[],
        'original_unchanged'=>$saved===[['order_ref'=>'ORDER-A','amount'=>'12.34']],
        'error_response_consumed'=>$outcome['has_more']===[false] && $control===['ready'=>1]];
    $observations=['callback_outcome'=>$outcome,'saved_rows'=>$saved,'control'=>$control,
        'attempted'=>['order_ref'=>'ORDER-A','amount'=>'99.99']];

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

x145Report('mysql145-x-callback-rejected-import', 'Отклонить повторный заказ и сохранить исходные данные', $rows, $checks, $observations, $runtime, $owned, $removed);

Команда отправлена — да
Ответ сообщает успех — нет
Код отказа — 1062
SQLSTATE — 23000
Успешных callback завершения — 0
Сохранённых заказов ORDER-A — 1
Исходная сумма сохранена — 12.34
Следующий запрос выполнен — да

CLI-программа создаёт собственные учебные объекты в подготовленной локальной схеме, сохраняет результат и настоящую диагностику, затем удаляет только эти объекты. Это самостоятельный пример, не обработчик формы.