[Home] [Help]
348: IS
349: l_msg VARCHAR2(4000);
350: BEGIN
351: l_msg := 'Exception: (Code('||p_error_code||'), Message("'||p_error_msg||'"))';
352: fnd_oam_debug.log(3, p_ctxt, l_msg);
353: l_msg := '['||p_ctxt||']'||l_msg;
354: MARK_OBJECT_AS_ERRORED(p_object_id,
355: l_msg);
356: END;
369: ELSE
370: l_msg := p_message;
371: END IF;
372: --don't log a level 3 because this is a common case.
373: fnd_oam_debug.log(1, p_ctxt, l_msg);
374:
375: IF b_objects(p_object_id).new_message IS NULL THEN
376: b_objects(p_object_id).new_message := l_msg;
377: ELSE
393: IS
394: l_msg VARCHAR2(4000);
395: BEGIN
396: l_msg := 'Invalid Property "'||px_prop.property_name||'"('||px_prop.property_id||'), Error: (Code('||p_error_code||'), Message("'||p_error_msg||'"))';
397: fnd_oam_debug.log(3, p_ctxt, l_msg);
398: MARK_OBJECT_AS_ERRORED(px_object,
399: l_msg);
400: END;
401:
407: IS
408: l_msg VARCHAR2(4000);
409: BEGIN
410: l_msg := 'Unrecognized Property: '||px_prop.property_name||'('||px_prop.property_id||')';
411: fnd_oam_debug.log(3, p_ctxt, l_msg);
412: --unrecognized property
413: MARK_OBJECT_AS_ERRORED(px_object,
414: l_msg);
415: END;
432: WHEN FND_OAM_DSCFG_API_PKG.G_PROP_ADDITIONAL_DOMAIN THEN
433: --the additional domain can't be null
434: IF px_prop.canonical_value IS NULL THEN
435: l_msg := 'Additional Domain properties cannot have NULL values.';
436: fnd_oam_debug.log(3, l_ctxt, l_msg);
437: --unrecognized property
438: MARK_OBJECT_AS_ERRORED(px_object,
439: l_msg);
440: RETURN FALSE;
440: RETURN FALSE;
441: END IF;
442:
443: --append the domain
444: fnd_oam_debug.log(1, l_ctxt, 'found additional_domain: '||px_prop.canonical_value);
445: IF px_object.additional_domains IS NOT NULL THEN
446: px_object.additional_domains.EXTEND;
447: px_object.additional_domains(px_object.additional_domains.COUNT) := UPPER(TRIM(px_prop.canonical_value));
448: ELSE
488: l_ctxt VARCHAR2(60) := PKG_NAME||'VALIDATE_DML_UPDATE_SEGMENT';
489:
490: l_valid BOOLEAN := TRUE;
491: BEGIN
492: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
493:
494: --check for our properties, add messages for each not found
495: IF p_segment.table_owner IS NULL THEN
496: MARK_OBJECT_AS_ERRORED(px_object,
515: 'Missing Property: '||FND_OAM_DSCFG_API_PKG.G_PROP_NEW_COLUMN_VALUE);
516: l_valid := FALSE;
517: END IF;
518:
519: fnd_oam_debug.log(1, l_ctxt, 'Verdict: '||FND_OAM_DSCFG_UTILS_PKG.BOOLEAN_TO_CANONICAL(l_valid));
520:
521: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
522: RETURN l_valid;
523: EXCEPTION
517: END IF;
518:
519: fnd_oam_debug.log(1, l_ctxt, 'Verdict: '||FND_OAM_DSCFG_UTILS_PKG.BOOLEAN_TO_CANONICAL(l_valid));
520:
521: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
522: RETURN l_valid;
523: EXCEPTION
524: WHEN OTHERS THEN
525: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
521: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
522: RETURN l_valid;
523: EXCEPTION
524: WHEN OTHERS THEN
525: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
526: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
527: RAISE PROGRAM_ERROR;
528: END;
529:
522: RETURN l_valid;
523: EXCEPTION
524: WHEN OTHERS THEN
525: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
526: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
527: RAISE PROGRAM_ERROR;
528: END;
529:
530: -- Private, helper to CACHE_OBJECT to cache an object of type DML_UPDATE_SEGMENT
539: k NUMBER;
540: l_prop b_property_def_type := NULL;
541: l_msg VARCHAR2(4000);
542: BEGIN
543: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
544:
545: --loop through the object properties, filling in the details of the dml_update_segment
546: BEGIN
547: k := px_object_props.FIRST;
570: ELSE
571: --defer to the common handler if none of the object_type-specific property names match.
572: IF NOT HANDLE_COMMON_PROPERTY(px_object,
573: l_prop) THEN
574: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
575: RETURN;
576: END IF;
577: END CASE;
578:
585: px_object,
586: l_prop,
587: SQLCODE,
588: SQLERRM);
589: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
590: RETURN;
591: END;
592:
593: -- only cache it if it's valid
609: --put it in the dml_update_segments cache
610: b_dml_update_segments(px_object.object_id) := l_dml_update_segment;
611: END IF;
612:
613: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
614: EXCEPTION
615: WHEN PROGRAM_ERROR THEN
616: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
617: RAISE;
612:
613: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
614: EXCEPTION
615: WHEN PROGRAM_ERROR THEN
616: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
617: RAISE;
618: WHEN OTHERS THEN
619: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
620: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
615: WHEN PROGRAM_ERROR THEN
616: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
617: RAISE;
618: WHEN OTHERS THEN
619: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
620: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
621: RAISE PROGRAM_ERROR;
622: END;
623:
616: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
617: RAISE;
618: WHEN OTHERS THEN
619: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
620: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
621: RAISE PROGRAM_ERROR;
622: END;
623:
624: -- Private, Helper to ADD_ENGINE_UNITS_FOR_DOMAIN to validate an object of type DML_DELETE_STMT
630: l_ctxt VARCHAR2(60) := PKG_NAME||'VALIDATE_DML_DELETE_STMT';
631:
632: l_valid BOOLEAN := TRUE;
633: BEGIN
634: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
635:
636: --check for our properties, add messages for each not found
637: IF p_stmt.table_owner IS NULL THEN
638: MARK_OBJECT_AS_ERRORED(px_object,
645: 'Missing Property: '||FND_OAM_DSCFG_API_PKG.G_PROP_TABLE_NAME);
646: l_valid := FALSE;
647: END IF;
648:
649: fnd_oam_debug.log(1, l_ctxt, 'Verdict: '||FND_OAM_DSCFG_UTILS_PKG.BOOLEAN_TO_CANONICAL(l_valid));
650:
651: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
652: RETURN l_valid;
653: EXCEPTION
647: END IF;
648:
649: fnd_oam_debug.log(1, l_ctxt, 'Verdict: '||FND_OAM_DSCFG_UTILS_PKG.BOOLEAN_TO_CANONICAL(l_valid));
650:
651: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
652: RETURN l_valid;
653: EXCEPTION
654: WHEN OTHERS THEN
655: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
651: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
652: RETURN l_valid;
653: EXCEPTION
654: WHEN OTHERS THEN
655: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
656: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
657: RAISE PROGRAM_ERROR;
658: END;
659:
652: RETURN l_valid;
653: EXCEPTION
654: WHEN OTHERS THEN
655: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
656: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
657: RAISE PROGRAM_ERROR;
658: END;
659:
660: -- Private, helper to CACHE_OBJECT to cache an object of type DML_DELETE_STMT
669: k NUMBER;
670: l_prop b_property_def_type := NULL;
671: l_msg VARCHAR2(4000);
672: BEGIN
673: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
674:
675: --loop through the object properties, filling in the details of the dml_delete_stmt
676: BEGIN
677: k := px_object_props.FIRST;
694: ELSE
695: --defer to the common handler if none of the object_type-specific property names match.
696: IF NOT HANDLE_COMMON_PROPERTY(px_object,
697: l_prop) THEN
698: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
699: RETURN;
700: END IF;
701: END CASE;
702:
709: px_object,
710: l_prop,
711: SQLCODE,
712: SQLERRM);
713: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
714: RETURN;
715: END;
716:
717: -- only cache it if it's valid
733: --put it in the dml_delete_stmts cache
734: b_dml_delete_stmts(px_object.object_id) := l_dml_delete_stmt;
735: END IF;
736:
737: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
738: EXCEPTION
739: WHEN PROGRAM_ERROR THEN
740: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
741: RAISE;
736:
737: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
738: EXCEPTION
739: WHEN PROGRAM_ERROR THEN
740: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
741: RAISE;
742: WHEN OTHERS THEN
743: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
744: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
739: WHEN PROGRAM_ERROR THEN
740: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
741: RAISE;
742: WHEN OTHERS THEN
743: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
744: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
745: RAISE PROGRAM_ERROR;
746: END;
747:
740: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
741: RAISE;
742: WHEN OTHERS THEN
743: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
744: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
745: RAISE PROGRAM_ERROR;
746: END;
747:
748: -- Private, Helper to ADD_ENGINE_UNITS_FOR_DOMAIN to validate an object of type DML_TRUNCATE_STMT
754: l_ctxt VARCHAR2(60) := PKG_NAME||'VALIDATE_DML_TRUNCATE_STMT';
755:
756: l_valid BOOLEAN := TRUE;
757: BEGIN
758: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
759:
760: --check for our properties, add messages for each not found
761: IF p_stmt.table_owner IS NULL THEN
762: MARK_OBJECT_AS_ERRORED(px_object,
769: 'Missing Property: '||FND_OAM_DSCFG_API_PKG.G_PROP_TABLE_NAME);
770: l_valid := FALSE;
771: END IF;
772:
773: fnd_oam_debug.log(1, l_ctxt, 'Verdict: '||FND_OAM_DSCFG_UTILS_PKG.BOOLEAN_TO_CANONICAL(l_valid));
774:
775: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
776: RETURN l_valid;
777: EXCEPTION
771: END IF;
772:
773: fnd_oam_debug.log(1, l_ctxt, 'Verdict: '||FND_OAM_DSCFG_UTILS_PKG.BOOLEAN_TO_CANONICAL(l_valid));
774:
775: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
776: RETURN l_valid;
777: EXCEPTION
778: WHEN OTHERS THEN
779: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
775: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
776: RETURN l_valid;
777: EXCEPTION
778: WHEN OTHERS THEN
779: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
780: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
781: RAISE PROGRAM_ERROR;
782: END;
783:
776: RETURN l_valid;
777: EXCEPTION
778: WHEN OTHERS THEN
779: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
780: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
781: RAISE PROGRAM_ERROR;
782: END;
783:
784: -- Private, helper to CACHE_OBJECT to cache an object of type DML_TRUNCATE_STMT
793: k NUMBER;
794: l_prop b_property_def_type := NULL;
795: l_msg VARCHAR2(4000);
796: BEGIN
797: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
798:
799: --loop through the object properties, filling in the details of the dml_truncate_stmt
800: BEGIN
801: k := px_object_props.FIRST;
815: ELSE
816: --defer to the common handler if none of the object_type-specific property names match.
817: IF NOT HANDLE_COMMON_PROPERTY(px_object,
818: l_prop) THEN
819: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
820: RETURN;
821: END IF;
822: END CASE;
823:
830: px_object,
831: l_prop,
832: SQLCODE,
833: SQLERRM);
834: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
835: RETURN;
836: END;
837:
838: -- only cache it if it's valid
851: --put it in the dml_truncate_stmts cache
852: b_dml_truncate_stmts(px_object.object_id) := l_dml_truncate_stmt;
853: END IF;
854:
855: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
856: EXCEPTION
857: WHEN PROGRAM_ERROR THEN
858: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
859: RAISE;
854:
855: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
856: EXCEPTION
857: WHEN PROGRAM_ERROR THEN
858: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
859: RAISE;
860: WHEN OTHERS THEN
861: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
862: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
857: WHEN PROGRAM_ERROR THEN
858: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
859: RAISE;
860: WHEN OTHERS THEN
861: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
862: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
863: RAISE PROGRAM_ERROR;
864: END;
865:
858: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
859: RAISE;
860: WHEN OTHERS THEN
861: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
862: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
863: RAISE PROGRAM_ERROR;
864: END;
865:
866: -- Private, Helper to ADD_ENGINE_UNITS_FOR_DOMAIN to validate an object of type PLSQL_TEXT
872: l_ctxt VARCHAR2(60) := PKG_NAME||'VALIDATE_PLSQL_TEXT';
873:
874: l_valid BOOLEAN := TRUE;
875: BEGIN
876: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
877:
878: --check for our properties, add messages for each not found
879: IF p_plsql.plsql_text IS NULL THEN
880: MARK_OBJECT_AS_ERRORED(px_object,
881: 'Missing Property: '||FND_OAM_DSCFG_API_PKG.G_PROP_PLSQL_TEXT);
882: l_valid := FALSE;
883: END IF;
884:
885: fnd_oam_debug.log(1, l_ctxt, 'Verdict: '||FND_OAM_DSCFG_UTILS_PKG.BOOLEAN_TO_CANONICAL(l_valid));
886:
887: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
888: RETURN l_valid;
889: EXCEPTION
883: END IF;
884:
885: fnd_oam_debug.log(1, l_ctxt, 'Verdict: '||FND_OAM_DSCFG_UTILS_PKG.BOOLEAN_TO_CANONICAL(l_valid));
886:
887: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
888: RETURN l_valid;
889: EXCEPTION
890: WHEN OTHERS THEN
891: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
887: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
888: RETURN l_valid;
889: EXCEPTION
890: WHEN OTHERS THEN
891: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
892: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
893: RAISE PROGRAM_ERROR;
894: END;
895:
888: RETURN l_valid;
889: EXCEPTION
890: WHEN OTHERS THEN
891: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
892: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
893: RAISE PROGRAM_ERROR;
894: END;
895:
896: -- Private, helper to CACHE_OBJECT to cache an object of type PLSQL_TEXT
905: k NUMBER;
906: l_prop b_property_def_type := NULL;
907: l_msg VARCHAR2(4000);
908: BEGIN
909: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
910:
911: --loop through the object properties, filling in the details of the plsql_text
912: BEGIN
913: k := px_object_props.FIRST;
930: ELSE
931: --defer to the common handler if none of the object_type-specific property names match.
932: IF NOT HANDLE_COMMON_PROPERTY(px_object,
933: l_prop) THEN
934: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
935: RETURN;
936: END IF;
937: END CASE;
938:
945: px_object,
946: l_prop,
947: SQLCODE,
948: SQLERRM);
949: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
950: RETURN;
951: END;
952:
953: -- only cache it if it's valid
964: --put it in the plsql_texts cache
965: b_plsql_texts(px_object.object_id) := l_plsql_text;
966: END IF;
967:
968: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
969: EXCEPTION
970: WHEN PROGRAM_ERROR THEN
971: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
972: RAISE;
967:
968: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
969: EXCEPTION
970: WHEN PROGRAM_ERROR THEN
971: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
972: RAISE;
973: WHEN OTHERS THEN
974: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
975: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
970: WHEN PROGRAM_ERROR THEN
971: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
972: RAISE;
973: WHEN OTHERS THEN
974: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
975: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
976: RAISE PROGRAM_ERROR;
977: END;
978:
971: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
972: RAISE;
973: WHEN OTHERS THEN
974: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
975: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
976: RAISE PROGRAM_ERROR;
977: END;
978:
979: -- Private, helper to CACHE_OBJECT to cache the run metadata information
986: k NUMBER;
987: l_prop b_property_def_type := NULL;
988: l_msg VARCHAR2(4000);
989: BEGIN
990: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
991:
992: --if we've already initialized the run metadata, this object is invalid, we need only one
993: --run metadata entry per config instance
994: IF b_run.object_id IS NOT NULL THEN
992: --if we've already initialized the run metadata, this object is invalid, we need only one
993: --run metadata entry per config instance
994: IF b_run.object_id IS NOT NULL THEN
995: l_msg := 'Run Metadata already defined by Object ID: "'||b_run.object_id||'"';
996: fnd_oam_debug.log(3, l_ctxt, l_msg);
997: MARK_OBJECT_AS_ERRORED(px_object,
998: l_msg);
999: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1000: RETURN;
995: l_msg := 'Run Metadata already defined by Object ID: "'||b_run.object_id||'"';
996: fnd_oam_debug.log(3, l_ctxt, l_msg);
997: MARK_OBJECT_AS_ERRORED(px_object,
998: l_msg);
999: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1000: RETURN;
1001: END IF;
1002:
1003: --loop through the object properties, filling in the details of the run object
1026: --invalid property
1027: HANDLE_UNKNOWN_PROPERTY(l_ctxt,
1028: px_object,
1029: l_prop);
1030: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1031: RETURN;
1032: END CASE;
1033:
1034: k := px_object_props.NEXT(k);
1040: px_object,
1041: l_prop,
1042: SQLCODE,
1043: SQLERRM);
1044: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1045: RETURN;
1046: END;
1047:
1048: --defer validation until the GENERATE-phase because we need to have read in all objects to
1051: --set the object_id to mark that we've seen runtime metadata
1052: b_run.object_id := px_object.object_id;
1053:
1054: --success
1055: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1056: RETURN;
1057: EXCEPTION
1058: WHEN OTHERS THEN
1059: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
1055: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1056: RETURN;
1057: EXCEPTION
1058: WHEN OTHERS THEN
1059: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
1060: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1061: RAISE PROGRAM_ERROR;
1062: END;
1063:
1056: RETURN;
1057: EXCEPTION
1058: WHEN OTHERS THEN
1059: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
1060: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1061: RAISE PROGRAM_ERROR;
1062: END;
1063:
1064: -- Private, helper to CACHE_OBJECT to cache the metadata for a bundle
1073: k NUMBER;
1074: l_prop b_property_def_type := NULL;
1075: l_msg VARCHAR2(4000);
1076: BEGIN
1077: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
1078:
1079: --if we've already seen run.num_bundles of bundles, this one is too many
1080: IF b_run.num_bundles IS NOT NULL AND b_run.num_bundles = b_bundles.COUNT THEN
1081: l_msg := 'Already seen expected number of bundles: "'||b_run.num_bundles||'".';
1078:
1079: --if we've already seen run.num_bundles of bundles, this one is too many
1080: IF b_run.num_bundles IS NOT NULL AND b_run.num_bundles = b_bundles.COUNT THEN
1081: l_msg := 'Already seen expected number of bundles: "'||b_run.num_bundles||'".';
1082: fnd_oam_debug.log(3, l_ctxt, l_msg);
1083: MARK_OBJECT_AS_ERRORED(px_object,
1084: l_msg);
1085: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1086: RETURN;
1081: l_msg := 'Already seen expected number of bundles: "'||b_run.num_bundles||'".';
1082: fnd_oam_debug.log(3, l_ctxt, l_msg);
1083: MARK_OBJECT_AS_ERRORED(px_object,
1084: l_msg);
1085: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1086: RETURN;
1087: END IF;
1088:
1089: --loop through the object properties, filling in the details of the run object
1115: --invalid property
1116: HANDLE_UNKNOWN_PROPERTY(l_ctxt,
1117: px_object,
1118: l_prop);
1119: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1120: RETURN;
1121: END CASE;
1122:
1123: k := px_object_props.NEXT(k);
1129: px_object,
1130: l_prop,
1131: SQLCODE,
1132: SQLERRM);
1133: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1134: RETURN;
1135: END;
1136:
1137: --defer validation until the GENERATE-phase because we need to have read in all objects to
1140: --add the bundle to the bundles list
1141: b_bundles(px_object.object_id) := l_bundle;
1142:
1143: --success
1144: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1145: RETURN;
1146: EXCEPTION
1147: WHEN OTHERS THEN
1148: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
1144: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1145: RETURN;
1146: EXCEPTION
1147: WHEN OTHERS THEN
1148: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
1149: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1150: RAISE PROGRAM_ERROR;
1151: END;
1152:
1145: RETURN;
1146: EXCEPTION
1147: WHEN OTHERS THEN
1148: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
1149: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1150: RAISE PROGRAM_ERROR;
1151: END;
1152:
1153: /*
1169: k NUMBER;
1170: l_prop b_property_def_type := NULL;
1171: l_msg VARCHAR2(4000);
1172: BEGIN
1173: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
1174:
1175: --loop through the object properties, filling in the details of the run object
1176: BEGIN
1177: k := px_object_props.FIRST;
1186: --invalid property
1187: HANDLE_UNKNOWN_PROPERTY(l_ctxt,
1188: px_object,
1189: l_prop);
1190: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1191: RETURN;
1192: END CASE;
1193:
1194: k := px_object_props.NEXT(k);
1200: px_object,
1201: l_prop,
1202: SQLCODE,
1203: SQLERRM);
1204: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1205: RETURN;
1206: END;
1207:
1208: --add the bundle to the bundles list
1208: --add the bundle to the bundles list
1209: --b_bundles(px_object.object_id) := l_bundle;
1210:
1211: --success
1212: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1213: RETURN;
1214: EXCEPTION
1215: WHEN OTHERS THEN
1216: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
1212: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1213: RETURN;
1214: EXCEPTION
1215: WHEN OTHERS THEN
1216: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
1217: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1218: RAISE;
1219: END;
1220: */
1213: RETURN;
1214: EXCEPTION
1215: WHEN OTHERS THEN
1216: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
1217: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1218: RAISE;
1219: END;
1220: */
1221: -- Private, used by FETCH_COMPILABLE_OBJECTS to put a new object into the various
1227:
1228: l_number_list b_number_list_type;
1229: l_msg VARCHAR2(4000);
1230: BEGIN
1231: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
1232:
1233: --prepare the object and cache it in the object_type-specific cache
1234: CASE px_object.object_type
1235: WHEN FND_OAM_DSCFG_API_PKG.G_OTYPE_DML_UPDATE_SEGMENT THEN
1255: -- px_object_props);
1256: ELSE
1257: --unknown object type, add a message, set the errors flag
1258: l_msg := 'Object Type: "'||px_object.object_type||'" not supported';
1259: fnd_oam_debug.log(3, l_ctxt, l_msg);
1260: MARK_OBJECT_AS_ERRORED(px_object,
1261: l_msg);
1262: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1263: RETURN;
1258: l_msg := 'Object Type: "'||px_object.object_type||'" not supported';
1259: fnd_oam_debug.log(3, l_ctxt, l_msg);
1260: MARK_OBJECT_AS_ERRORED(px_object,
1261: l_msg);
1262: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1263: RETURN;
1264: END CASE;
1265:
1266: --check that the object came back with a primary domain
1267: IF px_object.primary_domain IS NULL AND
1268: px_object.object_type NOT IN (FND_OAM_DSCFG_API_PKG.G_OTYPE_RUN,
1269: FND_OAM_DSCFG_API_PKG.G_OTYPE_BUNDLE) THEN
1270: l_msg := 'Object has no primary domain - this is not allowed.';
1271: fnd_oam_debug.log(3, l_ctxt, l_msg);
1272: MARK_OBJECT_AS_ERRORED(px_object,
1273: l_msg);
1274: END IF;
1275:
1278:
1279: --so we don't have to traverse the object list right after this, go ahead and add this object to
1280: --the primary domains cache if it hasn't errored out yet.
1281: IF px_object.new_errors_found_flag IS NULL AND px_object.primary_domain IS NOT NULL THEN
1282: fnd_oam_debug.log(1, l_ctxt, 'Caching valid primary_domain('||px_object.primary_domain||'), object_id('||px_object.object_id||')');
1283: IF b_primary_domains.EXISTS(px_object.primary_domain) THEN
1284: --add this object_id
1285: b_primary_domains(px_object.primary_domain).EXTEND;
1286: b_primary_domains(px_object.primary_domain)(b_primary_domains(px_object.primary_domain).COUNT) := px_object.object_id;
1290: b_primary_domains(px_object.primary_domain) := l_number_list;
1291: END IF;
1292: END IF;
1293:
1294: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1295: EXCEPTION
1296: WHEN PROGRAM_ERROR THEN
1297: --any errors in the CACHE_
1298: --so we can work try other objects
1295: EXCEPTION
1296: WHEN PROGRAM_ERROR THEN
1297: --any errors in the CACHE_
1298: --so we can work try other objects
1299: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1300: RETURN;
1301: WHEN OTHERS THEN
1302: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
1303: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1298: --so we can work try other objects
1299: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1300: RETURN;
1301: WHEN OTHERS THEN
1302: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
1303: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1304: RAISE PROGRAM_ERROR;
1305: END;
1306:
1299: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1300: RETURN;
1301: WHEN OTHERS THEN
1302: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
1303: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1304: RAISE PROGRAM_ERROR;
1305: END;
1306:
1307: -- Private
1333: l_curr_object_index NUMBER;
1334: l_curr_prop_index NUMBER;
1335:
1336: BEGIN
1337: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
1338:
1339: fnd_oam_debug.log(1, l_ctxt, 'Fetching compilable objects...');
1340: -- obtain all compilable objects
1341: SELECT object_id, object_type, target_type, target_id
1335:
1336: BEGIN
1337: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
1338:
1339: fnd_oam_debug.log(1, l_ctxt, 'Fetching compilable objects...');
1340: -- obtain all compilable objects
1341: SELECT object_id, object_type, target_type, target_id
1342: BULK COLLECT INTO l_object_ids, l_object_types, l_target_types, l_target_ids
1343: FROM fnd_oam_dscfg_objects
1349: FND_OAM_DSCFG_API_PKG.G_OTYPE_RUN,
1350: FND_OAM_DSCFG_API_PKG.G_OTYPE_BUNDLE,
1351: FND_OAM_DSCFG_API_PKG.G_OTYPE_DOMAIN_METADATA)
1352: ORDER BY object_id DESC;
1353: fnd_oam_debug.log(1, l_ctxt, '...Done');
1354:
1355: -- since we can't use l_object_ids to only get the properties we want, duplicate the object conditions above
1356: -- for selecting the entire list of properties
1357: fnd_oam_debug.log(1, l_ctxt, 'Fetching all corresponding object properties...');
1353: fnd_oam_debug.log(1, l_ctxt, '...Done');
1354:
1355: -- since we can't use l_object_ids to only get the properties we want, duplicate the object conditions above
1356: -- for selecting the entire list of properties
1357: fnd_oam_debug.log(1, l_ctxt, 'Fetching all corresponding object properties...');
1358: SELECT property_id, parent_id, property_name, datatype, canonical_value
1359: BULK COLLECT INTO l_prop_ids, l_prop_object_ids, l_prop_names, l_datatypes, l_canonical_values
1360: FROM fnd_oam_dscfg_properties
1361: WHERE parent_type = FND_OAM_DSCFG_API_PKG.G_TYPE_OBJECT
1369: FND_OAM_DSCFG_API_PKG.G_OTYPE_RUN,
1370: FND_OAM_DSCFG_API_PKG.G_OTYPE_BUNDLE,
1371: FND_OAM_DSCFG_API_PKG.G_OTYPE_DOMAIN_METADATA))
1372: ORDER BY parent_id DESC, property_id DESC;
1373: fnd_oam_debug.log(1, l_ctxt, '...Done');
1374:
1375: --now we need to go through and create b_objects entries and b_
1376: l_curr_object_index := l_object_ids.FIRST;
1377: l_curr_prop_index := l_prop_ids.FIRST;
1377: l_curr_prop_index := l_prop_ids.FIRST;
1378: WHILE l_curr_object_index IS NOT NULL LOOP
1379: l_curr_object_id := l_object_ids(l_curr_object_index);
1380:
1381: fnd_oam_debug.log(1, l_ctxt, 'Processing object_id: '||l_curr_object_id);
1382: --for each object create a new object def record
1383: l_curr_object := CREATE_OBJECT_DEF(l_curr_object_id,
1384: l_object_types(l_curr_object_index),
1385: l_target_types(l_curr_object_index),
1392: IF l_prop_object_ids(l_curr_prop_index) <> l_curr_object_id THEN
1393: EXIT;
1394: END IF;
1395:
1396: fnd_oam_debug.log(1, l_ctxt, 'Processing property_id: '||l_prop_ids(l_curr_prop_index));
1397: --property belongs to this object, make a prop def and add it to the object props with the prop_id as the key
1398: l_curr_prop := CREATE_PROPERTY_DEF(l_prop_ids(l_curr_prop_index),
1399: l_prop_names(l_curr_prop_index),
1400: l_datatypes(l_curr_prop_index),
1414: l_curr_object_index := l_object_ids.NEXT(l_curr_object_index);
1415: END LOOP;
1416:
1417: --all objects fetched and cached, return success
1418: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1419: RETURN;
1420: EXCEPTION
1421: WHEN PROGRAM_ERROR THEN
1422: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1418: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1419: RETURN;
1420: EXCEPTION
1421: WHEN PROGRAM_ERROR THEN
1422: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1423: RAISE;
1424: WHEN OTHERS THEN
1425: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
1426: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1421: WHEN PROGRAM_ERROR THEN
1422: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1423: RAISE;
1424: WHEN OTHERS THEN
1425: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
1426: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1427: RAISE PROGRAM_ERROR;
1428: END;
1429:
1422: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1423: RAISE;
1424: WHEN OTHERS THEN
1425: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
1426: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1427: RAISE PROGRAM_ERROR;
1428: END;
1429:
1430: -- Private
1451: l_domain VARCHAR2(120);
1452: l_from_index NUMBER;
1453: l_to_index NUMBER;
1454: BEGIN
1455: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
1456:
1457: fnd_oam_debug.log(1, l_ctxt, 'Reassigning group '||p_from_group_id||' to '||p_to_group_id);
1458:
1459: --get a local handle to the from
1453: l_to_index NUMBER;
1454: BEGIN
1455: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
1456:
1457: fnd_oam_debug.log(1, l_ctxt, 'Reassigning group '||p_from_group_id||' to '||p_to_group_id);
1458:
1459: --get a local handle to the from
1460: l_from_group := b_dependency_groups(p_from_group_id);
1461:
1464: b_dependency_groups(p_to_group_id).primary_domains.EXTEND(l_from_group.primary_domains.COUNT);
1465: l_from_index := l_from_group.primary_domains.FIRST;
1466: WHILE l_from_index IS NOT NULL LOOP
1467: l_domain := l_from_group.primary_domains(l_from_index);
1468: fnd_oam_debug.log(1, l_ctxt, 'Moving primary_domain: '||l_domain);
1469: b_domain_to_group_map(l_domain) := p_to_group_id;
1470: b_dependency_groups(p_to_group_id).primary_domains(l_to_index) := l_domain;
1471: l_to_index := l_to_index + 1;
1472: l_from_index := l_from_group.primary_domains.NEXT(l_from_index);
1474:
1475: --insert the additional domains
1476: l_domain := l_from_group.additional_domains.FIRST;
1477: WHILE l_domain IS NOT NULL LOOP
1478: fnd_oam_debug.log(2, l_ctxt, 'Moving additional_domain: '||l_domain);
1479: b_domain_to_group_map(l_domain) := p_to_group_id;
1480: ADD_ADDITIONAL_DOMAIN_TO_GROUP(p_to_group_id,
1481: l_domain);
1482: l_domain := l_from_group.additional_domains.NEXT(l_domain);
1482: l_domain := l_from_group.additional_domains.NEXT(l_domain);
1483: END LOOP;
1484:
1485: --remove the from group
1486: fnd_oam_debug.log(1, l_ctxt, 'Removing the from group.');
1487: b_dependency_groups.DELETE(p_from_group_id);
1488:
1489: --success
1490: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1486: fnd_oam_debug.log(1, l_ctxt, 'Removing the from group.');
1487: b_dependency_groups.DELETE(p_from_group_id);
1488:
1489: --success
1490: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1491: EXCEPTION
1492: WHEN OTHERS THEN
1493: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
1494: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1489: --success
1490: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1491: EXCEPTION
1492: WHEN OTHERS THEN
1493: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
1494: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1495: RAISE PROGRAM_ERROR;
1496: END;
1497:
1490: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1491: EXCEPTION
1492: WHEN OTHERS THEN
1493: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
1494: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1495: RAISE PROGRAM_ERROR;
1496: END;
1497:
1498: -- Private
1512:
1513: k NUMBER;
1514: j NUMBER;
1515: BEGIN
1516: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
1517:
1518: --traverse the map of primary domains, ignore the NULL domain key, shouldn't be allowed.
1519: l_primary_domain := b_primary_domains.FIRST;
1520: WHILE l_primary_domain IS NOT NULL LOOP
1520: WHILE l_primary_domain IS NOT NULL LOOP
1521: --default objects in this primary domain to the next available group_id and store
1522: --the bidirectional mapping between them. All future conflicting domains will be rolled into this
1523: --one.
1524: fnd_oam_debug.log(1, l_ctxt, 'Processing primary_domain: '||l_primary_domain);
1525: l_this_group_id := l_next_group_id;
1526: fnd_oam_debug.log(1, l_ctxt, 'Given group ID: '||l_this_group_id);
1527: l_next_group_id := l_next_group_id + 1;
1528: b_domain_to_group_map(l_primary_domain) := l_this_group_id;
1522: --the bidirectional mapping between them. All future conflicting domains will be rolled into this
1523: --one.
1524: fnd_oam_debug.log(1, l_ctxt, 'Processing primary_domain: '||l_primary_domain);
1525: l_this_group_id := l_next_group_id;
1526: fnd_oam_debug.log(1, l_ctxt, 'Given group ID: '||l_this_group_id);
1527: l_next_group_id := l_next_group_id + 1;
1528: b_domain_to_group_map(l_primary_domain) := l_this_group_id;
1529: b_dependency_groups(l_this_group_id) := CREATE_DEPENDENCY_GROUP_DEF(l_primary_domain);
1530:
1533: l_object_ids := b_primary_domains(l_primary_domain);
1534: k := l_object_ids.FIRST;
1535: WHILE k IS NOT NULL LOOP
1536: l_object_id := l_object_ids(k);
1537: fnd_oam_debug.log(1, l_ctxt, 'Processing domain object_id: '||l_object_id);
1538: -- see if the object_id has any additional domains, if it doesn't then this object produces no conflicts.
1539: IF b_objects(l_object_id).additional_domains IS NOT NULL THEN
1540: fnd_oam_debug.log(1, l_ctxt, 'Has Additional Domains');
1541: --loop over the additional domains
1536: l_object_id := l_object_ids(k);
1537: fnd_oam_debug.log(1, l_ctxt, 'Processing domain object_id: '||l_object_id);
1538: -- see if the object_id has any additional domains, if it doesn't then this object produces no conflicts.
1539: IF b_objects(l_object_id).additional_domains IS NOT NULL THEN
1540: fnd_oam_debug.log(1, l_ctxt, 'Has Additional Domains');
1541: --loop over the additional domains
1542: l_additional_domains := b_objects(l_object_id).additional_domains;
1543: j := l_additional_domains.FIRST;
1544: WHILE j IS NOT NULL LOOP
1542: l_additional_domains := b_objects(l_object_id).additional_domains;
1543: j := l_additional_domains.FIRST;
1544: WHILE j IS NOT NULL LOOP
1545: l_additional_domain := l_additional_domains(j);
1546: fnd_oam_debug.log(1, l_ctxt, 'Processing additional_domain: '||l_additional_domain);
1547: --see if the additional domain has already been seen
1548: IF b_domain_to_group_map.EXISTS(l_additional_domain) THEN
1549: --see if the additional domain is not already in this group, if it is we don't have to do anything
1550: l_found_group_id := b_domain_to_group_map(l_additional_domain);
1572: l_primary_domain := b_primary_domains.NEXT(l_primary_domain);
1573: END LOOP;
1574:
1575: -- success
1576: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1577: RETURN;
1578: EXCEPTION
1579: WHEN PROGRAM_ERROR THEN
1580: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1576: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1577: RETURN;
1578: EXCEPTION
1579: WHEN PROGRAM_ERROR THEN
1580: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1581: RAISE;
1582: WHEN OTHERS THEN
1583: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
1584: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1579: WHEN PROGRAM_ERROR THEN
1580: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1581: RAISE;
1582: WHEN OTHERS THEN
1583: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
1584: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1585: RAISE PROGRAM_ERROR;
1586: END;
1587:
1580: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1581: RAISE;
1582: WHEN OTHERS THEN
1583: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
1584: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1585: RAISE PROGRAM_ERROR;
1586: END;
1587:
1588: -- Private, helper to COMPILE_CONFIG_INSTANCE to dump out the run entity
1599: l_display_name VARCHAR2(120);
1600: l_description VARCHAR2(2000);
1601: l_language VARCHAR2(12);
1602: BEGIN
1603: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
1604:
1605: --see if we need to create a run object if none was cached on fetch
1606: IF b_run.object_id IS NULL THEN
1607: fnd_oam_debug.log(2, l_ctxt, 'Creating new run object');
1603: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
1604:
1605: --see if we need to create a run object if none was cached on fetch
1606: IF b_run.object_id IS NULL THEN
1607: fnd_oam_debug.log(2, l_ctxt, 'Creating new run object');
1608: FND_OAM_DSCFG_API_PKG.ADD_OBJECT(p_object_type => FND_OAM_DSCFG_API_PKG.G_OTYPE_RUN,
1609: x_object_id => b_run.object_id);
1610: fnd_oam_debug.log(2, l_ctxt, 'run object_id: '||b_run.object_id);
1611: --add an entry to the b_objects array so we can cache messages there
1606: IF b_run.object_id IS NULL THEN
1607: fnd_oam_debug.log(2, l_ctxt, 'Creating new run object');
1608: FND_OAM_DSCFG_API_PKG.ADD_OBJECT(p_object_type => FND_OAM_DSCFG_API_PKG.G_OTYPE_RUN,
1609: x_object_id => b_run.object_id);
1610: fnd_oam_debug.log(2, l_ctxt, 'run object_id: '||b_run.object_id);
1611: --add an entry to the b_objects array so we can cache messages there
1612: b_objects(b_run.object_id) := CREATE_OBJECT_DEF(b_run.object_id,
1613: FND_OAM_DSCFG_API_PKG.G_OTYPE_RUN);
1614: END IF;
1625: FND_OAM_DSCRAM_UTILS_PKG.G_MODE_TEST,
1626: FND_OAM_DSCRAM_UTILS_PKG.G_MODE_TEST_NO_EXEC,
1627: FND_OAM_DSCRAM_UTILS_PKG.G_MODE_DIAGNOSTIC) THEN
1628: l_msg := 'Invalid run mode specified: "'||b_run.run_mode||'".';
1629: fnd_oam_debug.log(3, l_ctxt, l_msg);
1630: MARK_OBJECT_AS_ERRORED(b_run.object_id,
1631: l_msg);
1632: RAISE PROGRAM_ERROR;
1633: END IF;
1631: l_msg);
1632: RAISE PROGRAM_ERROR;
1633: END IF;
1634: END IF;
1635: fnd_oam_debug.log(1, l_ctxt, 'Run Mode: '||b_run.run_mode);
1636:
1637: --default the valid_check_interval if not present
1638: IF b_run.valid_check_interval IS NULL THEN
1639: b_run.valid_check_interval := GET_DFLT_VALID_CHECK_INTERVAL;
1643: x_property_id => l_property_id);
1644: ELSE
1645: IF b_run.valid_check_interval < 0 THEN
1646: l_msg := 'Invalid valid_check_interval specified: "'||b_run.valid_check_interval||'".';
1647: fnd_oam_debug.log(3, l_ctxt, l_msg);
1648: MARK_OBJECT_AS_ERRORED(b_run.object_id,
1649: l_msg);
1650: RAISE PROGRAM_ERROR;
1651: END IF;
1649: l_msg);
1650: RAISE PROGRAM_ERROR;
1651: END IF;
1652: END IF;
1653: fnd_oam_debug.log(1, l_ctxt, 'Valid Check Interval: '||b_run.valid_check_interval);
1654:
1655: --default the # of bundles using what we've read into b_bundles or the default
1656: IF b_run.num_bundles IS NULL THEN
1657: IF b_bundles.COUNT > 0 THEN
1666: x_property_id => l_property_id);
1667: ELSE
1668: IF b_run.num_bundles < 1 THEN
1669: l_msg := 'Invalid num_bundles specified: "'||b_run.num_bundles||'".';
1670: fnd_oam_debug.log(3, l_ctxt, l_msg);
1671: MARK_OBJECT_AS_ERRORED(b_run.object_id,
1672: l_msg);
1673: RAISE PROGRAM_ERROR;
1674: END IF;
1672: l_msg);
1673: RAISE PROGRAM_ERROR;
1674: END IF;
1675: END IF;
1676: fnd_oam_debug.log(1, l_ctxt, 'Number of Bundles: '||b_run.num_bundles);
1677:
1678: --make sure the num_bundles is >= the # of bundle objects we read in
1679: IF b_bundles.COUNT > b_run.num_bundles THEN
1680: l_msg := 'Number of specified run bundles, '||b_run.num_bundles||', less than the number of bundles seen in configuration, '||b_bundles.COUNT;
1677:
1678: --make sure the num_bundles is >= the # of bundle objects we read in
1679: IF b_bundles.COUNT > b_run.num_bundles THEN
1680: l_msg := 'Number of specified run bundles, '||b_run.num_bundles||', less than the number of bundles seen in configuration, '||b_bundles.COUNT;
1681: fnd_oam_debug.log(3, l_ctxt, l_msg);
1682: MARK_OBJECT_AS_ERRORED(b_run.object_id,
1683: l_msg);
1684: RAISE PROGRAM_ERROR;
1685: END IF;
1690: SELECT FND_OAM_DSCRAM_RUNS_S.NEXTVAL
1691: INTO b_run.run_id
1692: FROM dual;
1693: ELSE
1694: fnd_oam_debug.log(1, l_ctxt, 'Deleting Existing, Stale run_id: '||b_run.run_id);
1695: --TODO: make this smarter
1696: IF NOT FND_OAM_DSCRAM_UTILS_PKG.DELETE_RUN(b_run.run_id) THEN
1697: l_msg := 'Failed to delete previously compiled run: '||b_run.run_id;
1698: fnd_oam_debug.log(3, l_ctxt, l_msg);
1694: fnd_oam_debug.log(1, l_ctxt, 'Deleting Existing, Stale run_id: '||b_run.run_id);
1695: --TODO: make this smarter
1696: IF NOT FND_OAM_DSCRAM_UTILS_PKG.DELETE_RUN(b_run.run_id) THEN
1697: l_msg := 'Failed to delete previously compiled run: '||b_run.run_id;
1698: fnd_oam_debug.log(3, l_ctxt, l_msg);
1699: END IF;
1700: END IF;
1701:
1702: --query the current db as the target_dbname
1730: FND_GLOBAL.USER_ID,
1731: SYSDATE,
1732: FND_GLOBAL.USER_ID)
1733: RETURNING run_id INTO b_run.run_id;
1734: fnd_oam_debug.log(1, l_ctxt, 'Created new run_id: '||b_run.run_id);
1735:
1736: --store the run_id
1737: FND_OAM_DSCFG_API_PKG.SET_OR_ADD_OBJECT_PROPERTY(p_object_id => b_run.object_id,
1738: p_property_name => FND_OAM_DSCFG_API_PKG.G_PROP_RUN_ID,
1738: p_property_name => FND_OAM_DSCFG_API_PKG.G_PROP_RUN_ID,
1739: p_number_value => b_run.run_id,
1740: x_property_id => l_property_id);
1741:
1742: fnd_oam_debug.log(1, l_ctxt, 'Querying config_instance attributes');
1743: -- get the name/description from the config instance
1744: SELECT name, description, language
1745: INTO l_display_name, l_description, l_language
1746: FROM fnd_oam_dscfg_instances
1745: INTO l_display_name, l_description, l_language
1746: FROM fnd_oam_dscfg_instances
1747: WHERE config_instance_id = p_config_instance_id;
1748:
1749: fnd_oam_debug.log(1, l_ctxt, 'Inserting runs_tl row');
1750: INSERT INTO FND_OAM_DSCRAM_RUNS_TL (RUN_ID,
1751: DISPLAY_NAME,
1752: DESCRIPTION,
1753: LANGUAGE,
1773:
1774: COMMIT;
1775:
1776: --success
1777: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1778: EXCEPTION
1779: WHEN PROGRAM_ERROR THEN
1780: ROLLBACK;
1781: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1777: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1778: EXCEPTION
1779: WHEN PROGRAM_ERROR THEN
1780: ROLLBACK;
1781: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1782: RAISE;
1783: WHEN OTHERS THEN
1784: ROLLBACK;
1785: --try to mark the run object
1788: l_ctxt,
1789: SQLCODE,
1790: SQLERRM);
1791: END IF;
1792: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
1793: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1794: RAISE PROGRAM_ERROR;
1795: END;
1796:
1789: SQLCODE,
1790: SQLERRM);
1791: END IF;
1792: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
1793: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
1794: RAISE PROGRAM_ERROR;
1795: END;
1796:
1797: -- Private, helper to COMPILE_CONFIG_INSTANCE to dump out bundle entities
1813: l_found BOOLEAN;
1814: l_bundles_to_create NUMBER;
1815:
1816: BEGIN
1817: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
1818:
1819: --get the list of hosts for this DB
1820: SELECT UPPER(host_name)
1821: BULK COLLECT INTO l_host_names
1823:
1824: --make sure we don't have more bundles than hosts
1825: IF b_run.num_bundles > l_host_names.COUNT THEN
1826: l_msg := 'More bundles defined in run configuration, '||b_run.num_bundles||', than defined for database: '||l_host_names.COUNT;
1827: fnd_oam_debug.log(3, l_ctxt, l_msg);
1828: MARK_OBJECT_AS_ERRORED(b_run.object_id,
1829: l_msg);
1830: RAISE PROGRAM_ERROR;
1831: END IF;
1834: --workers_allowed, batch_size and min_parallel_weight attributes
1835: k := b_bundles.FIRST;
1836: WHILE k IS NOT NULL LOOP
1837: l_host_name := b_bundles(k).target_hostname;
1838: fnd_oam_debug.log(1, l_ctxt, 'Validating Bundle with object_id: '||k);
1839:
1840: --if a host is specified, do validation/bookkeeping
1841: IF l_host_name IS NOT NULL THEN
1842: fnd_oam_debug.log('Validating specified host_name: '||l_host_name);
1838: fnd_oam_debug.log(1, l_ctxt, 'Validating Bundle with object_id: '||k);
1839:
1840: --if a host is specified, do validation/bookkeeping
1841: IF l_host_name IS NOT NULL THEN
1842: fnd_oam_debug.log('Validating specified host_name: '||l_host_name);
1843: --see if the host name is already used
1844: IF b_host_name_map.EXISTS(l_host_name) THEN
1845: l_msg := 'Target Hostname "'||l_host_name||'" already used by object id: '||b_host_name_map(l_host_name);
1846: fnd_oam_debug.log(3, l_ctxt, l_msg);
1842: fnd_oam_debug.log('Validating specified host_name: '||l_host_name);
1843: --see if the host name is already used
1844: IF b_host_name_map.EXISTS(l_host_name) THEN
1845: l_msg := 'Target Hostname "'||l_host_name||'" already used by object id: '||b_host_name_map(l_host_name);
1846: fnd_oam_debug.log(3, l_ctxt, l_msg);
1847: MARK_OBJECT_AS_ERRORED(k,
1848: l_msg);
1849: RAISE PROGRAM_ERROR;
1850: ELSE
1862:
1863: --if we didn't find it, it's invalid
1864: IF NOT l_found THEN
1865: l_msg := 'Target Hostname "'||l_host_name||'" is not a hostname attached to this instance, check gv$instance.host_name.';
1866: fnd_oam_debug.log(3, l_ctxt, l_msg);
1867: MARK_OBJECT_AS_ERRORED(k,
1868: l_msg);
1869: RAISE PROGRAM_ERROR;
1870: END IF;
1883: x_property_id => l_property_id);
1884: ELSE
1885: IF b_bundles(k).workers_allowed < 1 THEN
1886: l_msg := 'Invalid workers_allowed specified: "'||b_bundles(k).workers_allowed||'".';
1887: fnd_oam_debug.log(3, l_ctxt, l_msg);
1888: MARK_OBJECT_AS_ERRORED(k,
1889: l_msg);
1890: RAISE PROGRAM_ERROR;
1891: END IF;
1889: l_msg);
1890: RAISE PROGRAM_ERROR;
1891: END IF;
1892: END IF;
1893: fnd_oam_debug.log(1, l_ctxt, 'Workers Allowed: '||b_bundles(k).workers_allowed);
1894:
1895: --validate the batch_size
1896: IF b_bundles(k).batch_size IS NULL THEN
1897: b_bundles(k).batch_size := GET_DEFAULT_BATCH_SIZE;
1901: x_property_id => l_property_id);
1902: ELSE
1903: IF b_bundles(k).batch_size < 1 THEN
1904: l_msg := 'Invalid batch_size specified: "'||b_bundles(k).batch_size||'".';
1905: fnd_oam_debug.log(3, l_ctxt, l_msg);
1906: MARK_OBJECT_AS_ERRORED(k,
1907: l_msg);
1908: RAISE PROGRAM_ERROR;
1909: END IF;
1907: l_msg);
1908: RAISE PROGRAM_ERROR;
1909: END IF;
1910: END IF;
1911: fnd_oam_debug.log(1, l_ctxt, 'Batch Size: '||b_bundles(k).batch_size);
1912:
1913: --validate the min_parallel_unit_weight
1914: IF b_bundles(k).min_parallel_unit_weight IS NULL THEN
1915: b_bundles(k).min_parallel_unit_weight := GET_DFLT_MIN_PARALLEL_WEIGHT;
1919: x_property_id => l_property_id);
1920: ELSE
1921: IF b_bundles(k).min_parallel_unit_weight < 1 THEN
1922: l_msg := 'Invalid min_parallel_unit_weight specified: "'||b_bundles(k).min_parallel_unit_weight||'".';
1923: fnd_oam_debug.log(3, l_ctxt, l_msg);
1924: MARK_OBJECT_AS_ERRORED(k,
1925: l_msg);
1926: RAISE PROGRAM_ERROR;
1927: END IF;
1925: l_msg);
1926: RAISE PROGRAM_ERROR;
1927: END IF;
1928: END IF;
1929: fnd_oam_debug.log(1, l_ctxt, 'Minimum unit weight to parallelize: '||b_bundles(k).min_parallel_unit_weight);
1930:
1931: k := b_bundles.NEXT(k);
1932: END LOOP;
1933:
1939:
1940: IF l_host_name IS NULL THEN
1941: --just get the next one off of l_host_names
1942: b_bundles(k).target_hostname := l_host_names(l_host_names.FIRST);
1943: fnd_oam_debug.log(1, l_ctxt, 'Assigned host_name "'||l_host_name||'" to bundle_object_id: '||k);
1944: l_host_names.DELETE(l_host_names.FIRST);
1945: b_host_name_map(b_bundles(k).target_hostname) := k;
1946:
1947: FND_OAM_DSCFG_API_PKG.ADD_OBJECT_PROPERTY(p_object_id => k,
1957: --make sure we've got as many b_bundles entries as expected by b_run.num_bundles.
1958: --As an invariant, we can't have more but if we have less we need to create some default bundles.
1959: IF b_bundles.COUNT < b_run.num_bundles THEN
1960: l_bundles_to_create := b_run.num_bundles - b_bundles.COUNT;
1961: fnd_oam_debug.log(1, l_ctxt, 'Creating '||l_bundles_to_create||' bundle objects...');
1962: FOR k in 1..l_bundles_to_create LOOP
1963: --create a bundle object
1964: FND_OAM_DSCFG_API_PKG.ADD_OBJECT(p_object_type => FND_OAM_DSCFG_API_PKG.G_OTYPE_BUNDLE,
1965: x_object_id => l_bundle_object_id);
1962: FOR k in 1..l_bundles_to_create LOOP
1963: --create a bundle object
1964: FND_OAM_DSCFG_API_PKG.ADD_OBJECT(p_object_type => FND_OAM_DSCFG_API_PKG.G_OTYPE_BUNDLE,
1965: x_object_id => l_bundle_object_id);
1966: fnd_oam_debug.log(1, l_ctxt, 'Bundle object_id: '||l_bundle_object_id);
1967: b_objects(l_bundle_object_id) := CREATE_OBJECT_DEF(l_bundle_object_id,
1968: FND_OAM_DSCFG_API_PKG.G_OTYPE_BUNDLE);
1969:
1970: --use the next available host name
1976: FND_OAM_DSCFG_API_PKG.ADD_OBJECT_PROPERTY(p_object_id => l_bundle_object_id,
1977: p_property_name => FND_OAM_DSCFG_API_PKG.G_PROP_TARGET_HOSTNAME,
1978: p_varchar2_value => b_bundles(l_bundle_object_id).target_hostname,
1979: x_property_id => l_property_id);
1980: fnd_oam_debug.log(1, l_ctxt, 'Target Hostname: '||b_bundles(l_bundle_object_id).target_hostname);
1981: FND_OAM_DSCFG_API_PKG.ADD_OBJECT_PROPERTY(p_object_id => l_bundle_object_id,
1982: p_property_name => FND_OAM_DSCFG_API_PKG.G_PROP_WORKERS_ALLOWED,
1983: p_number_value => b_bundles(l_bundle_object_id).workers_allowed,
1984: x_property_id => l_property_id);
1981: FND_OAM_DSCFG_API_PKG.ADD_OBJECT_PROPERTY(p_object_id => l_bundle_object_id,
1982: p_property_name => FND_OAM_DSCFG_API_PKG.G_PROP_WORKERS_ALLOWED,
1983: p_number_value => b_bundles(l_bundle_object_id).workers_allowed,
1984: x_property_id => l_property_id);
1985: fnd_oam_debug.log(1, l_ctxt, 'Workers Allowed: '||b_bundles(l_bundle_object_id).workers_allowed);
1986: FND_OAM_DSCFG_API_PKG.ADD_OBJECT_PROPERTY(p_object_id => l_bundle_object_id,
1987: p_property_name => FND_OAM_DSCFG_API_PKG.G_PROP_BATCH_SIZE,
1988: p_number_value => b_bundles(l_bundle_object_id).batch_size,
1989: x_property_id => l_property_id);
1986: FND_OAM_DSCFG_API_PKG.ADD_OBJECT_PROPERTY(p_object_id => l_bundle_object_id,
1987: p_property_name => FND_OAM_DSCFG_API_PKG.G_PROP_BATCH_SIZE,
1988: p_number_value => b_bundles(l_bundle_object_id).batch_size,
1989: x_property_id => l_property_id);
1990: fnd_oam_debug.log(1, l_ctxt, 'Batch Size: '||b_bundles(l_bundle_object_id).batch_size);
1991: FND_OAM_DSCFG_API_PKG.ADD_OBJECT_PROPERTY(p_object_id => l_bundle_object_id,
1992: p_property_name => FND_OAM_DSCFG_API_PKG.G_PROP_MIN_PARALLEL_WEIGHT,
1993: p_number_value => b_bundles(l_bundle_object_id).min_parallel_unit_weight,
1994: x_property_id => l_property_id);
1991: FND_OAM_DSCFG_API_PKG.ADD_OBJECT_PROPERTY(p_object_id => l_bundle_object_id,
1992: p_property_name => FND_OAM_DSCFG_API_PKG.G_PROP_MIN_PARALLEL_WEIGHT,
1993: p_number_value => b_bundles(l_bundle_object_id).min_parallel_unit_weight,
1994: x_property_id => l_property_id);
1995: fnd_oam_debug.log(1, l_ctxt, 'Min Parallel Unit Weight: '||b_bundles(l_bundle_object_id).min_parallel_unit_weight);
1996: END LOOP;
1997: END IF;
1998:
1999: --At this point, we should have b_run.num_bundles entries in b_bundles and each should be valid, create entries for each.
2030: FND_GLOBAL.USER_ID,
2031: SYSDATE,
2032: FND_GLOBAL.USER_ID)
2033: RETURNING bundle_id INTO b_bundles(k).bundle_id;
2034: fnd_oam_debug.log(1, l_ctxt, 'Bundle Object ID ('||k||') created bundle_id ('||b_bundles(k).bundle_id||')');
2035:
2036: --add the property for bundle id
2037: FND_OAM_DSCFG_API_PKG.SET_OR_ADD_OBJECT_PROPERTY(p_object_id => k,
2038: p_property_name => FND_OAM_DSCFG_API_PKG.G_PROP_BUNDLE_ID,
2044:
2045: COMMIT;
2046:
2047: --success
2048: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2049: EXCEPTION
2050: WHEN PROGRAM_ERROR THEN
2051: ROLLBACK;
2052: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2048: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2049: EXCEPTION
2050: WHEN PROGRAM_ERROR THEN
2051: ROLLBACK;
2052: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2053: RAISE;
2054: WHEN OTHERS THEN
2055: ROLLBACK;
2056: --mark the run object
2057: MARK_OBJECT_AS_ERRORED(b_run.object_id,
2058: l_ctxt,
2059: SQLCODE,
2060: SQLERRM);
2061: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
2062: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2063: RAISE PROGRAM_ERROR;
2064: END;
2065:
2058: l_ctxt,
2059: SQLCODE,
2060: SQLERRM);
2061: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
2062: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2063: RAISE PROGRAM_ERROR;
2064: END;
2065:
2066: -- Private, gets the table_objects_def entity from the px_table_bound_map or creates one if necessary.
2092: RETURN l_table_objects_def;
2093: END IF;
2094: EXCEPTION
2095: WHEN OTHERS THEN
2096: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
2097: RAISE;
2098: END;
2099:
2100: -- Private, helper to ADD_ENGINE_UNITS to do the physical insert
2115: l_ctxt VARCHAR2(60) := PKG_NAME||'ADD_UNIT';
2116:
2117: l_unit_id NUMBER;
2118: BEGIN
2119: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
2120:
2121: IF px_unit_id IS NULL THEN
2122: SELECT FND_OAM_DSCRAM_UNITS_S.NEXTVAL
2123: INTO px_unit_id
2169: RETURNING UNIT_ID INTO l_unit_id;
2170:
2171: px_unit_id := l_unit_id;
2172:
2173: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2174: EXCEPTION
2175: WHEN OTHERS THEN
2176: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
2177: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2172:
2173: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2174: EXCEPTION
2175: WHEN OTHERS THEN
2176: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
2177: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2178: RAISE;
2179: END;
2180:
2173: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2174: EXCEPTION
2175: WHEN OTHERS THEN
2176: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
2177: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2178: RAISE;
2179: END;
2180:
2181: --Simple helper to get the next unit id from its sequence.
2217: IS
2218: l_ctxt VARCHAR2(60) := PKG_NAME||'ADD_ENGINE_DML';
2219: l_dml_id NUMBER;
2220: BEGIN
2221: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
2222:
2223: INSERT INTO FND_OAM_DSCRAM_DMLS (DML_ID,
2224: UNIT_ID,
2225: PRIORITY,
2247: RETURNING DML_ID INTO l_dml_id;
2248:
2249: x_dml_id := l_dml_id;
2250:
2251: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2252: EXCEPTION
2253: WHEN OTHERS THEN
2254: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Exception: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
2255: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2250:
2251: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2252: EXCEPTION
2253: WHEN OTHERS THEN
2254: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Exception: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
2255: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2256: RAISE;
2257: END;
2258:
2251: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2252: EXCEPTION
2253: WHEN OTHERS THEN
2254: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Exception: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
2255: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2256: RAISE;
2257: END;
2258:
2259: -- Helper to construct a DML DELETE statement and add it to a unit.
2268: l_stmt VARCHAR2(4000);
2269: l_weight NUMBER;
2270: l_dml_id NUMBER;
2271: BEGIN
2272: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
2273:
2274: --get a reference
2275: l_delete_def := b_dml_delete_stmts(p_object_id);
2276:
2290: x_dml_id => l_dml_id);
2291:
2292: --success
2293: x_weight := l_weight;
2294: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2295: RETURN TRUE;
2296: EXCEPTION
2297: WHEN OTHERS THEN
2298: MARK_OBJECT_AS_ERRORED(p_object_id,
2298: MARK_OBJECT_AS_ERRORED(p_object_id,
2299: l_ctxt,
2300: SQLCODE,
2301: SQLERRM);
2302: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2303: RAISE PROGRAM_ERROR;
2304: END;
2305:
2306: -- Helper to construct a DML DELETE statement and add it to a unit.
2333: l_weight NUMBER;
2334: k NUMBER;
2335: l_msg VARCHAR2(4000);
2336: BEGIN
2337: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
2338:
2339: --prep the dml prefix and suffix
2340: l_prefix := 'UPDATE '||p_table_owner||'.'||p_table_name;
2341: IF p_where_clause IS NOT NULL THEN
2341: IF p_where_clause IS NOT NULL THEN
2342: l_suffix := ' WHERE ';
2343: IF length(l_suffix) + length(p_where_clause) > B_STMT_MAXLEN THEN
2344: l_msg := 'Table '||p_table_owner||'.'||p_table_name||' has a where clause that is too long.';
2345: fnd_oam_debug.log(3, l_ctxt, l_msg);
2346: MARK_OBJECT_AS_ERRORED(b_run.object_id,
2347: l_msg);
2348: RAISE PROGRAM_ERROR;
2349: ELSE
2385: --no room left
2386: IF l_column_count = 0 THEN
2387: --no room for the first element, this is bad
2388: l_msg := 'This set clause alone is too large('||to_char(l_prefix_len + length(l_set_clause) + length(l_set_snippet) + l_suffix_len)||') for a single statement with the where clause provided.';
2389: fnd_oam_debug.log(3, l_ctxt, l_msg);
2390: MARK_OBJECT_AS_ERRORED(px_column_map(l_column),
2391: l_msg);
2392: RAISE PROGRAM_ERROR;
2393: END IF;
2428:
2429: --success
2430: x_logical_weight := l_logical_weight;
2431: x_physical_weight := l_physical_weight;
2432: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2433: RETURN TRUE;
2434: EXCEPTION
2435: WHEN PROGRAM_ERROR THEN
2436: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2432: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2433: RETURN TRUE;
2434: EXCEPTION
2435: WHEN PROGRAM_ERROR THEN
2436: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2437: RAISE;
2438: WHEN OTHERS THEN
2439: MARK_OBJECT_AS_ERRORED(b_run.object_id,
2440: l_ctxt,
2439: MARK_OBJECT_AS_ERRORED(b_run.object_id,
2440: l_ctxt,
2441: SQLCODE,
2442: SQLERRM);
2443: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2444: RAISE PROGRAM_ERROR;
2445: END;
2446:
2447: -- create a plsql entry for a given unit
2454: l_ctxt VARCHAR2(60) := PKG_NAME||'ADD_ENGINE_PLSQL';
2455:
2456: l_plsql_id NUMBER;
2457: BEGIN
2458: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
2459:
2460: INSERT INTO FND_OAM_DSCRAM_PLSQLS (PLSQL_ID,
2461: UNIT_ID,
2462: PRIORITY,
2482: RETURNING PLSQL_ID INTO l_plsql_id;
2483:
2484: x_plsql_id := l_plsql_id;
2485:
2486: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2487: EXCEPTION
2488: WHEN OTHERS THEN
2489: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Exception: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
2490: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2485:
2486: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2487: EXCEPTION
2488: WHEN OTHERS THEN
2489: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Exception: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
2490: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2491: RAISE;
2492: END;
2493:
2486: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2487: EXCEPTION
2488: WHEN OTHERS THEN
2489: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Exception: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
2490: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2491: RAISE;
2492: END;
2493:
2494: -- Helper function to ADD_ENGINE_UNITS_FOR_DOMAIN to handle the table_bound objects of a specific domain.
2524: l_weight NUMBER;
2525: k NUMBER;
2526: j NUMBER;
2527: BEGIN
2528: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
2529:
2530: -- Go through each owner/name
2531: -- combo and create units. For now, each owner/name combo will produce one unit in a different phase. Other tables
2532: -- in the same domain usually means overlap so they'd need a different phase anyhow. Lumping all the operations
2534: -- Finally, use and increment the passed in phases for each instead of using NULLs to keep NULL open for any ops the user
2535: -- wants to have run at the very end.
2536: l_table_owner := px_table_bound_map.FIRST;
2537: WHILE l_table_owner IS NOT NULL LOOP
2538: fnd_oam_debug.log(1, l_ctxt, 'Processing Table Owner: '||l_table_owner);
2539: --loop over the table names for this owner
2540: l_table_name := px_table_bound_map(l_table_owner).FIRST;
2541: WHILE l_table_name IS NOT NULL LOOP
2542: fnd_oam_debug.log(1, l_ctxt, 'Processing Table Name: '||l_table_name);
2538: fnd_oam_debug.log(1, l_ctxt, 'Processing Table Owner: '||l_table_owner);
2539: --loop over the table names for this owner
2540: l_table_name := px_table_bound_map(l_table_owner).FIRST;
2541: WHILE l_table_name IS NOT NULL LOOP
2542: fnd_oam_debug.log(1, l_ctxt, 'Processing Table Name: '||l_table_name);
2543: --get a reference to the table_objects_def
2544: l_table_objects_def := px_table_bound_map(l_table_owner)(l_table_name);
2545:
2546: --see if we've got dmls and plsqls, this requires a concurrent unit
2659:
2660: --increment the phase
2661: px_bound_operations_phase := px_bound_operations_phase + B_PHASE_INCREMENT;
2662:
2663: fnd_oam_debug.log(1, l_ctxt, 'Unit logical/physical weight: ('||l_unit_logical_weight||')('||l_unit_physical_weight||')');
2664: --integrate the unit's logical/physical weights
2665: INTEGRATE_WEIGHTS(l_total_logical_weight,
2666: l_total_physical_weight,
2667: l_unit_logical_weight,
2676:
2677: --success
2678: x_logical_weight := l_total_logical_weight;
2679: x_physical_weight := l_total_physical_weight;
2680: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2681: RETURN TRUE;
2682: EXCEPTION
2683: WHEN PROGRAM_ERROR THEN
2684: ROLLBACK;
2681: RETURN TRUE;
2682: EXCEPTION
2683: WHEN PROGRAM_ERROR THEN
2684: ROLLBACK;
2685: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2686: RAISE;
2687: WHEN OTHERS THEN
2688: ROLLBACK;
2689: --mark the run becaues we have no place better.
2690: MARK_OBJECT_AS_ERRORED(b_run.object_id,
2691: l_ctxt,
2692: SQLCODE,
2693: SQLERRM);
2694: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
2695: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2696: RAISE;
2697: END;
2698:
2691: l_ctxt,
2692: SQLCODE,
2693: SQLERRM);
2694: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
2695: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
2696: RAISE;
2697: END;
2698:
2699: -- Private, helper to COMPILE_CONFIG_INSTANCE to dump out tasks/units for a specific primary domain.
2747: l_logical_weight NUMBER;
2748: l_physical_weight NUMBER;
2749: k NUMBER;
2750: BEGIN
2751: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
2752:
2753: -- loop through the domain's contents, grouping the objects
2754: k := b_primary_domains(p_primary_domain).FIRST;
2755: WHILE k IS NOT NULL LOOP
2753: -- loop through the domain's contents, grouping the objects
2754: k := b_primary_domains(p_primary_domain).FIRST;
2755: WHILE k IS NOT NULL LOOP
2756: l_object_id := b_primary_domains(p_primary_domain)(k);
2757: fnd_oam_debug.log(1, l_ctxt, 'Parsing object_id: '||l_object_id||'('||b_objects(l_object_id).object_type||')');
2758: --case the object type
2759: CASE b_objects(l_object_id).object_type
2760: WHEN FND_OAM_DSCFG_API_PKG.G_OTYPE_DML_UPDATE_SEGMENT THEN
2761: l_segment := b_dml_update_segments(l_object_id);
2813: l_ctxt,
2814: 'Duplicate of Object ID: '||l_table_objects_def.delete_map(l_where_clause));
2815: ELSE
2816: --add it
2817: fnd_oam_debug.log(1, l_ctxt, 'New where clause');
2818: l_table_objects_def.delete_map(NVL(l_where_clause, '')) := l_object_id;
2819: END IF;
2820:
2821: --set the table_objects_def back
2924: END;
2925: END IF;
2926: ELSE
2927: --unmatched object type, shouldn't happen
2928: fnd_oam_debug.log(6, l_ctxt, 'Unknown Object Type: '||b_objects(l_object_id).object_type);
2929: RAISE PROGRAM_ERROR;
2930: END CASE;
2931:
2932: k := b_primary_domains(p_primary_domain).NEXT(k);
2997:
2998: COMMIT;
2999:
3000: --success
3001: fnd_oam_debug.log(1, l_ctxt, 'Domain logical/physical weights: ('||l_domain_logical_weight||')('||l_domain_physical_weight||')');
3002: x_logical_weight := l_domain_logical_weight;
3003: x_physical_weight := l_domain_physical_weight;
3004: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3005: RETURN TRUE;
3000: --success
3001: fnd_oam_debug.log(1, l_ctxt, 'Domain logical/physical weights: ('||l_domain_logical_weight||')('||l_domain_physical_weight||')');
3002: x_logical_weight := l_domain_logical_weight;
3003: x_physical_weight := l_domain_physical_weight;
3004: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3005: RETURN TRUE;
3006: EXCEPTION
3007: WHEN PROGRAM_ERROR THEN
3008: ROLLBACK;
3005: RETURN TRUE;
3006: EXCEPTION
3007: WHEN PROGRAM_ERROR THEN
3008: ROLLBACK;
3009: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3010: RAISE;
3011: WHEN OTHERS THEN
3012: ROLLBACK;
3013: --mark the run becaues we have no place better.
3014: MARK_OBJECT_AS_ERRORED(b_run.object_id,
3015: l_ctxt,
3016: SQLCODE,
3017: SQLERRM);
3018: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
3019: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3020: RAISE;
3021: END;
3022:
3015: l_ctxt,
3016: SQLCODE,
3017: SQLERRM);
3018: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
3019: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3020: RAISE;
3021: END;
3022:
3023: -- To support multiple bundles/bundle work partitioning, use this call to encapsulate the
3086: k NUMBER;
3087: j NUMBER;
3088: l_msg VARCHAR2(4000);
3089: BEGIN
3090: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
3091:
3092: -- fetch a task_id to use for creating units
3093: SELECT FND_OAM_DSCRAM_TASKS_S.NEXTVAL
3094: INTO l_task_id
3093: SELECT FND_OAM_DSCRAM_TASKS_S.NEXTVAL
3094: INTO l_task_id
3095: FROM dual;
3096: b_dependency_groups(p_group_id).task_id := l_task_id;
3097: fnd_oam_debug.log(1, l_ctxt, 'Using task_id: '||l_task_id);
3098:
3099: -- loop through the primary domains, creating units for each kind of object in each domain - we don't allow
3100: -- collecting objects across primary domains.
3101: k := b_dependency_groups(p_group_id).primary_domains.FIRST;
3100: -- collecting objects across primary domains.
3101: k := b_dependency_groups(p_group_id).primary_domains.FIRST;
3102: WHILE k IS NOT NULL LOOP
3103: l_domain := b_dependency_groups(p_group_id).primary_domains(k);
3104: fnd_oam_debug.log(1, l_ctxt, 'Processing primary_domain: '||l_domain);
3105: --for a given domain, create the units, only do weight calculation if it came back true for sucess.
3106: IF ADD_ENGINE_UNITS_FOR_DOMAIN(l_task_id,
3107: l_domain,
3108: l_truncate_phase,
3121:
3122: k := b_dependency_groups(p_group_id).primary_domains.NEXT(k);
3123: END LOOP;
3124:
3125: fnd_oam_debug.log(1, l_ctxt, 'Task logical/physical weights: ('||l_task_logical_weight||')('||l_task_physical_weight||')');
3126: -- now that we've composed the task components, figure out what bundle to give it to and make the task
3127: fnd_oam_debug.log(1, l_ctxt, 'Getting bundle for group...');
3128: l_bundle_object_id := GET_BUNDLE_FOR_GROUP(b_dependency_groups(p_group_id));
3129: fnd_oam_debug.log(1, l_ctxt, 'Using Bundle_id: '||b_bundles(l_bundle_object_id).bundle_id);
3123: END LOOP;
3124:
3125: fnd_oam_debug.log(1, l_ctxt, 'Task logical/physical weights: ('||l_task_logical_weight||')('||l_task_physical_weight||')');
3126: -- now that we've composed the task components, figure out what bundle to give it to and make the task
3127: fnd_oam_debug.log(1, l_ctxt, 'Getting bundle for group...');
3128: l_bundle_object_id := GET_BUNDLE_FOR_GROUP(b_dependency_groups(p_group_id));
3129: fnd_oam_debug.log(1, l_ctxt, 'Using Bundle_id: '||b_bundles(l_bundle_object_id).bundle_id);
3130: l_weight := NVL(b_dependency_groups(p_group_id).weight, l_task_logical_weight);
3131: fnd_oam_debug.log(1, l_ctxt, 'Using Task Weight: '||l_weight);
3125: fnd_oam_debug.log(1, l_ctxt, 'Task logical/physical weights: ('||l_task_logical_weight||')('||l_task_physical_weight||')');
3126: -- now that we've composed the task components, figure out what bundle to give it to and make the task
3127: fnd_oam_debug.log(1, l_ctxt, 'Getting bundle for group...');
3128: l_bundle_object_id := GET_BUNDLE_FOR_GROUP(b_dependency_groups(p_group_id));
3129: fnd_oam_debug.log(1, l_ctxt, 'Using Bundle_id: '||b_bundles(l_bundle_object_id).bundle_id);
3130: l_weight := NVL(b_dependency_groups(p_group_id).weight, l_task_logical_weight);
3131: fnd_oam_debug.log(1, l_ctxt, 'Using Task Weight: '||l_weight);
3132:
3133: --skip the PRIORITY column for now
3127: fnd_oam_debug.log(1, l_ctxt, 'Getting bundle for group...');
3128: l_bundle_object_id := GET_BUNDLE_FOR_GROUP(b_dependency_groups(p_group_id));
3129: fnd_oam_debug.log(1, l_ctxt, 'Using Bundle_id: '||b_bundles(l_bundle_object_id).bundle_id);
3130: l_weight := NVL(b_dependency_groups(p_group_id).weight, l_task_logical_weight);
3131: fnd_oam_debug.log(1, l_ctxt, 'Using Task Weight: '||l_weight);
3132:
3133: --skip the PRIORITY column for now
3134: INSERT INTO FND_OAM_DSCRAM_TASKS (TASK_ID,
3135: BUNDLE_ID,
3160:
3161: COMMIT;
3162:
3163: --success
3164: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3165: RETURN TRUE;
3166: EXCEPTION
3167: WHEN PROGRAM_ERROR THEN
3168: ROLLBACK;
3165: RETURN TRUE;
3166: EXCEPTION
3167: WHEN PROGRAM_ERROR THEN
3168: ROLLBACK;
3169: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3170: --quick fail, cause other tasks to skip so we can write the error somewhere
3171: RAISE;
3172: WHEN OTHERS THEN
3173: ROLLBACK;
3175: MARK_OBJECT_AS_ERRORED(b_run.object_id,
3176: l_ctxt,
3177: SQLCODE,
3178: SQLERRM);
3179: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
3180: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3181: RAISE PROGRAM_ERROR;
3182: END;
3183:
3176: l_ctxt,
3177: SQLCODE,
3178: SQLERRM);
3179: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
3180: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3181: RAISE PROGRAM_ERROR;
3182: END;
3183:
3184: -- Private, helper to COMPILE_CONFIG_INSTANCE to dump out tasks/units
3190: l_ignore BOOLEAN;
3191:
3192: k NUMBER;
3193: BEGIN
3194: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
3195:
3196: -- loop through the dependency groups
3197: l_group_id := b_dependency_groups.FIRST;
3198: WHILE l_group_id IS NOT NULL LOOP
3199: --TODO: come up with a way to identify a task we've already compiled.
3200: --Problem: group_ids are transient and can be totally different based on the domain distribution. re-compiling
3201: --and trying to match them up would require a full task comparison?
3202: --For now, just create a new task for each dependency group
3203: fnd_oam_debug.log(1, l_ctxt, 'Adding Task for group_id: '||l_group_id);
3204: l_ignore := ADD_ENGINE_TASK_WITH_UNITS(l_group_id);
3205:
3206: l_group_id := b_dependency_groups.NEXT(l_group_id);
3207: END LOOP;
3206: l_group_id := b_dependency_groups.NEXT(l_group_id);
3207: END LOOP;
3208:
3209: --success
3210: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3211: EXCEPTION
3212: WHEN PROGRAM_ERROR THEN
3213: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3214: RAISE;
3209: --success
3210: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3211: EXCEPTION
3212: WHEN PROGRAM_ERROR THEN
3213: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3214: RAISE;
3215: WHEN OTHERS THEN
3216: --mark the run object
3217: MARK_OBJECT_AS_ERRORED(b_run.object_id,
3217: MARK_OBJECT_AS_ERRORED(b_run.object_id,
3218: l_ctxt,
3219: SQLCODE,
3220: SQLERRM);
3221: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
3222: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3223: RAISE PROGRAM_ERROR;
3224: END;
3225:
3218: l_ctxt,
3219: SQLCODE,
3220: SQLERRM);
3221: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
3222: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3223: RAISE PROGRAM_ERROR;
3224: END;
3225:
3226: -- Private, helper to COMPILE_CONFIG_INSTANCE to write the updated weight of the run/bundles to the db.
3231: l_ctxt VARCHAR2(60) := PKG_NAME||'UPDATE_RUN_BUNDLE_WEIGHTS';
3232: l_weight NUMBER;
3233: k NUMBER;
3234: BEGIN
3235: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
3236:
3237: k := b_bundles.FIRST;
3238: WHILE k IS NOT NULL LOOP
3239: l_weight := NVL(b_bundles(k).weight, b_bundles(k).assigned_physical_weight);
3238: WHILE k IS NOT NULL LOOP
3239: l_weight := NVL(b_bundles(k).weight, b_bundles(k).assigned_physical_weight);
3240: --add this bundle's weight to the run's assigned_physical_weight
3241: b_run.assigned_physical_weight := b_run.assigned_physical_weight + l_weight;
3242: fnd_oam_debug.log(1, l_ctxt, 'Updating bundle_id('||b_bundles(k).bundle_id||') weight('||l_weight||')');
3243: UPDATE fnd_oam_dscram_bundles
3244: SET weight = l_weight
3245: WHERE bundle_id = b_bundles(k).bundle_id;
3246: k := b_bundles.NEXT(k);
3246: k := b_bundles.NEXT(k);
3247: END LOOP;
3248:
3249: l_weight := NVL(b_run.weight, b_run.assigned_physical_weight);
3250: fnd_oam_debug.log(1, l_ctxt, 'Updating run_id('||b_run.run_id||') weight ('||l_weight||')');
3251: UPDATE fnd_oam_dscram_runs_b
3252: SET weight = l_weight
3253: WHERE run_id = b_run.run_id;
3254:
3254:
3255: COMMIT;
3256:
3257: --success
3258: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3259: EXCEPTION
3260: WHEN OTHERS THEN
3261: ROLLBACK;
3262: MARK_OBJECT_AS_ERRORED(b_run.object_id,
3262: MARK_OBJECT_AS_ERRORED(b_run.object_id,
3263: l_ctxt,
3264: SQLCODE,
3265: SQLERRM);
3266: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
3267: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3268: RAISE PROGRAM_ERROR;
3269: END;
3270:
3263: l_ctxt,
3264: SQLCODE,
3265: SQLERRM);
3266: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
3267: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3268: RAISE PROGRAM_ERROR;
3269: END;
3270:
3271: -- Private, helper to COMPILE_CONFIG_INSTANCE to write dirty objects to the db.
3277:
3278: k NUMBER;
3279: l_error_found BOOLEAN := FALSE;
3280: BEGIN
3281: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
3282:
3283: --TODO: see if we can make this bulk
3284: --TODO: need to write the target_type/target_id at some point - probably requires many changes.
3285: k := b_objects.FIRST;
3297: last_update_login = FND_GLOBAL.USER_ID
3298: WHERE object_id = b_objects(k).object_id;
3299: EXCEPTION
3300: WHEN OTHERS THEN
3301: fnd_oam_debug.log(3, l_ctxt, 'While writing object_id('||b_objects(k).object_id||'): Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
3302: l_error_found := TRUE;
3303: END;
3304: END IF;
3305: k := b_objects.NEXT(k);
3313: RAISE STORAGE_ERROR;
3314: END IF;
3315:
3316: --success
3317: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3318: EXCEPTION
3319: WHEN STORAGE_ERROR THEN
3320: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3321: RAISE;
3316: --success
3317: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3318: EXCEPTION
3319: WHEN STORAGE_ERROR THEN
3320: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3321: RAISE;
3322: WHEN OTHERS THEN
3323: ROLLBACK;
3324: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
3320: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3321: RAISE;
3322: WHEN OTHERS THEN
3323: ROLLBACK;
3324: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
3325: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3326: --raise a special kind of error to signal the caller
3327: RAISE STORAGE_ERROR;
3328: END;
3321: RAISE;
3322: WHEN OTHERS THEN
3323: ROLLBACK;
3324: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
3325: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3326: --raise a special kind of error to signal the caller
3327: RAISE STORAGE_ERROR;
3328: END;
3329:
3333: l_ctxt VARCHAR2(60) := PKG_NAME||'COMPILE_CONFIG_INSTANCE';
3334:
3335: l_config_instance_id NUMBER;
3336: BEGIN
3337: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
3338:
3339: --get the config_instance_id, throws error if not initialized
3340: l_config_instance_id := FND_OAM_DSCFG_INSTANCES_PKG.GET_CURRENT_ID;
3341: fnd_oam_debug.log(1, l_ctxt, 'Using config instance id: '||l_config_instance_id);
3337: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
3338:
3339: --get the config_instance_id, throws error if not initialized
3340: l_config_instance_id := FND_OAM_DSCFG_INSTANCES_PKG.GET_CURRENT_ID;
3341: fnd_oam_debug.log(1, l_ctxt, 'Using config instance id: '||l_config_instance_id);
3342:
3343: --clear the package state data
3344: fnd_oam_debug.log(1, l_ctxt, 'Resetting package state variables');
3345: b_objects.DELETE;
3340: l_config_instance_id := FND_OAM_DSCFG_INSTANCES_PKG.GET_CURRENT_ID;
3341: fnd_oam_debug.log(1, l_ctxt, 'Using config instance id: '||l_config_instance_id);
3342:
3343: --clear the package state data
3344: fnd_oam_debug.log(1, l_ctxt, 'Resetting package state variables');
3345: b_objects.DELETE;
3346: b_dml_update_segments.DELETE;
3347: b_dml_delete_stmts.DELETE;
3348: b_dml_truncate_stmts.DELETE;
3353: b_run.object_id := NULL;
3354: b_bundles.DELETE;
3355:
3356: --bulk fetch the objects from the database and fill the state
3357: fnd_oam_debug.log(1, l_ctxt, 'Fetching Compilable Objects');
3358: FETCH_COMPILABLE_OBJECTS(l_config_instance_id);
3359:
3360: --now that all the objects have been fetched and cached, traverse the caches
3361: --and figure out which primary domains are related to one another and group them into
3359:
3360: --now that all the objects have been fetched and cached, traverse the caches
3361: --and figure out which primary domains are related to one another and group them into
3362: --dependency groups
3363: fnd_oam_debug.log(1, l_ctxt, 'Computing Dependency Groups');
3364: COMPUTE_DEPENDENCY_GROUPS;
3365:
3366: --ALL of the data should be parsed into groups and validated by this point.
3367:
3367:
3368: --dump out the engine entities, if any fail, skip processing the rest since we don't
3369: --have a solid way to
3370: BEGIN
3371: fnd_oam_debug.log(1, l_ctxt, 'Generating an Engine Run Entity');
3372: GENERATE_ENGINE_RUN(l_config_instance_id);
3373:
3374: --generate the engine bundles
3375: fnd_oam_debug.log(1, l_ctxt, 'Generating Engine Bundles');
3371: fnd_oam_debug.log(1, l_ctxt, 'Generating an Engine Run Entity');
3372: GENERATE_ENGINE_RUN(l_config_instance_id);
3373:
3374: --generate the engine bundles
3375: fnd_oam_debug.log(1, l_ctxt, 'Generating Engine Bundles');
3376: GENERATE_ENGINE_BUNDLES;
3377:
3378: --traverse the dependency groups and output
3379: fnd_oam_debug.log(1, l_ctxt, 'Generating Engine Tasks');
3375: fnd_oam_debug.log(1, l_ctxt, 'Generating Engine Bundles');
3376: GENERATE_ENGINE_BUNDLES;
3377:
3378: --traverse the dependency groups and output
3379: fnd_oam_debug.log(1, l_ctxt, 'Generating Engine Tasks');
3380: GENERATE_ENGINE_TASKS;
3381:
3382: --write out the updated run and bundle weights
3383: UPDATE_RUN_BUNDLE_WEIGHTS;
3400: WRITE_DIRTY_OBJECTS;
3401:
3402: --success
3403: x_run_id := b_run.run_id;
3404: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3405: EXCEPTION
3406: WHEN STORAGE_ERROR THEN
3407: -- only raised by write_dirty_objects to tell us it failed and we should skip trying to
3408: -- write the dirty objects again.
3405: EXCEPTION
3406: WHEN STORAGE_ERROR THEN
3407: -- only raised by write_dirty_objects to tell us it failed and we should skip trying to
3408: -- write the dirty objects again.
3409: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3410: RAISE;
3411: WHEN PROGRAM_ERROR THEN
3412: -- one of the child methods failed, try to write dirty objects out
3413: BEGIN
3417: -- if we can't then there's nothing else we can do but raise the exception and hope
3418: -- there's something in the logs.
3419: null;
3420: END;
3421: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3422: RAISE;
3423: WHEN NO_DATA_FOUND THEN
3424: --just exit, this should only occur at the beginning before processing
3425: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3421: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3422: RAISE;
3423: WHEN NO_DATA_FOUND THEN
3424: --just exit, this should only occur at the beginning before processing
3425: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3426: RAISE;
3427: WHEN OTHERS THEN
3428: -- this should only occur locally if something is really wrong, just raise it up
3429: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
3425: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3426: RAISE;
3427: WHEN OTHERS THEN
3428: -- this should only occur locally if something is really wrong, just raise it up
3429: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
3430: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3431: RAISE;
3432: END;
3433:
3426: RAISE;
3427: WHEN OTHERS THEN
3428: -- this should only occur locally if something is really wrong, just raise it up
3429: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
3430: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3431: RAISE;
3432: END;
3433:
3434: -- Public
3436: RETURN NUMBER
3437: IS
3438: l_ctxt VARCHAR2(60) := PKG_NAME||'GET_DEFAULT_NUM_WORKERS';
3439: BEGIN
3440: fnd_oam_debug.log(2, l_ctxt, 'ENTER');
3441:
3442: --make sure we've set the default_workers_allowed
3443: IF B_DEFAULT_WORKERS_ALLOWED IS NULL THEN
3444: BEGIN
3454: WHEN OTHERS THEN
3455: B_DEFAULT_WORKERS_ALLOWED := 1;
3456: END;
3457: END IF;
3458: fnd_oam_debug.log(1, l_ctxt, 'Default Workers Allowed: '||B_DEFAULT_WORKERS_ALLOWED);
3459:
3460: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3461: RETURN B_DEFAULT_WORKERS_ALLOWED;
3462: EXCEPTION
3456: END;
3457: END IF;
3458: fnd_oam_debug.log(1, l_ctxt, 'Default Workers Allowed: '||B_DEFAULT_WORKERS_ALLOWED);
3459:
3460: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3461: RETURN B_DEFAULT_WORKERS_ALLOWED;
3462: EXCEPTION
3463: WHEN OTHERS THEN
3464: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
3460: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3461: RETURN B_DEFAULT_WORKERS_ALLOWED;
3462: EXCEPTION
3463: WHEN OTHERS THEN
3464: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
3465: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3466: RAISE;
3467: END;
3468:
3461: RETURN B_DEFAULT_WORKERS_ALLOWED;
3462: EXCEPTION
3463: WHEN OTHERS THEN
3464: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
3465: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3466: RAISE;
3467: END;
3468:
3469: -- Public
3475: --currently static
3476: RETURN B_DEFAULT_BATCH_SIZE;
3477: EXCEPTION
3478: WHEN OTHERS THEN
3479: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
3480: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3481: RAISE;
3482: END;
3483:
3476: RETURN B_DEFAULT_BATCH_SIZE;
3477: EXCEPTION
3478: WHEN OTHERS THEN
3479: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
3480: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3481: RAISE;
3482: END;
3483:
3484: -- Public
3490: --currently static
3491: RETURN B_DEFAULT_VALID_CHECK_INTERVAL;
3492: EXCEPTION
3493: WHEN OTHERS THEN
3494: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
3495: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3496: RAISE;
3497: END;
3498:
3491: RETURN B_DEFAULT_VALID_CHECK_INTERVAL;
3492: EXCEPTION
3493: WHEN OTHERS THEN
3494: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
3495: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3496: RAISE;
3497: END;
3498:
3499: -- Public
3505: --currently static
3506: RETURN B_DEFAULT_MIN_PARALLEL_WEIGHT;
3507: EXCEPTION
3508: WHEN OTHERS THEN
3509: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
3510: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3511: RAISE;
3512: END;
3513:
3506: RETURN B_DEFAULT_MIN_PARALLEL_WEIGHT;
3507: EXCEPTION
3508: WHEN OTHERS THEN
3509: fnd_oam_debug.log(6, l_ctxt, 'Unexpected Error: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
3510: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
3511: RAISE;
3512: END;
3513:
3514: END FND_OAM_DSCFG_COMPILER_PKG;