DBA Data[Home] [Help]

APPS.PJI_PJ_PROJ_CLASS_EXTR dependencies on PJI_PJ_EXTR_PRJCLS

Line 250: ** to pji_pj_extr_prjcls to create a snapshot of

246: Pji_Utils.write2log('Entering PJI_PJ_PROJ_CLASS_EXTR.EXTR_PROJECT_CLASSES',TRUE,2);
247:
248: /*
249: ** Extract all the change records from event log
250: ** to pji_pj_extr_prjcls to create a snapshot of
251: ** data which needed to be deleted once the extract
252: ** is done.
253: */
254:

Line 257: INSERT INTO pji_pj_extr_prjcls

253: */
254:
255: if (l_extraction_type <> 'FULL') then
256:
257: INSERT INTO pji_pj_extr_prjcls
258: (
259: ROW_ID,
260: WORKER_ID,
261: PROJECT_ID,

Line 293: /* Bug 7517578 replaced join with pji_pj_extr_prjcls by exists clause. */

289: AND bat.worker_id = p_worker_id;
290:
291: end if;
292:
293: /* Bug 7517578 replaced join with pji_pj_extr_prjcls by exists clause. */
294:
295: INSERT INTO pji_pj_extr_prjcls
296: (
297: ROW_ID

Line 295: INSERT INTO pji_pj_extr_prjcls

291: end if;
292:
293: /* Bug 7517578 replaced join with pji_pj_extr_prjcls by exists clause. */
294:
295: INSERT INTO pji_pj_extr_prjcls
296: (
297: ROW_ID
298: , WORKER_ID
299: , PROJECT_ID

Line 369: FROM pji_pj_extr_prjcls ext

365: AND cls.class_category (+) = prj.class_category
366: AND cls.class_code(+) = prj.class_code
367: AND exists
368: ( select 1
369: FROM pji_pj_extr_prjcls ext
370: WHERE ext.record_type = 'E'
371: AND ext.project_id = bat.project_id
372: AND ext.class_category = prj.class_category
373: AND ext.class_code = prj.class_code)

Line 400: FROM pji_pj_extr_prjcls ext

396: AND bat.project_id = cls.project_id
397: AND bat.worker_id = p_worker_id
398: AND Exists
399: ( SELECT 1
400: FROM pji_pj_extr_prjcls ext
401: WHERE ext.record_type = 'E'
402: AND ext.project_id = bat.project_id
403: AND ext.class_category = cls.class_category
404: AND ext.class_code = cls.class_code )

Line 475: FROM pji_pj_extr_prjcls ext WHERE ext.record_type = 'E'

471: AND bat.worker_id = p_worker_id
472: AND not exists
473: (
474: SELECT 1
475: FROM pji_pj_extr_prjcls ext WHERE ext.record_type = 'E'
476: AND ext.project_id = bat.project_id
477: AND ext.class_category = cls.class_category
478: AND ext.class_code = cls.class_code
479: )

Line 482: Pji_Utils.write2log('Inserted ' || SQL%ROWCOUNT || ' record(s) into PJI_PJ_EXTR_PRJCLS',TRUE,2);

478: AND ext.class_code = cls.class_code
479: )
480: AND bat.extraction_type = 'P';
481:
482: Pji_Utils.write2log('Inserted ' || SQL%ROWCOUNT || ' record(s) into PJI_PJ_EXTR_PRJCLS',TRUE,2);
483:
484: -- Delete the temporary entries.
485:
486: DELETE pji_pj_extr_prjcls

Line 486: DELETE pji_pj_extr_prjcls

482: Pji_Utils.write2log('Inserted ' || SQL%ROWCOUNT || ' record(s) into PJI_PJ_EXTR_PRJCLS',TRUE,2);
483:
484: -- Delete the temporary entries.
485:
486: DELETE pji_pj_extr_prjcls
487: WHERE worker_id = g_worker_id
488: AND record_type = 'E';
489:
490: Pji_Utils.write2log('Deleted ' || SQL%ROWCOUNT || ' temporary record(s) from PJI_PJ_EXTR_PRJCLS',TRUE,2);

Line 490: Pji_Utils.write2log('Deleted ' || SQL%ROWCOUNT || ' temporary record(s) from PJI_PJ_EXTR_PRJCLS',TRUE,2);

486: DELETE pji_pj_extr_prjcls
487: WHERE worker_id = g_worker_id
488: AND record_type = 'E';
489:
490: Pji_Utils.write2log('Deleted ' || SQL%ROWCOUNT || ' temporary record(s) from PJI_PJ_EXTR_PRJCLS',TRUE,2);
491:
492: -- Delete records for class categories that are not
493: -- included into PJI summaries
494:

Line 495: DELETE FROM PJI_PJ_EXTR_PRJCLS

491:
492: -- Delete records for class categories that are not
493: -- included into PJI summaries
494:
495: DELETE FROM PJI_PJ_EXTR_PRJCLS
496: WHERE worker_id = g_worker_id
497: AND class_category IN (
498: SELECT class_category
499: FROM pa_class_categories

Line 504: ' dangling record(s) from PJI_PJ_EXTR_PRJCLS - first delete',TRUE,2);

500: WHERE NVL(include_in_pji_flag,'N') = 'N'
501: );
502:
503: Pji_Utils.write2log('Deleted ' || SQL%ROWCOUNT ||
504: ' dangling record(s) from PJI_PJ_EXTR_PRJCLS - first delete',TRUE,2);
505:
506: DELETE pji_pj_extr_prjcls extr
507: WHERE worker_id = g_worker_id
508: AND record_type = 'C'

Line 506: DELETE pji_pj_extr_prjcls extr

502:
503: Pji_Utils.write2log('Deleted ' || SQL%ROWCOUNT ||
504: ' dangling record(s) from PJI_PJ_EXTR_PRJCLS - first delete',TRUE,2);
505:
506: DELETE pji_pj_extr_prjcls extr
507: WHERE worker_id = g_worker_id
508: AND record_type = 'C'
509: AND NOT EXISTS (
510: SELECT 1 FROM pa_class_codes cls

Line 516: ' dangling record(s) from PJI_PJ_EXTR_PRJCLS - second delete',TRUE,2);

512: AND extr.class_category = cls.class_category
513: );
514:
515: Pji_Utils.write2log('Deleted ' || SQL%ROWCOUNT ||
516: ' dangling record(s) from PJI_PJ_EXTR_PRJCLS - second delete',TRUE,2);
517:
518:
519: DELETE pji_pj_extr_prjcls extr
520: WHERE worker_id = g_worker_id

Line 519: DELETE pji_pj_extr_prjcls extr

515: Pji_Utils.write2log('Deleted ' || SQL%ROWCOUNT ||
516: ' dangling record(s) from PJI_PJ_EXTR_PRJCLS - second delete',TRUE,2);
517:
518:
519: DELETE pji_pj_extr_prjcls extr
520: WHERE worker_id = g_worker_id
521: AND record_type = 'C'
522: AND NOT EXISTS (
523: SELECT 1 FROM pa_class_categories cat

Line 528: ' dangling record(s) from PJI_PJ_EXTR_PRJCLS - third delete',TRUE,2);

524: WHERE extr.class_category = cat.class_category
525: );
526:
527: Pji_Utils.write2log('Deleted ' || SQL%ROWCOUNT ||
528: ' dangling record(s) from PJI_PJ_EXTR_PRJCLS - third delete',TRUE,2);
529:
530:
531:
532: -- Check for dangling records

Line 536: FROM PJI_PJ_EXTR_PRJCLS

532: -- Check for dangling records
533:
534: SELECT COUNT(*)
535: INTO l_dangling_rowcount
536: FROM PJI_PJ_EXTR_PRJCLS
537: WHERE project_class_id IS NULL
538: AND worker_id = g_worker_id;
539:
540: Pji_Utils.write2log('Count of dangling records: ' || l_dangling_rowcount,TRUE,2);

Line 556: UPDATE PJI_PJ_EXTR_PRJCLS extr

552:
553: -- Try to map class_code, class_category to updated classification
554: -- dimension.
555:
556: UPDATE PJI_PJ_EXTR_PRJCLS extr
557: SET project_class_id = (
558: SELECT cls.class_id
559: FROM pji_class_codes cls
560: WHERE cls.class_code = extr.class_code

Line 572: FROM PJI_PJ_EXTR_PRJCLS

568: -- Check if dangling records still exist.
569:
570: SELECT COUNT(*)
571: INTO l_dangling_rowcount
572: FROM PJI_PJ_EXTR_PRJCLS
573: WHERE project_class_id IS NULL
574: AND worker_id = g_worker_id;
575:
576: Pji_Utils.write2log('Identified ' || l_dangling_rowcount || ' record(s) that remain dangling',TRUE,2);

Line 624: PJI_PJ_EXTR_PRJCLS

620: , class_category
621: , record_type
622: , SUM(code_percentage) code_percentage
623: FROM
624: PJI_PJ_EXTR_PRJCLS
625: WHERE
626: worker_id = g_worker_id
627: GROUP BY
628: project_id

Line 670: --Pji_Process_Util.TRUNC_INT_TABLE( l_schema , 'PJI_PJ_EXTR_PRJCLS' , 'NORMAL',NULL);

666: Pji_Process_Util.REGISTER_STEP_COMPLETION(l_process,'PJI_PJ_PROJ_CLASS_EXTR.EXTR_PROJECT_CLASSES(p_worker_id);');
667:
668: -- truncate intermediate tables no longer required
669: l_schema := Pji_Utils.GET_PJI_SCHEMA_NAME;
670: --Pji_Process_Util.TRUNC_INT_TABLE( l_schema , 'PJI_PJ_EXTR_PRJCLS' , 'NORMAL',NULL);
671:
672: COMMIT;
673:
674: Pji_Utils.write2log('Completed PJI_PJ_PROJ_CLASS_EXTR.EXTR_PROJECT_CLASSES',TRUE,2);

Line 701: Pji_Process_Util.TRUNC_INT_TABLE( l_pji_schema , 'PJI_PJ_EXTR_PRJCLS', 'NORMAL',NULL);

697: Pji_Utils.write2log('Entering PJI_PJ_PROJ_CLASS_EXTR.TRUNCATE_INTERIM_TABLES',TRUE,2);
698:
699: l_pji_schema := Pji_Utils.get_pji_schema_name;
700:
701: Pji_Process_Util.TRUNC_INT_TABLE( l_pji_schema , 'PJI_PJ_EXTR_PRJCLS', 'NORMAL',NULL);
702:
703: -- PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process,'PJI_PJ_PROJ_CLASS_EXTR.CLEANUP(p_worker_id)');
704:
705: COMMIT;