450: -- horizon between OPM and OPI inserts.
451: l_stmt_id := 20;
452: SELECT sysdate
453: INTO l_to_bound_date
454: FROM DUAL;
455:
456: -- Select the start transaction id's in MMT
457: -- past the global start date.
458: -- If there are no transactions past the global start date,
610: s_program_login_id,
611: s_program_application_id,
612: s_request_id
613: FROM
614: (SELECT JOB_TXN_ETL etl_id FROM dual
615: UNION ALL
616: SELECT ACTUAL_RES_ETL FROM dual
617: UNION ALL
618: SELECT RESOURCE_VAR_ETL FROM dual
612: s_request_id
613: FROM
614: (SELECT JOB_TXN_ETL etl_id FROM dual
615: UNION ALL
616: SELECT ACTUAL_RES_ETL FROM dual
617: UNION ALL
618: SELECT RESOURCE_VAR_ETL FROM dual
619: UNION ALL
620: SELECT JOB_MASTER_ETL FROM dual) etls;
614: (SELECT JOB_TXN_ETL etl_id FROM dual
615: UNION ALL
616: SELECT ACTUAL_RES_ETL FROM dual
617: UNION ALL
618: SELECT RESOURCE_VAR_ETL FROM dual
619: UNION ALL
620: SELECT JOB_MASTER_ETL FROM dual) etls;
621:
622:
616: SELECT ACTUAL_RES_ETL FROM dual
617: UNION ALL
618: SELECT RESOURCE_VAR_ETL FROM dual
619: UNION ALL
620: SELECT JOB_MASTER_ETL FROM dual) etls;
621:
622:
623: -- Max bounds for the Actual Resource Utilization ETL
624: l_stmt_id := 70;
679: s_program_login_id,
680: s_program_application_id,
681: s_request_id
682: FROM
683: (SELECT OPI_SOURCE source_type FROM dual
684: ) src;
685:
686:
687: -- For Resource and Job Master ETLs, we need from bound date
729: s_program_login_id,
730: s_program_application_id,
731: s_request_id
732: FROM
733: (SELECT RESOURCE_VAR_ETL etl_id FROM dual
734: UNION ALL
735: SELECT JOB_MASTER_ETL FROM dual) etls;
736: -- terminate successfully
737: l_stmt_id := 130;
731: s_request_id
732: FROM
733: (SELECT RESOURCE_VAR_ETL etl_id FROM dual
734: UNION ALL
735: SELECT JOB_MASTER_ETL FROM dual) etls;
736: -- terminate successfully
737: l_stmt_id := 130;
738: retcode := s_SUCCESS;
739: errbuf := '';
802: l_stmt_id := 5;
803: BEGIN
804: SELECT 1
805: INTO l_exists
806: FROM dual
807: WHERE (EXISTS (SELECT source
808: FROM opi_dbi_run_log_curr
809: WHERE rownum = 1));
810:
901: l_stmt_id := 10;
902: BEGIN
903: SELECT 1
904: INTO l_exists
905: FROM dual
906: WHERE (EXISTS (SELECT start_txn_id
907: FROM opi_dbi_run_log_curr
908: WHERE start_txn_id IS NULL
909: AND source = p_source
920: l_stmt_id := 20;
921: BEGIN
922: SELECT 1
923: INTO l_exists
924: FROM dual
925: WHERE (EXISTS (SELECT next_start_txn_id
926: FROM opi_dbi_run_log_curr
927: WHERE next_start_txn_id IS NULL
928: AND source = p_source
1018: l_stmt_id := 20;
1019: BEGIN
1020: SELECT 1
1021: INTO l_exists
1022: FROM dual
1023: WHERE (EXISTS (SELECT from_bound_date
1024: FROM opi_dbi_run_log_curr
1025: WHERE from_bound_date IS NULL
1026: AND source = p_source
1037: l_stmt_id := 30;
1038: BEGIN
1039: SELECT 1
1040: INTO l_exists
1041: FROM dual
1042: WHERE (EXISTS (SELECT to_bound_date
1043: FROM opi_dbi_run_log_curr
1044: WHERE to_bound_date IS NULL
1045: AND source = p_source