DBA Data[Home] [Help]

APPS.PJI_PJI_EXTRACTION_UTILS dependencies on PJI_UTILS

Line 234: PJI_UTILS.write2log('PJI_PJI_EXTRACTION_UTILS.mview_refresh '||sqlerrm);

230: retcode := 0;
231: exception when others then
232: retcode := 2;
233: errbuf := sqlerrm;
234: PJI_UTILS.write2log('PJI_PJI_EXTRACTION_UTILS.mview_refresh '||sqlerrm);
235: PJI_UTILS.write2out('PJI_PJI_EXTRACTION_UTILS.mview_refresh '||sqlerrm);
236: raise;
237: end MVIEW_REFRESH;
238:

Line 235: PJI_UTILS.write2out('PJI_PJI_EXTRACTION_UTILS.mview_refresh '||sqlerrm);

231: exception when others then
232: retcode := 2;
233: errbuf := sqlerrm;
234: PJI_UTILS.write2log('PJI_PJI_EXTRACTION_UTILS.mview_refresh '||sqlerrm);
235: PJI_UTILS.write2out('PJI_PJI_EXTRACTION_UTILS.mview_refresh '||sqlerrm);
236: raise;
237: end MVIEW_REFRESH;
238:
239:

Line 253: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;

249:
250:
251: begin
252:
253: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
254: l_degree := PJI_UTILS.GET_DEGREE_OF_PARALLELISM();
255:
256: FND_STATS.GATHER_TABLE_STATS(
257: ownname => l_schema

Line 254: l_degree := PJI_UTILS.GET_DEGREE_OF_PARALLELISM();

250:
251: begin
252:
253: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
254: l_degree := PJI_UTILS.GET_DEGREE_OF_PARALLELISM();
255:
256: FND_STATS.GATHER_TABLE_STATS(
257: ownname => l_schema
258: , tabname => 'PJI_FP_PROJ_ET_WT_F'

Line 361: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;

357: l_high_blocks := 1.25*(l_high_rows*225)/l_db_block_size;
358: l_med_blocks := 1.25*(l_med_rows*150)/l_db_block_size;
359: l_low_blocks := 1.25*(l_low_rows*75)/l_db_block_size;
360:
361: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
362: l_degree := PJI_UTILS.GET_DEGREE_OF_PARALLELISM();
363:
364: -- partitioned tables
365: FND_STATS.SET_TABLE_STATS(l_schema,'PJI_FM_EXTR_PLN' , l_med_rows, l_med_blocks, 150, 'P0' );

Line 362: l_degree := PJI_UTILS.GET_DEGREE_OF_PARALLELISM();

358: l_med_blocks := 1.25*(l_med_rows*150)/l_db_block_size;
359: l_low_blocks := 1.25*(l_low_rows*75)/l_db_block_size;
360:
361: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
362: l_degree := PJI_UTILS.GET_DEGREE_OF_PARALLELISM();
363:
364: -- partitioned tables
365: FND_STATS.SET_TABLE_STATS(l_schema,'PJI_FM_EXTR_PLN' , l_med_rows, l_med_blocks, 150, 'P0' );
366: FND_STATS.SET_TABLE_STATS(l_schema,'PJI_FM_EXTR_PLN' , l_med_rows, l_med_blocks, 150, 'P1' );

Line 519: l_extraction_type := PJI_UTILS.get_parameter (

515:
516: --Conditional processing based on extraction type
517: --Work type change processing is not done for
518: --Partial refresh
519: l_extraction_type := PJI_UTILS.get_parameter (
520: p_name => 'EXTRACTION_TYPE');
521:
522: IF l_extraction_type = 'PARTIAL' THEN
523: return;

Line 567: pji_utils.write2log(sql%rowcount || ' rows deleted.');

563: wt_r.PJI_ROWID is not null
564: )
565: and wt.RECORD_TYPE = 'NORMAL';
566:
567: pji_utils.write2log(sql%rowcount || ' rows deleted.');
568:
569: update PJI_RM_WORK_TYPE_INFO wt
570: set
571: (

Line 610: pji_utils.write2log(sql%rowcount || ' rows updated.');

606: wt_r.PJI_ROWID is not null and
607: wt_r.CHANGE_FLAG = 'Y'
608: );
609:
610: pji_utils.write2log(sql%rowcount || ' rows updated.');
611:
612: insert into PJI_RM_WORK_TYPE_INFO
613: (
614: WORK_TYPE_ID,

Line 651: pji_utils.write2log(sql%rowcount || ' rows inserted.');

647: where
648: wt_r.PJI_ROWID is null
649: );
650:
651: pji_utils.write2log(sql%rowcount || ' rows inserted.');
652:
653: --Only those work type changes which occured upto launch of summarization
654: --process will be handled in a given run. This is done by tracking
655: --the MAX(EVENT_ID) on the log table PA_PJI_PROJ_EVENTS_LOG

Line 689: pji_utils.write2log(sql%rowcount || ' rows deleted :2.');

685: where log1.event_object = log.EVENT_OBJECT
686: and log1.operation_type = 'U'
687: group by log1.event_object );
688:
689: pji_utils.write2log(sql%rowcount || ' rows deleted :2.');
690:
691: --populate CHANGE_OLD slice from PA_PJI_PROJ_EVENTS_LOG table
692: insert into PJI_RM_WORK_TYPE_INFO
693: (

Line 724: pji_utils.write2log(sql%rowcount || ' rows inserted :2.');

720: EVENT_ID <= l_event_id and
721: EVENT_TYPE = 'Work Types' and
722: OPERATION_TYPE = 'U';
723:
724: pji_utils.write2log(sql%rowcount || ' rows inserted :2.');
725:
726: --Cleanup log table for processed Worktype changes
727: delete
728: from

Line 734: pji_utils.write2log(sql%rowcount || ' rows deleted 3.');

730: where
731: log.EVENT_ID <= l_event_id and
732: log.EVENT_TYPE = 'Work Types' and
733: log.OPERATION_TYPE = 'U';
734: pji_utils.write2log(sql%rowcount || ' rows deleted 3.');
735:
736: --Populate PJI_RM_WORK_TYPE_INFO with CHANGE_NEW records
737: insert into PJI_RM_WORK_TYPE_INFO
738: (

Line 769: pji_utils.write2log(sql%rowcount || ' rows inserted :3.');

765: and info.WORK_TYPE_ID in ( select WORK_TYPE_ID
766: from PJI_RM_WORK_TYPE_INFO wt
767: where wt.RECORD_TYPE = 'CHANGE_OLD');
768:
769: pji_utils.write2log(sql%rowcount || ' rows inserted :3.');
770:
771: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(p_process, 'PJI_PJI_EXTRACTION_UTILS.UPDATE_PJI_RM_WORK_TYPE_INFO(p_process);');
772:
773: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(PJI_UTILS.GET_PJI_SCHEMA_NAME, 'PJI_RM_WORK_TYPE_ROWID', 'NORMAL', null);

Line 773: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(PJI_UTILS.GET_PJI_SCHEMA_NAME, 'PJI_RM_WORK_TYPE_ROWID', 'NORMAL', null);

769: pji_utils.write2log(sql%rowcount || ' rows inserted :3.');
770:
771: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(p_process, 'PJI_PJI_EXTRACTION_UTILS.UPDATE_PJI_RM_WORK_TYPE_INFO(p_process);');
772:
773: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(PJI_UTILS.GET_PJI_SCHEMA_NAME, 'PJI_RM_WORK_TYPE_ROWID', 'NORMAL', null);
774:
775: commit;
776:
777: end UPDATE_PJI_RM_WORK_TYPE_INFO;

Line 835: pji_utils.write2log(sql%rowcount || ' rows deleted.');

831: where
832: org_r.PJI_ROWID is not null
833: );
834:
835: pji_utils.write2log(sql%rowcount || ' rows deleted.');
836:
837: update /*+ use_nl(denorm) rowid(denorm) */ PJI_ORG_DENORM denorm
838: set
839: (

Line 866: pji_utils.write2log(sql%rowcount || ' rows updated.');

862: org_r.PJI_ROWID is not null and
863: org_r.CHANGE_FLAG = 'Y'
864: );
865:
866: pji_utils.write2log(sql%rowcount || ' rows updated.');
867:
868: insert into PJI_ORG_DENORM
869: (
870: ORGANIZATION_ID,

Line 893: pji_utils.write2log(sql%rowcount || ' rows inserted.');

889: where
890: org_r.PJI_ROWID is null
891: );
892:
893: pji_utils.write2log(sql%rowcount || ' rows inserted.');
894:
895: execute immediate 'truncate table '|| pji_utils.get_pji_schema_name
896: || '.PJI_ROWID_ORG_DENORM drop storage';
897:

Line 895: execute immediate 'truncate table '|| pji_utils.get_pji_schema_name

891: );
892:
893: pji_utils.write2log(sql%rowcount || ' rows inserted.');
894:
895: execute immediate 'truncate table '|| pji_utils.get_pji_schema_name
896: || '.PJI_ROWID_ORG_DENORM drop storage';
897:
898: commit;
899:

Line 934: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

930: return;
931: end if;
932:
933: l_max_date := PJI_RM_SUM_MAIN.g_max_date;
934: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
935:
936: insert into PJI_ROWID_RESOURCES_DENORM
937: (
938: PA_ROWID,

Line 1063: pji_utils.write2log(sql%rowcount || ' rows deleted.');

1059: where
1060: res_r.PJI_ROWID is not null
1061: );
1062:
1063: pji_utils.write2log(sql%rowcount || ' rows deleted.');
1064:
1065: update /*+ use_nl(denorm) rowid(denorm) */ PJI_RESOURCES_DENORM denorm
1066: set
1067: (

Line 1094: pji_utils.write2log(sql%rowcount || ' rows updated.');

1090: res_r.PJI_ROWID is not null and
1091: res_r.CHANGE_FLAG = 'Y'
1092: );
1093:
1094: pji_utils.write2log(sql%rowcount || ' rows updated.');
1095:
1096: insert into PJI_RESOURCES_DENORM
1097: (
1098: PERSON_ID,

Line 1129: pji_utils.write2log(sql%rowcount || ' rows inserted.');

1125: where
1126: res_r.PJI_ROWID is null
1127: );
1128:
1129: pji_utils.write2log(sql%rowcount || ' rows inserted.');
1130:
1131: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(p_process, 'PJI_PJI_EXTRACTION_UTILS.UPDATE_RESOURCE_DATA(p_process);');
1132:
1133: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(PJI_UTILS.GET_PJI_SCHEMA_NAME, 'PJI_ROWID_RESOURCES_DENORM', 'NORMAL', null);

Line 1133: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(PJI_UTILS.GET_PJI_SCHEMA_NAME, 'PJI_ROWID_RESOURCES_DENORM', 'NORMAL', null);

1129: pji_utils.write2log(sql%rowcount || ' rows inserted.');
1130:
1131: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(p_process, 'PJI_PJI_EXTRACTION_UTILS.UPDATE_RESOURCE_DATA(p_process);');
1132:
1133: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(PJI_UTILS.GET_PJI_SCHEMA_NAME, 'PJI_ROWID_RESOURCES_DENORM', 'NORMAL', null);
1134:
1135: commit;
1136:
1137: end UPDATE_RESOURCE_DATA;

Line 1165: pji_utils.write2out(FND_MESSAGE.GET);

1161:
1162: FND_MESSAGE.SET_NAME('PJI', 'PJI_SUM_CLEANALL_FAILED');
1163:
1164: if (upper(nvl(l_profile_check, 'N')) <> 'Y') then
1165: pji_utils.write2out(FND_MESSAGE.GET);
1166: commit;
1167: retcode := 1;
1168: return;
1169: end if;

Line 1172: pji_utils.write2out(FND_MESSAGE.GET);

1168: return;
1169: end if;
1170:
1171: if (upper(nvl(p_check, 'N')) <> 'Y') then
1172: pji_utils.write2out(FND_MESSAGE.GET);
1173: commit;
1174: retcode := 1;
1175: return;
1176: end if;

Line 1190: l_pji_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;

1186: PROFILE_OPTION_NAME = 'PJI_SUM_CLEANALL');
1187:
1188: commit;
1189:
1190: l_pji_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
1191:
1192: insert into PJI_SYSTEM_CONFIG_HIST
1193: (
1194: REQUEST_ID,