Изменения документа MSSQL. Организация блокировок с пропуском заблокированных
Редактировал(а) Alexandr Fokin 2024/06/07 23:56
<
отредактировано Alexandr Fokin
на 2024/06/07 23:56
на 2024/06/07 23:56
отредактировано Alexandr Fokin
на 2024/06/07 23:52
на 2024/06/07 23:52
Изменить комментарий:
К данной версии нет комментариев
Комментарий
-
Свойства страницы (1 изменено, 0 добавлено, 0 удалено)
Подробности
- Свойства страницы
-
- Содержимое
-
... ... @@ -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 ==== Внутренние ссылки: ====