Изменения документа PostgreSQL. Организация блокировок с пропуском заблокированных
Редактировал(а) Alexandr Fokin 2024/06/07 23:49
<
>
отредактировано Alexandr Fokin
на 2024/02/07 21:15
на 2024/02/07 21:15
отредактировано Alexandr Fokin
на 2024/03/16 20:52
на 2024/03/16 20:52
Изменить комментарий:
К данной версии нет комментариев
Комментарий
-
Свойства страницы (1 изменено, 0 добавлено, 0 удалено)
Подробности
- Свойства страницы
-
- Содержимое
-
... ... @@ -1,6 +1,6 @@ 1 -|(% style="width:218px" %) |(% style="width: 518px" %)[[Пессимистичная блокировка>>doc:Архитектура и модели.Блокировки.Пессимистичная блокировка.WebHome]]|(% style="width:752px" %)2 -|(% style="width:218px" %) |(% style="width: 518px" %)[[https:~~/~~/postgrespro.ru/docs/postgresql/12/functions-admin>>https://postgrespro.ru/docs/postgresql/12/functions-admin]]|(% style="width:752px" %)3 -|(% style="width:218px" %)Блокировка через основной механизм БД|(% style="width: 518px" %){{code language="sql"}}Begin;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; 4 4 5 5 select * 6 6 from table ... ... @@ -8,8 +8,8 @@ 8 8 9 9 --action 10 10 11 -Commit;{{/code}}|(% style="width: 752px" %)12 -|(% style="width:218px" %)Рекомендательные блокировки|(% style="width: 518px" %){{code language="sql"}}Begin;11 +Commit;{{/code}}|(% style="width:804px" %) 12 +|(% style="width:218px" %)Рекомендательные блокировки|(% style="width:462px" %){{code language="sql"}}Begin; 13 13 14 14 select * 15 15 from table ... ... @@ -20,10 +20,31 @@ 20 20 21 21 -- action 22 22 23 -Commit;{{/code}}|(% style="width:752px" %)Данный подход может комбинироваться с вышестоящим. 24 -\\Пример: Мы сначала отбираем батч id, чтобы потом обработать каждую запись в отдельной транзакции. Мы не хотим блокировать сами строки, но также не хотим, чтобы другой (параллельный) обработчик отбирал их к себе. 23 +Commit;{{/code}}|(% style="width:804px" %)((( 24 +|Данный подход может комбинироваться с вышестоящим. 25 +|Пример: Мы сначала отбираем батч id, чтобы потом обработать каждую запись в отдельной транзакции. Мы не хотим блокировать сами строки, но также не хотим, чтобы другой (параллельный) обработчик отбирал их к себе. 25 25 Мы можем использовать рекомендательную блокировку. При этом при обработке каждой строки отдельной транзакцией мы накладываем For Update. 26 -|( % style="width:218px" %) |(% style="width:518px" %) |(% style="width:752px" %)27 - |(% style="width:218px"%)|(%style="width:518px"%)|(%style="width:752px"%)27 +|((( 28 +ЗАМЕЧАНИЕ: быть аккуратнее при использовании условий с JOIN или сортировке, чтобы не блокировать больше строк, чем нужно. 28 28 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 t1.id 35 +from ( 36 + SELECT 37 + t1.id, 38 + pg_catalog.pg_try_advisory_xact_lock(-1, t1.id) as locked 39 + FROM table1 AS t1 40 + join table2 as r2 on 41 + --WHERE rules 42 +) t1 43 +where 44 + t1.locked 45 +LIMIT 20; 46 +{{/code}} 47 +))) 48 +))) 49 +|(% style="width:218px" %) |(% style="width:462px" %) |(% style="width:804px" %) 50 +|(% style="width:218px" %) |(% style="width:462px" %) |(% style="width:804px" %)