sql Talend - 表上的CDC删除的SQL过程

Posted 2021-05-13

CREATE OR REPLACE FUNCTION bct_mstr_record_d()
  RETURNS trigger AS
$BODY$
BEGIN
 INSERT INTO  "public"."TCDC_bct_mstr" 
   ( 
    "TALEND_CDC_SUBSCRIBERS_NAME",
    "TALEND_CDC_STATE",
    "TALEND_CDC_TYPE",
    "TALEND_CDC_CREATION_DATE",
    "unique_rec_id"
   ) SELECT 
      "TALEND_CDC_SUBSCRIBER_NAME",
      '0',
      'D',
      CURRENT_TIMESTAMP,
      old."unique_rec_id" 
    FROM "public"."TSUBSCRIBERS"
    WHERE "TALEND_CDC_TABLE_TO_WATCH"='public.bct_mstr' ;
RETURN old ;
END ;$BODY$
  LANGUAGE plpgsql VOLATILE
  COST 100;