PostgreSQL: savoir si une ligne a été créée par la transaction en cours

Question

Est-il possible de savoir si une ligne d'une table a été créée par la transaction en cours (et n'est donc pas encore visible pour les autres transactions, car le la transaction est toujours active)?

Mon cas d'utilisation: J'ajoute la journalisation des événements à la base de données. Ceci est fait dans les déclencheurs de plpgsql. Une ligne dans la table des événements ressemble à ceci: (event id:serial, event action:text, count:integer:default 1). Maintenant, le raisonnement derrière ma question: Si une certaine ligne a été créée par cette transaction (probablement dans un autre déclencheur), je pourrais incrémenter le compte au lieu de créer une nouvelle ligne dans la table d'événements.

Answer 1

Vous pouvez simplement rechercher des entrées de journalisation comme ceci:

SELECT ... 
FROM tablename 
WHERE xmin = current_txid() % (2^32)::bigint; 

qui trouveront toutes les lignes ajoutées ou modifiées dans la transaction en cours. L'inconvénient est que cela va forcer une analyse séquentielle de la table entière, et vous ne pouvez pas éviter cela car vous ne pouvez pas avoir un index sur une colonne système.

Vous pouvez donc ajouter une colonne supplémentaire xid à votre tableau remplie de txid_current()::bigint chaque fois qu'une ligne est insérée ou mise à jour. Une telle colonne peut être indexée et efficacement utilisée dans une recherche:

SELECT ... 
FROM tablename 
WHERE xid = current_txid(); 

Answer 2

Vous pourriez envisager quelque chose comme ceci:

create table ConnectionCurrentAction (
    connectionID int primary key, 
    currentActionID uuid 
) 

puis au début de la transaction:

delete ConnectionCurrentAction where connectionID = pg_backend_pid() 
insert ConnectionCurrentAction(connectionID, currentActionID) 
select pg_backend_pid(), uuid_generate_v4() 

Vous pouvez envelopper cela dans un proc appelé dire audit_action_begin

Remarque : Vous pouvez choisir à la place d'appliquer l'exigence qu'une "action" soit créée explicitement en supprimant la suppression ici.

A la fin d'une transaction, faire audit_action_end:

delete ConnectionCurrentAction where connectionID = pg_backend_pid() 

Chaque fois que vous voulez savoir la transaction en cours:

(select currentActionID from ConnectionCurrentAction where connectionID - pg_backend_pid()(

Vous pouvez envelopper que dans une fonction audit_action_current()

Vous Vous pouvez ensuite insérer currentActionID dans votre journal, ce qui vous permettra d'identifier si une ligne a été créée dans l'action en cours ou non. Cela vous permettra également d'identifier où les lignes des différentes tables d'audit ont été créées dans l'action logique en cours.

Si vous ne voulez pas utiliser un uuid, une séquence ferait aussi bien ici. J'aime les uuids.