Как правильно удалять модели внутри транзакции?

Question

[McMike]

Открываю транзакцию, затем делаю на модели ->delete().
Затем делаю rollback, но по итогу данные в базе удалены.

Как правильно использовать удаление модели и транзакции?

$transaction = \Yii::$app->db->beginTransaction();
        try {
            $params = Param::findAll(['type_id' => $typeId]);
            foreach ($params as $param) {
                if (!$param->delete()) {
                    throw new Exception('deleting error');
                }
            }
            $transaction->commit();
        } catch (\Exception $e) {
            $transaction->rollBack();
            $this->error('Transaction rollback with error - ' . $e->getMessage());
        }

Comments

[Дмитрий]

Открываю транзакцию, затем делаю на модели ->delete().
Затем делаю rollback, но по итогу данные в базе удалены.

И где это видно?

[McMike]

Дмитрий, добавил

[Дмитрий]

McMike, а чем Вас не устраивает deleteAll()?

[Дмитрий]

McMike,

$transaction = $connection->beginTransaction();
try {
    $connection->createCommand($sql1)->execute();
    $connection->createCommand($sql2)->execute();
    //.... other SQL executions
    $transaction->commit();
} catch (\Exception $e) {
    $transaction->rollBack();
    throw $e;
} catch (\Throwable $e) {
    $transaction->rollBack();
    throw $e;
}

Note: in the above code we have two catch-blocks for compatibility with PHP 5.x and PHP 7.x. \Exception implements the \Throwable interface since PHP 7.0, so you can skip the part with \Exception if your app uses only PHP 7.0 and higher.

[McMike]

Дмитрий, оно точно так же "не работает" с транзакцией

[Дмитрий]

McMike, но не нужно использовать цикл.

[Дмитрий]

McMike, а где Вы после удаления делаете "rollback"?

[McMike]

Дмитрий, да, с createCommand работает как надо.
Вопрос можно ли, и если да, то как, удалять с помощью моделей?

[Дмитрий]

McMike, а как с createCommand делаете?

[McMike]

Дмитрий, ровно как вы написали ->createCommand('delete from table')->execute();
если после нее делаю commit - записей в бд нет, если rollBack - записи есть

[Дмитрий]

McMike, а здесь вы не делаете

if (!$param->delete()) {
   throw new Exception('deleting error');
}

[McMike]

Дмитрий, ну я перехожу в catch где выполняю rollBack. Могу просто rollback сразу вызвать, все равно данные не восстанавливаются.

Короче спасибо, разобрался. На моей стороне, естественно был косяк. Старый кривой проект, у моделей была прослойка, которая по getDb возвращала экземпляр соединения отличный от того, для которого я делал транзакцию.

Answer 1

[eternalfire]

Привет!
В общих чертах так

$transaction = $connection->beginTransaction();
try {
    $model->delete();
    $transaction->commit();
} catch (\Exception $e) {
    $transaction->rollBack();
    throw $e;
}

или

$transaction = $connection->beginTransaction();
if ($model->delete()) {
    $transaction->commit();
} else {
    $transaction->rollBack();
}

Comments

[McMike]

Да, в общих чертах так, но оно не работает.
Я так понимаю из-за того, что метод delete сам реализует транзакцию и делает коммит, соотвественно внешняя транзакция уже не отрабатывает как надо

[eternalfire]

попробуй в модели AR которую удаляешь, описать метод transactions()

public function transactions(): array
    {
        return [
            self::SCENARIO_DEFAULT => self::OP_ALL,
        ];
    }

[McMike]

eternalfire, пробовал, все то же самое.
При подобных странностях у меня возникает ощущение, что что-то где-то у меня в проетке не так.
Так вот вопрос, те примеры что вы привели, у вас реально отрабатывают как надо? Или вы не проверяли?