Как получить новые записи из БД?

Question

[kategg]

Допустим, я получаю n кол-во строк из таблицы chats, далее мне надо пройтись по полученной коллекции и произвести некоторые действия с каждой полученной записью. Но, во время работы цикла, в базе могут появиться новые записи, которые соответствуют условию выборки. И получается, что скрипт их не обработает, т.к. запрос к модели Chat уже сделан ранее. Есть ли какой-нибудь способ получить старые + новые записи?
Уточнение: запись после обработки удаляется, массив обрабатываемых данных небольшой, максимум - 10-20 записей

$chats = Chat::where("unread_messages", 0)->get();
$chats->each(function($chat) {
   // ...работа с записью 
  $chat->delete();
});

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

while($chat = Chat::where("unread_messages", 0)->first()) {
    // ...работа с записью
    $chat->delete();
}

Comments

[Виктор]

можно запросить информацию повторно или делать на сокетах

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

[Антон Антон]

А какая разница с тем, что новые записи появятся не в процессе работы скрипта, а через 0.001 секунды после его завершения?

[kategg]

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

[YepBro]

А в чем именно мина будет? Вполне нормальное решение.

[kategg]

YepBro, как минимум, кол-во запросов к БД будет равно кол-ву записей, а это лишние нагрузки на базу

[YepBro]

kategg, Это реальная проблема или ты считаешь, что так может когда-нибудь быть?

Один запрос по первичному ключу с выборкой одной записи не создаст какой-то особой нагрузки на базу.

Если же ты в любом случае хочешь ее избежать, то делай пакетный запрос и доставай 10/100/1000 записей обрабатывай их в цикле. И так пока записей не останется.

[YepBro]

kategg, почему-то тебя не смущает, что в твоем коде кол-во запросов на удаление будет равно кол-ву записей. А это более тяжелый запрос для бд :)

Answer 1

[Илья М]

Вам нужно создать event при вставке новой записи и при его срабатывании запрос будет выполняться. То есть, делаем событие на вставку новой записи. Слушаем событие в нужном компоненте и если оно срабатывает обновляем запрос.
Подробнее вот тут:
https://laravel.com/docs/11.x/events