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

<
От версии < 1.4
отредактировано Alexandr Fokin
на 2024/06/07 23:56
К версии < 1.2 >
отредактировано Alexandr Fokin
на 2024/06/07 23:52
Изменить комментарий: К данной версии нет комментариев

Комментарий

Подробности

Свойства страницы
Содержимое
... ... @@ -1,25 +1,55 @@
1 1  
2 2  
3 3  | |[[Пессимистичная блокировка>>doc:Архитектура и модели.Блокировки.Пессимистичная блокировка.WebHome]]|
4 -| |sp_getapplock
5 -[[https:~~/~~/learn.microsoft.com/ru-ru/sql/relational-databases/system-stored-procedures/sp-getapplock-transact-sql?view=sql-server-ver16>>https://learn.microsoft.com/ru-ru/sql/relational-databases/system-stored-procedures/sp-getapplock-transact-sql?view=sql-server-ver16]]|Prevent multiple users from running the same SQL Server stored procedure at the same time
6 -[[https:~~/~~/www.mssqltips.com/sqlservertip/3202/prevent-multiple-users-from-running-the-same-sql-server-stored-procedure-at-the-same-time/>>https://www.mssqltips.com/sqlservertip/3202/prevent-multiple-users-from-running-the-same-sql-server-stored-procedure-at-the-same-time/]]
4 +| |[[https:~~/~~/postgrespro.ru/docs/postgresql/12/functions-admin>>https://postgrespro.ru/docs/postgresql/12/functions-admin]]|
7 7  |Блокировка через основной механизм БД|{{code language="sql"}}Begin;
8 8  
9 9   select *
10 - from table with (UPDLOCK, READPAST)
8 + from table
9 + FOR UPDATE SKIP LOCKED;
11 11  
12 12   --action
13 13  
14 14  Commit;{{/code}}|
15 -|Рекомендательные блокировки| |
16 -|Other|(((
17 -Использование уровня изоляции Read uncommitted для чтения и пометки заблокированных обработчиком (до конца транзакции) строк.
14 +|Рекомендательные блокировки|{{code language="sql"}}Begin;
18 18  
19 -1) В отличии от postgresql позволяет задействовать индекс.
20 -2) Изменение строки накладывает блокировку на строку, что не позволит обновить из другой транзакции и в этом плане равноценно updatelock. Что делает не подходящим решением.
21 -)))|
16 + select *
17 + from table
18 + where
19 + -- (table or action key, rowKey)
20 + pg_try_advisory_xact_lock(1, id)
21 + -- or pg_try_advisory_xact_lock(1, uuid_hash(guidId))
22 +
23 + -- action
24 +
25 +Commit;{{/code}}|(((
26 +|Данный подход может комбинироваться с вышестоящим.
27 +|Пример: Мы сначала отбираем батч id, чтобы потом обработать каждую запись в отдельной транзакции. Мы не хотим блокировать сами строки, но также не хотим, чтобы другой (параллельный) обработчик отбирал их к себе.
28 +Мы можем использовать рекомендательную блокировку. При этом при обработке каждой строки отдельной транзакцией мы накладываем For Update.
29 +|(((
30 +ЗАМЕЧАНИЕ: быть аккуратнее при использовании условий с JOIN или сортировке, чтобы не блокировать больше строк, чем нужно.
22 22  
32 +Postgres pg_try_advisory_lock blocks all records
33 +[[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]]
34 +
35 +{{code language="sql"}}
36 +select t1.id
37 +from (
38 + SELECT
39 + t1.id,
40 + pg_catalog.pg_try_advisory_xact_lock(-1, t1.id) as locked
41 + FROM table1 AS t1
42 + join table2 as r2 on
43 + --WHERE rules
44 +) t1
45 +where
46 + t1.locked
47 +LIMIT 20;
48 +{{/code}}
49 +)))
50 +)))
51 +| | |
52 +
23 23  ----
24 24  
25 25  ==== Внутренние ссылки: ====