sql Talend - CDC的SQL视图

Posted 2021-05-13

CREATE OR REPLACE VIEW "TCDC_VIEW_bct_mstr" AS 
 SELECT src."TALEND_CDC_TYPE", src."TALEND_CDC_SUBSCRIBERS_NAME", 
    max(src."TALEND_CDC_CREATION_DATE") AS "TALEND_CDC_CREATION_DATE", 
    src.unique_rec_id, targ.dbid, targ.bct_code, targ.ctl_document, 
    targ.ctl_payments, targ.ctl_adjustments, targ.act_document, 
    targ.act_payments, targ.act_adjustments, targ.posting_date, targ.initials, 
    targ.ok_to_post_flag, targ.batch_busy_flag, targ.sb12_claims_flag, 
    targ.disposition_code, targ.xref_comment, targ.deposit_date, 
    targ.create_date, targ.calpost_date, targ.purge_date, targ.lockbox, 
    targ.arf_ok_to_post, targ.client_code, targ.bank_code, targ.ok_to_post_cat, 
    targ.ok_to_post_user, targ.report_mth, targ.xref_flag, targ.orig_ctl_pmts, 
    targ.created_by_user, targ.scan_to
   FROM "TCDC_bct_mstr" src
   LEFT JOIN bct_mstr targ ON src.unique_rec_id = targ.unique_rec_id
  WHERE src."TALEND_CDC_STATE"::text = '1'::text
  GROUP BY src."TALEND_CDC_SUBSCRIBERS_NAME", src.unique_rec_id, targ.dbid, targ.bct_code, targ.ctl_document, targ.ctl_payments, targ.ctl_adjustments, targ.act_document, targ.act_payments, targ.act_adjustments, targ.posting_date, targ.initials, targ.ok_to_post_flag, targ.batch_busy_flag, targ.sb12_claims_flag, targ.disposition_code, targ.xref_comment, targ.deposit_date, targ.create_date, targ.calpost_date, targ.purge_date, targ.lockbox, targ.arf_ok_to_post, targ.client_code, targ.bank_code, targ.ok_to_post_cat, targ.ok_to_post_user, targ.report_mth, targ.xref_flag, targ.orig_ctl_pmts, targ.created_by_user, targ.scan_to, src."TALEND_CDC_TYPE";