Исходный код вики Организация блокировок с пропуском заблокированных
Версия 1.5 от Alexandr Fokin на 2024/03/16 20:12
Последние авторы
author | version | line-number | content |
---|---|---|---|
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 | |||
5 | select * | ||
6 | from table | ||
7 | FOR UPDATE SKIP LOCKED; | ||
8 | |||
9 | --action | ||
10 | |||
11 | Commit;{{/code}}|(% style="width:804px" %) | ||
12 | |(% style="width:218px" %)Рекомендательные блокировки|(% style="width:462px" %){{code language="sql"}}Begin; | ||
13 | |||
14 | select * | ||
15 | from table | ||
16 | where | ||
17 | -- (table or action key, rowKey) | ||
18 | pg_try_advisory_xact_lock(1, id) | ||
19 | -- or pg_try_advisory_xact_lock(1, uuid_hash(guidId)) | ||
20 | |||
21 | -- action | ||
22 | |||
23 | Commit;{{/code}}|(% style="width:804px" %)((( | ||
24 | Данный подход может комбинироваться с вышестоящим. | ||
25 | \\Пример: Мы сначала отбираем батч id, чтобы потом обработать каждую запись в отдельной транзакции. Мы не хотим блокировать сами строки, но также не хотим, чтобы другой (параллельный) обработчик отбирал их к себе. | ||
26 | Мы можем использовать рекомендательную блокировку. При этом при обработке каждой строки отдельной транзакцией мы накладываем For Update. | ||
27 | |||
28 | ЗАМЕЧАНИЕ: данный способ блокировки может подходить не для всех сценариев. | ||
29 | Не подходит для ситуаций, когда выборка содержит условия к другим таблицам (JOIN или EXSISTS). | ||
30 | При использовании сортировок необходимо убедиться в наличии индексов. | ||
31 | Иначе может приводить к ситуации, когда при считывании (по where) будет заблокировано больше строк, чем планировалось. | ||
32 | ))) | ||
33 | |(% style="width:218px" %) |(% style="width:462px" %) |(% style="width:804px" %) | ||
34 | |(% style="width:218px" %) |(% style="width:462px" %) |(% style="width:804px" %) | ||
35 | |||
36 |