Блог хеллоуворлдщика

SELECT FOR UPDATE в Yii2

30 июня 2018 г., 0:12:13 12350 Yii2 yii2 select for update active record 7 Комментариев

Задача предельно простая: добавить SELECT FOR UPDATE. В обсуждении подобного вопроса в оф. репозитории фреймворка нам сообщают, что из коробки такой возможности нет и что решать данную проблему нужно самому.

Так же есть расширение, которое не имеет какого-то смысла вообще, т.к. суть работы SELECT FOR UPDATE не реализована: отсутствует актуализация данных после блокировки. Придется обновлять записи после блокировки вручную и надеятся, что это отработает корректно.

Еще есть вот такое расширение, но я его особо не смотрел. Вроде рабочее. Если кто-то тестировал или использовал - пишите в комментарии.

Дак что же делать для тех, кто хочет просто применить SELECT FOR UPDATE? Решение очень простое! Нужно всего лишь...

использовать yii\db\ActiveRecord::findBySql()!

Пишем метод в модели:

public static function findOneForUpdate(int $id): ?ActiveRecord
{
    $sql = self::find()
        ->where(['id' => $id])
        ->createCommand()
        ->getRawSql();
 
    return self::findBySql($sql . ' FOR UPDATE')->one();
}

И все! Вот так просто.

Комментарии [7]

Новый комментарий
[1]
[Александр] 26 сент. 2018 г., 18:12:37

Здравствуйте, а можно более детально установку? На примере...

Ответить
[2]
Администратор [IAMRUSTY] 26 сент. 2018 г., 18:27:38

Нет установки. Просто добавляете метод в свой абстрактный класс унаследованный от класс yii\db\ActiveRecord из ядра фреймворка.

Ответить
[3]
[Александр] 26 сент. 2018 г., 19:16:38

Это для меня набор букв, на примере можете показать?

Ответить
[4]
Администратор [IAMRUSTY] 26 сент. 2018 г., 19:20:24 
abstract class YourActiveRecord extends \yii\db\ActiveRecord
{
    public static function findOneForUpdate(int $id): ?YourActiveRecord
    {
        $sql = self::find()
            ->where(['id' => $id])
            ->createCommand()
            ->getRawSql();
 
        return self::findBySql($sql . ' FOR UPDATE')->one();
    }
}
 
/**
 * @param int $id
 * @param int $counter
 */
class YourModel extends YourActiveRecord
{
 
}
 
$yourModel = YourModel::findOneForUpdate(14);
++$yourModel->counter;
$yourModel->save();
Ответить
[5]
[Александр] 26 сент. 2018 г., 20:08:28

Я так и делал но выдает ошибку: syntax error, unexpected ':', expecting ';' or '{' На строку: public static function findOneForUpdate(int $id): ?YourActiveRecord

Ответить
[6]
Администратор [IAMRUSTY] 26 сент. 2018 г., 20:10:53

Пример рассчитан на PHP 7.1 и выше. Если у Вас версия ниже - уберите type hinting из кода.

Ответить
[7]
Администратор [IAMRUSTY] 26 сент. 2018 г., 20:11:57 
abstract class YourActiveRecord extends \yii\db\ActiveRecord
{
    public static function findOneForUpdate($id)
    {
        $sql = self::find()
            ->where(['id' => $id])
            ->createCommand()
            ->getRawSql();
 
        return self::findBySql($sql . ' FOR UPDATE')->one();
    }
}
 
/**
 * @param int $id
 * @param int $counter
 */
class YourModel extends YourActiveRecord
{
 
}
 
$yourModel = YourModel::findOneForUpdate(14);
++$yourModel->counter;
$yourModel->save();
Ответить