diff --git a/dev/workflow/TK_Cust/yi_api_contact/api_contact_events/S98_S_api_contact_events.sql b/dev/workflow/TK_Cust/yi_api_contact/api_contact_events/S98_S_api_contact_events.sql index cbf60af..d39dc4a 100644 --- a/dev/workflow/TK_Cust/yi_api_contact/api_contact_events/S98_S_api_contact_events.sql +++ b/dev/workflow/TK_Cust/yi_api_contact/api_contact_events/S98_S_api_contact_events.sql @@ -16,6 +16,7 @@ insert into p10_sa.S98_S_api_contact_events , meta_name , meta_remark , properties + , contact_id , etl_tx_dt ) select at @@ -29,6 +30,7 @@ insert into p10_sa.S98_S_api_contact_events , meta_name , meta_remark , properties + , contact_id , etl_tx_dt from p00_tal.S98_S_api_contact_events ; @@ -47,6 +49,7 @@ insert into p12_sfull.S98_S_api_contact_events , meta_name , meta_remark , properties + , contact_id , etl_tx_dt ) select at @@ -60,6 +63,7 @@ insert into p12_sfull.S98_S_api_contact_events , meta_name , meta_remark , properties + , contact_id , etl_tx_dt from p10_sa.S98_S_api_contact_events ; diff --git a/dev/workflow/TK_Cust/yi_api_contact/api_contact_events/sa_foreign_tables.sql b/dev/workflow/TK_Cust/yi_api_contact/api_contact_events/sa_foreign_tables.sql index 0910777..c1f6bd0 100644 --- a/dev/workflow/TK_Cust/yi_api_contact/api_contact_events/sa_foreign_tables.sql +++ b/dev/workflow/TK_Cust/yi_api_contact/api_contact_events/sa_foreign_tables.sql @@ -11,6 +11,7 @@ CREATE FOREIGN TABLE if not exists p00_tal.S98_S_api_contact_events ( , meta_name TEXT , meta_remark TEXT , properties TEXT + , contact_id TEXT , etl_tx_dt TIMESTAMP ) diff --git a/dev/workflow/TK_Cust/yi_api_contact/api_contact_events/sa_tables.sql b/dev/workflow/TK_Cust/yi_api_contact/api_contact_events/sa_tables.sql index 152c738..06d67d8 100644 --- a/dev/workflow/TK_Cust/yi_api_contact/api_contact_events/sa_tables.sql +++ b/dev/workflow/TK_Cust/yi_api_contact/api_contact_events/sa_tables.sql @@ -11,6 +11,7 @@ create table if not exists p10_sa.S98_S_api_contact_events ( , meta_name TEXT , meta_remark TEXT , properties TEXT + , contact_id TEXT , etl_tx_dt TIMESTAMP ) ; @@ -25,6 +26,7 @@ create table if not exists p10_sa.S98_S_api_contact_events ( COMMENT ON COLUMN p10_sa.S98_S_api_contact_events.meta_name IS ''; COMMENT ON COLUMN p10_sa.S98_S_api_contact_events.meta_remark IS ''; COMMENT ON COLUMN p10_sa.S98_S_api_contact_events.properties IS ''; + COMMENT ON COLUMN p10_sa.S98_S_api_contact_events.contact_id IS ''; COMMENT ON COLUMN p10_sa.S98_S_api_contact_events.etl_tx_dt IS ''; COMMENT ON TABLE p10_sa.S98_S_api_contact_events IS ''; @@ -43,6 +45,7 @@ create table if not exists p12_sfull.S98_S_api_contact_events ( , meta_name TEXT , meta_remark TEXT , properties TEXT + , contact_id TEXT , etl_tx_dt TIMESTAMP ) ; @@ -57,6 +60,7 @@ create table if not exists p12_sfull.S98_S_api_contact_events ( COMMENT ON COLUMN p12_sfull.S98_S_api_contact_events.meta_name IS ''; COMMENT ON COLUMN p12_sfull.S98_S_api_contact_events.meta_remark IS ''; COMMENT ON COLUMN p12_sfull.S98_S_api_contact_events.properties IS ''; + COMMENT ON COLUMN p12_sfull.S98_S_api_contact_events.contact_id IS ''; COMMENT ON COLUMN p12_sfull.S98_S_api_contact_events.etl_tx_dt IS ''; COMMENT ON TABLE p12_sfull.S98_S_api_contact_events IS '';