триггером вставляются записи, и там есть дефолтный флаг updated.
Раз в 10 минут я запускаю по крону процедуру, которая жирным запросом по незаапдейченным записям делает инсерты в другую таблицу, а потом апдейтом дополняет данные и ставит update = true.
Выглядит упрощенно это как-то так:
WITH t1 AS (select ... from t1 where not updated)
INSERT INTO t2
WITH t1 AS (select ... from t1 where not updated)
UPDATE t1 SET updated = true
Вопрос в том, что во время выполнения первого запроса могут в табличку t1 насыпаться еще данные, а второй запрос уже поставит на них флаг updated и насыпанные между запросами данные в t2 таблицу не попадут.
Как правильнее сделать? Я пока не очень шарю в блокировках и транзакциях, подскажете как лучше сделать?
> делает инсерты в другую таблицу, а потом апдейтом Если операции логически связаны — они должны быть в одной транзакции. > Выглядит упрощенно это как-то так Может, это вообще можно сделать одним запросом вроде "WITH u AS (UPDATE ... RETURNING ...) INSERT INTO t2(...) SELECT ... FROM u;"? > Я пока не очень шарю в блокировках и транзакциях Так прочитайте соответствующую главу документации.
Use transactions, Luke!
Обсуждают сегодня