Исходный код вики PostgreSQL. Организация блокировок с пропуском заблокированных
Редактировал(а) Alexandr Fokin 2024/06/07 23: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" %)((( |
![]() |
1.7 | 24 | |Данный подход может комбинироваться с вышестоящим. |
25 | |Пример: Мы сначала отбираем батч id, чтобы потом обработать каждую запись в отдельной транзакции. Мы не хотим блокировать сами строки, но также не хотим, чтобы другой (параллельный) обработчик отбирал их к себе. | ||
![]() |
1.3 | 26 | Мы можем использовать рекомендательную блокировку. При этом при обработке каждой строки отдельной транзакцией мы накладываем For Update. |
![]() |
1.7 | 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"}} | ||
![]() |
1.7 | 34 | select t1.id |
![]() |
1.6 | 35 | from ( |
36 | SELECT | ||
![]() |
1.7 | 37 | t1.id, |
38 | pg_catalog.pg_try_advisory_xact_lock(-1, t1.id) as locked | ||
![]() |
1.6 | 39 | FROM table1 AS t1 |
40 | join table2 as r2 on | ||
41 | --WHERE rules | ||
![]() |
1.7 | 42 | ) t1 |
![]() |
1.6 | 43 | where |
![]() |
1.7 | 44 | t1.locked |
![]() |
1.6 | 45 | LIMIT 20; |
46 | {{/code}} | ||
![]() |
1.4 | 47 | ))) |
![]() |
1.7 | 48 | ))) |
![]() |
1.4 | 49 | |(% style="width:218px" %) |(% style="width:462px" %) |(% style="width:804px" %) |
![]() |
1.8 | 50 | |
51 | ---- | ||
52 | |||
53 | ==== Внутренние ссылки: ==== | ||
54 | |||
55 | ====== Дочерние страницы: ====== | ||
56 | |||
57 | {{children/}} | ||
58 | |||
59 | ====== Обратные ссылки: ====== | ||
60 | |||
61 | {{velocity}} | ||
62 | #set ($links = $doc.getBacklinks()) | ||
63 | #if ($links.size() > 0) | ||
64 | #foreach ($docname in $links) | ||
65 | #set ($rdoc = $xwiki.getDocument($docname).getTranslatedDocument()) | ||
66 | * [[$escapetool.xml($rdoc.fullName)]] | ||
67 | #end | ||
68 | #else | ||
69 | No back links for this page! | ||
70 | #end | ||
71 | {{/velocity}} | ||
72 | |||
73 | ---- |