Início / dba / Perguntas / 217523
Accepted
Anentropic
Asked: 2018-09-14 07:17:43 +0800 CST

Entendendo o postgres txid_current e pg_locks

  • 772

Estou tentando obter uma lista de pg_locksrelevantes para a transação atual

por exemplo

> BEGIN;
BEGIN
> ALTER TABLE ... ;
ALTER TABLE
> select locktype,virtualxid,transactionid,mode,relation from pg_locks;
  locktype  | virtualxid | transactionid |        mode         | relation
------------+------------+---------------+---------------------+----------
 relation   | [NULL]     |        [NULL] | AccessShareLock     |    11695
 virtualxid | 2/24699    |        [NULL] | ExclusiveLock       |   [NULL]
 relation   | [NULL]     |        [NULL] | AccessExclusiveLock |   801091
(3 rows)

Ok, então o que eu considero como "minha" fechadura aqui é a última, aAccessExclusiveLock

Mas não tem transactionidou virtualxid.

Se houver outra atividade no banco de dados, verei outros bloqueios também nesta lista.

Como faço para filtrar apenas os bloqueios pertencentes à minha transação atual, se eles tiverem IDs de transação nulos?

postgresql

3 respostas

  1. Best Answer

    Eu encontrei uma resposta.

    Havia duas partes para isso.

    Em primeiro lugar, o que é importante é virtualtransactionem vez de virtualxid. Mesmo sendo virtualxidnulos transactionidpara tudo o que me interessa, todos eles compartilham um virtualtransactionid.

    Em segundo lugar, embora txid_current()retorne a transactionid, o que parece não ajudar porque todos os meus bloqueios têm null para isso, ainda podemos usá-lo para obter o que queremos.

    O que acontece é que quando você chama txid_current()postgres atribui um lock com o transactionidretornado por aquela função, que podemos ver se consultarmos pg_locks. Esse bloqueio compartilhará um virtualtransactionid com todo o resto da transação atual.

    Por exemplo:

    > BEGIN;
BEGIN
> SELECT locktype,transactionid,virtualtransaction,mode FROM pg_locks;
  locktype  | transactionid | virtualtransaction |      mode
------------+---------------+--------------------+-----------------
 relation   |        [NULL] | 3/38672            | AccessShareLock
 virtualxid |        [NULL] | 3/38672            | ExclusiveLock
(2 rows)

> SELECT txid_current();
 txid_current
--------------
       355056
(1 row)

> SELECT locktype,transactionid,virtualtransaction,mode FROM pg_locks;
   locktype    | transactionid | virtualtransaction |      mode
---------------+---------------+--------------------+-----------------
 relation      |        [NULL] | 3/38672            | AccessShareLock
 virtualxid    |        [NULL] | 3/38672            | ExclusiveLock
 transactionid |        355056 | 3/38672            | ExclusiveLock
(3 rows)

    Então agora a partir disso podemos obter o virtualtransactionid compartilhado por tudo na transação atual e filtrar isso.

    Em outras palavras:

    SELECT
    *
FROM pg_locks pl
WHERE
    virtualtransaction=(
        SELECT virtualtransaction FROM pg_locks
            WHERE
                transactionid::text = (txid_current() % (2^32)::bigint)::text
                -- compare int to xid, see https://dba.stackexchange.com/a/123183/10371 
                AND locktype='transactionid'
        LIMIT 1
    )

    ... retornará apenas bloqueios relevantes para a transação atual.

    • 1

  2. Que tal agora:

    pgb=# begin;
BEGIN
pgb=# select * from pg_locks where pid=pg_backend_pid();
  locktype  | database | relation | page | tuple | virtualxid | transactionid | classid | objid | objsubid | virtualtransaction |  pid   |      mode       | granted | fastp
ath
------------+----------+----------+------+-------+------------+---------------+---------+-------+----------+--------------------+--------+-----------------+---------+------
----
 relation   |    33154 |    12143 |      |       |            |               |         |       |          | 6/20625            | 167525 | AccessShareLock | t       | t
 virtualxid |          |          |      |       | 6/20625    |               |         |       |          | 6/20625            | 167525 | ExclusiveLock   | t       | t
(2 rows)

pgb=# insert into test values(4);
INSERT 0 1
pgb=# select * from pg_locks where pid=pg_backend_pid();
   locktype    | database | relation | page | tuple | virtualxid | transactionid | classid | objid | objsubid | virtualtransaction |  pid   |       mode       | granted | f
astpath
---------------+----------+----------+------+-------+------------+---------------+---------+-------+----------+--------------------+--------+------------------+---------+--
--------
 relation      |    33154 |    33212 |      |       |            |               |         |       |          | 6/20625            | 167525 | RowExclusiveLock | t       | t
 relation      |    33154 |    12143 |      |       |            |               |         |       |          | 6/20625            | 167525 | AccessShareLock  | t       | t
 virtualxid    |          |          |      |       | 6/20625    |               |         |       |          | 6/20625            | 167525 | ExclusiveLock    | t       | t
 transactionid |          |          |      |       |            |        592429 |         |       |          | 6/20625            | 167525 | ExclusiveLock    | t       | f
(4 rows)
    • 1

  3. Veja se isso ajuda:

    select l.relation::regclass, l.relation, l.locktype, l.database, l.classid, l.objid, l.objsubid, l.pid, l.mode, l.granted, l.fastpath 
from pg_locks l
where granted = false ;

    Ele exibirá o nome da tabela e onde concedido = false mostra onde o acesso não foi concedido (ou seja, existe um bloqueio).

    Além disso, você pode obter seu PID atual no BASH:

    $ (echo $$; echo $BASHPID)

    obter pid no shell (bash)

    Algumas consultas úteis aqui para monitorar bloqueios: Monitoramento de bloqueio

    • 0

relate perguntas