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

<?php
declare(strict_types=1);
require __DIR__.'/lab.php';
$db=null;$owned=$removed=$rows=$checks=$observations=[];
try {
    $config=c168Config();$db=c168Connect();$runtime=c168Runtime($db);

    $name=c168CreateTable($db,$owned,'budgets',[
        ['id'=>1,'sku'=>'CAB-168','title'=>'Кабель','category'=>'electric','price_cents'=>12900,'qty'=>3],
        ['id'=>2,'sku'=>'TERM-168','title'=>'Клемма','category'=>'electric','price_cents'=>1500,'qty'=>7]
    ]);$table=c168Qualified($name);$screen=null;$report=null;
    $parameters=cubrid_get_db_parameter($db);
    if(!is_array($parameters)){throw new RuntimeException('Не получены параметры соединения.');}
    try {
        $screen=cubrid_prepare($db,'SELECT title,qty FROM '.$table.' WHERE qty>0 ORDER BY id LIMIT 2');
        $report=cubrid_prepare($db,'SELECT category,COUNT(*) AS positions,SUM(qty) AS units FROM '.$table.' GROUP BY category ORDER BY category');
        if(!is_resource($screen)||!is_resource($report)){throw new RuntimeException('Не подготовлены два запроса.');}
        $defaultScreen=cubrid_get_query_timeout($screen);$defaultReport=cubrid_get_query_timeout($report);
        if($defaultScreen===false||$defaultReport===false){throw new RuntimeException('Не прочитан исходный лимит.');}
        if(!cubrid_set_query_timeout($screen,250)||!cubrid_set_query_timeout($report,1500)){
            throw new RuntimeException('Лимиты запросов не заданы.');
        }
        $screenMs=cubrid_get_query_timeout($screen);$reportMs=cubrid_get_query_timeout($report);
        if(!cubrid_execute($screen)){throw new RuntimeException('Экранный SELECT не завершён.');}
        $items=c168Rows($screen);
        if(!cubrid_execute($report)){throw new RuntimeException('Отчёт не завершён.');}
        $summary=c168Rows($report);
        // Changing one request does not silently reconfigure the other request.
        if(!cubrid_set_query_timeout($screen,400)){throw new RuntimeException('Лимит экрана не изменён.');}
        $afterChange=cubrid_get_query_timeout($screen);$reportStill=cubrid_get_query_timeout($report);
    } finally {c168Release($screen);c168Release($report);}
    c168Commit($db);
    $rows=[['Лимит экранного SELECT, мс',$screenMs],['Лимит отчёта, мс',$reportMs],
        ['Первая карточка',$items[0]['title'].' / остаток '.$items[0]['qty']],
        ['Вторая карточка',$items[1]['title'].' / остаток '.$items[1]['qty']],
        ['Отчёт по категории',$summary[0]['category'].' / позиций '.$summary[0]['positions'].' / единиц '.$summary[0]['units']],
        ['Новый лимит только экрана, мс',$afterChange],['Лимит отчёта остался, мс',$reportStill],
        ['Явные транзакции',(int)$parameters['PARAM_AUTO_COMMIT']===0]];
    $checks=['screen_budget'=>$screenMs===250,'report_budget'=>$reportMs===1500,
        'screen_rows'=>$items===[['title'=>'Кабель','qty'=>'3'],['title'=>'Клемма','qty'=>'7']],
        'report_value'=>count($summary)===1&&$summary[0]['category']==='electric'&&(int)$summary[0]['positions']===2&&(int)$summary[0]['units']===10,
        'independent_budgets'=>$afterChange===400&&$reportStill===1500,
        'explicit_transactions'=>(int)$parameters['PARAM_AUTO_COMMIT']===0,
        'requests_closed'=>$screen===null&&$report===null];
    $observations=['connection_parameters'=>$parameters,'request_defaults_ms'=>[$defaultScreen,$defaultReport],
        'screen'=>$items,'summary'=>$summary,'budgets_ms'=>['screen'=>250,'report'=>1500,'screen_after'=>400]];

} finally {
    if (function_exists('c168LockChildStopped') && !c168LockChildStopped()) {
        throw new RuntimeException('Дочерний процесс ещё работает; очистка таблицы запрещена до его остановки.');
    }
    if (is_resource($db)) {try {$removed=c168Cleanup($db,$owned);} finally {c168Close($db);}}
}

c168Report('cub168-request-budgets','Разделить допустимое ожидание экрана и небольшого отчёта',$rows,$checks,$observations,$runtime,$owned,$removed);

Лимит экранного SELECT, мс — 250
Лимит отчёта, мс — 1500
Первая карточка — Кабель / остаток 3
Вторая карточка — Клемма / остаток 7
Отчёт по категории — electric / позиций 2 / единиц 10
Новый лимит только экрана, мс — 400
Лимит отчёта остался, мс — 1500
Явные транзакции — да

Распакуйте полный ZIP и запустите example.php по README.txt в отдельной CUBRID-лаборатории. Одна собственная таблица создаётся и удаляется в finally; result.html показывает значения, result.json — наблюдения, metrics.json — проверки. Реквизиты подключения остаются в закрытом окружении.

<?php
declare(strict_types=1);
require __DIR__.'/lab.php';
require __DIR__.'/lock-lab.php';
$job=null;$db=null;$owned=$removed=$rows=$checks=$observations=[];
try {
    $config=c168Config();$job=c168LockStartEarly();$db=c168Connect();$runtime=c168Runtime($db);

    $name=c168CreateTable($db,$owned,'lockwait',[
        ['id'=>1,'sku'=>'CAB-168','title'=>'Кабель','category'=>'electric','price_cents'=>12900,'qty'=>3],
        ['id'=>2,'sku'=>'TERM-168','title'=>'Клемма','category'=>'electric','price_cents'=>1500,'qty'=>7,'note'=>'обычный']
    ]);$table=c168Qualified($name);$request=null;$proof=null;
    $initial=cubrid_get_db_parameter($db);
    if(!is_array($initial)){throw new RuntimeException('Не прочитаны параметры соединения.');}
    $attempt=null;$rollbackDone=false;$pendingChanged=false;
    try {
        if(!cubrid_set_db_parameter($db,CUBRID_PARAM_LOCK_TIMEOUT,1000)){
            throw new RuntimeException('Не задано ожидание блокировки.');
        }
        $params=cubrid_get_db_parameter($db);$lockMs=$params['PARAM_LOCK_TIMEOUT'];
        c168Commit($db);
        c168LockBegin($job,$name,$owned); // Returns only after the owner really holds row 1.
        // No preceding business write in the short lock-wait scenario.
        $request=cubrid_prepare($db,'UPDATE '.$table.' SET qty=qty-1 WHERE id=1 AND qty>0');
        if($request===false){throw new RuntimeException('Не подготовлена попытка резервирования.');}
        if(!cubrid_set_query_timeout($request,5000)){throw new RuntimeException('Не задан лимит запроса.');}
        $queryMs=cubrid_get_query_timeout($request);
        $started=microtime(true);
        $attempt=c168Capture(static function() use($request){return cubrid_execute($request);});
        $elapsedMs=(microtime(true)-$started)*1000;
        if($attempt['value']!==false||!$attempt['warning']||!$attempt['message_present']
            ||$attempt['code']!==-75||$attempt['facility']!==1){
            throw new RuntimeException('Ожидался диагностированный отказ при реальной блокировке.');
        }
        c168Release($request);
        // End the whole unsuccessful business operation explicitly, before a new attempt.
        c168Rollback($db);$rollbackDone=true;
    } finally {
        if(is_resource($request)){c168Release($request);}
        if(!$rollbackDone){c168Rollback($db);}
        if($job!==null&&!c168LockChildStopped()){$proof=c168LockStop($job);}
        if(!cubrid_set_db_parameter($db,CUBRID_PARAM_LOCK_TIMEOUT,(int)$initial['PARAM_LOCK_TIMEOUT'])){
            throw new RuntimeException('Исходное ожидание блокировки не восстановлено.');
        }
    }
    $afterFailure=c168Read($db,'SELECT id,title,qty,note FROM '.$table.' WHERE id IN (1,2) ORDER BY id');
    c168Commit($db);
    // This is an explicit second operation after the conflicting owner has finished.
    $reserved=c168Command($db,'UPDATE '.$table.' SET qty=qty-1 WHERE id=1 AND qty>0');
    if($reserved!==1){c168Rollback($db);throw new RuntimeException('Новая операция не зарезервировала товар.');}
    c168Commit($db);
    $final=c168Read($db,'SELECT title,qty FROM '.$table.' WHERE id=1');c168Commit($db);
    $restored=cubrid_get_db_parameter($db);
    $rows=[['Товар','Кабель'],['Ожидание блокировки, мс',$lockMs],['Лимит команды, мс',$queryMs],
        ['Первая попытка остановлена',($attempt['value']===false)],['Операция явно отменена',$rollbackDone],
        ['Остаток после двух откатов',(int)$afterFailure[0]['qty']],
        ['Примечание второй позиции',$afterFailure[1]['note']],
        ['Владелец блокировки завершён',$proof['stopped']&&$proof['exit_code']===0],
        ['Новая операция зарезервировала',1],['Итоговый остаток',(int)$final[0]['qty']]];
    $checks=['lock_budget'=>$lockMs===1000,'query_budget'=>$queryMs===5000,
        'diagnosed_timeout'=>$attempt['value']===false&&$attempt['code']===-75&&$attempt['facility']===1&&$attempt['warning']&&$attempt['message_present'],
        'explicit_rollback'=>$rollbackDone,'no_partial_change'=>$afterFailure[0]['qty']==='3'&&$afterFailure[1]['note']==='обычный',
        'owner_rollback'=>$proof['completed']['rolled_back']===true&&$proof['completed']['row']['qty']==='3',
        'owner_stopped'=>$proof['stopped']&&$proof['exit_code']===0&&!$proof['termination_by_parent'],
        'new_operation'=>$reserved===1&&$final===[['title'=>'Кабель','qty'=>'2']],
        'setting_restored'=>$restored['PARAM_LOCK_TIMEOUT']===$initial['PARAM_LOCK_TIMEOUT'],
        'request_closed'=>$request===null];
    $observations=['timeout_kind'=>'lock_timeout','diagnostic'=>$attempt,'elapsed_ms_observed'=>$elapsedMs,
        'lock_milliseconds'=>$lockMs,'query_milliseconds'=>$queryMs,'pending_note_changed_before_failure'=>$pendingChanged,
        'after_rollback'=>$afterFailure,'final_card'=>$final,
        'lock_child'=>array_intersect_key($proof,array_flip(['started','stopped','exit_code','termination_by_parent',
            'deadline_seconds','handshake','completed','launch_handshake'])),
        'settings_before'=>$initial,'settings_after'=>$restored];

} finally {
    if($job!==null&&!c168LockChildStopped()){c168LockStop($job);}
    if (function_exists('c168LockChildStopped') && !c168LockChildStopped()) {
        throw new RuntimeException('Дочерний процесс ещё работает; очистка таблицы запрещена до его остановки.');
    }
    if (is_resource($db)) {try {$removed=c168Cleanup($db,$owned);} finally {c168Close($db);}}
}

c168Report('cub168-lock-timeout','Не держать посетителя в ожидании занятого остатка',$rows,$checks,$observations,$runtime,$owned,$removed);

Товар — Кабель
Ожидание блокировки, мс — 1000
Лимит команды, мс — 5000
Первая попытка остановлена — да
Операция явно отменена — да
Остаток после двух откатов — 3
Примечание второй позиции — обычный
Владелец блокировки завершён — да
Новая операция зарезервировала — 1
Итоговый остаток — 2

Распакуйте полный ZIP и запустите example.php по README.txt в отдельной CUBRID-лаборатории. Одна собственная таблица создаётся и удаляется в finally; result.html показывает значения, result.json — наблюдения, metrics.json — проверки. Реквизиты подключения остаются в закрытом окружении. Проект запускает один короткий PHP-процесс до первого подключения родителя, синхронизируется сообщениями, затем подтверждает его остановку до удаления таблицы. Это две реальные сессии, а не выдуманный ответ execute.

<?php
declare(strict_types=1);
require __DIR__.'/lab.php';
require __DIR__.'/lock-lab.php';
$job=null;$db=null;$owned=$removed=$rows=$checks=$observations=[];
try {
    $config=c168Config();$job=c168LockStartEarly();$db=c168Connect();$runtime=c168Runtime($db);

    $name=c168CreateTable($db,$owned,'querywait',[
        ['id'=>1,'sku'=>'CAB-168','title'=>'Кабель','category'=>'electric','price_cents'=>12900,'qty'=>3],
        ['id'=>2,'sku'=>'TERM-168','title'=>'Клемма','category'=>'electric','price_cents'=>1500,'qty'=>7,'note'=>'обычный']
    ]);$table=c168Qualified($name);$request=null;$proof=null;
    $initial=cubrid_get_db_parameter($db);
    if(!is_array($initial)){throw new RuntimeException('Не прочитаны параметры соединения.');}
    $attempt=null;$rollbackDone=false;$pendingChanged=false;
    try {
        if(!cubrid_set_db_parameter($db,CUBRID_PARAM_LOCK_TIMEOUT,5000)){
            throw new RuntimeException('Не задано ожидание блокировки.');
        }
        $params=cubrid_get_db_parameter($db);$lockMs=$params['PARAM_LOCK_TIMEOUT'];
        c168Commit($db);
        c168LockBegin($job,$name,$owned); // Returns only after the owner really holds row 1.
        $pendingChanged=c168Command($db,'UPDATE '.$table.' SET note=? WHERE id=2',['ожидает резервирования'])===1;
        $request=cubrid_prepare($db,'UPDATE '.$table.' SET qty=qty-1 WHERE id=1 AND qty>0');
        if($request===false){throw new RuntimeException('Не подготовлена попытка резервирования.');}
        if(!cubrid_set_query_timeout($request,200)){throw new RuntimeException('Не задан лимит запроса.');}
        $queryMs=cubrid_get_query_timeout($request);
        $started=microtime(true);
        $attempt=c168Capture(static function() use($request){return cubrid_execute($request);});
        $elapsedMs=(microtime(true)-$started)*1000;
        if($attempt['value']!==false||!$attempt['warning']||!$attempt['message_present']
            ||$attempt['code']!==-4||$attempt['facility']!==1){
            throw new RuntimeException('Ожидался диагностированный отказ при реальной блокировке.');
        }
        c168Release($request);
        // End the whole unsuccessful business operation explicitly, before a new attempt.
        c168Rollback($db);$rollbackDone=true;
    } finally {
        if(is_resource($request)){c168Release($request);}
        if(!$rollbackDone){c168Rollback($db);}
        if($job!==null&&!c168LockChildStopped()){$proof=c168LockStop($job);}
        if(!cubrid_set_db_parameter($db,CUBRID_PARAM_LOCK_TIMEOUT,(int)$initial['PARAM_LOCK_TIMEOUT'])){
            throw new RuntimeException('Исходное ожидание блокировки не восстановлено.');
        }
    }
    $afterFailure=c168Read($db,'SELECT id,title,qty,note FROM '.$table.' WHERE id IN (1,2) ORDER BY id');
    c168Commit($db);
    // This is an explicit second operation after the conflicting owner has finished.
    $reserved=c168Command($db,'UPDATE '.$table.' SET qty=qty-1 WHERE id=1 AND qty>0');
    if($reserved!==1){c168Rollback($db);throw new RuntimeException('Новая операция не зарезервировала товар.');}
    c168Commit($db);
    $final=c168Read($db,'SELECT title,qty FROM '.$table.' WHERE id=1');c168Commit($db);
    $restored=cubrid_get_db_parameter($db);
    $rows=[['Товар','Кабель'],['Ожидание блокировки, мс',$lockMs],['Лимит команды, мс',$queryMs],
        ['Первая попытка остановлена',($attempt['value']===false)],['Операция явно отменена',$rollbackDone],
        ['Остаток после двух откатов',(int)$afterFailure[0]['qty']],
        ['Примечание второй позиции',$afterFailure[1]['note']],
        ['Владелец блокировки завершён',$proof['stopped']&&$proof['exit_code']===0],
        ['Новая операция зарезервировала',1],['Итоговый остаток',(int)$final[0]['qty']]];
    $checks=['lock_budget'=>$lockMs===5000,'query_budget'=>$queryMs===200,
        'diagnosed_timeout'=>$attempt['value']===false&&$attempt['code']===-4&&$attempt['facility']===1&&$attempt['warning']&&$attempt['message_present'],
        'explicit_rollback'=>$rollbackDone,'no_partial_change'=>$afterFailure[0]['qty']==='3'&&$afterFailure[1]['note']==='обычный',
        'owner_rollback'=>$proof['completed']['rolled_back']===true&&$proof['completed']['row']['qty']==='3',
        'owner_stopped'=>$proof['stopped']&&$proof['exit_code']===0&&!$proof['termination_by_parent'],
        'new_operation'=>$reserved===1&&$final===[['title'=>'Кабель','qty'=>'2']],
        'setting_restored'=>$restored['PARAM_LOCK_TIMEOUT']===$initial['PARAM_LOCK_TIMEOUT'],
        'request_closed'=>$request===null];
    $observations=['timeout_kind'=>'query_timeout','diagnostic'=>$attempt,'elapsed_ms_observed'=>$elapsedMs,
        'lock_milliseconds'=>$lockMs,'query_milliseconds'=>$queryMs,'pending_note_changed_before_failure'=>$pendingChanged,
        'after_rollback'=>$afterFailure,'final_card'=>$final,
        'lock_child'=>array_intersect_key($proof,array_flip(['started','stopped','exit_code','termination_by_parent',
            'deadline_seconds','handshake','completed','launch_handshake'])),
        'settings_before'=>$initial,'settings_after'=>$restored];

} finally {
    if($job!==null&&!c168LockChildStopped()){c168LockStop($job);}
    if (function_exists('c168LockChildStopped') && !c168LockChildStopped()) {
        throw new RuntimeException('Дочерний процесс ещё работает; очистка таблицы запрещена до его остановки.');
    }
    if (is_resource($db)) {try {$removed=c168Cleanup($db,$owned);} finally {c168Close($db);}}
}

c168Report('cub168-query-timeout','Отменить всю операцию, когда истёк бюджет конкретной команды',$rows,$checks,$observations,$runtime,$owned,$removed);

Товар — Кабель
Ожидание блокировки, мс — 5000
Лимит команды, мс — 200
Первая попытка остановлена — да
Операция явно отменена — да
Остаток после двух откатов — 3
Примечание второй позиции — обычный
Владелец блокировки завершён — да
Новая операция зарезервировала — 1
Итоговый остаток — 2

Распакуйте полный ZIP и запустите example.php по README.txt в отдельной CUBRID-лаборатории. Одна собственная таблица создаётся и удаляется в finally; result.html показывает значения, result.json — наблюдения, metrics.json — проверки. Реквизиты подключения остаются в закрытом окружении. Проект запускает один короткий PHP-процесс до первого подключения родителя, синхронизируется сообщениями, затем подтверждает его остановку до удаления таблицы. Это две реальные сессии, а не выдуманный ответ execute.

<?php
declare(strict_types=1);
require __DIR__.'/lab.php';
$db=null;$owned=$removed=$rows=$checks=$observations=[];
try {
    $config=c168Config();$db=c168Connect();$runtime=c168Runtime($db);

    $name=c168CreateTable($db,$owned,'isolation',[
        ['id'=>1,'sku'=>'CAB-168','title'=>'Кабель','category'=>'electric','price_cents'=>12900,'qty'=>3]
    ]);$table=c168Qualified($name);$other=null;$runs=[];
    $original=cubrid_get_db_parameter($db);
    if(!is_array($original)){throw new RuntimeException('Не получена исходная изоляция.');}
    try {
        $other=c168Connect(); // new_link=true: another real session, not a second variable for the same connection.
        foreach([4,5] as $level){
            c168Rollback($db);c168Rollback($other);
            c168Command($other,'UPDATE '.$table.' SET qty=3 WHERE id=1');c168Commit($other);
            if(!cubrid_set_db_parameter($db,CUBRID_PARAM_ISOLATION_LEVEL,$level)){
                throw new RuntimeException('Уровень изоляции не принят.');
            }
            $active=cubrid_get_db_parameter($db);
            $first=c168Read($db,'SELECT title,qty FROM '.$table.' WHERE id=1');
            c168Command($other,'UPDATE '.$table.' SET qty=7 WHERE id=1');c168Commit($other);
            $second=c168Read($db,'SELECT title,qty FROM '.$table.' WHERE id=1');
            c168Commit($db);
            $next=c168Read($db,'SELECT title,qty FROM '.$table.' WHERE id=1');c168Commit($db);
            $runs[]=['level'=>$active['PARAM_ISOLATION_LEVEL'],'before'=>$first[0],
                'after_foreign_commit'=>$second[0],'after_own_commit'=>$next[0]];
        }
    } finally {
        c168Rollback($db);
        if(is_resource($other)){c168Rollback($other);c168Close($other);}
        if(!cubrid_set_db_parameter($db,CUBRID_PARAM_ISOLATION_LEVEL,(int)$original['PARAM_ISOLATION_LEVEL'])){
            throw new RuntimeException('Исходная изоляция не восстановлена.');
        }
    }
    $restored=cubrid_get_db_parameter($db);
    $rows=[['Товар','Кабель'],['READ COMMITTED: первое чтение',(int)$runs[0]['before']['qty']],
        ['READ COMMITTED: после чужого COMMIT',(int)$runs[0]['after_foreign_commit']['qty']],
        ['REPEATABLE READ: первое чтение',(int)$runs[1]['before']['qty']],
        ['REPEATABLE READ: после чужого COMMIT',(int)$runs[1]['after_foreign_commit']['qty']],
        ['REPEATABLE READ: после собственного COMMIT',(int)$runs[1]['after_own_commit']['qty']],
        ['Исходный режим восстановлен',$restored['PARAM_ISOLATION_LEVEL']===$original['PARAM_ISOLATION_LEVEL']]];
    $checks=['levels_readback'=>array_column($runs,'level')===[4,5],
        'committed_read'=>$runs[0]['before']['qty']==='3'&&$runs[0]['after_foreign_commit']['qty']==='7',
        'repeatable_read'=>$runs[1]['before']['qty']==='3'&&$runs[1]['after_foreign_commit']['qty']==='3',
        'new_transaction_sees_commit'=>$runs[1]['after_own_commit']['qty']==='7',
        'named_cards'=>$runs[0]['before']['title']==='Кабель'&&$runs[1]['after_own_commit']['title']==='Кабель',
        'restored_isolation'=>$restored['PARAM_ISOLATION_LEVEL']===$original['PARAM_ISOLATION_LEVEL'],
        'other_session_closed'=>$other===null];
    $observations=['two_sessions'=>true,'runs'=>$runs,'initial_parameters'=>$original,'restored_parameters'=>$restored];

} finally {
    if (function_exists('c168LockChildStopped') && !c168LockChildStopped()) {
        throw new RuntimeException('Дочерний процесс ещё работает; очистка таблицы запрещена до его остановки.');
    }
    if (is_resource($db)) {try {$removed=c168Cleanup($db,$owned);} finally {c168Close($db);}}
}

c168Report('cub168-read-isolation','Сравнить карточку сейчас и стабильное чтение внутри транзакции',$rows,$checks,$observations,$runtime,$owned,$removed);

Товар — Кабель
READ COMMITTED: первое чтение — 3
READ COMMITTED: после чужого COMMIT — 7
REPEATABLE READ: первое чтение — 3
REPEATABLE READ: после чужого COMMIT — 3
REPEATABLE READ: после собственного COMMIT — 7
Исходный режим восстановлен — да

Распакуйте полный ZIP и запустите example.php по README.txt в отдельной CUBRID-лаборатории. Одна собственная таблица создаётся и удаляется в finally; result.html показывает значения, result.json — наблюдения, metrics.json — проверки. Реквизиты подключения остаются в закрытом окружении.