Изменения документа PostgreSQL. Организация блокировок с пропуском заблокированных
Редактировал(а) Alexandr Fokin 2024/06/07 23:49
<
отредактировано Alexandr Fokin
на 2024/06/07 23:49
на 2024/06/07 23:49
отредактировано Alexandr Fokin
на 2024/03/16 20:49
на 2024/03/16 20:49
Изменить комментарий:
К данной версии нет комментариев
Комментарий
-
Свойства страницы (2 изменено, 0 добавлено, 0 удалено)
Подробности
- Свойства страницы
-
- Название
-
... ... @@ -1,1 +1,1 @@ 1 - PostgreSQL.Организация блокировок с пропуском заблокированных1 +Организация блокировок с пропуском заблокированных - Содержимое
-
... ... @@ -21,10 +21,10 @@ 21 21 -- action 22 22 23 23 Commit;{{/code}}|(% style="width:804px" %)((( 24 - |Данный подход может комбинироваться с вышестоящим.25 - |Пример: Мы сначала отбираем батч id, чтобы потом обработать каждую запись в отдельной транзакции. Мы не хотим блокировать сами строки, но также не хотим, чтобы другой (параллельный) обработчик отбирал их к себе.24 +Данный подход может комбинироваться с вышестоящим. 25 +\\Пример: Мы сначала отбираем батч id, чтобы потом обработать каждую запись в отдельной транзакции. Мы не хотим блокировать сами строки, но также не хотим, чтобы другой (параллельный) обработчик отбирал их к себе. 26 26 Мы можем использовать рекомендательную блокировку. При этом при обработке каждой строки отдельной транзакцией мы накладываем For Update. 27 - |(((27 + 28 28 ЗАМЕЧАНИЕ: быть аккуратнее при использовании условий с JOIN или сортировке, чтобы не блокировать больше строк, чем нужно. 29 29 30 30 Postgres pg_try_advisory_lock blocks all records ... ... @@ -31,43 +31,20 @@ 31 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 32 33 33 {{code language="sql"}} 34 -select t1.id34 +select g.id 35 35 from ( 36 36 SELECT 37 - t1.id,38 - pg_catalog.pg_try_advisory_xact_lock(-1, t 1.id) as locked37 + g.id, 38 + pg_catalog.pg_try_advisory_xact_lock(-1, pg_catalog.uuid_hash(g.id)) as locked 39 39 FROM table1 AS t1 40 40 join table2 as r2 on 41 41 --WHERE rules 42 -) t142 +) g 43 43 where 44 - t1.locked44 + g.locked 45 45 LIMIT 20; 46 46 {{/code}} 47 47 ))) 48 -))) 49 49 |(% style="width:218px" %) |(% style="width:462px" %) |(% style="width:804px" %) 49 +|(% style="width:218px" %) |(% style="width:462px" %) |(% style="width:804px" %) 50 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 -----