DBA Data[Home] [Help]

APPS.CSI_ML_PROGRAM_PUB dependencies on CSI_II_RELATION_INTERFACE

Line 233: DELETE FROM CSI_II_RELATION_INTERFACE

229: DELETE FROM CSI_IEA_VALUE_INTERFACE
230: WHERE inst_interface_id=inst_intf_id_del(i1);
231:
232: FORALL i1 IN 1 .. inst_intf_id_del.COUNT
233: DELETE FROM CSI_II_RELATION_INTERFACE
234: WHERE subject_interface_id=inst_intf_id_del(i1)
235: AND source_system_name = nvl(p_source_system_name,source_system_name); --included for bug5949328
236:
237: FORALL i1 IN 1 .. inst_intf_id_del.COUNT

Line 238: DELETE FROM CSI_II_RELATION_INTERFACE

234: WHERE subject_interface_id=inst_intf_id_del(i1)
235: AND source_system_name = nvl(p_source_system_name,source_system_name); --included for bug5949328
236:
237: FORALL i1 IN 1 .. inst_intf_id_del.COUNT
238: DELETE FROM CSI_II_RELATION_INTERFACE
239: WHERE object_interface_id=inst_intf_id_del(i1)
240: AND source_system_name = nvl(p_source_system_name,source_system_name); --included for bug5949328
241: COMMIT;
242: EXIT WHEN purge_cur%NOTFOUND;

Line 358: FROM csi_ii_relation_interface

354:
355: -- start rel_enh
356: CURSOR relations_exist_cur IS
357: SELECT distinct parallel_worker_id
358: FROM csi_ii_relation_interface
359: WHERE process_status = 'R'
360: AND source_system_name = nvl(p_source_system_name,source_system_name) --included for bug5949328
361: AND parallel_worker_id IS NOT NULL
362: AND transaction_identifier IS NULL;

Line 449: DELETE FROM CSI_II_RELATION_INTERFACE

445: DELETE FROM CSI_IEA_VALUE_INTERFACE
446: WHERE inst_interface_id=inst_intf_id_del(i1);
447:
448: FORALL i1 IN 1 .. inst_intf_id_del.COUNT
449: DELETE FROM CSI_II_RELATION_INTERFACE
450: WHERE subject_interface_id=inst_intf_id_del(i1)
451: AND source_system_name = nvl(p_source_system_name,source_system_name); --included for bug5949328;;
452:
453: FORALL i1 IN 1 .. inst_intf_id_del.COUNT

Line 454: DELETE FROM CSI_II_RELATION_INTERFACE

450: WHERE subject_interface_id=inst_intf_id_del(i1)
451: AND source_system_name = nvl(p_source_system_name,source_system_name); --included for bug5949328;;
452:
453: FORALL i1 IN 1 .. inst_intf_id_del.COUNT
454: DELETE FROM CSI_II_RELATION_INTERFACE
455: WHERE object_interface_id=inst_intf_id_del(i1)
456: AND source_system_name = nvl(p_source_system_name,source_system_name); --included for bug5949328;;
457:
458: COMMIT;

Line 649: FROM csi_ii_relation_interface

645:
646: BEGIN
647: SELECT COUNT(*)
648: INTO l_rel_count
649: FROM csi_ii_relation_interface
650: WHERE process_status = 'R'
651: AND source_system_name = nvl(p_source_system_name,source_system_name) --included for bug5949328;
652: AND parallel_worker_id = -1;
653: EXCEPTION

Line 673: FROM csi_ii_relation_interface

669: END IF;
670:
671: SELECT ceil(count(1)/l_r_worker_count)
672: INTO x_r_count
673: FROM csi_ii_relation_interface
674: WHERE trunc(source_transaction_date) BETWEEN
675: nvl(l_txn_from_date,trunc(source_transaction_date)) AND
676: nvl(l_txn_to_date,trunc(source_transaction_date))
677: AND transaction_identifier IS NULL

Line 684: UPDATE csi_ii_relation_interface

680: AND parallel_worker_id = -1;
681:
682: FOR l_r_count IN 1 .. l_r_worker_count LOOP
683:
684: UPDATE csi_ii_relation_interface
685: SET parallel_worker_id = l_r_count
686: WHERE ROWNUM <= x_r_count
687: AND parallel_worker_id = -1
688: AND source_system_name = nvl(p_source_system_name,source_system_name)

Line 790: FROM csi_ii_relation_interface

786: -- Added for relationship interface
787: BEGIN
788: SELECT COUNT(*)
789: INTO l_rel_count
790: FROM csi_ii_relation_interface
791: WHERE process_status = 'R'
792: AND source_system_name = nvl(p_source_system_name,source_system_name); --included for bug5949328
793: -- AND parallel_worker_id = -1;
794: EXCEPTION

Line 804: FROM csi_ii_relation_interface

800: END IF;
801: BEGIN
802: SELECT COUNT(*)
803: INTO l_valid_count
804: FROM csi_ii_relation_interface
805: WHERE process_status = 'V'
806: AND source_system_name = nvl(p_source_system_name,source_system_name); --included for bug5949328
807: --AND parallel_worker_id = -1;
808:

Line 819: FROM csi_ii_relation_interface

815: END IF;
816: BEGIN
817: SELECT COUNT(*)
818: INTO l_update_count
819: FROM csi_ii_relation_interface
820: WHERE process_status = 'U'
821: AND source_system_name = nvl(p_source_system_name,source_system_name); --included for bug5949328
822: -- AND parallel_worker_id = -1;
823:

Line 836: FROM csi_ii_relation_interface

832:
833: BEGIN
834: SELECT COUNT(*)
835: INTO l_insert_count
836: FROM csi_ii_relation_interface
837: WHERE process_status = 'I'
838: AND source_system_name = nvl(p_source_system_name,source_system_name); --included for bug5949328
839: --AND parallel_worker_id = -1;
840:

Line 926: FROM csi_ii_relation_interface

922: FND_File.Put_Line(Fnd_File.LOG,'source' || p_source_system_name);
923:
924: SELECT ceil(count(1)/l_r_worker_count)
925: INTO x_r_count
926: FROM csi_ii_relation_interface
927: WHERE trunc(source_transaction_date) BETWEEN
928: nvl(l_txn_from_date,trunc(source_transaction_date)) AND
929: nvl(l_txn_to_date,trunc(source_transaction_date))
930: AND transaction_identifier IS NULL

Line 943: UPDATE csi_ii_relation_interface

939: FOR l_r_count in 1 .. l_r_worker_count
940: LOOP
941:
942: FND_File.Put_Line(Fnd_File.LOG,'updating CIRI');
943: UPDATE csi_ii_relation_interface
944: SET parallel_worker_id = l_r_count
945: WHERE ROWNUM <= x_r_count
946: AND parallel_worker_id = -1
947: AND source_system_name = nvl(p_source_system_name,source_system_name)

Line 1028: FROM csi_ii_relation_interface

1024: ELSIF l_valid_count <> 0
1025: THEN
1026: SELECT COUNT(DISTINCT(parallel_worker_id))
1027: INTO l_r_worker_count
1028: FROM csi_ii_relation_interface
1029: WHERE process_status='V'
1030: AND source_system_name = nvl(p_source_system_name,source_system_name); --included for bug5949328
1031:
1032: FOR l_count IN 1..l_r_worker_count

Line 1079: FROM csi_ii_relation_interface

1075: ELSIF l_update_count <> 0
1076: THEN
1077: SELECT COUNT(DISTINCT(parallel_worker_id))
1078: INTO l_r_worker_count
1079: FROM csi_ii_relation_interface
1080: WHERE process_status='U'
1081: AND source_system_name = nvl(p_source_system_name,source_system_name); --included for bug5949328;
1082:
1083:

Line 1131: FROM csi_ii_relation_interface

1127: ELSIF l_insert_count <> 0
1128: THEN
1129: SELECT COUNT(DISTINCT(parallel_worker_id))
1130: INTO l_r_worker_count
1131: FROM csi_ii_relation_interface
1132: WHERE process_status='I'
1133: AND source_system_name = nvl(p_source_system_name,source_system_name); --included for bug5949328;
1134:
1135: