Редактировал(а) Alexandr Fokin 2024/06/07 23:49

Скрыть последних авторов
Alexandr Fokin 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;
Alexandr Fokin 1.1 4
5 select *
6 from table
7 FOR UPDATE SKIP LOCKED;
8
9 --action
10
Alexandr Fokin 1.4 11 Commit;{{/code}}|(% style="width:804px" %)
12 |(% style="width:218px" %)Рекомендательные блокировки|(% style="width:462px" %){{code language="sql"}}Begin;
Alexandr Fokin 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
Alexandr Fokin 1.4 23 Commit;{{/code}}|(% style="width:804px" %)(((
Alexandr Fokin 1.7 24 |Данный подход может комбинироваться с вышестоящим.
25 |Пример: Мы сначала отбираем батч id, чтобы потом обработать каждую запись в отдельной транзакции. Мы не хотим блокировать сами строки, но также не хотим, чтобы другой (параллельный) обработчик отбирал их к себе.
Alexandr Fokin 1.3 26 Мы можем использовать рекомендательную блокировку. При этом при обработке каждой строки отдельной транзакцией мы накладываем For Update.
Alexandr Fokin 1.7 27 |(((
Alexandr Fokin 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"}}
Alexandr Fokin 1.7 34 select t1.id
Alexandr Fokin 1.6 35 from (
36 SELECT
Alexandr Fokin 1.7 37 t1.id,
38 pg_catalog.pg_try_advisory_xact_lock(-1, t1.id) as locked
Alexandr Fokin 1.6 39 FROM table1 AS t1
40 join table2 as r2 on
41 --WHERE rules
Alexandr Fokin 1.7 42 ) t1
Alexandr Fokin 1.6 43 where
Alexandr Fokin 1.7 44 t1.locked
Alexandr Fokin 1.6 45 LIMIT 20;
46 {{/code}}
Alexandr Fokin 1.4 47 )))
Alexandr Fokin 1.7 48 )))
Alexandr Fokin 1.4 49 |(% style="width:218px" %) |(% style="width:462px" %) |(% style="width:804px" %)
Alexandr Fokin 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 ----