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 641: FROM csi_ii_relation_interface

637:
638: BEGIN
639: SELECT COUNT(*)
640: INTO l_rel_count
641: FROM csi_ii_relation_interface
642: WHERE process_status = 'R'
643: AND source_system_name = nvl(p_source_system_name,source_system_name) --included for bug5949328;
644: AND parallel_worker_id = -1;
645: EXCEPTION

Line 665: FROM csi_ii_relation_interface

661: END IF;
662:
663: SELECT ceil(count(1)/l_r_worker_count)
664: INTO x_r_count
665: FROM csi_ii_relation_interface
666: WHERE trunc(source_transaction_date) BETWEEN
667: nvl(l_txn_from_date,trunc(source_transaction_date)) AND
668: nvl(l_txn_to_date,trunc(source_transaction_date))
669: AND transaction_identifier IS NULL

Line 676: UPDATE csi_ii_relation_interface

672: AND parallel_worker_id = -1;
673:
674: FOR l_r_count IN 1 .. l_r_worker_count LOOP
675:
676: UPDATE csi_ii_relation_interface
677: SET parallel_worker_id = l_r_count
678: WHERE ROWNUM <= x_r_count
679: AND parallel_worker_id = -1
680: AND source_system_name = nvl(p_source_system_name,source_system_name)

Line 782: FROM csi_ii_relation_interface

778: -- Added for relationship interface
779: BEGIN
780: SELECT COUNT(*)
781: INTO l_rel_count
782: FROM csi_ii_relation_interface
783: WHERE process_status = 'R'
784: AND source_system_name = nvl(p_source_system_name,source_system_name); --included for bug5949328
785: -- AND parallel_worker_id = -1;
786: EXCEPTION

Line 796: FROM csi_ii_relation_interface

792: END IF;
793: BEGIN
794: SELECT COUNT(*)
795: INTO l_valid_count
796: FROM csi_ii_relation_interface
797: WHERE process_status = 'V'
798: AND source_system_name = nvl(p_source_system_name,source_system_name); --included for bug5949328
799: --AND parallel_worker_id = -1;
800:

Line 811: FROM csi_ii_relation_interface

807: END IF;
808: BEGIN
809: SELECT COUNT(*)
810: INTO l_update_count
811: FROM csi_ii_relation_interface
812: WHERE process_status = 'U'
813: AND source_system_name = nvl(p_source_system_name,source_system_name); --included for bug5949328
814: -- AND parallel_worker_id = -1;
815:

Line 828: FROM csi_ii_relation_interface

824:
825: BEGIN
826: SELECT COUNT(*)
827: INTO l_insert_count
828: FROM csi_ii_relation_interface
829: WHERE process_status = 'I'
830: AND source_system_name = nvl(p_source_system_name,source_system_name); --included for bug5949328
831: --AND parallel_worker_id = -1;
832:

Line 918: FROM csi_ii_relation_interface

914: FND_File.Put_Line(Fnd_File.LOG,'source' || p_source_system_name);
915:
916: SELECT ceil(count(1)/l_r_worker_count)
917: INTO x_r_count
918: FROM csi_ii_relation_interface
919: WHERE trunc(source_transaction_date) BETWEEN
920: nvl(l_txn_from_date,trunc(source_transaction_date)) AND
921: nvl(l_txn_to_date,trunc(source_transaction_date))
922: AND transaction_identifier IS NULL

Line 935: UPDATE csi_ii_relation_interface

931: FOR l_r_count in 1 .. l_r_worker_count
932: LOOP
933:
934: FND_File.Put_Line(Fnd_File.LOG,'updating CIRI');
935: UPDATE csi_ii_relation_interface
936: SET parallel_worker_id = l_r_count
937: WHERE ROWNUM <= x_r_count
938: AND parallel_worker_id = -1
939: AND source_system_name = nvl(p_source_system_name,source_system_name)

Line 1020: FROM csi_ii_relation_interface

1016: ELSIF l_valid_count <> 0
1017: THEN
1018: SELECT COUNT(DISTINCT(parallel_worker_id))
1019: INTO l_r_worker_count
1020: FROM csi_ii_relation_interface
1021: WHERE process_status='V'
1022: AND source_system_name = nvl(p_source_system_name,source_system_name); --included for bug5949328
1023:
1024: FOR l_count IN 1..l_r_worker_count

Line 1071: FROM csi_ii_relation_interface

1067: ELSIF l_update_count <> 0
1068: THEN
1069: SELECT COUNT(DISTINCT(parallel_worker_id))
1070: INTO l_r_worker_count
1071: FROM csi_ii_relation_interface
1072: WHERE process_status='U'
1073: AND source_system_name = nvl(p_source_system_name,source_system_name); --included for bug5949328;
1074:
1075:

Line 1123: FROM csi_ii_relation_interface

1119: ELSIF l_insert_count <> 0
1120: THEN
1121: SELECT COUNT(DISTINCT(parallel_worker_id))
1122: INTO l_r_worker_count
1123: FROM csi_ii_relation_interface
1124: WHERE process_status='I'
1125: AND source_system_name = nvl(p_source_system_name,source_system_name); --included for bug5949328;
1126:
1127: