DBA Data[Home] [Help]

APPS.HZ_DQM_DUP_ID_PKG dependencies on HZ_DUP_WORKER_CHUNK_GT

Line 909: l_owner := HZ_IMP_DQM_STAGE.get_owner_name('HZ_DUP_WORKER_CHUNK_GT', 'TABLE');

905: values (-1,-1,-1,-1,chunk_limit,cnt,sysdate);
906: */
907:
908: -- truncate chunk table before inserting into it
909: l_owner := HZ_IMP_DQM_STAGE.get_owner_name('HZ_DUP_WORKER_CHUNK_GT', 'TABLE');
910: execute immediate ' truncate table ' || l_owner || '.HZ_DUP_WORKER_CHUNK_GT';
911:
912: FORALL I in start_idx..end_idx
913: INSERT INTO hz_dup_worker_chunk_gt values (pid_list(I));

Line 910: execute immediate ' truncate table ' || l_owner || '.HZ_DUP_WORKER_CHUNK_GT';

906: */
907:
908: -- truncate chunk table before inserting into it
909: l_owner := HZ_IMP_DQM_STAGE.get_owner_name('HZ_DUP_WORKER_CHUNK_GT', 'TABLE');
910: execute immediate ' truncate table ' || l_owner || '.HZ_DUP_WORKER_CHUNK_GT';
911:
912: FORALL I in start_idx..end_idx
913: INSERT INTO hz_dup_worker_chunk_gt values (pid_list(I));
914:

Line 913: INSERT INTO hz_dup_worker_chunk_gt values (pid_list(I));

909: l_owner := HZ_IMP_DQM_STAGE.get_owner_name('HZ_DUP_WORKER_CHUNK_GT', 'TABLE');
910: execute immediate ' truncate table ' || l_owner || '.HZ_DUP_WORKER_CHUNK_GT';
911:
912: FORALL I in start_idx..end_idx
913: INSERT INTO hz_dup_worker_chunk_gt values (pid_list(I));
914:
915: x_rows_in_chunk:=SQL%ROWCOUNT;
916:
917: DELETE FROM hz_dup_worker_chunk_gt WHERE

Line 917: DELETE FROM hz_dup_worker_chunk_gt WHERE

913: INSERT INTO hz_dup_worker_chunk_gt values (pid_list(I));
914:
915: x_rows_in_chunk:=SQL%ROWCOUNT;
916:
917: DELETE FROM hz_dup_worker_chunk_gt WHERE
918: EXISTS (Select 1 from HZ_DUP_RESULTS t
919: WHERE t.tid = party_id);
920: x_rows_in_chunk:=x_rows_in_chunk-SQL%ROWCOUNT;
921: start_idx:=start_idx+chunk_limit;

Line 956: l_owner := HZ_IMP_DQM_STAGE.get_owner_name('HZ_DUP_WORKER_CHUNK_GT', 'TABLE');

952: insert into hz_dup_results(fid, tid, ord_fid, ord_tid, score,chunk_num,chunk_stime)
953: values (-1,-1,-1,-1,chunk_limit,cnt,sysdate);
954: */
955: -- truncate chunk table before inserting into it
956: l_owner := HZ_IMP_DQM_STAGE.get_owner_name('HZ_DUP_WORKER_CHUNK_GT', 'TABLE');
957: execute immediate ' truncate table ' || l_owner || '.HZ_DUP_WORKER_CHUNK_GT';
958:
959: -- insert all the parties in the chunk to the temp table
960: FORALL I in 1..pid_list.COUNT

Line 957: execute immediate ' truncate table ' || l_owner || '.HZ_DUP_WORKER_CHUNK_GT';

953: values (-1,-1,-1,-1,chunk_limit,cnt,sysdate);
954: */
955: -- truncate chunk table before inserting into it
956: l_owner := HZ_IMP_DQM_STAGE.get_owner_name('HZ_DUP_WORKER_CHUNK_GT', 'TABLE');
957: execute immediate ' truncate table ' || l_owner || '.HZ_DUP_WORKER_CHUNK_GT';
958:
959: -- insert all the parties in the chunk to the temp table
960: FORALL I in 1..pid_list.COUNT
961: INSERT INTO hz_dup_worker_chunk_gt values (pid_list(I));

Line 961: INSERT INTO hz_dup_worker_chunk_gt values (pid_list(I));

957: execute immediate ' truncate table ' || l_owner || '.HZ_DUP_WORKER_CHUNK_GT';
958:
959: -- insert all the parties in the chunk to the temp table
960: FORALL I in 1..pid_list.COUNT
961: INSERT INTO hz_dup_worker_chunk_gt values (pid_list(I));
962:
963: x_rows_in_chunk:=SQL%ROWCOUNT;
964:
965: -- remove any party ids from temp table if in case

Line 971: DELETE FROM hz_dup_worker_chunk_gt WHERE

967: -- so that collision does not happen
968: -- ( for example if 1 finds 2 as a duplicate
969: -- we would like to avoid doing anything with 2, if 2 indeed happens
970: -- to be allocated to this worker )
971: DELETE FROM hz_dup_worker_chunk_gt WHERE
972: EXISTS (Select 1 from HZ_DUP_RESULTS t
973: WHERE t.tid = party_id);
974:
975: x_rows_in_chunk:=x_rows_in_chunk-SQL%ROWCOUNT;