Vous n'êtes pas identifié(e).

Pages : 1

#1 Re : Optimisation » CDC en PostgreSQL » 23/11/2010 12:05:17

romainalcaraz

C'est bon j'ai reussi à régler mon problème j'ai appliquer ce script :
CREATE TABLE logs2
AS
SELECT
    0::BIGINT AS operation_id,
    ''::char AS operation,
    current_timestamp::timestamp AS operation_time,
    src2.*
FROM src2
WHERE 1 = 0;

ALTER TABLE logs2 ADD PRIMARY KEY(operation_id);
CREATE SEQUENCE operation_id_seq ;
ALTER TABLE logs2 ALTER operation_id SET DEFAULT nextval('operation_id_seq'::regclass);
ALTER TABLE logs2 ALTER operation_time SET DEFAULT current_timestamp;
       
CREATE OR REPLACE FUNCTION audit_src2() RETURNS TRIGGER AS $logs2$
BEGIN
    IF (TG_OP = 'DELETE') THEN
        INSERT INTO logs2 VALUES (DEFAULT,'D', DEFAULT, OLD.*);
        RETURN OLD;
    ELSIF (TG_OP = 'UPDATE') THEN
        INSERT INTO logs2 VALUES (DEFAULT,'U', DEFAULT, NEW.*);
        RETURN NEW;
    ELSIF (TG_OP = 'INSERT') THEN
        INSERT INTO logs2 VALUES (DEFAULT,'I', DEFAULT, NEW.*);
        RETURN NEW;
    END IF;
    RETURN NULL; -- le résultat est ignoré car il s'agit d'un trigger AFTER
END;
$logs2$ language plpgsql;
       
CREATE TRIGGER logs2
    AFTER INSERT OR UPDATE OR DELETE ON src2
    FOR EACH ROW EXECUTE PROCEDURE audit_src2();

Et c'est parfait !

#2 Re : Optimisation » CDC en PostgreSQL » 23/11/2010 11:39:54

romainalcaraz

CDC c'est pour change data capture pardon.
J'ai un schema ayant ce nom pour séparer mes tables de journal et de sources.

ne s'appliquent pas veut dire que mes DELETE s'effectue mais mes enregistrement réapparaissent immédiatement. quand je fais un DELETE puis un SELECT * j'ai tous (y compris mes enregistrements supprimés).

J'ai modifié ma fonction :

CREATE OR REPLACE FUNCTION cdc.logs2_archive()
RETURNS trigger AS $$
DECLARE
op cdc.operation_enum ;
BEGIN
    op = TG_OP;
    IF (TG_WHEN = 'BEFORE') THEN
        INSERT INTO cdc.logs2 VALUES ( DEFAULT, DEFAULT, op, OLD.*);
    ELSE
        INSERT INTO cdc.logs2 VALUES ( DEFAULT, DEFAULT, op, NEW.*);
    END IF;
    RETURN NULL;
END;
$$ LANGUAGE plpgsql;

Je pensais que c'était mon RETURN NEW; et j'ai donc mis un RETURN NULL; mais cela ne change rien.
Pour les parenthèses c'est juste un bug d'écriture mais elle y étaient bien.

#3 Optimisation » CDC en PostgreSQL » 23/11/2010 11:12:36

romainalcaraz
Réponses : 7

Bonjour,

Je suis actuellement sur un projet de journalisation de traitements BDD de type CDC sur une serveur PostgreSQL.
J'ai tenté jusqu'à présent d'utiliser le CDC géré par Talend (une solution d'ETL) mais le résultat ne me convient pas trop.
J'ai donc tenté de le faire de manière interne à ma base pour créer dynamiquement un CDC :

CREATE SCHEMA cdc;
GRANT USAGE ON SCHEMA cdc TO public;
CREATE TYPE cdc.operation_enum AS ENUM( 'DELETE', 'INSERT', 'UPDATE_BEFORE', 'UPDATE_AFTER', 'UPDATE' );
CREATE TABLE cdc.logs2
AS
SELECT
  0::BIGINT AS logs2_id,
  current_timestamp AS cdc_time,
  'DELETE'::cdc.operation_enum AS cdc_opeation,
  src2.*
FROM src2 WHERE 0 = 1;
GRANT INSERT ON cdc.logs2 TO public;

ALTER TABLE cdc.logs2 ADD PRIMARY KEY( logs2_id);
CREATE SEQUENCE cdc.logs2_id_seq ;
GRANT UPDATE ON cdc.logs2_id_seq TO public;
ALTER TABLE cdc.logs2 ALTER logs2_id SET DEFAULT nextval('cdc.logs2_id_seq'::regclass);
ALTER TABLE cdc.logs2 ALTER cdc_time SET DEFAULT current_timestamp;

CREATE OR REPLACE FUNCTION cdc.logs2_archive()
RETURNS trigger AS $$
DECLARE
  op cdc.operation_enum ;
BEGIN
  op = TG_OP;
  IF (TG_WHEN = 'BEFORE' THEN
    IF (TG_OP = 'UPDATE' THEN
      op = 'UPDATE_BEFORE';
    END IF;
    INSERT INTO cdc.logs2 VALUES ( DEFAULT, DEFAULT, op, OLD.*);
  ELSE
    IF (TG_OP = 'UPDATE' THEN
      op = 'UPDATE_AFTER';
    END IF;
    INSERT INTO cdc.logs2 VALUES ( DEFAULT, DEFAULT, op, NEW.*);
  END IF;
  RETURN NEW;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER cdc_logs2_before BEFORE UPDATE OR DELETE ON src2 FOR EACH ROW EXECUTE PROCEDURE cdc.logs2_archive();
CREATE TRIGGER cdc_logs2_after AFTER INSERT OR UPDATE ON src2 FOR EACH ROW EXECUTE PROCEDURE cdc.logs2_archive();


Pour être clair, j'ai récupéré ce script sur un forum et je l'ai remanié.
Je l'avais exécuté sans modifier mais cela ne marchait pas : lorsque je faisais une suppression sur ma table à 'loguer' (src2), les DELETE ne s'appliquaient pas (les enregistrements réapparaissaient).
Je l'ai modifié, enlevé ce qui me paraissait inutile mais le problème persiste : mes DELETE ne s'appliquent pas !
Est ce que quelqu'un arrive à voir pourquoi ?

Merci !

Pages : 1

Pied de page des forums

Propulsé par FluxBB