Почему Doctrine обрабатывает запрос, но данные в БД не меняются?

Question

[galliard]

Есть вот такой код для обновления баланса

public function up(Account $account, int $amount): void
{
    $query = sprintf(
        'UPDATE %s t SET t.balance = t.balance + %d WHERE t.id = %d',
        get_class($account),
        $amount,
        $account->getId(),
    );

    $this->entityManager->createQuery($query)
        ->execute();
}

Он простой, как тапочек, и казалось бы, что там может не работать? Но... он не работает! Ну то есть он выполняется, конечно, никаких ошибок и эксепшнов не вылетает, $this->entityManager->createQuery($query)->execute() возвращает 1.

Но фактически данные в базе не обновляются. И я не могу понять почему. Пробовал и в транзакцию заворачивать, и блокировки ставить, и на нативный SQL переписывал, что только не дела - а результат один: скрипт отрабатывает, а данные в базе не меняются.

Обновление баланса вызывается последней функцией в бизнес-логике, когда уже сделан flush сущностей и другие sql-запросы. И все они выполнились и сохранились а БД.

Если завернуть его в одну транзакцию с flush сущностей и другими sql-запросами - результат тот же: все данные сохраняются, кроме баланса, обновляемого этой функцией. У меня уже закончились инструменты для отладки, я не знаю куда еще можно смотреть. В чем может быть причина такого поведения?

База postgres 15.1.

Comments

[Rsa97]

А зачем тут сырой запрос? Почему не

$account->setBalance($account->getBalance() + $amount);
$this->entityManager->flush();

[smilingcheater]

get_class возвращает полное имя класса со всеми неймспейсами. У вас в проекте неймспейсы не используются, или вы рассчитываете что в БД есть таблица \App\Models\Account?

[galliard]

Rsa97, Потому что если будет 2 одновременных запроса - то выполнится только последний.

[galliard]

smilingcheater, это DQL, а не SQL. А DQL требует указание имени класса со всеми неймспейсами.

[Rsa97]

galliard, IMHO, race condition вы и с этим запросом можете поймать

Поток 1 получает объект Account
Поток 2 получает объект Account
Поток 1 меняет объект Account
Поток 1 делает flush
Поток 1 выполняет функцию up
Поток 2 меняет объект Account
Поток 2 делает flush

[galliard]

Rsa97, Account во время обработки не изменяется и не флашится, он только справочную информацию содержит.

[tukreb]

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

Используйте очереди свои примитивные или посмотрите компонент от симфони.

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

[galliard]

tukreb, была такая мысль, но это уже костыли, а хотелось бы понять суть возникшей проблемы.

P.S. Реалтайм баланс проще всего сделать вычислениями. Сверка в конце каждого дня, конечно, проводится, но делать это после каждой транзакции - абсолютно ненужная нагрузка. И вообще это офтоп, вопрос был не как балансы считать, а почему запрос выполняется, но не меняет данные в базе.

[tukreb]

galliard, вы наверняка же используете Симфони? Так вот там есть потрясающая вещь - дебагер, зайдите и посмотрите какие запросы там вообще проходят и в каком порядке, а затем скопируйте их и вручную отправьте в БД в том же порядке, может у вас глушатся ошибки от БД, поэтому кажется что запрос проходит.

[galliard]

tukreb, запросы напрямую в БД уже кидал и там они отрабатывают и обновляют ее.