Изменения документа PostgreSQL. Организация блокировок с пропуском заблокированных
Редактировал(а) Alexandr Fokin 2024/06/07 23:49
отредактировано Alexandr Fokin
на 2024/02/07 21:11
на 2024/02/07 21:11
отредактировано Alexandr Fokin
на 2024/03/16 20:49
на 2024/03/16 20:49
Изменить комментарий:
К данной версии нет комментариев
Комментарий
-
Свойства страницы (1 изменено, 0 добавлено, 0 удалено)
Подробности
- Свойства страницы
-
- Содержимое
-
... ... @@ -1,6 +1,6 @@ 1 -|(% style="width:2 52px" %) |(% style="width:1202px" %)[[Пессимистичная блокировка>>doc:Архитектура и модели.Блокировки.Пессимистичная блокировка.WebHome]]2 -|(% style="width:2 52px" %) |(% style="width:1202px" %)3 -|(% style="width:2 52px" %)Блокировка через основной механизм БД|(% style="width:1202px" %){{code language="sql"}}Begin;1 +|(% style="width:218px" %) |(% style="width:462px" %)[[Пессимистичная блокировка>>doc:Архитектура и модели.Блокировки.Пессимистичная блокировка.WebHome]]|(% style="width:804px" %) 2 +|(% style="width:218px" %) |(% style="width:462px" %)[[https:~~/~~/postgrespro.ru/docs/postgresql/12/functions-admin>>https://postgrespro.ru/docs/postgresql/12/functions-admin]]|(% style="width:804px" %) 3 +|(% style="width:218px" %)Блокировка через основной механизм БД|(% style="width:462px" %){{code language="sql"}}Begin; 4 4 5 5 select * 6 6 from table ... ... @@ -8,8 +8,8 @@ 8 8 9 9 --action 10 10 11 -Commit;{{/code}} 12 -|(% style="width:2 52px" %)Рекомендательные блокировки|(% style="width:1202px" %){{code language="sql"}}Begin;11 +Commit;{{/code}}|(% style="width:804px" %) 12 +|(% style="width:218px" %)Рекомендательные блокировки|(% style="width:462px" %){{code language="sql"}}Begin; 13 13 14 14 select * 15 15 from table ... ... @@ -20,7 +20,31 @@ 20 20 21 21 -- action 22 22 23 -Commit;{{/code}} 24 -|(% style="width:252px" %) |(% style="width:1202px" %) 23 +Commit;{{/code}}|(% style="width:804px" %)((( 24 +Данный подход может комбинироваться с вышестоящим. 25 +\\Пример: Мы сначала отбираем батч id, чтобы потом обработать каждую запись в отдельной транзакции. Мы не хотим блокировать сами строки, но также не хотим, чтобы другой (параллельный) обработчик отбирал их к себе. 26 +Мы можем использовать рекомендательную блокировку. При этом при обработке каждой строки отдельной транзакцией мы накладываем For Update. 25 25 26 - 28 +ЗАМЕЧАНИЕ: быть аккуратнее при использовании условий с JOIN или сортировке, чтобы не блокировать больше строк, чем нужно. 29 + 30 +Postgres pg_try_advisory_lock blocks all records 31 +[[https:~~/~~/stackoverflow.com/questions/20115907/postgres-pg-try-advisory-lock-blocks-all-records>>https://stackoverflow.com/questions/20115907/postgres-pg-try-advisory-lock-blocks-all-records]] 32 + 33 +{{code language="sql"}} 34 +select g.id 35 +from ( 36 + SELECT 37 + g.id, 38 + pg_catalog.pg_try_advisory_xact_lock(-1, pg_catalog.uuid_hash(g.id)) as locked 39 + FROM table1 AS t1 40 + join table2 as r2 on 41 + --WHERE rules 42 +) g 43 +where 44 + g.locked 45 +LIMIT 20; 46 +{{/code}} 47 +))) 48 +|(% style="width:218px" %) |(% style="width:462px" %) |(% style="width:804px" %) 49 +|(% style="width:218px" %) |(% style="width:462px" %) |(% style="width:804px" %) 50 +