From e08ba5ff2857fbae16015aaa57368386d0edffbf Mon Sep 17 00:00:00 2001 From: Harish Date: Wed, 23 Feb 2022 20:32:11 +0530 Subject: [PATCH] etl config file for transaction --- .../table/fw_config_etl_mapping_txn.sql | 103 ++++++++++++++++++ 1 file changed, 103 insertions(+) create mode 100644 retail_model/table/fw_config_etl_mapping_txn.sql diff --git a/retail_model/table/fw_config_etl_mapping_txn.sql b/retail_model/table/fw_config_etl_mapping_txn.sql new file mode 100644 index 0000000..120deb0 --- /dev/null +++ b/retail_model/table/fw_config_etl_mapping_txn.sql @@ -0,0 +1,103 @@ +-- DROP TABLE fw_config_etl_mapping_txn; + +CREATE TABLE fw_config_etl_mapping_txn ( + syspk bigserial not null, + client_id fw_num_dimid not null, + function_id fw_num_dimid not null, + target_table_name fw_text not null, + d0l1_src_id_src_col fw_text, + date_timestamp_src_col fw_text not null, + txna01_name_src_col fw_text, + txna02_name_src_col fw_text, + txna03_name_src_col fw_text, + txna04_name_src_col fw_text, + txna05_name_src_col fw_text, + txna06_name_src_col fw_text, + txna07_name_src_col fw_text, + txna08_name_src_col fw_text, + txna09_name_src_col fw_text, + txna10_name_src_col fw_text, + d3_unique_id_src_col fw_text, + d3_src_id_src_col fw_text, + d3_unique_id_name_src_col fw_text, + d3a01_src_col fw_text, + d3a02_src_col fw_text, + d3_geo_id_src_col fw_text, + d3_country_src_col fw_text, + d3_region_src_col fw_text, + d3_state_src_col fw_text, + d3_district_src_col fw_text, + d3_city_town_src_col fw_text, + d3_location_area_src_col fw_text, + d3_zipcode_src_col fw_text, + d3_locality_type_src_col fw_text, + d3_latitude_src_col fw_text, + d3_longitude_src_col fw_text, + d4_unique_id_src_col fw_text, + d4_src_id_src_col fw_text, + d4_unique_id_name_src_col fw_text, + d4a02_src_col fw_text, + d4a03_src_col fw_text, + d5_unique_id_src_col fw_text, + d5_src_id_src_col fw_text, + d5_unique_id_name_src_col fw_text, + d5a01_src_col fw_text, + d5a02_src_col fw_text, + d5a03_src_col fw_text, + date_lunarmonth_src_col fw_text, + date_lunarday_src_col fw_text, + date_holiday_src_col fw_text, + date_festival_src_col fw_text, + date_special_src_col fw_text, + m1101_src_col fw_text, + m1102_src_col fw_text, + m1103_src_col fw_text, + m1104_src_col fw_text, + m1105_src_col fw_text, + m1106_src_col fw_text, + m1107_src_col fw_text, + m1108_src_col fw_text, + where_join_condition fw_text, + group_by_clause fw_text, + order_by_clause fw_text, + created_by_appuser fw_text default current_user, + updated_by_appuser fw_text default current_user, + created_by_dbuser fw_text default current_user, + updated_by_dbuser fw_text default current_user, + create_time fw_timestamp default current_timestamp, + update_time fw_timestamp default current_timestamp, + CONSTRAINT fw_config_etl_mapping_txn_syspk_pkey PRIMARY KEY (syspk) +); + + +INSERT INTO fw_config_etl_mapping_txn +(client_id, function_id, target_table_name, d0l1_src_id_src_col, date_timestamp_src_col, txna01_name_src_col, txna02_name_src_col, txna03_name_src_col, txna04_name_src_col, +txna05_name_src_col, txna06_name_src_col, txna07_name_src_col, txna08_name_src_col, txna09_name_src_col, txna10_name_src_col, d3_unique_id_src_col, d3_src_id_src_col, +d3_unique_id_name_src_col, d3a01_src_col, d3a02_src_col, d3_geo_id_src_col, d3_country_src_col, d3_region_src_col, d3_state_src_col, d3_district_src_col, d3_city_town_src_col, +d3_location_area_src_col, d3_zipcode_src_col, d3_locality_type_src_col, d3_latitude_src_col, d3_longitude_src_col, d4_unique_id_src_col, d4_src_id_src_col, +d4_unique_id_name_src_col, d4a02_src_col, d4a03_src_col, d5_unique_id_src_col, d5_src_id_src_col, d5_unique_id_name_src_col, d5a01_src_col, d5a02_src_col, d5a03_src_col, +date_lunarmonth_src_col, date_lunarday_src_col, date_holiday_src_col, date_festival_src_col, date_special_src_col, m1101_src_col, m1102_src_col, m1103_src_col, +m1104_src_col, m1105_src_col, m1106_src_col, m1107_src_col, m1108_src_col, where_join_condition, group_by_clause, order_by_clause, +created_by_appuser, updated_by_appuser, created_by_dbuser, updated_by_dbuser, create_time, update_time) +VALUES(10, 1, 'fw_ods_txn', 'b.txn_id', 'b.txn_time', '''sale''', '''In-store''', '', '', '''In-store''', '', '''normal''', '', '', '''Cash''', 'd.id', 'b.retailer_id', +'d.name', 'd.category', '', '', 'd.country', '', '', '', '', '', '', '', '', '', '', '', '', '', '', '', '', '', '', '', '', '', '', '', '', '', +'count(a.salesorder_id)', 'sum(a.quantity)', 'b.txn_amount', '', '', '', '', 'b.txn_amount', +'customer_salesorder a JOIN customer_sales b ON a.salesorder_id = b.salesorder_id JOIN retailers d ON b.retailer_id = d.id ', +'', 'order by b.txn_id', CURRENT_USER, CURRENT_USER, CURRENT_USER, CURRENT_USER, CURRENT_TIMESTAMP, CURRENT_TIMESTAMP); + +/* +INSERT INTO retail.fw_config_etl_mapping_txn +(client_id, function_id, target_table_name, d0l1_src_id_src_col, date_timestamp_src_col, txna01_name_src_col, txna02_name_src_col, txna03_name_src_col, txna04_name_src_col, +txna05_name_src_col, txna06_name_src_col, txna07_name_src_col, txna08_name_src_col, txna09_name_src_col, txna10_name_src_col, d3_unique_id_src_col, d3_src_id_src_col, +d3_unique_id_name_src_col, d3a01_src_col, d3a02_src_col, d3_geo_id_src_col, d3_country_src_col, d3_region_src_col, d3_state_src_col, d3_district_src_col, d3_city_town_src_col, +d3_location_area_src_col, d3_zipcode_src_col, d3_locality_type_src_col, d3_latitude_src_col, d3_longitude_src_col, d4_unique_id_src_col, d4_src_id_src_col, +d4_unique_id_name_src_col, d4a02_src_col, d4a03_src_col, d5_unique_id_src_col, d5_src_id_src_col, d5_unique_id_name_src_col, d5a01_src_col, d5a02_src_col, d5a03_src_col, +date_lunarmonth_src_col, date_lunarday_src_col, date_holiday_src_col, date_festival_src_col, date_special_src_col, m1101_src_col, m1102_src_col, m1103_src_col, +m1104_src_col, m1105_src_col, m1106_src_col, m1107_src_col, m1108_src_col, where_join_condition, group_by_clause, order_by_clause, +created_by_appuser, updated_by_appuser, created_by_dbuser, updated_by_dbuser, create_time, update_time) +VALUES(10, 1, 'fw_ods_txn', 'b.txn_id', 'b.txn_time', '''sale''', '''In-store''', '', '', '''In-store''', '', '''normal''', '', '', '''Cash''', 'd.id', 'b.retailer_id', +'d.name', 'd.category', '', '', 'd.country', '', '', '', '', '', '', '', '', '', 's.salesman_id', '', 's.salesman_name', '', '', '', '', '', '', '', '', '', '', '', '', '', +'count(a.salesorder_id)', 'sum(a.quantity)', 'b.txn_amount', '', '', '', '', 'b.txn_amount', +'customer_salesorder a JOIN customer_sales b ON a.salesorder_id = b.salesorder_id JOIN retailers d ON b.retailer_id = d.id JOIN salesman_src s ON b.salesorder_id = s.salesman_id ', +'', 'order by b.txn_id', CURRENT_USER, CURRENT_USER, CURRENT_USER, CURRENT_USER, CURRENT_TIMESTAMP, CURRENT_TIMESTAMP); +*/ \ No newline at end of file