etl config file for transaction
This commit is contained in:
103
retail_model/table/fw_config_etl_mapping_txn.sql
Normal file
103
retail_model/table/fw_config_etl_mapping_txn.sql
Normal file
@@ -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);
|
||||||
|
*/
|
||||||
Reference in New Issue
Block a user