321: l_fnd_error VARCHAR2(1);
322: l_fnd_unexpected VARCHAR2(1);
323: l_api_name VARCHAR2(255) :=
324: 'CSI_ML_CREATE_PUB.EXECUTE_PARALLEL_CREATE';
325: l_inst_id_tbl CSI_ML_UTIL_PVT.INST_INTERFACE_TBL_TYPE;
326: ii PLS_INTEGER;
327: j PLS_INTEGER;
328: l_tbl_count NUMBER :=0;
329: l_dummy NUMBER;
690: COMMIT;
691: END LOOP;
692:
693: IF(l_debug_level>1) THEN
694: FND_File.Put_Line(Fnd_File.LOG,'Before calling csi_ml_util_pvt.resolve_rel_ids');
695: END IF;
696: -- To resolve id columns
697: csi_ml_util_pvt.resolve_rel_ids
698: (p_source_system => p_source_system_name
693: IF(l_debug_level>1) THEN
694: FND_File.Put_Line(Fnd_File.LOG,'Before calling csi_ml_util_pvt.resolve_rel_ids');
695: END IF;
696: -- To resolve id columns
697: csi_ml_util_pvt.resolve_rel_ids
698: (p_source_system => p_source_system_name
699: ,p_txn_from_date => p_txn_from_date
700: ,p_txn_to_date => p_txn_to_date
701: ,x_return_status => l_return_status
701: ,x_return_status => l_return_status
702: ,x_error_message => l_error_message
703: );
704: IF(l_debug_level>1) THEN
705: FND_File.Put_Line(Fnd_File.LOG,'After calling csi_ml_util_pvt.resolve_rel_ids');
706: END IF;
707:
708: csi_ml_util_pvt.eliminate_dup_records;
709: csi_ml_util_pvt.eliminate_dup_subject;
704: IF(l_debug_level>1) THEN
705: FND_File.Put_Line(Fnd_File.LOG,'After calling csi_ml_util_pvt.resolve_rel_ids');
706: END IF;
707:
708: csi_ml_util_pvt.eliminate_dup_records;
709: csi_ml_util_pvt.eliminate_dup_subject;
710: csi_ml_util_pvt.check_cyclic;
711:
712: OPEN relations_exist_cur;
705: FND_File.Put_Line(Fnd_File.LOG,'After calling csi_ml_util_pvt.resolve_rel_ids');
706: END IF;
707:
708: csi_ml_util_pvt.eliminate_dup_records;
709: csi_ml_util_pvt.eliminate_dup_subject;
710: csi_ml_util_pvt.check_cyclic;
711:
712: OPEN relations_exist_cur;
713: FETCH relations_exist_cur INTO l_rel_dummy;
706: END IF;
707:
708: csi_ml_util_pvt.eliminate_dup_records;
709: csi_ml_util_pvt.eliminate_dup_subject;
710: csi_ml_util_pvt.check_cyclic;
711:
712: OPEN relations_exist_cur;
713: FETCH relations_exist_cur INTO l_rel_dummy;
714: IF relations_exist_cur%NOTFOUND
949: COMMIT;
950: END LOOP;
951:
952: IF(l_debug_level>1) THEN
953: FND_File.Put_Line(Fnd_File.LOG,'Before calling csi_ml_util_pvt.resolve_rel_ids');
954: END IF;
955: -- To resolve id columns
956: csi_ml_util_pvt.resolve_rel_ids
957: (p_source_system => p_source_system_name
952: IF(l_debug_level>1) THEN
953: FND_File.Put_Line(Fnd_File.LOG,'Before calling csi_ml_util_pvt.resolve_rel_ids');
954: END IF;
955: -- To resolve id columns
956: csi_ml_util_pvt.resolve_rel_ids
957: (p_source_system => p_source_system_name
958: ,p_txn_from_date => p_txn_from_date
959: ,p_txn_to_date => p_txn_to_date
960: ,x_return_status => l_return_status
960: ,x_return_status => l_return_status
961: ,x_error_message => l_error_message
962: );
963: IF(l_debug_level>1) THEN
964: FND_File.Put_Line(Fnd_File.LOG,'After calling csi_ml_util_pvt.resolve_rel_ids');
965: END IF;
966:
967: csi_ml_util_pvt.eliminate_dup_records;
968: csi_ml_util_pvt.eliminate_dup_subject;
963: IF(l_debug_level>1) THEN
964: FND_File.Put_Line(Fnd_File.LOG,'After calling csi_ml_util_pvt.resolve_rel_ids');
965: END IF;
966:
967: csi_ml_util_pvt.eliminate_dup_records;
968: csi_ml_util_pvt.eliminate_dup_subject;
969: csi_ml_util_pvt.check_cyclic;
970:
971: OPEN relations_exist_cur;
964: FND_File.Put_Line(Fnd_File.LOG,'After calling csi_ml_util_pvt.resolve_rel_ids');
965: END IF;
966:
967: csi_ml_util_pvt.eliminate_dup_records;
968: csi_ml_util_pvt.eliminate_dup_subject;
969: csi_ml_util_pvt.check_cyclic;
970:
971: OPEN relations_exist_cur;
972: FETCH relations_exist_cur INTO l_rel_dummy;
965: END IF;
966:
967: csi_ml_util_pvt.eliminate_dup_records;
968: csi_ml_util_pvt.eliminate_dup_subject;
969: csi_ml_util_pvt.check_cyclic;
970:
971: OPEN relations_exist_cur;
972: FETCH relations_exist_cur INTO l_rel_dummy;
973: IF relations_exist_cur%NOTFOUND