diff --git a/MMT_SQL/ods/BUDNI_ARC_ODS.SQL b/MMT_SQL/ods/BUDNI_ARC_ODS.SQL index 02e9753..5cd7229 100644 --- a/MMT_SQL/ods/BUDNI_ARC_ODS.SQL +++ b/MMT_SQL/ods/BUDNI_ARC_ODS.SQL @@ -15,11 +15,11 @@ Updation Date: Author: compegence team Function Call: select mmt_staging2.fn_BUDNI_ARC_ODS() ***************************************************************/ - -delete from mmt_ods.test_instance_engine_info where test_file_ref_no=273; - delete from mmt_ods.test_instance_tractor_info where test_file_ref_no=273; -delete from mmt_ods.budni_air_cleaner_perf_results where test_file_ref_no=273; -delete from mmt_ods.budni_test_observations where test_file_ref_no=273; +delete from mmt_ods.test_instance where test_file_sheet_format='BUDNI_ARC'; +delete from mmt_ods.test_instance_engine_info where test_file_sheet_format='BUDNI_ARC'; + delete from mmt_ods.test_instance_tractor_info where test_file_sheet_format='BUDNI_ARC'; +delete from mmt_ods.budni_air_cleaner_perf_results where test_file_sheet_format='BUDNI_ARC'; +delete from mmt_ods.budni_test_observations where test_file_sheet_format='BUDNI_ARC'; SET search_path TO mmt_staging2; @@ -153,7 +153,7 @@ test_file_format, test_file_sheet_format, tractor_make, tractor_model, -srl_no, +sequence_number, characteristic, category_evaluative_or_non_evaluative, requirements_as_per_is_12207_2008, @@ -168,7 +168,7 @@ file_syspk, file_format, sheet_mnemonic, make,model, -column3, +column3::int, column4, column5, column6, diff --git a/MMT_SQL/ods/BUDNI_BRK_ODS.SQL b/MMT_SQL/ods/BUDNI_BRK_ODS.SQL new file mode 100644 index 0000000..9741e4d --- /dev/null +++ b/MMT_SQL/ods/BUDNI_BRK_ODS.SQL @@ -0,0 +1,462 @@ +drop function if exists mmt_staging2.fn_BUDNI_BRK_ODS; +CREATE OR REPLACE FUNCTION mmt_staging2.fn_BUDNI_BRK_ODS() + RETURNS void AS $$ + declare __test_instance_id int; + declare __file_syspk int; + begin + +/************************************************************ +Function Name:fn_BUDNI_BRK_ODS +Function Desc: This function populates data into ODS +File Format: BUDNI +Sheet Format: BUDNI_BRK +Creation Date: +Updation Date: +Author: compegence team +Function Call: select mmt_staging2.fn_BUDNI_BRK_ODS() +***************************************************************/ + +delete from mmt_ods.test_instance where test_file_sheet_format='BUDNI_BRK'; +delete from mmt_ods.test_instance_engine_info where test_file_sheet_format='BUDNI_BRK'; +delete from mmt_ods.test_instance_tractor_info where test_file_sheet_format='BUDNI_BRK'; +delete from mmt_ods.budni_brake_perf_parking_brake_test_results +where test_file_sheet_format='BUDNI_BRK'; +delete from mmt_ods.budni_brake_perf_service_brake_test_results +where test_file_sheet_format='BUDNI_BRK'; +delete from mmt_ods.budni_test_observations +where test_file_sheet_format='BUDNI_BRK'; + + +SET search_path TO mmt_staging2; + +insert into mmt_ods.test_instance_tractor_info +( +client_id, +function_id, +test_file_ref_no, +test_file_format, +test_file_sheet_format, +tractor_make, +tractor_model, +tractor_engine_hp, +brake_type, +brake_free_play_lh, +brake_free_play_rh, +unballasted_max_speed_kmph, +road_ballasted_max_speed_kmph +) +select +client_id, +function_id, +file_syspk, +file_format, +sheet_mnemonic, +make, +model, +tractor_HP::numeric tractor_engine_hp, +Type_of_brake, +brake_free_play_lh::numeric , +brake_free_play_rh::numeric , +maximum_attainable_speed_kmph_unballasted::numeric , +maximum_attainable_speed_kmph_ballasted::numeric +from mmt_staging2.BUDNI_BRK_Spec_H1_block; + +insert into mmt_ods.test_instance +( +client_id, +function_id, +test_file_ref_no, +test_file_format, +test_file_sheet_format, +tractor_make, +tractor_model, +type_of_road +) +select +client_id, +function_id, +file_syspk, +file_format, +sheet_mnemonic, +make,model, +type_of_track +from + mmt_staging2.BUDNI_BRK_Spec_H1_block; + + insert into mmt_ods.test_instance_engine_info + ( + client_id, +function_id, +test_file_ref_no, +test_file_format, +test_file_sheet_format, +tractor_make, +tractor_model, +rated_rpm +) +select +client_id, +function_id, +file_syspk, +file_format, +sheet_mnemonic, +make,model, +rated_rpm::int +from mmt_staging2.BUDNI_BRK_Spec_H1_block; + + +/*block */ + +insert into mmt_ods.budni_brake_perf_service_brake_test_results +( +client_id, +function_id, +test_file_ref_no, +test_file_format, +test_file_sheet_format, +tractor_make, +tractor_model, +brake_test_type, +brake_test_name, +speed_condition, +ballast_condition, +braking_device_control_force_n, +mean_deceleration_msec2, +stopping_dist_m +) +select +client_id, +function_id, +file_syspk, +file_format, +sheet_mnemonic, +make,model, +brake_test_type, +brake_test_name, +speed_condition, +ballast_condition, +Braking_device_control_force_N::numeric , +Mean_deceleration_m_sec2::numeric , +Stopping_distance_m ::numeric +from mmt_staging2.budni_brk_service_cold_ballasted_25kmph_block; + +insert into mmt_ods.budni_brake_perf_service_brake_test_results +( +client_id, +function_id, +test_file_ref_no, +test_file_format, +test_file_sheet_format, +tractor_make, +tractor_model, +brake_test_type, +brake_test_name, +speed_condition, +ballast_condition, +braking_device_control_force_n, +mean_deceleration_msec2, +stopping_dist_m +) +select +client_id, +function_id, +file_syspk, +file_format, +sheet_mnemonic, +make,model, +brake_test_type, +brake_test_name, +speed_condition, +ballast_condition, +Braking_device_control_force_N::numeric , +Mean_deceleration_m_sec2::numeric , +Stopping_distance_m ::numeric +from mmt_staging2.budni_brk_service_cold_ballasted_maximum_block; + +insert into mmt_ods.budni_brake_perf_service_brake_test_results +( +client_id, +function_id, +test_file_ref_no, +test_file_format, +test_file_sheet_format, +tractor_make, +tractor_model, +brake_test_type, +brake_test_name, +speed_condition, +ballast_condition, +braking_device_control_force_n, +mean_deceleration_msec2, +stopping_dist_m +) +select +client_id, +function_id, +file_syspk, +file_format, +sheet_mnemonic, +make,model, +brake_test_type, +brake_test_name, +speed_condition, +ballast_condition, +Braking_device_control_force_N::numeric , +Mean_deceleration_m_sec2::numeric , +Stopping_distance_m ::numeric +from mmt_staging2.budni_brk_service_cold_standard_25kmph_block; + +insert into mmt_ods.budni_brake_perf_service_brake_test_results +( +client_id, +function_id, +test_file_ref_no, +test_file_format, +test_file_sheet_format, +tractor_make, +tractor_model, +brake_test_type, +brake_test_name, +speed_condition, +ballast_condition, +braking_device_control_force_n, +mean_deceleration_msec2, +stopping_dist_m +) +select +client_id, +function_id, +file_syspk, +file_format, +sheet_mnemonic, +make,model, +brake_test_type, +brake_test_name, +speed_condition, +ballast_condition, +Braking_device_control_force_N::numeric , +Mean_deceleration_m_sec2::numeric , +Stopping_distance_m ::numeric +from mmt_staging2.budni_brk_service_cold_standard_maximum_block; + + +insert into mmt_ods.budni_brake_perf_service_brake_test_results +( +client_id, +function_id, +test_file_ref_no, +test_file_format, +test_file_sheet_format, +tractor_make, +tractor_model, +brake_test_type, +brake_test_name, +speed_condition, +ballast_condition, +braking_device_control_force_n, +mean_deceleration_msec2, +stopping_dist_m +) +select +client_id, +function_id, +file_syspk, +file_format, +sheet_mnemonic, +make,model, +brake_test_type, +brake_test_name, +speed_condition, +ballast_condition, +Braking_device_control_force_N::numeric , +Mean_deceleration_m_sec2::numeric , +Stopping_distance_m ::numeric +from mmt_staging2.budni_brk_service_fade_standard_maximum_block; + +insert into mmt_ods.budni_brake_perf_service_brake_test_results +( +client_id, +function_id, +test_file_ref_no, +test_file_format, +test_file_sheet_format, +tractor_make, +tractor_model, +brake_test_type, +brake_test_name, +speed_condition, +ballast_condition, +braking_device_control_force_n, +mean_deceleration_msec2, +stopping_dist_m +) +select +client_id, +function_id, +file_syspk, +file_format, +sheet_mnemonic, +make,model, +brake_test_type, +brake_test_name, +speed_condition, +ballast_condition, +Braking_device_control_force_N::numeric , +Mean_deceleration_m_sec2::numeric , +Stopping_distance_m ::numeric +from mmt_staging2.budni_brk_service_fade_ballasted_25kmph_block; + + + +update mmt_ods.budni_brake_perf_service_brake_test_results +set max_dev_of_tractor_from_its_org_course_m =column3, +abnormal_vibration=column5, +the_brakes_were_heated_by =column7 +from mmt_staging2.budni_brk_other_observations_Block where ods_record =1; + +insert into mmt_ods.budni_brake_perf_parking_brake_test_results +( +client_id, +function_id, +test_file_ref_no, +test_file_format, +test_file_sheet_format, +tractor_make, +tractor_model, +test_condition +) +select +client_id, +function_id, +file_syspk, +file_format, +sheet_mnemonic, +make,model, +particulars +from mmt_staging2.budni_brk_parking_barke_test_block where particulars is not null; + +update mmt_ods.budni_brake_perf_parking_brake_test_results +set braking_device_control_force_n_facing_up = (select +Braking_device_control_force::numeric +from mmt_staging2.budni_brk_parking_barke_test_block +where facing='Facing up' and particulars='18 percent slope') +where test_condition='18 percent slope'; + +update mmt_ods.budni_brake_perf_parking_brake_test_results +set braking_device_control_force_n_facing_down = (select +Braking_device_control_force::numeric +from mmt_staging2.budni_brk_parking_barke_test_block +where facing='Facing Down' and particulars='18 percent slope') +where test_condition='18 percent slope'; + +update mmt_ods.budni_brake_perf_parking_brake_test_results +set efficacy_of_parking_brake_facing_down = (select +Efficacy_of_parking_brake +from mmt_staging2.budni_brk_parking_barke_test_block +where facing='Facing Down' and particulars='18 percent slope') +where test_condition='18 percent slope'; + +update mmt_ods.budni_brake_perf_parking_brake_test_results +set efficacy_of_parking_brake_facing_up = (select +Efficacy_of_parking_brake +from mmt_staging2.budni_brk_parking_barke_test_block +where facing='Facing up' and particulars='18 percent slope') +where test_condition='18 percent slope'; + +update mmt_ods.budni_brake_perf_parking_brake_test_results +set braking_device_control_force_n_facing_up = (select +Braking_device_control_force::numeric +from mmt_staging2.budni_brk_parking_barke_test_block +where facing='Facing up' and particulars='12 percent slope with trailer of 2.55 tonnes.') +where test_condition='12 percent slope with trailer of 2.55 tonnes.'; + +update mmt_ods.budni_brake_perf_parking_brake_test_results +set braking_device_control_force_n_facing_down = (select +Braking_device_control_force::numeric +from mmt_staging2.budni_brk_parking_barke_test_block +where facing='Facing Down' and particulars='12 percent slope with trailer of 2.55 tonnes.') +where test_condition='12 percent slope with trailer of 2.55 tonnes.'; + +update mmt_ods.budni_brake_perf_parking_brake_test_results +set efficacy_of_parking_brake_facing_down = (select +Efficacy_of_parking_brake +from mmt_staging2.budni_brk_parking_barke_test_block +where facing='Facing Down' and particulars='12 percent slope with trailer of 2.55 tonnes.') +where test_condition='12 percent slope with trailer of 2.55 tonnes.'; + +update mmt_ods.budni_brake_perf_parking_brake_test_results +set efficacy_of_parking_brake_facing_up = (select +Efficacy_of_parking_brake +from mmt_staging2.budni_brk_parking_barke_test_block +where facing='Facing up' and particulars='12 percent slope with trailer of 2.55 tonnes.') +where test_condition='12 percent slope with trailer of 2.55 tonnes.'; + +delete from mmt_ods.budni_brake_perf_parking_brake_test_results a +using mmt_ods.budni_brake_perf_parking_brake_test_results b +where a.syspk < b.syspk and a.test_condition =b.test_condition ; + + +insert into mmt_ods.budni_test_observations +( +client_id, +function_id, +test_file_ref_no, +test_file_format, +test_file_sheet_format, +tractor_make, +tractor_model, +characteristic, +category_evaluative_or_non_evaluative, +requirements_as_per_is_12207_2008, +values_declared_by_the_applicant_d_rqmt, +as_observed, +whether_meets_the_requirements_yn +) +select +client_id, +function_id, +file_syspk, +file_format, +sheet_mnemonic, +make,model, +column3, +column4, +column5, +column6, +column7, +column8 +from mmt_staging2.BUDNI_BRK_test_obs_summary_block where ods_record=1; + + +select file_syspk into __file_syspk from mmt_staging2.BUDNI_BRK_Spec_H1_block; +select syspk into __test_instance_id from mmt_ods.test_instance where test_file_ref_no =__file_syspk; + + +update mmt_ods.test_instance_engine_info +set test_instance_id=__test_instance_id +where test_file_ref_no=__file_syspk; + + +update mmt_ods.test_instance_tractor_info +set test_instance_id=__test_instance_id +where test_file_ref_no=__file_syspk; + + +update mmt_ods.budni_brake_perf_parking_brake_test_results +set test_instance_id=__test_instance_id +where test_file_ref_no=__file_syspk; + +update mmt_ods.budni_brake_perf_service_brake_test_results +set test_instance_id=__test_instance_id +where test_file_ref_no=__file_syspk; + +update mmt_ods.budni_test_observations +set test_instance_id=__test_instance_id +where test_file_ref_no=__file_syspk; + + +end +$$ LANGUAGE plpgsql; + + + diff --git a/MMT_SQL/ods/BUDNI_DBP_ODS.SQL b/MMT_SQL/ods/BUDNI_DBP_ODS.SQL index f436998..f0f4bf3 100644 --- a/MMT_SQL/ods/BUDNI_DBP_ODS.SQL +++ b/MMT_SQL/ods/BUDNI_DBP_ODS.SQL @@ -15,10 +15,10 @@ Updation Date: Author: compegence team Function Call: select mmt_staging2.fn_BUDNI_DBP_ODS() ***************************************************************/ - -delete from mmt_ods.test_instance_engine_info where test_file_ref_no=261; -delete from mmt_ods.test_instance_tractor_info where test_file_ref_no=261; -delete from mmt_ods.budni_drawbar_perf_results where test_file_ref_no=261; +delete from mmt_ods.test_instance where test_file_sheet_format='BUDNI_DBP'; +delete from mmt_ods.test_instance_engine_info where test_file_sheet_format='BUDNI_DBP'; +delete from mmt_ods.test_instance_tractor_info where test_file_sheet_format='BUDNI_DBP'; +delete from mmt_ods.budni_drawbar_perf_results where test_file_sheet_format='BUDNI_DBP'; insert into mmt_ods.test_instance_tractor_info ( diff --git a/MMT_SQL/ods/BUDNI_FLD_ODS.SQL b/MMT_SQL/ods/BUDNI_FLD_ODS.SQL index 50b70f6..0b88fb7 100644 --- a/MMT_SQL/ods/BUDNI_FLD_ODS.SQL +++ b/MMT_SQL/ods/BUDNI_FLD_ODS.SQL @@ -16,15 +16,17 @@ Author: compegence team Function Call: select mmt_staging2.fn_BUDNI_FLD_ODS() ***************************************************************/ -delete from mmt_ods.test_instance_engine_info where test_file_ref_no=261; +delete from mmt_ods.test_instance where test_file_sheet_format='BUDNI_FLD'; + +delete from mmt_ods.test_instance_engine_info where test_file_sheet_format='BUDNI_FLD'; -delete from mmt_ods.test_instance_tractor_info where test_file_ref_no=261; +delete from mmt_ods.test_instance_tractor_info where test_file_sheet_format='BUDNI_FLD'; -delete from mmt_ods.test_instance_implement_info where test_file_ref_no=261; +delete from mmt_ods.test_instance_implement_info where test_file_sheet_format='BUDNI_FLD'; -delete from mmt_ods.budni_field_perf_results where test_file_ref_no=261; +delete from mmt_ods.budni_field_perf_results where test_file_sheet_format='BUDNI_FLD'; -delete from mmt_ods.budni_test_observations where test_file_ref_no=261; +delete from mmt_ods.budni_test_observations where test_file_sheet_format='BUDNI_FLD'; insert into mmt_ods.test_instance_tractor_info ( diff --git a/MMT_SQL/ods/BUDNI_HDL_ODS.SQL b/MMT_SQL/ods/BUDNI_HDL_ODS.SQL index dc7c953..a83b31a 100644 --- a/MMT_SQL/ods/BUDNI_HDL_ODS.SQL +++ b/MMT_SQL/ods/BUDNI_HDL_ODS.SQL @@ -16,19 +16,29 @@ Author: compegence team Function Call: select mmt_staging2.fn_BUDNI_HDL_ODS() ***************************************************************/ -delete from mmt_ods.test_instance_engine_info where test_file_ref_no=261; +delete from mmt_ods.test_instance +where test_file_sheet_format='BUDNI_HDL'; -delete from mmt_ods.test_instance_tractor_info where test_file_ref_no=261; +delete from mmt_ods.test_instance_engine_info +where test_file_sheet_format='BUDNI_HDL'; -delete from mmt_ods.test_instance_tractor_info_misc where test_file_ref_no=261; +delete from mmt_ods.test_instance_tractor_info +where test_file_sheet_format='BUDNI_HDL'; -delete from mmt_ods.budni_hydraulic_maint_of_lift_load_results where test_file_ref_no=261; +delete from mmt_ods.test_instance_tractor_info_misc +where test_file_sheet_format='BUDNI_HDL'; -delete from mmt_ods.budni_hydraulic_power_test_results where test_file_ref_no=261; +delete from mmt_ods.budni_hydraulic_maint_of_lift_load_results +where test_file_sheet_format='BUDNI_HDL'; -delete from mmt_ods.budni_hydraulic_lifting_capacity_test_results where test_file_ref_no=261; +delete from mmt_ods.budni_hydraulic_power_test_results +where test_file_sheet_format='BUDNI_HDL'; -delete from mmt_ods.budni_test_observations where test_file_ref_no=261; +delete from mmt_ods.budni_hydraulic_lifting_capacity_test_results +where test_file_sheet_format='BUDNI_HDL'; + +delete from mmt_ods.budni_test_observations +where test_file_sheet_format='BUDNI_HDL'; insert into mmt_ods.test_instance_tractor_info diff --git a/MMT_SQL/ods/BUDNI_HLG_ODS.SQL b/MMT_SQL/ods/BUDNI_HLG_ODS.SQL index 6d30b4c..4af2d5f 100644 --- a/MMT_SQL/ods/BUDNI_HLG_ODS.SQL +++ b/MMT_SQL/ods/BUDNI_HLG_ODS.SQL @@ -15,16 +15,16 @@ Updation Date: Author: compegence team Function Call: select mmt_staging2.fn_BUDNI_HLG_ODS() ***************************************************************/ + +delete from mmt_ods.test_instance where test_file_sheet_format='BUDNI_HLG'; +delete from mmt_ods.test_instance_engine_info where test_file_sheet_format='BUDNI_HLG'; -delete from mmt_ods.test_instance_engine_info where test_file_ref_no=261; +delete from mmt_ods.test_instance_tractor_info where test_file_sheet_format='BUDNI_HLG'; +delete from mmt_ods.budni_haulage_perf_results where test_file_sheet_format='BUDNI_HLG'; -delete from mmt_ods.test_instance_tractor_info where test_file_ref_no=261; - -delete from mmt_ods.budni_haulage_perf_results where test_file_ref_no=261; - -delete from mmt_ods.budni_test_observations where test_file_ref_no=261; +delete from mmt_ods.budni_test_observations where test_file_sheet_format='BUDNI_HLG'; insert into mmt_ods.test_instance_tractor_info @@ -160,7 +160,7 @@ test_file_format, test_file_sheet_format, tractor_make, tractor_model, -srl_no, +sequence_number , characteristic, category_evaluative_or_non_evaluative, requirements_as_per_is_12207_2008, @@ -175,7 +175,7 @@ file_syspk, file_format, sheet_mnemonic, make,model, -column3, +column3::numeric , column4, column5, column6, diff --git a/MMT_SQL/ods/BUDNI_LCG_ODS.SQL b/MMT_SQL/ods/BUDNI_LCG_ODS.SQL index 317b982..9fa1a56 100644 --- a/MMT_SQL/ods/BUDNI_LCG_ODS.SQL +++ b/MMT_SQL/ods/BUDNI_LCG_ODS.SQL @@ -16,13 +16,13 @@ Author: compegence team Function Call: select mmt_staging2.fn_BUDNI_LCG_ODS() ***************************************************************/ +delete from mmt_ods.test_instance where test_file_sheet_format='BUDNI_LCG'; -delete from mmt_ods.test_instance_engine_info where test_file_ref_no=261; +delete from mmt_ods.test_instance_engine_info where test_file_sheet_format='BUDNI_LCG'; -delete from mmt_ods.test_instance_tractor_info where test_file_ref_no=261; +delete from mmt_ods.test_instance_tractor_info where test_file_sheet_format='BUDNI_LCG'; - -delete from mmt_ods.budni_centre_of_gravity_location where test_file_ref_no=261; +delete from mmt_ods.budni_centre_of_gravity_location where test_file_ref_no =261; diff --git a/MMT_SQL/ods/BUDNI_NMT_ODS.SQL b/MMT_SQL/ods/BUDNI_NMT_ODS.SQL index 9e53df9..0d05e19 100644 --- a/MMT_SQL/ods/BUDNI_NMT_ODS.SQL +++ b/MMT_SQL/ods/BUDNI_NMT_ODS.SQL @@ -17,19 +17,18 @@ Author: compegence team Function Call: select mmt_staging2.fn_BUDNI_NMT_ODS() ***************************************************************/ + +delete from mmt_ods.test_instance where test_file_sheet_format='BUDNI_NMT'; -delete from mmt_ods.test_instance_engine_info where test_file_ref_no=261; +delete from mmt_ods.test_instance_engine_info where test_file_sheet_format='BUDNI_NMT'; +delete from mmt_ods.test_instance_tractor_info where test_file_sheet_format='BUDNI_NMT'; -delete from mmt_ods.test_instance_tractor_info where test_file_ref_no=261; +delete from mmt_ods.budni_noise_atmospheric_conditions where test_file_sheet_format='BUDNI_NMT'; -delete from mmt_ods.budni_noise_atmospheric_conditions where test_file_ref_no=261; +delete from mmt_ods.budni_noise_measurement_results where test_file_sheet_format='BUDNI_NMT'; - -delete from mmt_ods.budni_noise_measurement_results where test_file_ref_no=261; - - -delete from mmt_ods.budni_test_observations where test_file_ref_no=261; +delete from mmt_ods.budni_test_observations where test_file_sheet_format='BUDNI_NMT'; @@ -252,7 +251,7 @@ test_file_format, test_file_sheet_format, tractor_make, tractor_model, -srl_no, +sequence_number, characteristic, category_evaluative_or_non_evaluative, requirements_as_per_is_12207_2008, @@ -267,7 +266,7 @@ file_syspk, file_format, sheet_mnemonic, make,model, -column3, +column3::numeric, column4, column5, column6, diff --git a/MMT_SQL/ods/BUDNI_PTO_ODS.SQL b/MMT_SQL/ods/BUDNI_PTO_ODS.SQL index 9ddf225..4fcacc4 100644 --- a/MMT_SQL/ods/BUDNI_PTO_ODS.SQL +++ b/MMT_SQL/ods/BUDNI_PTO_ODS.SQL @@ -16,16 +16,17 @@ Author: compegence team Function Call: select mmt_staging2.fn_BUDNI_PTO_ODS() ***************************************************************/ +delete from mmt_ods.test_instance where test_file_sheet_format='BUDNI_PTO'; -delete from mmt_ods.test_instance_engine_info where test_file_ref_no=261; +delete from mmt_ods.test_instance_engine_info where test_file_sheet_format='BUDNI_PTO'; -delete from mmt_ods.test_instance_tractor_info where test_file_ref_no=261; +delete from mmt_ods.test_instance_tractor_info where test_file_sheet_format='BUDNI_PTO'; -delete from mmt_ods.budni_pto_perf_results_summary where test_file_ref_no=261; +delete from mmt_ods.budni_pto_perf_results_summary where test_file_sheet_format='BUDNI_PTO'; -delete from mmt_ods.budni_test_observations where test_file_ref_no=261; +delete from mmt_ods.budni_test_observations where test_file_sheet_format='BUDNI_PTO'; -delete from mmt_ods.budni_pto_perf_results_details where test_file_ref_no=261; +delete from mmt_ods.budni_pto_perf_results_details where test_file_sheet_format='BUDNI_PTO'; insert into mmt_ods.test_instance_tractor_info ( diff --git a/MMT_SQL/ods/BUDNI_VMT_ODS.SQL b/MMT_SQL/ods/BUDNI_VMT_ODS.SQL index 9594cb7..cddeb15 100644 --- a/MMT_SQL/ods/BUDNI_VMT_ODS.SQL +++ b/MMT_SQL/ods/BUDNI_VMT_ODS.SQL @@ -16,15 +16,16 @@ Author: compegence team Function Call: select mmt_staging2.fn_BUDNI_VMT_ODS() ***************************************************************/ +delete from mmt_ods.test_instance where test_file_sheet_format='BUDNI_VMT'; -delete from mmt_ods.test_instance_engine_info where test_file_ref_no=261; +delete from mmt_ods.test_instance_engine_info where test_file_sheet_format='BUDNI_VMT'; -delete from mmt_ods.test_instance_tractor_info where test_file_ref_no=261; +delete from mmt_ods.test_instance_tractor_info where test_file_sheet_format='BUDNI_VMT'; -delete from mmt_ods.budni_vibration_measurements where test_file_ref_no=261; +delete from mmt_ods.budni_vibration_measurement where test_file_sheet_format='BUDNI_VMT'; -delete from mmt_ods.budni_test_observations where test_file_ref_no=261; +delete from mmt_ods.budni_test_observations where test_file_sheet_format='BUDNI_VMT'; insert into mmt_ods.test_instance_tractor_info @@ -144,7 +145,7 @@ test_file_format, test_file_sheet_format, tractor_make, tractor_model, -sequence_number, +srl_no, characteristic, category_evaluative_or_non_evaluative, requirements_as_per_is_12207_2008, diff --git a/MMT_SQL/onetime/create_tables_budni_brk.sql b/MMT_SQL/onetime/create_tables_budni_brk.sql new file mode 100644 index 0000000..6048fac --- /dev/null +++ b/MMT_SQL/onetime/create_tables_budni_brk.sql @@ -0,0 +1,428 @@ +drop table if exists mmt_staging2.BUDNI_BRK_Spec_H1_Block; +drop table if exists mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int; +drop table if exists mmt_staging2.BUDNI_BRK_service_cold_standard_maximum_Block; +drop table if exists mmt_staging2.BUDNI_BRK_service_cold_ballasted_maximum_Block; +drop table if exists mmt_staging2.BUDNI_BRK_service_cold_standard_25kmph_Block; +drop table if exists mmt_staging2.BUDNI_BRK_service_cold_ballasted_25kmph_Block; +drop table if exists mmt_staging2.BUDNI_BRK_service_fade_standard_maximum_Block; +drop table if exists mmt_staging2.BUDNI_BRK_service_fade_ballasted_25kmph_Block; +drop table if exists mmt_staging2.BUDNI_BRK_other_observations_Block; +drop table if exists mmt_staging2.BUDNI_BRK_Parking_Barke_Test_Int ; +drop table if exists mmt_staging2.BUDNI_BRK_Parking_Barke_Test_Block; +drop table if exists mmt_staging2.BUDNI_BRK_Test_Obs_Summary_Block; +drop table if exists mmt_staging2.stg_process_table_BUDNI_BRK; +drop table if exists mmt_staging2.stg_specific_table_BUDNI_BRK; + + +create table mmt_staging2.BUDNI_BRK_Spec_H1_Block +( +syspk serial, +file_syspk int, +client_id int, +function_id int, +file_format text, +sheet_mnemonic text, +dummy_f text, +make text, +model text, +tractor_HP text, +rated_rpm text, +Type_of_brake text, +Type_of_track text , +brake_free_play_lh text, +brake_free_play_rh text, +maximum_attainable_speed_kmph_unballasted text, +maximum_attainable_speed_kmph_ballasted text, +rank int, +ods_record int default 1 +); + +create table mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int +( +syspk serial, +file_syspk int, +client_id int, +function_id int, +file_format text, +sheet_mnemonic text, +dummy_f text, +make text, +model text, +column1 text, +column2 text, +column3 text, +column4 text, +column5 text, +column6 text, +column7 text, +column8 text, +column9 text, +rank int, +ods_record int default 1 +); + +create table mmt_staging2.BUDNI_BRK_service_cold_standard_maximum_Block +( +syspk serial, +file_syspk int, +client_id int, +function_id int, +file_format text, +sheet_mnemonic text, +dummy_f text, +make text, +model text, +brake_test_type text, +brake_test_name text, +speed_condition text, +ballast_condition text, +Braking_device_control_force_N text, +Mean_deceleration_m_sec2 text, +Stopping_distance_m text, +rank int, +ods_record int default 1 +); + +create table mmt_staging2.BUDNI_BRK_service_cold_ballasted_maximum_Block +( +syspk serial, +file_syspk int, +client_id int, +function_id int, +file_format text, +sheet_mnemonic text, +dummy_f text, +make text, +model text, +brake_test_type text, +brake_test_name text, +speed_condition text, +ballast_condition text, +Braking_device_control_force_N text, +Mean_deceleration_m_sec2 text, +Stopping_distance_m text, +rank int, +ods_record int default 1 +); + +create table mmt_staging2.BUDNI_BRK_service_cold_standard_25kmph_Block +( +syspk serial, +file_syspk int, +client_id int, +function_id int, +file_format text, +sheet_mnemonic text, +dummy_f text, +make text, +model text, +brake_test_type text, +brake_test_name text, +speed_condition text, +ballast_condition text, +Braking_device_control_force_N text, +Mean_deceleration_m_sec2 text, +Stopping_distance_m text, +rank int, +ods_record int default 1 +); + +create table mmt_staging2.BUDNI_BRK_service_cold_ballasted_25kmph_Block +( +syspk serial, +file_syspk int, +client_id int, +function_id int, +file_format text, +sheet_mnemonic text, +dummy_f text, +make text, +model text, +brake_test_type text, +brake_test_name text, +speed_condition text, +ballast_condition text, +Braking_device_control_force_N text, +Mean_deceleration_m_sec2 text, +Stopping_distance_m text, +rank int, +ods_record int default 1 +); + +create table mmt_staging2.BUDNI_BRK_service_fade_standard_maximum_Block +( +syspk serial, +file_syspk int, +client_id int, +function_id int, +file_format text, +sheet_mnemonic text, +dummy_f text, +make text, +model text, +brake_test_type text, +brake_test_name text, +speed_condition text, +ballast_condition text, +Braking_device_control_force_N text, +Mean_deceleration_m_sec2 text, +Stopping_distance_m text, +rank int, +ods_record int default 1 +); + +create table mmt_staging2.BUDNI_BRK_service_fade_ballasted_25kmph_Block +( +syspk serial, +file_syspk int, +client_id int, +function_id int, +file_format text, +sheet_mnemonic text, +dummy_f text, +make text, +model text, +brake_test_type text, +brake_test_name text, +speed_condition text, +ballast_condition text, +Braking_device_control_force_N text, +Mean_deceleration_m_sec2 text, +Stopping_distance_m text, +rank int, +ods_record int default 1 +); + +create table mmt_staging2.BUDNI_BRK_other_observations_Block +( +syspk serial, +file_syspk int, +client_id int, +function_id int, +file_format text, +sheet_mnemonic text, +dummy_f text, +make text, +model text, +column1 text, +column2 text, +column3 text, +column4 text, +column5 text, +column6 text, +column7 text, +column8 text, +column9 text, +rank int, +ods_record int default 1 +); + +create table mmt_staging2.budni_brk_parking_barke_test_int +( +syspk serial, +file_syspk int, +client_id int, +function_id int, +file_format text, +sheet_mnemonic text, +dummy_f text, +make text, +model text, +column1 text, +column2 text, +column3 text, +column4 text, +column5 text, +column6 text, +column7 text, +column8 text, +column9 text, +rank int, +ods_record int default 1 +); + +create table mmt_staging2.BUDNI_BRK_Parking_Barke_Test_Block +( +syspk serial, +file_syspk int, +client_id int, +function_id int, +file_format text, +sheet_mnemonic text, +dummy_f text, +make text, +model text, +particulars text, +facing text, +Braking_device_control_force text, +Efficacy_of_parking_brake text, +rank int, +ods_record int default 1 +); + + + +create table mmt_staging2.BUDNI_BRK_Test_Obs_Summary_Block +( +syspk serial, +file_syspk int, +client_id int, +function_id int, +file_format text, +sheet_mnemonic text, +dummy_f text, +make text, +model text, +column3 text, +column4 text, +column5 text, +column6 text, +column7 text, +column8 text, +column9 text, +rank int, +ods_record int default 1 +); + +create TABLE mmt_staging2.stg_process_table_BUDNI_BRK ( + generic_syspk int, +file_syspk bigint, +file_name varchar(1024) NULL, +file_date date NULL, +file_format varchar(1024) NULL, +sheet_number int4 NULL, +sheet_name varchar(1024) NULL, +sheet_format text, +sheet_mnemonic varchar(1024) NULL, +row_number int4 NULL, +file_creation_date timestamp NULL, +column1 varchar(1024) NULL, +column2 varchar(1024) NULL, +column3 varchar(1024) NULL, +column4 varchar(1024) NULL, +column5 varchar(1024) NULL, +column6 varchar(1024) NULL, +column7 varchar(1024) NULL, +column8 varchar(1024) NULL, +column9 varchar(1024) NULL, +column10 varchar(1024) NULL, +column11 varchar(1024) NULL, +column12 varchar(1024) NULL, +column13 varchar(1024) NULL, +column14 varchar(1024) NULL, +column15 varchar(1024) NULL, +column16 varchar(1024) NULL, +column17 varchar(1024) NULL, +column18 varchar(1024) NULL, +column19 varchar(1024) NULL, +column20 varchar(1024) NULL, +column21 varchar(1024) NULL, +column22 varchar(1024) NULL, +column23 varchar(1024) NULL, +column24 varchar(1024) NULL, +column25 varchar(1024) NULL, +column26 varchar(1024) NULL, +column27 varchar(1024) NULL, +column28 varchar(1024) NULL, +column29 varchar(1024) NULL, +column30 varchar(1024) NULL, +column31 varchar(1024) NULL, +column32 varchar(1024) NULL, +column33 varchar(1024) NULL, +column34 varchar(1024) NULL, +column35 varchar(1024) NULL, +column36 varchar(1024) NULL, +column37 varchar(1024) NULL, +column38 varchar(1024) NULL, +column39 varchar(1024) NULL, +column40 varchar(1024) NULL, +column41 varchar(1024) NULL, +column42 varchar(1024) NULL, +column43 varchar(1024) NULL, +column44 varchar(1024) NULL, +column45 varchar(1024) NULL, +column46 varchar(1024) NULL, +column47 varchar(1024) NULL, +column48 varchar(1024) NULL, +column49 varchar(1024) NULL, +column50 varchar(1024) NULL, +column51 varchar(1024) NULL, +column52 varchar(1024) NULL, +column53 varchar(1024) NULL, +is_rownumber_fetched int4 NULL, +create_time timestamp DEFAULT current_timestamp, +rank int4 NULL, +rank_tag text null +); + + +CREATE TABLE mmt_staging2.stg_specific_table_BUDNI_BRK ( + generic_syspk int, +file_syspk bigint, +file_name varchar(1024) NULL, +file_date date NULL, +file_format varchar(1024) NULL, +sheet_number int4 NULL, +sheet_name varchar(1024) NULL, +sheet_format text, +sheet_mnemonic varchar(1024) NULL, +row_number int4 NULL, +file_creation_date timestamp NULL, +column1 varchar(1024) NULL, +column2 varchar(1024) NULL, +column3 varchar(1024) NULL, +column4 varchar(1024) NULL, +column5 varchar(1024) NULL, +column6 varchar(1024) NULL, +column7 varchar(1024) NULL, +column8 varchar(1024) NULL, +column9 varchar(1024) NULL, +column10 varchar(1024) NULL, +column11 varchar(1024) NULL, +column12 varchar(1024) NULL, +column13 varchar(1024) NULL, +column14 varchar(1024) NULL, +column15 varchar(1024) NULL, +column16 varchar(1024) NULL, +column17 varchar(1024) NULL, +column18 varchar(1024) NULL, +column19 varchar(1024) NULL, +column20 varchar(1024) NULL, +column21 varchar(1024) NULL, +column22 varchar(1024) NULL, +column23 varchar(1024) NULL, +column24 varchar(1024) NULL, +column25 varchar(1024) NULL, +column26 varchar(1024) NULL, +column27 varchar(1024) NULL, +column28 varchar(1024) NULL, +column29 varchar(1024) NULL, +column30 varchar(1024) NULL, +column31 varchar(1024) NULL, +column32 varchar(1024) NULL, +column33 varchar(1024) NULL, +column34 varchar(1024) NULL, +column35 varchar(1024) NULL, +column36 varchar(1024) NULL, +column37 varchar(1024) NULL, +column38 varchar(1024) NULL, +column39 varchar(1024) NULL, +column40 varchar(1024) NULL, +column41 varchar(1024) NULL, +column42 varchar(1024) NULL, +column43 varchar(1024) NULL, +column44 varchar(1024) NULL, +column45 varchar(1024) NULL, +column46 varchar(1024) NULL, +column47 varchar(1024) NULL, +column48 varchar(1024) NULL, +column49 varchar(1024) NULL, +column50 varchar(1024) NULL, +column51 varchar(1024) NULL, +column52 varchar(1024) NULL, +column53 varchar(1024) NULL, +is_rownumber_fetched int4 null, +create_time timestamp DEFAULT current_timestamp +); + + diff --git a/MMT_SQL/staging2/budni_brk_stg2.sql b/MMT_SQL/staging2/budni_brk_stg2.sql index 55bae36..7ffdc6a 100644 --- a/MMT_SQL/staging2/budni_brk_stg2.sql +++ b/MMT_SQL/staging2/budni_brk_stg2.sql @@ -4,13 +4,13 @@ p_sheet_mnemonic text, p_file_syspk int) RETURNS void AS $$ declare __make text; declare __model text; - - declare __client_id int :=p_client_id; + declare __characteristic_1 text; + declare __client_id int :=p_client_id; declare __function_id int :=p_function_id; declare __file_format text :=p_file_format; declare __sheet_mnemonic text :=p_sheet_mnemonic; declare __file_syspk int :=p_file_syspk; - + begin @@ -27,12 +27,23 @@ Function Call: select mmt_staging2.fn_BUDNI_BRK_Block(20,1,'BUDNI','BUDNI_BRK',2 SET search_path TO mmt_staging2; -delete from mmt_staging2.BUDNI_BRK_Spec_H1_Block; -delete from mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int; -delete from mmt_staging2.BUDNI_BRK_Service_Barke_Test_Block; -delete from mmt_staging2.BUDNI_BRK_Test_Obs_Summary_Block; -delete from mmt_staging2.stg_specific_table_BUDNI_BRK; -delete from mmt_staging2.stg_process_table_BUDNI_BRK; +truncate table mmt_staging2.BUDNI_BRK_Spec_H1_Block; +truncate table mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int; +truncate table mmt_staging2.budni_brk_service_cold_ballasted_maximum_block; +truncate table mmt_staging2.budni_brk_service_cold_standard_25kmph_block; +truncate table mmt_staging2.budni_brk_service_cold_standard_maximum_block; +truncate table mmt_staging2.BUDNI_BRK_service_cold_ballasted_25kmph_Block; +truncate table mmt_staging2.BUDNI_BRK_service_fade_standard_maximum_Block; +truncate table mmt_staging2.BUDNI_BRK_service_fade_ballasted_25kmph_Block; +truncate table mmt_staging2.BUDNI_BRK_other_observations_Block; +truncate table mmt_staging2.BUDNI_BRK_Parking_Barke_Test_Int; +truncate table mmt_staging2.BUDNI_BRK_Parking_Barke_Test_Block; +truncate table mmt_staging2.BUDNI_BRK_Test_Obs_Summary_Block; +truncate table mmt_staging2.stg_specific_table_BUDNI_BRK; +truncate table mmt_staging2.stg_process_table_BUDNI_BRK; + + +execute 'delete from mmt_ods.fw_jobctrl_file_sheet_block_run_schedule where file_syspk='||p_file_syspk||' and sheet_mnemonic='''||p_sheet_mnemonic||''''; execute 'update mmt_ods.mmt_config a set row_number_start=null, @@ -41,13 +52,13 @@ row_read_end=null, run_time=null where a.file_format='''||p_file_format||''' and a.sheet_mnemonic='''||p_sheet_mnemonic||''''; - +/* transfer data from generic to specific for ftdry*/ execute 'insert into mmt_staging2.stg_specific_table_BUDNI_BRK select * from mmt_staging1.mmt_staging_generic_table a where a.file_format='''||p_file_format||''' and a.sheet_mnemonic='''||p_sheet_mnemonic||''' and a.file_syspk='||p_file_syspk||''; - +/* trimming data */ execute 'update mmt_staging2.stg_specific_table_BUDNI_BRK set column2 = TRIM (TRAILING FROM column2 )'; execute 'update mmt_staging2.stg_specific_table_BUDNI_BRK set column2 = TRIM (LEADING FROM column2 )'; @@ -58,27 +69,7 @@ execute 'update mmt_ods.mmt_config set F1_source=F1_modified' ; execute 'update mmt_ods.mmt_config set F1_source = TRIM (TRAILING FROM F1_source)'; execute 'update mmt_ods.mmt_config set F1_source = TRIM (LEADING FROM F1_source)' ; -execute 'update mmt_ods.mmt_config a set f1_source = replace(f1_source,''_1'','''') -where a.file_format='''||p_file_format||''' and a.sheet_mnemonic='''||p_sheet_mnemonic||''''; - -execute 'update mmt_ods.mmt_config a -set row_number_start=(select min(b.row_number) -from mmt_staging2.stg_specific_table_BUDNI_BRK b -where trim(upper(F1_source))= trim(upper(column3)) -and b.is_rownumber_fetched is null) -where a.row_number_start is null -and a.file_format='''||p_file_format||''' and a.sheet_mnemonic='''||p_sheet_mnemonic||''''; - -execute 'update mmt_staging2.stg_specific_table_BUDNI_BRK a -set is_rownumber_fetched=1 -from mmt_ods.mmt_config b -where trim(upper(F1_source))= trim(upper(column3)) -and b.row_number_start=a.row_number -and is_rownumber_fetched is null and a.file_format='''||p_file_format||''' and a.sheet_mnemonic='''||p_sheet_mnemonic||''''; - -execute 'update mmt_ods.mmt_config a set f1_source = replace(f1_source,''_2'','''') - where a.file_format='''||p_file_format||''' and a.sheet_mnemonic='''||p_sheet_mnemonic||''''; - +/* keyword match in config table*/ execute 'update mmt_ods.mmt_config a set row_number_start=(select min(b.row_number) from mmt_staging2.stg_specific_table_BUDNI_BRK b @@ -87,6 +78,7 @@ and b.is_rownumber_fetched is null) where a.row_number_start is null and a.file_format='''||p_file_format||''' and a.sheet_mnemonic='''||p_sheet_mnemonic||''''; +/* reverese update in process table for match*/ execute 'update mmt_staging2.stg_specific_table_BUDNI_BRK a set is_rownumber_fetched=1 from mmt_ods.mmt_config b @@ -99,23 +91,25 @@ and is_rownumber_fetched is null and a.file_format='''||p_file_format||''' and a execute 'update mmt_ods.mmt_config a set row_previous_number=row_number_start-1 where a.file_format='''||p_file_format||''' and a.sheet_mnemonic='''||p_sheet_mnemonic||''''; - +/* update config files for row numbers start, end */ execute 'update mmt_ods.mmt_config a set row_read_end= (select b.row_number_start from mmt_ods.mmt_config b where b.syspk=a.syspk+1 ) where a.file_format='''||p_file_format||''' and a.sheet_mnemonic='''||p_sheet_mnemonic||''''; +/* config file last field update as null otherwise it picks up next format row number*/ execute 'update mmt_ods.mmt_config a set row_read_end = null where f1_modified =''Brake Performance Test Observations Summary'' and a.file_format='''||p_file_format||''' and a.sheet_mnemonic='''||p_sheet_mnemonic||''''; +/*inserting run_time in config*/ execute 'update mmt_ods.mmt_config a set run_time=current_timestamp where a.file_format='''||p_file_format||''' and a.sheet_mnemonic='''||p_sheet_mnemonic||''''; - +/* tagging ranks for each block in process table*/ execute 'insert into mmt_staging2.stg_process_table_BUDNI_BRK select a.* , RANK () OVER ( ORDER BY row_number) as rank,b.rank_tag as rank_tag from mmt_staging2.stg_specific_table_BUDNI_BRK a @@ -158,7 +152,7 @@ and f1_modified=''Brake Performance Test Observations Summary'' and b.file_format='''||p_file_format||''' and b.sheet_mnemonic='''||p_sheet_mnemonic||''' order by a.row_number'; - +/* fetching tractor model and make */ select column3 into __make from mmt_staging2.stg_process_table_BUDNI_BRK a where rank_tag='BUDNI_BRK_Spec_H1' and rank=3; @@ -166,6 +160,12 @@ select column4 into __model from mmt_staging2.stg_process_table_BUDNI_BRK a where rank_tag='BUDNI_BRK_Spec_H1' and rank=3; +/* blocks data loading start - BUDNI_BRK_Spec_H1_Block */ + +perform mmt_staging2.fn_jobctrl_block_begin(__client_id,__function_id,__file_syspk, +'BUDNI_BRK_Spec_H1_Block',__file_format,__sheet_mnemonic,1); + + insert into mmt_staging2.BUDNI_BRK_Spec_H1_block ( make,model,tractor_HP,rated_rpm,Type_of_brake , @@ -192,6 +192,7 @@ where b.rank_tag='BUDNI_BRK_Spec_H1' and b.rank=6 and a.file_syspk=b.file_syspk; +perform mmt_staging2.fn_jobctrl_block_end(__file_syspk,'BUDNI_BRK_Spec_H1_block'); insert into mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int ( @@ -210,76 +211,50 @@ from mmt_staging2.stg_process_table_BUDNI_BRK a where rank_tag ='BUDNI_BRK_Service_Barke_Test' order by rank; -update mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int a -set column4= b.first_value from (SELECT - rank, column4, value_partition, first_value(column4) over (partition by value_partition order by rank) +update mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int +set column2=(select column3 from mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int +where rank=1) where rank=3; + +update mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int +set column3=(select column3 from mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int +where rank=2) where rank=3; + +update mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int +set column3=(select column3 from mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int +where rank=3)where rank=10; + +update mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int +set column5=(select column5 from mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int +where rank=18)where rank=17; + +update mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int +set column3=(select column3 from mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int +where rank=17)where rank=22; + +update mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int +set column3=null where rank =1; + +update mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int +set column3=null where rank =2; + +update mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int + set column5 =null where rank=18; + + +update mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int a +set column2= b.first_value from (SELECT + rank, column2, value_partition, first_value(column2) over (partition by value_partition order by rank) FROM ( SELECT rank, - column4, - sum(case when column4 is null then 0 else 1 end) over (order by rank) as value_partition - FROM mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int + column2, + sum(case when column2 is null then 0 else 1 end) over (order by rank) as value_partition + FROM mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int ORDER BY rank ASC ) as q) b where a.rank = b.rank; -update mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int a -set ods_record =0 where rank in (1,2); - - -insert into mmt_staging2.BUDNI_BRK_Service_Barke_Test_Block -( -dummy_f, -brake_test_type, -brake_test_name, -speed_condition, -Braking_device_control_force_N, -Mean_deceleration_m_sec2, -Stopping_distance_m, -Max_deviation_of_tractor_from_its_original_course_m, -Abnormal_vibration, -The_brakes_were_heated_by -) -SELECT * -FROM crosstab( - 'SELECT unnest(''{column3,column5,column6,column7,column8,column9}''::text[]) AS col - , row_number() OVER () - , unnest(ARRAY[column3::text,column5::text,column6::text,column7::text -,column8::text,column9::text]) AS val - FROM mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int where rank <=6 - ORDER BY generate_series(1,15),rank,2' - ) t (col text,a_1 text,a_2 text,a_3 text,a_4 text,a_5 text,a_6 text,a_7 text,a_8 text,a_9 text); - -update mmt_staging2.BUDNI_BRK_Service_Barke_Test_Block a -set brake_test_type= b.first_value from (SELECT - rank, brake_test_type, value_partition, first_value(brake_test_type) over (partition by value_partition order by rank) -FROM ( - SELECT - rank, - brake_test_type, - sum(case when brake_test_type is null then 0 else 1 end) over (order by rank) as value_partition - FROM mmt_staging2.BUDNI_BRK_Service_Barke_Test_Block - ORDER BY rank ASC -) as q) b; - - -update mmt_staging2.BUDNI_BRK_Service_Barke_Test_Block a -set brake_test_name= b.first_value from (SELECT - rank, brake_test_name, value_partition, first_value(brake_test_name) over (partition by value_partition order by rank) -FROM ( - SELECT - rank, - brake_test_name , - sum(case when brake_test_name is null then 0 else 1 end) over (order by rank) as value_partition - FROM mmt_staging2.BUDNI_BRK_Service_Barke_Test_Block - ORDER BY rank ASC -) as q) b; - -update mmt_staging2.BUDNI_BRK_Service_Barke_Test_Block set -ballast_condition ='Standard ballasted tractor'; - - -update mmt_staging2.BUDNI_BRK_Service_Barke_Test_Block set make=__make,model=__model; -execute 'update mmt_staging2.BUDNI_BRK_Service_Barke_Test_Block set +update mmt_staging2.budni_brk_service_barke_test_int set make=__make,model=__model; +execute 'update mmt_staging2.BUDNI_BRK_Service_Barke_Test_int set client_id='||p_client_id||', function_id='||p_function_id||', file_syspk='||p_file_syspk||', @@ -287,6 +262,396 @@ file_format='''||p_file_format||''', sheet_mnemonic='''||p_sheet_mnemonic||''''; +/* blocks data loading start - BUDNI_BRK_service_cold_standard_maximum_Block */ + +perform mmt_staging2.fn_jobctrl_block_begin(__client_id,__function_id,__file_syspk, +'BUDNI_BRK_service_cold_standard_maximum_Block',__file_format,__sheet_mnemonic,2); + +insert into mmt_staging2.BUDNI_BRK_service_cold_standard_maximum_Block +( +dummy_f, +Braking_device_control_force_N, +Mean_deceleration_m_sec2, +Stopping_distance_m +) +SELECT * +FROM crosstab( + 'SELECT unnest(''{column5,column6,column7,column8}''::text[]) AS col + , row_number() OVER () + , unnest(ARRAY[column5::text,column6::text,column7::text,column8::text]) AS val + FROM mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int where rank in (4,5,6) + ORDER BY generate_series(1,15),2' + ) t (col text,a_1 text,a_2 text,a_3 text); + +update mmt_staging2.BUDNI_BRK_service_cold_standard_maximum_Block set make=__make,model=__model; +delete from mmt_staging2.BUDNI_BRK_service_cold_standard_maximum_Block where dummy_f is null; +execute 'update mmt_staging2.BUDNI_BRK_service_cold_standard_maximum_Block set +client_id='||p_client_id||', +function_id='||p_function_id||', +file_syspk='||p_file_syspk||', +file_format='''||p_file_format||''', +sheet_mnemonic='''||p_sheet_mnemonic||''''; + + + +update mmt_staging2.BUDNI_BRK_service_cold_standard_maximum_Block a +set brake_test_type =column2, +brake_test_name =column3, +speed_condition =column5 +from mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int b +where b.rank=3 and a.file_syspk=b.file_syspk; + +update mmt_staging2.BUDNI_BRK_service_cold_standard_maximum_Block a +set ballast_condition =column3 +from mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int b +where b.rank=4 and a.file_syspk=b.file_syspk; + +perform mmt_staging2.fn_jobctrl_block_end(__file_syspk,'BUDNI_BRK_service_cold_standard_maximum_Block'); + + +/* blocks data loading start - BUDNI_BRK_service_cold_ballasted_maximum_Block */ + +perform mmt_staging2.fn_jobctrl_block_begin(__client_id,__function_id,__file_syspk, +'BUDNI_BRK_service_cold_ballasted_maximum_Block',__file_format,__sheet_mnemonic,3); + +insert into mmt_staging2.BUDNI_BRK_service_cold_ballasted_maximum_Block +( +dummy_f, +Braking_device_control_force_N, +Mean_deceleration_m_sec2, +Stopping_distance_m +) +SELECT * +FROM crosstab( + 'SELECT unnest(''{column5,column6,column7,column8}''::text[]) AS col + , row_number() OVER () + , unnest(ARRAY[column5::text,column6::text,column7::text,column8::text]) AS val + FROM mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int where rank in (7,8,9) + ORDER BY generate_series(1,15),2' + ) t (col text,a_1 text,a_2 text,a_3 text); + + + +update mmt_staging2.BUDNI_BRK_service_cold_ballasted_maximum_Block set make=__make,model=__model; +delete from mmt_staging2.BUDNI_BRK_service_cold_ballasted_maximum_Block where dummy_f is null; +execute 'update mmt_staging2.BUDNI_BRK_service_cold_ballasted_maximum_Block set +client_id='||p_client_id||', +function_id='||p_function_id||', +file_syspk='||p_file_syspk||', +file_format='''||p_file_format||''', +sheet_mnemonic='''||p_sheet_mnemonic||''''; + + + +update mmt_staging2.BUDNI_BRK_service_cold_ballasted_maximum_Block a +set brake_test_type =column2, +brake_test_name =column3, +speed_condition =column5 +from mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int b +where b.rank=3 and a.file_syspk=b.file_syspk; + +update mmt_staging2.BUDNI_BRK_service_cold_ballasted_maximum_Block a +set ballast_condition =column3 +from mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int b +where b.rank=7 and a.file_syspk=b.file_syspk; + +perform mmt_staging2.fn_jobctrl_block_end(__file_syspk,'BUDNI_BRK_service_cold_ballasted_maximum_Block'); + + +/* blocks data loading start - BUDNI_BRK_service_cold_standard_25kmph_Block */ + +perform mmt_staging2.fn_jobctrl_block_begin(__client_id,__function_id,__file_syspk, +'BUDNI_BRK_service_cold_standard_25kmph_Block',__file_format,__sheet_mnemonic,4); + + +insert into mmt_staging2.BUDNI_BRK_service_cold_standard_25kmph_Block +( +dummy_f, +Braking_device_control_force_N, +Mean_deceleration_m_sec2, +Stopping_distance_m +) +SELECT * +FROM crosstab( + 'SELECT unnest(''{column5,column6,column7,column8}''::text[]) AS col + , row_number() OVER () + , unnest(ARRAY[column5::text,column6::text,column7::text,column8::text]) AS val + FROM mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int where rank in (11,12,13) + ORDER BY generate_series(1,15),2' + ) t (col text,a_1 text,a_2 text,a_3 text); + + + update mmt_staging2.BUDNI_BRK_service_cold_standard_25kmph_Block set make=__make,model=__model; +delete from mmt_staging2.BUDNI_BRK_service_cold_standard_25kmph_Block where dummy_f is null; +execute 'update mmt_staging2.BUDNI_BRK_service_cold_standard_25kmph_Block set +client_id='||p_client_id||', +function_id='||p_function_id||', +file_syspk='||p_file_syspk||', +file_format='''||p_file_format||''', +sheet_mnemonic='''||p_sheet_mnemonic||''''; + +update mmt_staging2.BUDNI_BRK_service_cold_standard_25kmph_Block a +set brake_test_type =column2, +brake_test_name =column3, +speed_condition =column5 +from mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int b +where b.rank=10 and a.file_syspk=b.file_syspk; + +update mmt_staging2.BUDNI_BRK_service_cold_standard_25kmph_Block a +set ballast_condition =column3 +from mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int b +where b.rank=11 and a.file_syspk=b.file_syspk; + +perform mmt_staging2.fn_jobctrl_block_end(__file_syspk,'BUDNI_BRK_service_cold_standard_25kmph_Block'); + + +/* blocks data loading start - BUDNI_BRK_service_cold_ballasted_25kmph_Block*/ + +perform mmt_staging2.fn_jobctrl_block_begin(__client_id,__function_id,__file_syspk, +'BUDNI_BRK_service_cold_ballasted_25kmph_Block',__file_format,__sheet_mnemonic,5); + + +insert into mmt_staging2.BUDNI_BRK_service_cold_ballasted_25kmph_Block +( +dummy_f, +Braking_device_control_force_N, +Mean_deceleration_m_sec2, +Stopping_distance_m +) +SELECT * +FROM crosstab( + 'SELECT unnest(''{column5,column6,column7,column8}''::text[]) AS col + , row_number() OVER () + , unnest(ARRAY[column5::text,column6::text,column7::text,column8::text]) AS val + FROM mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int where rank in (14,15,16) + ORDER BY generate_series(1,15),2' + ) t (col text,a_1 text,a_2 text,a_3 text); + +update mmt_staging2.BUDNI_BRK_service_cold_ballasted_25kmph_Block set make=__make,model=__model; +delete from mmt_staging2.BUDNI_BRK_service_cold_ballasted_25kmph_Block where dummy_f is null; +execute 'update mmt_staging2.BUDNI_BRK_service_cold_ballasted_25kmph_Block set +client_id='||p_client_id||', +function_id='||p_function_id||', +file_syspk='||p_file_syspk||', +file_format='''||p_file_format||''', +sheet_mnemonic='''||p_sheet_mnemonic||''''; + +update mmt_staging2.BUDNI_BRK_service_cold_ballasted_25kmph_Block a +set brake_test_type =column2, +brake_test_name =column3, +speed_condition =column5 +from mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int b +where b.rank=10 and a.file_syspk=b.file_syspk; + +update mmt_staging2.BUDNI_BRK_service_cold_ballasted_25kmph_Block a +set ballast_condition =column3 +from mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int b +where b.rank=14 and a.file_syspk=b.file_syspk; + +perform mmt_staging2.fn_jobctrl_block_end(__file_syspk,'BUDNI_BRK_service_cold_ballasted_25kmph_Block'); + + +/* blocks data loading start - BUDNI_BRK_service_fade_standard_maximum_Block */ + +perform mmt_staging2.fn_jobctrl_block_begin(__client_id,__function_id,__file_syspk, +'BUDNI_BRK_service_fade_standard_maximum_Block',__file_format,__sheet_mnemonic,6); + + + insert into mmt_staging2.BUDNI_BRK_service_fade_standard_maximum_Block +( +dummy_f, +Braking_device_control_force_N, +Mean_deceleration_m_sec2, +Stopping_distance_m +) +SELECT * +FROM crosstab( + 'SELECT unnest(''{column5,column6,column7,column8}''::text[]) AS col + , row_number() OVER () + , unnest(ARRAY[column5::text,column6::text,column7::text,column8::text]) AS val + FROM mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int where rank in (19,20,21) + ORDER BY generate_series(1,15),2' + ) t (col text,a_1 text,a_2 text,a_3 text); + +update mmt_staging2.BUDNI_BRK_service_fade_standard_maximum_Block set make=__make,model=__model; +delete from mmt_staging2.BUDNI_BRK_service_fade_standard_maximum_Block where dummy_f is null; +execute 'update mmt_staging2.BUDNI_BRK_service_fade_standard_maximum_Block set +client_id='||p_client_id||', +function_id='||p_function_id||', +file_syspk='||p_file_syspk||', +file_format='''||p_file_format||''', +sheet_mnemonic='''||p_sheet_mnemonic||''''; + +update mmt_staging2.BUDNI_BRK_service_fade_standard_maximum_Block a +set brake_test_type =column2, +brake_test_name =column3, +speed_condition =column5 +from mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int b +where b.rank=17 and a.file_syspk=b.file_syspk; + +update mmt_staging2.BUDNI_BRK_service_fade_standard_maximum_Block a +set ballast_condition =column3 +from mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int b +where b.rank=19 and a.file_syspk=b.file_syspk; + +perform mmt_staging2.fn_jobctrl_block_end(__file_syspk,'BUDNI_BRK_service_fade_standard_maximum_Block'); + + +/* blocks data loading start - BUDNI_BRK_service_fade_ballasted_25kmph_Block */ + +perform mmt_staging2.fn_jobctrl_block_begin(__client_id,__function_id,__file_syspk, +'BUDNI_BRK_service_fade_ballasted_25kmph_Block',__file_format,__sheet_mnemonic,7); + + + insert into mmt_staging2.BUDNI_BRK_service_fade_ballasted_25kmph_Block +( +dummy_f, +Braking_device_control_force_N, +Mean_deceleration_m_sec2, +Stopping_distance_m +) +SELECT * +FROM crosstab( + 'SELECT unnest(''{column5,column6,column7,column8}''::text[]) AS col + , row_number() OVER () + , unnest(ARRAY[column5::text,column6::text,column7::text,column8::text]) AS val + FROM mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int where rank in (23,24,25) + ORDER BY generate_series(1,15),2' + ) t (col text,a_1 text,a_2 text,a_3 text); + +update mmt_staging2.BUDNI_BRK_service_fade_ballasted_25kmph_Block set make=__make,model=__model; +delete from mmt_staging2.BUDNI_BRK_service_fade_ballasted_25kmph_Block where dummy_f is null; +execute 'update mmt_staging2.BUDNI_BRK_service_fade_ballasted_25kmph_Block set +client_id='||p_client_id||', +function_id='||p_function_id||', +file_syspk='||p_file_syspk||', +file_format='''||p_file_format||''', +sheet_mnemonic='''||p_sheet_mnemonic||''''; + + +update mmt_staging2.BUDNI_BRK_service_fade_ballasted_25kmph_Block a +set brake_test_type =column2, +brake_test_name =column3, +speed_condition =column5 +from mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int b +where b.rank=22 and a.file_syspk=b.file_syspk; + +update mmt_staging2.BUDNI_BRK_service_fade_ballasted_25kmph_Block a +set ballast_condition =column3 +from mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int b +where b.rank=23 and a.file_syspk=b.file_syspk; + +perform mmt_staging2.fn_jobctrl_block_end(__file_syspk,'BUDNI_BRK_service_fade_ballasted_25kmph_Block'); + +/* blocks data loading start - BUDNI_BRK_other_observations_Block */ + +perform mmt_staging2.fn_jobctrl_block_begin(__client_id,__function_id,__file_syspk, +'BUDNI_BRK_other_observations_Block',__file_format,__sheet_mnemonic,8); + +insert into mmt_staging2.BUDNI_BRK_other_observations_Block +( +column3, +column5, +column7, +rank +) +select +column3, +column5, +column7, +rank +from mmt_staging2.BUDNI_BRK_Service_Barke_Test_Int +where rank in (26,27,28) order by rank; + +update mmt_staging2.BUDNI_BRK_other_observations_Block +set ods_record=0 where rank in (26,27); + +update mmt_staging2.BUDNI_BRK_other_observations_Block set make=__make,model=__model; +execute 'update mmt_staging2.BUDNI_BRK_other_observations_Block set +client_id='||p_client_id||', +function_id='||p_function_id||', +file_syspk='||p_file_syspk||', +file_format='''||p_file_format||''', +sheet_mnemonic='''||p_sheet_mnemonic||''''; + +perform mmt_staging2.fn_jobctrl_block_end(__file_syspk,'BUDNI_BRK_other_observations_Block'); + + +insert into mmt_staging2.BUDNI_BRK_Parking_Barke_Test_Int +( +column3, +column5, +column6, +column7, +column8, +rank +) +select +column3,column5,column6,column7,column8,rank +from mmt_staging2.stg_process_table_BUDNI_BRK a +where rank_tag ='BUDNI_BRK_Parking_Brake_Test' +order by rank; + +update mmt_staging2.BUDNI_BRK_Parking_Barke_Test_Int +set column6=column5 where rank=2; + +update mmt_staging2.BUDNI_BRK_Parking_Barke_Test_Int +set column8=column7 where rank=2; + +update mmt_staging2.BUDNI_BRK_Parking_Barke_Test_Int +set column6=column5 where rank=5; + +update mmt_staging2.BUDNI_BRK_Parking_Barke_Test_Int +set column8=column7 where rank=5; + +update mmt_staging2.BUDNI_BRK_Parking_Barke_Test_Int set make=__make,model=__model; +execute 'update mmt_staging2.BUDNI_BRK_Parking_Barke_Test_Int set +client_id='||p_client_id||', +function_id='||p_function_id||', +file_syspk='||p_file_syspk||', +file_format='''||p_file_format||''', +sheet_mnemonic='''||p_sheet_mnemonic||''''; + + +/* blocks data loading start -BUDNI_BRK_Parking_Barke_Test_Block */ + +perform mmt_staging2.fn_jobctrl_block_begin(__client_id,__function_id,__file_syspk, +'BUDNI_BRK_Parking_Barke_Test_Block',__file_format,__sheet_mnemonic,9); + +insert into mmt_staging2.BUDNI_BRK_Parking_Barke_Test_Block +( +dummy_f, +particulars, +facing, +Braking_device_control_force, +Efficacy_of_parking_brake +) +SELECT * +FROM crosstab( + 'SELECT unnest(''{column5,column6,column7,column8}''::text[]) AS col + , row_number() OVER () + , unnest(ARRAY[column5::text,column6::text,column7::text,column8::text]) AS val + FROM mmt_staging2.BUDNI_BRK_Parking_Barke_Test_Int where rank <> 1 + ORDER BY generate_series(1,15),rank,2' + ) t (col text,a_1 text,a_2 text,a_3 text,a_4 text); + +update mmt_staging2.BUDNI_BRK_Parking_Barke_Test_Block set make=__make,model=__model; +delete from mmt_staging2.BUDNI_BRK_Parking_Barke_Test_Block where dummy_f is null; +execute 'update mmt_staging2.BUDNI_BRK_Parking_Barke_Test_Block set +client_id='||p_client_id||', +function_id='||p_function_id||', +file_syspk='||p_file_syspk||', +file_format='''||p_file_format||''', +sheet_mnemonic='''||p_sheet_mnemonic||''''; + +perform mmt_staging2.fn_jobctrl_block_end(__file_syspk,'BUDNI_BRK_Parking_Barke_Test_Block'); + +/* blocks data loading start - BUDNI_BRK_Test_Obs_Summary_Block */ + +perform mmt_staging2.fn_jobctrl_block_begin(__client_id,__function_id,__file_syspk, +'BUDNI_BRK_Test_Obs_Summary_Block',__file_format,__sheet_mnemonic,10); + + insert into mmt_staging2.BUDNI_BRK_Test_Obs_Summary_Block ( column3,column4,column5,column6,column7, @@ -296,48 +661,19 @@ select column3,column4,column5,column6,column7, column8,column9,rank from mmt_staging2.stg_process_table_BUDNI_BRK a -where rank_tag='BUDNI_BRK_Test_Obs_Summary' and rank <=6 +where rank_tag='BUDNI_BRK_Test_Obs_Summary' and rank <=7 order by rank; -update mmt_staging2.BUDNI_BRK_Test_Obs_Summary_Block a -set column5= b.first_value from (SELECT - rank, column5, value_partition, first_value(column5) over (partition by value_partition order by rank) -FROM ( - SELECT - rank, - column5, - sum(case when column5 is null then 0 else 1 end) over (order by rank) as value_partition - FROM mmt_staging2.BUDNI_BRK_Test_Obs_Summary_Block - ORDER BY rank ASC -) as q) b where a.rank = b.rank; +select column3 into __characteristic_1 from mmt_staging2.BUDNI_BRK_Test_Obs_Summary_Block +where rank=3; -update mmt_staging2.BUDNI_BRK_Test_Obs_Summary_Block a -set column6= b.first_value from (SELECT - rank, column6, value_partition, first_value(column6) over (partition by value_partition order by rank) -FROM ( - SELECT - rank, - column6, - sum(case when column6 is null then 0 else 1 end) over (order by rank) as value_partition - FROM mmt_staging2.BUDNI_BRK_Test_Obs_Summary_Block - ORDER BY rank ASC -) as q) b where a.rank = b.rank; +update mmt_staging2.BUDNI_BRK_Test_Obs_Summary_Block set +column3=concat(__characteristic_1,'-',column3) where rank in (4,5); -update mmt_staging2.BUDNI_BRK_Test_Obs_Summary_Block a -set column7= b.first_value from (SELECT - rank, column7, value_partition, first_value(column7) over (partition by value_partition order by rank) -FROM ( - SELECT - rank, - column7, - sum(case when column7 is null then 0 else 1 end) over (order by rank) as value_partition - FROM mmt_staging2.BUDNI_BRK_Test_Obs_Summary_Block - ORDER BY rank ASC -) as q) b where a.rank = b.rank; update mmt_staging2.BUDNI_BRK_Test_Obs_Summary_Block set ods_record=0 where -rank in(1,2); +rank in(1,2,3); update mmt_staging2.BUDNI_BRK_Test_Obs_Summary_Block set make=__make,model=__model; diff --git a/MMT_SQL/staging2/budni_dbp_stg2.sql b/MMT_SQL/staging2/budni_dbp_stg2.sql index e47f0c2..2c6b2d7 100644 --- a/MMT_SQL/staging2/budni_dbp_stg2.sql +++ b/MMT_SQL/staging2/budni_dbp_stg2.sql @@ -94,7 +94,7 @@ where a.file_format='''||p_file_format||''' and a.sheet_mnemonic='''||p_sheet_mn /* config file last field update as null otherwise it picks up next format row number*/ execute 'update mmt_ods.mmt_config a set row_read_end = null -where f1_modified =''Tractor Drawbar Performance Report'' +where f1_modified =''Tractor Drawbar Performance Report.'' and a.file_format='''||p_file_format||''' and a.sheet_mnemonic='''||p_sheet_mnemonic||''''; execute 'update mmt_ods.mmt_config a @@ -183,7 +183,8 @@ column2,column3,column4,column5,column6,column7, column8,column9,column10,column11,column12,column13,column14, column15,column16,column17,column18,column19,rank from mmt_staging2.stg_process_table_budni_dbp a -where rank_tag='BUDNI_DBP_Drawbar_Perf'; +where rank_tag='BUDNI_DBP_Drawbar_Perf' and rank <=22 +order by rank; update mmt_staging2.BUDNI_DBP_Drawbar_Perf_Block set make=__make,model=__model; diff --git a/MMT_SQL/staging2/budni_hdl_stg2.sql b/MMT_SQL/staging2/budni_hdl_stg2.sql index b3a416a..d9090e6 100644 --- a/MMT_SQL/staging2/budni_hdl_stg2.sql +++ b/MMT_SQL/staging2/budni_hdl_stg2.sql @@ -365,8 +365,8 @@ FROM crosstab( 'SELECT unnest(''{column7,column8,column9,column10,column11,column12}''::text[]) AS col , row_number() OVER () , unnest(ARRAY[column7::text,column8::text,column9::text, -column10::text,column11::text,column12::text]) AS val - FROM mmt_staging2.budni_hdl_Maintenance_of_lift_load_int +column10::text,column11::text,column12::text]) AS val + FROM mmt_staging2.budni_hdl_Maintenance_of_lift_load_int where rank in (2,3) ORDER BY generate_series(1,15),rank,2' ) t (col text,a_1 text,a_2 text); diff --git a/MMT_SQL/staging2/budni_lcg_stg2.sql b/MMT_SQL/staging2/budni_lcg_stg2.sql index 550de73..b802fa3 100644 --- a/MMT_SQL/staging2/budni_lcg_stg2.sql +++ b/MMT_SQL/staging2/budni_lcg_stg2.sql @@ -188,7 +188,8 @@ select column2,column3,column4,column5,column6,column7, column8,rank from mmt_staging2.stg_process_table_BUDNI_LCG a -where rank_tag='BUDNI_LCG_Gravity_Test'; +where rank_tag='BUDNI_LCG_Gravity_Test' and rank <=5 +order by rank; update mmt_staging2.BUDNI_LCG_Gravity_Test_Block set make=__make,model=__model; diff --git a/MMT_SQL/staging2/budni_pto_stg2.sql b/MMT_SQL/staging2/budni_pto_stg2.sql index 7a99689..e5681be 100644 --- a/MMT_SQL/staging2/budni_pto_stg2.sql +++ b/MMT_SQL/staging2/budni_pto_stg2.sql @@ -334,5 +334,5 @@ perform mmt_staging2.fn_jobctrl_block_end(__file_syspk,'mmt_staging2.BUDNI_PTO_S end $$ LANGUAGE plpgsql; -select mmt_staging2.fn_BUDNI_PTO_block(20,1,'BUDNI','BUDNI_PTO',182); + diff --git a/MMT_SQL/staging2/budni_vmt_stg2.sql b/MMT_SQL/staging2/budni_vmt_stg2.sql index 6c23acd..6efa27d 100644 --- a/MMT_SQL/staging2/budni_vmt_stg2.sql +++ b/MMT_SQL/staging2/budni_vmt_stg2.sql @@ -344,6 +344,6 @@ end $$ LANGUAGE plpgsql; -select mmt_staging2.fn_BUDNI_VMT_Block(20,1,'BUDNI','BUDNI_VMT',261); +