PHP PDO Как добиться синхронной работы COMMIT?

Question

[sir_genry]

Всем привет!
Чтобы разъяснить суть вопроса приведу следующий кейс:
1. Выполняем в PHP скрипте №1 транзакцию, которую завершаем commit-ом
2. Посылаем сообщение в RabbitMQ.
3. Скрипт завершается
4. В это же время другой процесс (скрипт №2) слушает очередь и получает сообщение, посланное скриптом №1.
5. Скрипт №2 ищет в базе запись. которую только что создал Скрипт №1. И не находит!
6. Ждем какое-то время, запись появляется.

Вывод: Commit работает асинхронно.
Вопрос: Есть ли способ дождаться реального окончания commit-а и только после этого продолжать выполнение скрипта?
Использование различных уровней изоляции не помогают

Comments

[sir_genry]

Лентюй, база одна, PostgreSQL версии 10.3. PHP версии 5.6.34

[FanatPHP]

Вывод: у таракана уши в ногах

[sir_genry]

FanatPHP, если вы фанат PHP, то должны понимать. что одним из плюсов PHP является его синхронное выполнение, что позволяет реализовать простую линейную логику. Ожидается, что и PDO придерживается таких же принципов. Так что ваш коментарий бессмысленен. Соответствующая жалоба отправлена. Не засоряйте эфир

[FanatPHP]

Да, если логика недоступна, только и остается что жаловаться.

[Станислав Б]

sir_genry,

Ожидается, что и PDO придерживается таких же принципов.

дело совсем не в пдо... он то как раз синхронный

[sir_genry]

Станислав Б, а вот и получается что не синхронный, раз не дожидается реального окончания операции и при этом рапортует об успехе.

[sir_genry]

Станислав Б, еще один момент. Та же самая проблема имеет место и в MySQL

[Станислав Б]

sir_genry,

а вот и получается что не синхронный, раз не дожидается реального окончания операции

то есть, вы не допускаете возможности наличия ошибок в вашем коде, а на 100% уверены что имеет место баг в ПДО?

[sir_genry]

1. Не допускаю
2. Может быть это не баг, а так и было задумано разработчиками
3. Проверьте сами

[FanatPHP]

Перед "проверьте сами" должен идти полнофункциональный пример, демонстрирующий данную проблему.
Без такого примера вся история изложенная выше будет восприниматься как занимательная беллетристика, и не больше.
Ссылки для самообразования:
idownvotedbecau.se/nomcve
https://ru.stackoverflow.com/help/mcve

[sir_genry]

FanatPHP, Прежде чем писать свои гнусные инсинуации, прочти внимательно вопрос. Там все предельно ясно описано. А если тебе не хватает мозгов понять столь простые вещи, то завязывай с программированием.

[FanatPHP]

sir_genry, то есть у тебя не только с логикой, но и с чтением проблемы. Ну ничего, в программистах ты надолго не задержишься, а дворникам умение читать ни к чему

[sir_genry]

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

Answer 1

[sir_genry]

Если кому-то будет интересно, то сообщаю, что использование PDOStatement::execute вместо PDO::commit в моем случае решило проблему.
На примере фреймворка yii2/
Было:

$transaction = \Yii::$app->db->beginTransaction();
try {
    ...
    $transaction->commit();
} catch (\Exception $exception) {
    $transaction->rollBack();
    throw $exception;
}

Стало:

\Yii::$app->db->createCommand('BEGIN TRANSACTION')->execute();
try {
    ...
    \Yii::$app->db->createCommand('COMMIT TRANSACTION')->execute();
} catch (\Exception $exception) {
    \Yii::$app->db->createCommand('ROLLBACK TRANSACTION')->execute();
    throw $exception;
}

Не совсем конечно красиво, и до конца не уверен, что это работает во всех случаях. Но все равно лучше чем искусственная задержка

Answer 2

[Melkij]

Для приложения commit синхронен. Если вы вышли из commit() - значит транзакция уже зафиксирована.

Проверяйте код приложения #2. Может быть вы уже в транзакции и потому не видите изменения. Может быть вы подключаетесь к асинхронной реплике

Comments

[sir_genry]

Вот кусок кода:

....
$transaction->commit();
Bus::Notify(Notification::DOCUMENT_FOLDER_SAVED, $this->folder->id);
....

Реплику не использую. Используется только один сервер.

[Melkij]

Мне эти две строки не говорят ни о чём. Я даже не могу знать вызывается ли у вас коммит вообще - или это какая-то обёртка.

[sir_genry]

Первая строчка однозначно выполняет COMMIT (см yii2). Вам придется поверить мне на слово. Вторая строчка отправляет сообщение в очередь. И эту строчку я привел с целью показать, что я не кидаю сообщения ДО выполнения коммита.
И я в других комментариях уже про то. что не использую реплику

[Melkij]

Первая строчка однозначно выполняет COMMIT (см yii2). Вам придется поверить мне на слово.

Я лучше поверю исходнику:
https://github.com/yiisoft/yii2/blob/master/framew...
Может коммит, а может и не коммит. Не знаю, надо смотреть остальной ваш код или это конкретное место дебаггером, есть ли тут коммит.

[sir_genry]

в логе я вижу

09:27:15.300	trace	yii\db\Transaction::commit	Commit transaction

в коде вижу

Yii::trace('Commit transaction', __METHOD__);
$this->db->pdo->commit();

где $this->db->pdo - это стандартная библиотека php.net/manual/en/pdo.commit.php

Так что я склонен думать, что COMMIT выполняется

Answer 3

[Konstantin Malyarov]

Между 1 и 2 пунктом сделате проверку.
1. Выполняем в PHP скрипте №1 транзакцию, которую завершаем commit-ом
2. Проверяем, добавилась ли запись, если да переходим к п. 3, если нет повторяем п. 2 через 5 секунд.
3. Посылаем сообщение в RabbitMQ.
...

Comments

[sir_genry]

То есть предлагаете решать вопрос искусственной задержкой? Я вобщем-то так и сделал, но не в скрипте №1, а в скрипте №2.
Может есть более элегантное решение?

[Konstantin Malyarov]

sir_genry, а теперь представите, что вы указали во 2 скрипте задержку 5 секунд, но спустя некоторое время интервал задержки вырос до 10 секунд - вам придется лезть во 2 скрип и увеличивать с 5 на 10.

Почему задержку делать именно в 1 скрипте: 1 скрипт отправит сообщение RabbitMQ только тогда, когда будет запись в БД.

Усложним ситуацию, допустим что у вес не 2 скрипта, а 20. Один отправляет 19 принимают, в Вашем случае придется лезть во все 19 скриптов и править там код.

[sir_genry]

Konstantin Malyarov, Именно по этой причине я и задал тут вопрос.
И далеко не факт, что проблема смоделируется при выполении запроса к БД после коммита в первом скрипте. Я лично не знаю как там устроено кэширование. И если честно, то даже и проверять этого не хочу. Вставлять в код после коммита некую циклическую проверку с предопределенным таймаутом - это костылизация кода, а не программирование

[Konstantin Malyarov]

sir_genry, или вы разбираетесь в коде, или делаете костыль.

Answer 4

[profaller]

Во втором скрипте надо зафиксировать таймстамп снапшота, либо через COMMIT, либо надо сделать выборку с блокировкой через SELECT ... LOCK IN SHARE MODE, таким образом вы получите свежую выборку данных.