deepthi/MMT
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

standardisation

Browse Source
This commit is contained in:
Deepthi
2021-04-01 14:15:45 +05:30
parent 1c1e8da68e
commit 37f73d5dfd
17 changed files with 1437 additions and 196 deletions
Download Patch File Download Diff File Expand all files Collapse all files

604
MMT_SQL/staging2/budni_brk_stg2.sql
View File

@@ -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;

5
MMT_SQL/staging2/budni_dbp_stg2.sql
View File

@@ -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;

4
MMT_SQL/staging2/budni_hdl_stg2.sql
View File

@@ -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);

3
MMT_SQL/staging2/budni_lcg_stg2.sql
View File

@@ -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;

2
MMT_SQL/staging2/budni_pto_stg2.sql
View File

@@ -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);

2
MMT_SQL/staging2/budni_vmt_stg2.sql
View File

@@ -344,6 +344,6 @@ end
$$ LANGUAGE plpgsql;
select mmt_staging2.fn_BUDNI_VMT_Block(20,1,'BUDNI','BUDNI_VMT',261);