PHP.SU

Программирование на PHP, MySQL и другие веб-технологии

PHP.SU Портал

Главная

Помощь

Поиск

Поиск Яндекс Вакансии

Пользователи

Здравствуйте, Гость

( Вход · Регистрация · Правила форума )

Забыли пароль?

Блокировка выполнения транзакции до её завершения

Форумы портала PHP.SU » PHP » Программирование на PHP » Вопросы новичков (Модераторы: OrmaJever, Саныч, Строитель)

Страниц (1): [1]

Без описания

Поиск в теме | Версия для печати

gheka	Отправлено: 18 Ноября, 2016 - 23:43:12
Частый гость Покинул форум Сообщений всего: 191 Дата рег-ции: Февр. 2011 Помог: 2 раз(а)	Здравствуйте Есть транзакция с выполнением нескольких запросов подряд. Суть примера такая. Есть таблица bank с полями id sum Сумма банка тип таблиц InnoDB Любой авторизованный пользователь нажимает на кнопку ПОЛУЧИТЬ БАНК и выполняется скрипт ниже ПРИМЕР PHP: скопировать код в буфер обмена try { /* Начало транзакции, отключение автоматической фиксации / $dbh->beginTransaction(); // Статус 1 (открыт) $sql = "SELECT `id`,`sum` FROM `bank` WHERE `status`=? LIMIT 0,1"; $stmt = $dbh->prepare ( $sql ); $stmt->execute ( array ( 1 ) ); if ( $data = $stmt->fetchAll ( PDO::FETCH_NUM ) ) { $id_invoice = $rows [0]; $sum = $rows [1]; $sql = "UPDATE `user` SET `balanse`=balanse+? WHERE `id`=?"; $stmt = $dbh->prepare ( $sql ); $stmt->execute ( array ( $sum, $id_user ) ); // ДРУГИЕ ДЕЙСТВИЕ // Обновляем статус на 0 (закрыт) $sql = "UPDATE `bank` SET `status`=? WHERE `id`=?"; $stmt = $dbh->prepare ( $sql ); $stmt->execute ( array ( 0, $id_invoice ) ); } / Фиксация изменений / $dbh->commit(); } catch ( Exception $e ) { $dbh -> rollBack (); die ("Ошибка : " . $e -> getMessage ()); } Тоесть выполняется запрос в базу bank* и вытаскивается первая попавшееся запись со СТАТУСОМ 1 (статус 1 - банк открыт, статус 0 - банк закрыт) Сумма из этого банка зачисляется на счёт этого пользователя. После чего банк закрывается Статус банка с определённый id обновляется на 0 ВОПРОС Мне нужно защитить данную транзакцию от двойной записи. тоесть если 2 пользователя одновременно нажмут на кнопку ПОЛУЧИТЬ БАНК то один и тот же банк может зачислится обоим пользователям. В том случае если транзакция не успеет завершится и статус таблицы bank ещё не изменится на 0 Надеюсь я понятно объяснил что я хочу. Подскажите каким образом мне это сделать? Читал про уровни изоляции READ UNCOMMITTED READ COMMITTED REPEATABLE READ SERIALIZABLE но как их применить так и не понял. (Отредактировано автором: 18 Ноября, 2016 - 23:53:55)

Мелкий	Отправлено: 18 Ноября, 2016 - 23:54:57
Активный участник Покинул форум Сообщений всего: 11926 Дата рег-ции: Июль 2009 Откуда: Россия, Санкт-Петербург Помог: 618 раз(а)	SELECT ... FOR UPDATE Захватит эксклюзивную блокировку на строку, соответственно до завершения этой транзакции остальные update или select for update (а так же select for share) будут ждать завершения транзакции. ----- PostgreSQL DBA

gheka	Отправлено: 19 Ноября, 2016 - 08:40:08
Частый гость Покинул форум Сообщений всего: 191 Дата рег-ции: Февр. 2011 Помог: 2 раз(а)	Мелкий пишет: SELECT ... FOR UPDATE Захватит эксклюзивную блокировку на строку, соответственно до завершения этой транзакции остальные update или select for update (а так же select for share) будут ждать завершения транзакции. Ну в этом примере да. Но это просто тестовый пример. Может быть и другие варианты. Вот пример где SELECT не задействован в транзакции 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_invoice = $rows [0]; $sum = $rows [1]; try { /* Начало транзакции, отключение автоматической фиксации / $dbh->beginTransaction(); $sql = "UPDATE `user` SET `balanse`=balanse+? WHERE `id`=?"; $stmt = $dbh->prepare ( $sql ); $stmt->execute ( array ( $sum, $id_user ) ); // ДРУГИЕ ДЕЙСТВИЕ // Обновляем статус на 0 (закрыт) $sql = "UPDATE `bank` SET `status`=? WHERE `id`=?"; $stmt = $dbh->prepare ( $sql ); $stmt->execute ( array ( 0, $id_invoice ) ); / Фиксация изменений / $dbh->commit(); } catch ( Exception $e ) { $dbh -> rollBack (); die ("Ошибка : " . $e -> getMessage ()); } } Как в этом случае? (Отредактировано автором: 19 Ноября, 2016 - 08:41:18)*

Мелкий	Отправлено: 19 Ноября, 2016 - 12:15:33
Активный участник Покинул форум Сообщений всего: 11926 Дата рег-ции: Июль 2009 Откуда: Россия, Санкт-Петербург Помог: 618 раз(а)	gheka пишет: Как в этом случае? Вы обязаны перенести запрос, на основании данных которого определяется дальнейшая логика в транзакцию и захватывать необходимые блокировки. Т.е. этот пример идентичен предыдущему и безопасный для конкурентного доступа код будет идентичен. ----- PostgreSQL DBA

gheka	Отправлено: 19 Ноября, 2016 - 13:05:07
Частый гость Покинул форум Сообщений всего: 191 Дата рег-ции: Февр. 2011 Помог: 2 раз(а)	Мелкий пишет: 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 (закрыт)

Мелкий	Отправлено: 19 Ноября, 2016 - 13:55:24
Активный участник Покинул форум Сообщений всего: 11926 Дата рег-ции: Июль 2009 Откуда: Россия, Санкт-Петербург Помог: 618 раз(а)	Всё верно. Классика race condition. Изначальный код в первом сообщении, где select уже в транзакции, но не захватывает эксклюзивную блокировку, тоже подвержен этому же race condition. Третий раз написать, что для исключения состояния гонки в этом коде необходимо использовать select for update внутри транзакции? Только в этом случае СУБД нормально сериализует происходящее. Этот кусок кода примечателен следующими штуками: - речь о mysql, что видно по стилю оформления имён объектов в БД - выбирается любой bank.status=1, а не какой-то конкретный. Значит при конкурентном доступе для второй транзакции может найтись другая подходящая строка после фиксации первой транзакции. В принципе, это условие даже можно сериализовать иным образом чем select for update, но эффективно получится то же самое при большем объёме кода и нескольких бесполезных транзакциях. gheka пишет: // Проверим нажал ли пользователь кнопку Проверка реализована некорректно, к слову. submit формы может происходить без отправки input type=submit. Это допустимое поведение клиента. ----- PostgreSQL DBA

gheka	Отправлено: 20 Ноября, 2016 - 13:55:18
Частый гость Покинул форум Сообщений всего: 191 Дата рег-ции: Февр. 2011 Помог: 2 раз(а)	Спасибо, да действительно то что нужно SELECT FOR UPDATE.

Поиск в теме | Версия для печати

Страниц (1): [1]

Сейчас эту тему просматривают: 0 (гостей: 0, зарегистрированных: 0)

« Вопросы новичков »

Все гости форума могут просматривать этот раздел.
Только зарегистрированные пользователи могут создавать новые темы в этом разделе.
Только зарегистрированные пользователи могут отвечать на сообщения в этом разделе.