[Home] [Help]
1: PACKAGE BODY hz_dqm_sync AS
2: /* $Header: ARHDQSNB.pls 120.57.12020000.2 2012/07/19 10:06:22 ajaising ship $ */
3:
4: --------------------------------------------------------------------------------
5: -- Note that when this profile option is not set, the default value is Y
101: PROCEDURE insert_into_interface(p_party_id IN NUMBER
102: ) IS
103: l_char NUMBER;
104: BEGIN
105: -- check if record already exists in HZ_DQM_SYNC_INTERFACE
106: BEGIN
107: select 'Y' into l_char
108: from hz_dqm_sync_interface
109: where party_id = p_party_id
104: BEGIN
105: -- check if record already exists in HZ_DQM_SYNC_INTERFACE
106: BEGIN
107: select 'Y' into l_char
108: from hz_dqm_sync_interface
109: where party_id = p_party_id
110: and entity = 'PARTY'
111: and staged_flag in ('N', 'Y')
112: and rownum = 1;
171: retcode OUT NOCOPY VARCHAR2,
172: err OUT NOCOPY VARCHAR2) IS
173:
174: cursor l_party_cur is select rowid, party_id, record_id
175: from hz_dqm_sync_interface a
176: where a.staged_flag = 'Y'
177: and a.entity = 'PARTY' AND REALTIME_SYNC_FLAG='Y';
178: cursor l_ps_cur is select rowid, party_id, record_id
179: from hz_dqm_sync_interface a
175: from hz_dqm_sync_interface a
176: where a.staged_flag = 'Y'
177: and a.entity = 'PARTY' AND REALTIME_SYNC_FLAG='Y';
178: cursor l_ps_cur is select rowid, party_id, record_id
179: from hz_dqm_sync_interface a
180: where a.staged_flag = 'Y'
181: and a.entity = 'PARTY_SITES' AND REALTIME_SYNC_FLAG='Y';
182: cursor l_ct_cur is select rowid, party_id, record_id
183: from hz_dqm_sync_interface a
179: from hz_dqm_sync_interface a
180: where a.staged_flag = 'Y'
181: and a.entity = 'PARTY_SITES' AND REALTIME_SYNC_FLAG='Y';
182: cursor l_ct_cur is select rowid, party_id, record_id
183: from hz_dqm_sync_interface a
184: where a.staged_flag = 'Y'
185: and entity = 'CONTACTS' AND REALTIME_SYNC_FLAG='Y';
186: cursor l_cp_cur is select rowid, party_id, record_id
187: from hz_dqm_sync_interface a
183: from hz_dqm_sync_interface a
184: where a.staged_flag = 'Y'
185: and entity = 'CONTACTS' AND REALTIME_SYNC_FLAG='Y';
186: cursor l_cp_cur is select rowid, party_id, record_id
187: from hz_dqm_sync_interface a
188: where a.staged_flag = 'Y'
189: and entity = 'CONTACT_POINTS' AND REALTIME_SYNC_FLAG='Y';
190:
191: l_limit NUMBER := 1000;
218: FORALL I in L_PARTY_ID.FIRST..L_PARTY_ID.LAST
219: update hz_staged_parties a set concat_col = concat_col
220: where a.party_id = L_PARTY_ID(I);
221: FORALL I in L_PARTY_ID.FIRST..L_PARTY_ID.LAST
222: delete from hz_dqm_sync_interface
223: where rowid = L_ROWID(I);
224: ad_ctx_Ddl.Sync_Index ( p_index_name );
225: IF l_last_fetch THEN
226: EXIT;
245: FORALL I in L_RECORD_ID.FIRST..L_RECORD_ID.LAST
246: update hz_staged_party_sites a set concat_col = concat_col
247: where a.party_site_id = L_RECORD_ID(I);
248: FORALL I in L_RECORD_ID.FIRST..L_RECORD_ID.LAST
249: delete from hz_dqm_sync_interface
250: where rowid = L_ROWID(I);
251: ad_ctx_Ddl.Sync_Index ( p_index_name );
252: IF l_last_fetch THEN
253: EXIT;
272: FORALL I in L_RECORD_ID.FIRST..L_RECORD_ID.LAST
273: update hz_staged_contacts a set concat_col = concat_col
274: where a.org_contact_id = L_RECORD_ID(I);
275: FORALL I in L_RECORD_ID.FIRST..L_RECORD_ID.LAST
276: delete from hz_dqm_sync_interface
277: where rowid = L_ROWID(I);
278: ad_ctx_Ddl.Sync_Index ( p_index_name );
279: IF l_last_fetch THEN
280: EXIT;
299: FORALL I in L_RECORD_ID.FIRST..L_RECORD_ID.LAST
300: update hz_staged_contact_points a set concat_col = concat_col
301: where a.contact_point_id = L_RECORD_ID(I);
302: FORALL I in L_RECORD_ID.FIRST..L_RECORD_ID.LAST
303: delete from hz_dqm_sync_interface
304: where rowid = L_ROWID(I);
305: ad_ctx_Ddl.Sync_Index ( p_index_name );
306: IF l_last_fetch THEN
307: EXIT;
320: retcode OUT NOCOPY VARCHAR2,
321: err OUT NOCOPY VARCHAR2) IS
322:
323: cursor l_party_cur is select rowid, party_id, record_id
324: from hz_dqm_sync_interface a
325: where a.staged_flag = 'Y'
326: and a.entity = 'PARTY';
327: cursor l_ps_cur is select rowid, party_id, record_id
328: from hz_dqm_sync_interface a
324: from hz_dqm_sync_interface a
325: where a.staged_flag = 'Y'
326: and a.entity = 'PARTY';
327: cursor l_ps_cur is select rowid, party_id, record_id
328: from hz_dqm_sync_interface a
329: where a.staged_flag = 'Y'
330: and a.entity = 'PARTY_SITES';
331: cursor l_ct_cur is select rowid, party_id, record_id
332: from hz_dqm_sync_interface a
328: from hz_dqm_sync_interface a
329: where a.staged_flag = 'Y'
330: and a.entity = 'PARTY_SITES';
331: cursor l_ct_cur is select rowid, party_id, record_id
332: from hz_dqm_sync_interface a
333: where a.staged_flag = 'Y'
334: and entity = 'CONTACTS' ;
335: cursor l_cp_cur is select rowid, party_id, record_id
336: from hz_dqm_sync_interface a
332: from hz_dqm_sync_interface a
333: where a.staged_flag = 'Y'
334: and entity = 'CONTACTS' ;
335: cursor l_cp_cur is select rowid, party_id, record_id
336: from hz_dqm_sync_interface a
337: where a.staged_flag = 'Y'
338: and entity = 'CONTACT_POINTS';
339:
340: l_limit NUMBER := 1000;
367: FORALL I in L_PARTY_ID.FIRST..L_PARTY_ID.LAST
368: update hz_staged_parties a set concat_col = concat_col
369: where a.party_id = L_PARTY_ID(I);
370: FORALL I in L_PARTY_ID.FIRST..L_PARTY_ID.LAST
371: delete from hz_dqm_sync_interface
372: where rowid = L_ROWID(I);
373: ad_ctx_Ddl.Sync_Index ( p_index_name );
374: IF l_last_fetch THEN
375: EXIT;
394: FORALL I in L_RECORD_ID.FIRST..L_RECORD_ID.LAST
395: update hz_staged_party_sites a set concat_col = concat_col
396: where a.party_site_id = L_RECORD_ID(I);
397: FORALL I in L_RECORD_ID.FIRST..L_RECORD_ID.LAST
398: delete from hz_dqm_sync_interface
399: where rowid = L_ROWID(I);
400: ad_ctx_Ddl.Sync_Index ( p_index_name );
401: IF l_last_fetch THEN
402: EXIT;
421: FORALL I in L_RECORD_ID.FIRST..L_RECORD_ID.LAST
422: update hz_staged_contacts a set concat_col = concat_col
423: where a.org_contact_id = L_RECORD_ID(I);
424: FORALL I in L_RECORD_ID.FIRST..L_RECORD_ID.LAST
425: delete from hz_dqm_sync_interface
426: where rowid = L_ROWID(I);
427: ad_ctx_Ddl.Sync_Index ( p_index_name );
428: IF l_last_fetch THEN
429: EXIT;
448: FORALL I in L_RECORD_ID.FIRST..L_RECORD_ID.LAST
449: update hz_staged_contact_points a set concat_col = concat_col
450: where a.contact_point_id = L_RECORD_ID(I);
451: FORALL I in L_RECORD_ID.FIRST..L_RECORD_ID.LAST
452: delete from hz_dqm_sync_interface
453: where rowid = L_ROWID(I);
454: ad_ctx_Ddl.Sync_Index ( p_index_name );
455: IF l_last_fetch THEN
456: EXIT;
501: ,p_record_id IN NUMBER
502: ,p_party_id IN NUMBER
503: ) RETURN BOOLEAN IS
504: CURSOR c_entity_sync_err (p_entity IN VARCHAR2, p_record_id IN NUMBER) IS
505: SELECT 1 from hz_dqm_sync_interface
506: WHERE entity = p_entity
507: AND record_id = p_record_id
508: AND staged_flag = 'E';
509:
507: AND record_id = p_record_id
508: AND staged_flag = 'E';
509:
510: CURSOR c_party_sync_err (p_entity IN VARCHAR2, p_party_id IN NUMBER) IS
511: SELECT 1 from hz_dqm_sync_interface
512: WHERE entity = p_entity
513: AND party_id = p_party_id
514: AND staged_flag = 'E';
515:
949: WHERE c.cust_account_id = p_cust_acct_id
950: AND p.party_id = c.party_id
951: AND NOT EXISTS (
952: SELECT d.PARTY_ID
953: FROM HZ_DQM_SYNC_INTERFACE d
954: WHERE d.ENTITY = 'PARTY'
955: AND d.PARTY_ID = c.PARTY_ID
956: AND d.STAGED_FLAG = 'N');
957:
965: OPEN c_cust_party;
966: FETCH c_cust_party INTO l_party_id, l_party_type;
967: IF c_cust_party%FOUND THEN
968: IF l_party_type = 'ORGANIZATION' THEN
969: HZ_DQM_SYNC.sync_org(l_party_id,'U');
970: ELSIF l_party_type = 'PERSON' THEN
971: HZ_DQM_SYNC.sync_person(l_party_id,'U');
972: END IF;
973: END IF;
967: IF c_cust_party%FOUND THEN
968: IF l_party_type = 'ORGANIZATION' THEN
969: HZ_DQM_SYNC.sync_org(l_party_id,'U');
970: ELSIF l_party_type = 'PERSON' THEN
971: HZ_DQM_SYNC.sync_person(l_party_id,'U');
972: END IF;
973: END IF;
974: CLOSE c_cust_party;
975: END IF;
985: FND_MSG_PUB.ADD;
986: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
987: END;
988:
989: -- VJN added for Reporting errored records into HZ_DQM_SYNC_INTERFACE
990:
991: PROCEDURE insert_error_rec (
992: p_party_id IN NUMBER,
993: p_record_id IN NUMBER,
1001: ) IS
1002:
1003: BEGIN
1004:
1005: INSERT INTO hz_dqm_sync_interface (
1006: PARTY_ID,
1007: RECORD_ID,
1008: PARTY_SITE_ID,
1009: ORG_CONTACT_ID,
1032: hz_utility_pub.creation_date,
1033: hz_utility_pub.last_update_login,
1034: hz_utility_pub.last_update_date,
1035: hz_utility_pub.user_id,
1036: HZ_DQM_SYNC_INTERFACE_S.nextval
1037: );
1038: END insert_error_rec;
1039:
1040: -- REPURI. Bug 4884742. Added this procedure to insert data into hz_dqm_sh_sync_interface table.
1133:
1134: --Bug 13810656 Logic for handling the Delete Operation
1135: IF (p_operation = 'D') THEN
1136:
1137: INSERT INTO HZ_DQM_SYNC_INTERFACE(
1138: PARTY_ID,
1139: RECORD_ID,
1140: PARTY_SITE_ID,
1141: ORG_CONTACT_ID,
1162: hz_utility_pub.creation_date,
1163: hz_utility_pub.last_update_login,
1164: hz_utility_pub.last_update_date,
1165: hz_utility_pub.user_id,
1166: HZ_DQM_SYNC_INTERFACE_S.nextval
1167: );
1168:
1169: ELSE
1170:
1170:
1171: -- REPURI. Bug 4968126.
1172: -- Using the Merge instead of Insert statement
1173: -- so that duplicate records dont get inserted.
1174: MERGE INTO hz_dqm_sync_interface S
1175: USING (
1176: SELECT
1177: p_entity AS entity
1178: ,p_party_id AS party_id
1216: hz_utility_pub.creation_date,
1217: hz_utility_pub.last_update_login,
1218: hz_utility_pub.last_update_date,
1219: hz_utility_pub.user_id,
1220: HZ_DQM_SYNC_INTERFACE_S.nextval
1221: );
1222:
1223: END IF;
1224:
1548: NULL;
1549: END;
1550: ELSIF ( L_REALTIME_SYNC_VALUE = 'N') THEN--Bug 13810656 Deferring the delete of from contact_point_id for Merge flow
1551: BEGIN
1552: DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE STAGED_FLAG='N'
1553: AND RECORD_ID=p_from_id AND ENTITY='CONTACT_POINTS';
1554: EXCEPTION
1555: WHEN NO_DATA_FOUND THEN
1556: NULL;
1774: and rownum = 1;
1775:
1776: IF (l_dqm_run = 'Y') THEN
1777:
1778: update HZ_DQM_SYNC_INTERFACE set STAGED_FLAG = 'P'
1779: where STAGED_FLAG = 'N' and REALTIME_SYNC_FLAG = 'Y'
1780: returning party_id, record_id, entity, operation, rowid BULK COLLECT into
1781: l_party_id, l_record_id, l_entity, l_operation, l_rowid;
1782:
1807: IF (l_entity(i) <> 'PARTY') THEN
1808: insert_into_interface(l_party_id(i));
1809: END IF;
1810: IF l_operation(i) = 'C' THEN
1811: DELETE FROM hz_dqm_sync_interface WHERE rowid = l_rowid(i) ;
1812: ELSE
1813: UPDATE hz_dqm_sync_interface SET staged_flag = 'Y' WHERE rowid = l_rowid(i);
1814: END IF;
1815: EXCEPTION WHEN OTHERS THEN
1809: END IF;
1810: IF l_operation(i) = 'C' THEN
1811: DELETE FROM hz_dqm_sync_interface WHERE rowid = l_rowid(i) ;
1812: ELSE
1813: UPDATE hz_dqm_sync_interface SET staged_flag = 'Y' WHERE rowid = l_rowid(i);
1814: END IF;
1815: EXCEPTION WHEN OTHERS THEN
1816: NULL;
1817: END;
1819: EXCEPTION
1820: WHEN OTHERS THEN
1821: -- update staged_flag to 'E' if program generates an error.
1822: l_sql_error_message := SQLERRM;
1823: UPDATE hz_dqm_sync_interface SET error_data = l_sql_error_message, staged_flag = 'E' WHERE ROWID = l_rowid(i);
1824: END;
1825:
1826: COMMIT;
1827: END LOOP ;
1832: END IF;
1833: EXCEPTION
1834: when others then
1835: IF p_subscription_guid IS NOT NULL THEN
1836: WF_CORE.context('HZ_DQM_SYNC', 'REALTIME_SYNC', p_event.getEventName(), p_subscription_guid);
1837: WF_EVENT.setErrorInfo(p_event, 'ERROR');
1838: END IF;
1839: return 'ERROR';
1840:
1908: bool varchar2(1) := 'N';
1909:
1910: BEGIN
1911: SELECT 'Y' INTO bool
1912: FROM HZ_DQM_SYNC_GT
1913: WHERE ROWNUM = 1;
1914: IF bool <> 'Y' THEN
1915: bool := 'N';
1916: END IF;
1933: -- as part of code changes for Sync Performance Improvement Project.
1934:
1935: l_sql_error_message VARCHAR2(2000);
1936: l_do_exec boolean := TRUE;
1937: l_sync_party_cur HZ_DQM_SYNC.SyncCurTyp;
1938: l_sync_party_site_cur HZ_DQM_SYNC.SyncCurTyp;
1939: l_sync_contact_cur HZ_DQM_SYNC.SyncCurTyp;
1940: l_sync_cpt_cur HZ_DQM_SYNC.SyncCurTyp;
1941:
1934:
1935: l_sql_error_message VARCHAR2(2000);
1936: l_do_exec boolean := TRUE;
1937: l_sync_party_cur HZ_DQM_SYNC.SyncCurTyp;
1938: l_sync_party_site_cur HZ_DQM_SYNC.SyncCurTyp;
1939: l_sync_contact_cur HZ_DQM_SYNC.SyncCurTyp;
1940: l_sync_cpt_cur HZ_DQM_SYNC.SyncCurTyp;
1941:
1942: BEGIN
1935: l_sql_error_message VARCHAR2(2000);
1936: l_do_exec boolean := TRUE;
1937: l_sync_party_cur HZ_DQM_SYNC.SyncCurTyp;
1938: l_sync_party_site_cur HZ_DQM_SYNC.SyncCurTyp;
1939: l_sync_contact_cur HZ_DQM_SYNC.SyncCurTyp;
1940: l_sync_cpt_cur HZ_DQM_SYNC.SyncCurTyp;
1941:
1942: BEGIN
1943:
1936: l_do_exec boolean := TRUE;
1937: l_sync_party_cur HZ_DQM_SYNC.SyncCurTyp;
1938: l_sync_party_site_cur HZ_DQM_SYNC.SyncCurTyp;
1939: l_sync_contact_cur HZ_DQM_SYNC.SyncCurTyp;
1940: l_sync_cpt_cur HZ_DQM_SYNC.SyncCurTyp;
1941:
1942: BEGIN
1943:
1944: log(' p_from_rec = '|| p_from_rec);
2053: HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor ('U', p_from_rec, p_to_rec, l_sync_cpt_cur);
2054: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points');
2055: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('U', 'DQM_SYNC', l_sync_cpt_cur);
2056:
2057: -- Delete from from hz_dqm_sync_interface table, all the range
2058: -- of records that are already processed
2059: DELETE FROM hz_dqm_sync_interface
2060: WHERE staged_flag = 'N'
2061: AND error_data IS NULL
2055: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('U', 'DQM_SYNC', l_sync_cpt_cur);
2056:
2057: -- Delete from from hz_dqm_sync_interface table, all the range
2058: -- of records that are already processed
2059: DELETE FROM hz_dqm_sync_interface
2060: WHERE staged_flag = 'N'
2061: AND error_data IS NULL
2062: AND sync_interface_num BETWEEN p_from_rec AND p_to_rec;
2063:
2156:
2157:
2158: /* Code for handling the records with operation 'D' Flag*/
2159:
2160: FOR I in (SELECT PARTY_ID,RECORD_ID,ENTITY FROM HZ_DQM_SYNC_INTERFACE WHERE OPERATION='D' AND STAGED_FLAG='N')
2161: LOOP
2162:
2163: IF (I.ENTITY='PARTY')
2164: THEN
2210:
2211: /* Code for handling the records with operation 'D' Flag*/
2212:
2213: --Start Bug:5407223---
2214: /* Delete records from HZ_DQM_SYNC_INTERFACE table if that record already exists in staged table*/
2215: log('Start Time for delete statements = ' || TO_CHAR(SYSDATE, 'MM-DD-YY HH24:MI:SS'));
2216: delete /*+ parallel(i) */ from hz_dqm_sync_interface i where entity='PARTY' and operation='C'
2217: and party_id in (select /*+ parallel_index(s) index_ffs(s) */ party_id from hz_staged_parties s );
2218: log (' After delete duplicate party entity records, time= '||TO_CHAR(SYSDATE, 'MM-DD-YY HH24:MI:SS'));
2212:
2213: --Start Bug:5407223---
2214: /* Delete records from HZ_DQM_SYNC_INTERFACE table if that record already exists in staged table*/
2215: log('Start Time for delete statements = ' || TO_CHAR(SYSDATE, 'MM-DD-YY HH24:MI:SS'));
2216: delete /*+ parallel(i) */ from hz_dqm_sync_interface i where entity='PARTY' and operation='C'
2217: and party_id in (select /*+ parallel_index(s) index_ffs(s) */ party_id from hz_staged_parties s );
2218: log (' After delete duplicate party entity records, time= '||TO_CHAR(SYSDATE, 'MM-DD-YY HH24:MI:SS'));
2219:
2220: delete /*+ parallel(i) */ from hz_dqm_sync_interface i where entity='PARTY_SITES' and operation='C'
2216: delete /*+ parallel(i) */ from hz_dqm_sync_interface i where entity='PARTY' and operation='C'
2217: and party_id in (select /*+ parallel_index(s) index_ffs(s) */ party_id from hz_staged_parties s );
2218: log (' After delete duplicate party entity records, time= '||TO_CHAR(SYSDATE, 'MM-DD-YY HH24:MI:SS'));
2219:
2220: delete /*+ parallel(i) */ from hz_dqm_sync_interface i where entity='PARTY_SITES' and operation='C'
2221: and record_id in (select /*+ parallel_index(s) index_ffs(s) */ party_site_id from hz_staged_party_sites s );
2222: log (' After delete duplicate party site entity records '||TO_CHAR(SYSDATE, 'MM-DD-YY HH24:MI:SS') );
2223:
2224: delete /*+ parallel(i) */ from hz_dqm_sync_interface i where entity='CONTACTS' and operation='C'
2220: delete /*+ parallel(i) */ from hz_dqm_sync_interface i where entity='PARTY_SITES' and operation='C'
2221: and record_id in (select /*+ parallel_index(s) index_ffs(s) */ party_site_id from hz_staged_party_sites s );
2222: log (' After delete duplicate party site entity records '||TO_CHAR(SYSDATE, 'MM-DD-YY HH24:MI:SS') );
2223:
2224: delete /*+ parallel(i) */ from hz_dqm_sync_interface i where entity='CONTACTS' and operation='C'
2225: and record_id in (select /*+ parallel_index(s) index_ffs(s) */ org_contact_id from hz_staged_contacts s );
2226: log (' After delete duplicate contact entity records = '||TO_CHAR(SYSDATE, 'MM-DD-YY HH24:MI:SS') );
2227:
2228: delete /*+ parallel(i) */ from hz_dqm_sync_interface i where entity='CONTACT_POINTS' and operation='C'
2224: delete /*+ parallel(i) */ from hz_dqm_sync_interface i where entity='CONTACTS' and operation='C'
2225: and record_id in (select /*+ parallel_index(s) index_ffs(s) */ org_contact_id from hz_staged_contacts s );
2226: log (' After delete duplicate contact entity records = '||TO_CHAR(SYSDATE, 'MM-DD-YY HH24:MI:SS') );
2227:
2228: delete /*+ parallel(i) */ from hz_dqm_sync_interface i where entity='CONTACT_POINTS' and operation='C'
2229: and record_id in (select /*+ parallel_index(s) index_ffs(s) */ contact_point_id from hz_staged_contact_points s );
2230: log (' After delete duplicate contact point entity records = '||TO_CHAR(SYSDATE, 'MM-DD-YY HH24:MI:SS') );
2231: log('End Time for delete statements = ' || TO_CHAR(SYSDATE, 'MM-DD-YY HH24:MI:SS'));
2232:
2249:
2250: -- Get range if any possible optimization could be done on the number of workers to
2251: -- be deployed
2252: SELECT min(sync_interface_num), max(sync_interface_num) into l_min_id, l_max_id
2253: FROM hz_dqm_sync_interface
2254: WHERE staged_flag = 'N';
2255: l_range := l_max_id - l_min_id;
2256:
2257: IF ( l_range <= l_num_of_workers) THEN
2359: IF(L_REALTIME_SYNC_VALUE = 'Y') THEN
2360: OPEN c_non_indexed;
2361: FETCH c_non_indexed INTO l_index_count;
2362: if(c_non_indexed%FOUND) then
2363: HZ_DQM_SYNC.set_index_transactional(enabled=>'Y');
2364: end if;
2365: CLOSE c_non_indexed;
2366: END IF;
2367: --End of Bug No : 4915282
2418: x_msg_data OUT NOCOPY VARCHAR2
2419: )
2420: IS
2421:
2422: l_sync_party_cur HZ_DQM_SYNC.SyncCurTyp;
2423: l_sync_party_site_cur HZ_DQM_SYNC.SyncCurTyp;
2424: l_sync_contact_cur HZ_DQM_SYNC.SyncCurTyp;
2425: l_sync_cpt_cur HZ_DQM_SYNC.SyncCurTyp;
2426:
2419: )
2420: IS
2421:
2422: l_sync_party_cur HZ_DQM_SYNC.SyncCurTyp;
2423: l_sync_party_site_cur HZ_DQM_SYNC.SyncCurTyp;
2424: l_sync_contact_cur HZ_DQM_SYNC.SyncCurTyp;
2425: l_sync_cpt_cur HZ_DQM_SYNC.SyncCurTyp;
2426:
2427: BEGIN
2420: IS
2421:
2422: l_sync_party_cur HZ_DQM_SYNC.SyncCurTyp;
2423: l_sync_party_site_cur HZ_DQM_SYNC.SyncCurTyp;
2424: l_sync_contact_cur HZ_DQM_SYNC.SyncCurTyp;
2425: l_sync_cpt_cur HZ_DQM_SYNC.SyncCurTyp;
2426:
2427: BEGIN
2428: -- Part of DQM Bulk Import Sync Peformance Improvements Project (REPURI). Bug 4884735.
2421:
2422: l_sync_party_cur HZ_DQM_SYNC.SyncCurTyp;
2423: l_sync_party_site_cur HZ_DQM_SYNC.SyncCurTyp;
2424: l_sync_contact_cur HZ_DQM_SYNC.SyncCurTyp;
2425: l_sync_cpt_cur HZ_DQM_SYNC.SyncCurTyp;
2426:
2427: BEGIN
2428: -- Part of DQM Bulk Import Sync Peformance Improvements Project (REPURI). Bug 4884735.
2429:
3050: END LOOP;
3051:
3052: END ;
3053:
3054: END HZ_DQM_SYNC;
3055: