Исходный код вики Организация блокировок с пропуском заблокированных
Версия 1.6 от Alexandr Fokin на 2024/03/16 20:49
Скрыть последних авторов
| author | version | line-number | content |
|---|---|---|---|
 |
1.4 | 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; | ||
| |
1.1 | 4 | |
| 5 | select * | ||
| 6 | from table | ||
| 7 | FOR UPDATE SKIP LOCKED; | ||
| 8 | |||
| 9 | --action | ||
| 10 | |||
| |
1.4 | 11 | Commit;{{/code}}|(% style="width:804px" %) |
| 12 | |(% style="width:218px" %)Рекомендательные блокировки|(% style="width:462px" %){{code language="sql"}}Begin; | ||
| |
1.1 | 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 | |||
| |
1.4 | 23 | Commit;{{/code}}|(% style="width:804px" %)((( |
| 24 | Данный подход может комбинироваться с вышестоящим. | ||
| |
1.3 | 25 | \\Пример: Мы сначала отбираем батч id, чтобы потом обработать каждую запись в отдельной транзакции. Мы не хотим блокировать сами строки, но также не хотим, чтобы другой (параллельный) обработчик отбирал их к себе. |
| 26 | Мы можем использовать рекомендательную блокировку. При этом при обработке каждой строки отдельной транзакцией мы накладываем For Update. | ||
| |
1.1 | 27 | |
| |
1.6 | 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}} | ||
| |
1.4 | 47 | ))) |
| 48 | |(% style="width:218px" %) |(% style="width:462px" %) |(% style="width:804px" %) | ||
| 49 | |(% style="width:218px" %) |(% style="width:462px" %) |(% style="width:804px" %) | ||
| 50 |