Форумы портала PHP.SU :: Версия для печати :: Блокировка выполнения транзакции до её завершения

4. Мелкий - 19 Ноября, 2016 - 12:15:33 - перейти к сообщению

gheka пишет:

Как в этом случае?

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

5. gheka - 19 Ноября, 2016 - 13:05:07 - перейти к сообщению

Мелкий пишет:

gheka пишет:

Как в этом случае?

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

К примеру есть страница такая.
В комментариях указаны этапы

PHP:
скопировать код в буфер обмена

 
// ------------ 1 ЭТАП ------------
// Проверяем есть ли открытые банки
$sql = "SELECT `id`,`sum` FROM `bank` WHERE `status`=? LIMIT 0,1";
$stmt = $dbh->prepare ( $sql );
$stmt->execute ( array ( 1 ) );
 
if ( $rows = $stmt->fetch ( PDO::FETCH_NUM ) ) {
        // Если есть выводим кнопку ПОЛУЧИТЬ БАНК
        $id = $rows [0]; // К промеру ID 100
        $sum = $rows [1]; // К примеру сумма 500
 
 
 
        // ВЫВОДИМ КНОПКУ
                echo "<form action='' method='post'>
                <input type='submit' name='receive_bonus' value='ПОЛУЧИТЬ БАНК'>
                </form>";
                
                
                
                // ------------ 2 ЭТАП ------------
                // Проверим нажал ли пользователь кнопку
                if ( $_POST ['receive_bonus'] == TRUE ) {
                
                        try {
                                  /* Начало транзакции, отключение автоматической фиксации */
                                  $dbh->beginTransaction();
                                                         
                                  // ------------ 3 ЭТАП ------------
                                  // Пополняем баланс пользователя который нажал кнопу
                                  $sql = "UPDATE `user` SET `balanse`=balanse+? WHERE `id`=?";
                                  $stmt = $dbh->prepare ( $sql );
                                  $stmt->execute ( array ( $sum, $id_user ) );
                         
                                  
                         
                                  // ------------ 4 ЭТАП ----------------------
                                  // Обновляем статус на 0 (банк закрыт)
                                  $sql = "UPDATE `bank` SET `status`=? WHERE `id`=?";
                                  $stmt = $dbh->prepare ( $sql );
                                  $stmt->execute ( array ( 0, $id ) );
                                         
                                  /* Фиксация изменений */
                                  $dbh->commit();
                        }
                         
                        catch ( Exception $e ) {
                         
                                $dbh -> rollBack ();
                                die ("Ошибка : " . $e -> getMessage ());
                        }
                }
} else {
        echo "НЕТ ОТКРЫТЫХ БАНКОВ";
}
 

И Если допустим 2 пользователя зашли на страницу получения банка
Тоесть выполнился 1 этап

Они одновременно нажали на кнопку ПОЛУЧИТЬ БАНК

SELTCT выполнился и пустил обоих на 2-3 этап (Так как банк ещё открыт)

то обоим пользователям зачислится на баланс 500 руб

И только после этого выполнится 4 этап обновится статус банка на 0 (закрыт)

6. Мелкий - 19 Ноября, 2016 - 13:55:24 - перейти к сообщению

Всё верно. Классика race condition.
Изначальный код в первом сообщении, где select уже в транзакции, но не захватывает эксклюзивную блокировку, тоже подвержен этому же race condition.

Третий раз написать, что для исключения состояния гонки в этом коде необходимо использовать select for update внутри транзакции? Только в этом случае СУБД нормально сериализует происходящее.

Этот кусок кода примечателен следующими штуками:
- речь о mysql, что видно по стилю оформления имён объектов в БД
- выбирается любой bank.status=1, а не какой-то конкретный. Значит при конкурентном доступе для второй транзакции может найтись другая подходящая строка после фиксации первой транзакции. В принципе, это условие даже можно сериализовать иным образом чем select for update, но эффективно получится то же самое при большем объёме кода и нескольких бесполезных транзакциях.

gheka пишет:

// Проверим нажал ли пользователь кнопку

Проверка реализована некорректно, к слову. submit формы может происходить без отправки input type=submit. Это допустимое поведение клиента.

7. gheka - 20 Ноября, 2016 - 13:55:18 - перейти к сообщению

Спасибо, да действительно то что нужно SELECT FOR UPDATE.