Есть ли простой способ обработать ситуацию 'DATABASE IS LOCKED' при обращении к SQLite из PHP?

Question

[Mithgol]

По адресу www.php.net/manual/en/pdo.begintransaction.php в комментариях рекомендуют вот такой способ оформления транзакций при обращении к базе SQLite:

<?php<br>
$conn = new PDO('sqlite:C:\path\to\file.sqlite');<br>
$stmt = $conn->prepare('INSERT INTO my_table(my_id, my_value) VALUES(?, ?)');<br>
$waiting = true; // Set a loop condition to test for<br>
while($waiting) {<br>
    try {<br>
        $conn->beginTransaction();<br>
        for($i=0; $i < 10; $i++) {<br>
            $stmt->bindValue(1, $i, PDO::PARAM_INT);<br>
            $stmt->bindValue(2, 'TEST', PDO::PARAM_STR);<br>
            $stmt->execute();<br>
            sleep(1);<br>
        }<br>
        $conn->commit();<br>
        $waiting = false;<br>
    } catch(PDOException $e) {<br>
        if(stripos($e->getMessage(), 'DATABASE IS LOCKED') !== false) {<br>
            // This should be specific to SQLite, sleep for 0.25 seconds<br>
            // and try again.  We do have to commit the open transaction first though<br>
            $conn->commit();<br>
            usleep(250000);<br>
        } else {<br>
            $conn->rollBack();<br>
            throw $e;<br>
        }<br>
    }<br>
}<br>

Спрашивается: существует ли ещё более нехитрый и изящный способ обработки ситуации 'DATABASE IS LOCKED'?



Можно ли, например, принудить модуль PDO в языке PHP к самостоятельному ожиданию разблокировки базы данных в течение некоторого заданного времени?



(А не то, сами понимаете, если при каждом обращении такой if нагородить, то падает обозримость кода и читаемость.)

Comments

[Сергей Савостин]

А кстати, почему ip, а не while?

[Сергей Савостин]

Сори, if

[Mithgol]

Собственно говоря — и if, и while, и даже $waiting.

[Сергей Савостин]

Отето я тупой…

Answer 1

[Сергей Береснев]

Можно написать небольшую обвёртку.

<?php

function myQuery(\PDO $conn, \closure $function)
    {
    $waiting = true; // Set a loop condition to test for
    while ($waiting)
        {
        try
            {
            $conn->beginTransaction();
            $function($pdo);
            $conn->commit();
            $waiting = false;
            } catch (PDOException $e)
            {
            if (stripos($e->getMessage(), 'DATABASE IS LOCKED') !== false)
                {
                // This should be specific to SQLite, sleep for 0.25 seconds
                // and try again.  We do have to commit the open transaction first though
                $conn->commit();
                usleep(250000);
                }
            else
                {
                $conn->rollBack();
                throw $e;
                }
            }
        } }

$conn = new PDO('sqlite:C:\path\to\file.sqlite');
$stmt = $conn->prepare('INSERT INTO my_table(my_id, my_value) VALUES(?, ?)');

myQuery($conn, function(\PDO $conn)use($stmt)
        {
        for ($i = 0; $i < 10; $i++)
            {
            $stmt->bindValue(1, $i, PDO::PARAM_INT);
            $stmt->bindValue(2, 'TEST', PDO::PARAM_STR);
            $stmt->execute();
            sleep(1);
            }
        });

Можно и не как функцию, а унаследоваться от PDO и сделать свой метод.

Answer 2

[cjey]

Я так понимаю, что ошибка происходит при многопоточном обращении к базе. Например попытка вставить данные в таблицу в то время пока второй поток выполняет выборку по этой же таблице. Где-то в документации читал, что SQLite так не умеет.

Поэтому когда я решал такую проблему в многопоточном приложении на C#, я создавал обертку с мониторными секциями на обращение к базе.

Comments

[Mithgol]

Ошибка происходит именно при многопоточном обращении к базе.

В своём вопросе я процитировал на языке PHP примерно такую же, наверное, обёртку, которую Вы создавали на Си#.

Мне интересно, однако же, можно ли упростить обёртку или обойтись вовсе без неё — об этом и вопрос мой.

[cjey]

В предложенном примере в бесконечном цикле пытаются выполнить операцию с задержкой в 0.25 секунд. Что не есть правильно, создает нагрузку на процессор и вообще некрасиво.

Я предлагаю приостановить выполнения потока до тех пор, пока второй поток не закончит работу с базой. Для этого в языке должны быть специальные конструкции для синхронизации потоков. Так как в php я не силен, то не знаю есть ли в нем мониторы, но я на 90 процентов уверен что есть.
Схематично мой вариант выглядит так:
1. Войти в мониторную секцию.
2. выполнить запрос.
3. обработать ответ.
4. выйти из мониторной секции.

Если единственно что вас смущает это нечитабельность, опишите функцию ExecuteQuery(Connection, Query) и спрячьте этот код туда.

Вовсе обойтись без обертке не получиться, так как sqlite не предназначен для многопоточной работы. К сожалению, я сходу не смог найти источник, в котором я это прочитал. Мне кажется что это был FAQ на официальном сайте SQLite, но я могу ошибаться.

Answer 3

[Константин]

Стандардная ситуация, для много поточного приложения, не знаю на сколько это решило бы вашу проблему, так как в пхп я никогда семафорами не пользовался, но: www.php.net/manual/en/ref.sem.php. Или написать свой междупроцессный lock