eTRM uses javascript that opens and focuses a separate window to display reports. Your browser does not appear to support javascript. This should not prevent you from using eTRM but it does mean the window focus feature will not work. Please check the contents of other windows on your desktop if you click on a link that does not appear to do anything.

APPS.HZ_DQM_SYNC dependencies on HZ_DQM_SYNC

Line 1: PACKAGE BODY HZ_DQM_SYNC AS

1: PACKAGE BODY HZ_DQM_SYNC AS
2: /* $Header: ARHDQSNB.pls 120.56 2008/02/06 11:14:06 amstephe ship $ */
3:
4: --------------------------------------------------------------------------------
5: -- Note that when this profile option is not set, the default value is Y

Line 105: -- check if record already exists in HZ_DQM_SYNC_INTERFACE

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

Line 108: from hz_dqm_sync_interface

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;

Line 175: from hz_dqm_sync_interface a

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

Line 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

Line 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

Line 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;

Line 222: delete from hz_dqm_sync_interface

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;

Line 249: delete from hz_dqm_sync_interface

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;

Line 276: delete from hz_dqm_sync_interface

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;

Line 303: delete from hz_dqm_sync_interface

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;

Line 324: from hz_dqm_sync_interface a

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

Line 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

Line 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

Line 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;

Line 371: delete from hz_dqm_sync_interface

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;

Line 398: delete from hz_dqm_sync_interface

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;

Line 425: delete from hz_dqm_sync_interface

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;

Line 452: delete from hz_dqm_sync_interface

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;

Line 505: SELECT 1 from hz_dqm_sync_interface

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:

Line 511: SELECT 1 from hz_dqm_sync_interface

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:

Line 942: FROM HZ_DQM_SYNC_INTERFACE d

938: WHERE c.cust_account_id = p_cust_acct_id
939: AND p.party_id = c.party_id
940: AND NOT EXISTS (
941: SELECT d.PARTY_ID
942: FROM HZ_DQM_SYNC_INTERFACE d
943: WHERE d.ENTITY = 'PARTY'
944: AND d.PARTY_ID = c.PARTY_ID
945: AND d.STAGED_FLAG = 'N');
946:

Line 958: HZ_DQM_SYNC.sync_org(l_party_id,'U');

954: OPEN c_cust_party;
955: FETCH c_cust_party INTO l_party_id, l_party_type;
956: IF c_cust_party%FOUND THEN
957: IF l_party_type = 'ORGANIZATION' THEN
958: HZ_DQM_SYNC.sync_org(l_party_id,'U');
959: ELSIF l_party_type = 'PERSON' THEN
960: HZ_DQM_SYNC.sync_person(l_party_id,'U');
961: END IF;
962: END IF;

Line 960: HZ_DQM_SYNC.sync_person(l_party_id,'U');

956: IF c_cust_party%FOUND THEN
957: IF l_party_type = 'ORGANIZATION' THEN
958: HZ_DQM_SYNC.sync_org(l_party_id,'U');
959: ELSIF l_party_type = 'PERSON' THEN
960: HZ_DQM_SYNC.sync_person(l_party_id,'U');
961: END IF;
962: END IF;
963: CLOSE c_cust_party;
964: END IF;

Line 978: -- VJN added for Reporting errored records into HZ_DQM_SYNC_INTERFACE

974: FND_MSG_PUB.ADD;
975: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
976: END;
977:
978: -- VJN added for Reporting errored records into HZ_DQM_SYNC_INTERFACE
979:
980: PROCEDURE insert_error_rec (
981: p_party_id IN NUMBER,
982: p_record_id IN NUMBER,

Line 994: INSERT INTO hz_dqm_sync_interface (

990: ) IS
991:
992: BEGIN
993:
994: INSERT INTO hz_dqm_sync_interface (
995: PARTY_ID,
996: RECORD_ID,
997: PARTY_SITE_ID,
998: ORG_CONTACT_ID,

Line 1025: HZ_DQM_SYNC_INTERFACE_S.nextval

1021: hz_utility_pub.creation_date,
1022: hz_utility_pub.last_update_login,
1023: hz_utility_pub.last_update_date,
1024: hz_utility_pub.user_id,
1025: HZ_DQM_SYNC_INTERFACE_S.nextval
1026: );
1027: END insert_error_rec;
1028:
1029: -- REPURI. Bug 4884742. Added this procedure to insert data into hz_dqm_sh_sync_interface table.

Line 1127: MERGE INTO hz_dqm_sync_interface S

1123: -- REPURI. Bug 4968126.
1124: -- Using the Merge instead of Insert statement
1125: -- so that duplicate records dont get inserted.
1126:
1127: MERGE INTO hz_dqm_sync_interface S
1128: USING (
1129: SELECT
1130: p_entity AS entity
1131: ,p_party_id AS party_id

Line 1172: HZ_DQM_SYNC_INTERFACE_S.nextval

1168: hz_utility_pub.creation_date,
1169: hz_utility_pub.last_update_login,
1170: hz_utility_pub.last_update_date,
1171: hz_utility_pub.user_id,
1172: HZ_DQM_SYNC_INTERFACE_S.nextval
1173: );
1174:
1175: END insert_interface_rec;
1176:

Line 1659: update HZ_DQM_SYNC_INTERFACE set STAGED_FLAG = 'P'

1655: and rownum = 1;
1656:
1657: IF (l_dqm_run = 'Y') THEN
1658:
1659: update HZ_DQM_SYNC_INTERFACE set STAGED_FLAG = 'P'
1660: where STAGED_FLAG = 'N' and REALTIME_SYNC_FLAG = 'Y'
1661: returning party_id, record_id, entity, operation, rowid BULK COLLECT into
1662: l_party_id, l_record_id, l_entity, l_operation, l_rowid;
1663:

Line 1692: DELETE FROM hz_dqm_sync_interface WHERE rowid = l_rowid(i) ;

1688: IF (l_entity(i) <> 'PARTY') THEN
1689: insert_into_interface(l_party_id(i));
1690: END IF;
1691: IF l_operation(i) = 'C' THEN
1692: DELETE FROM hz_dqm_sync_interface WHERE rowid = l_rowid(i) ;
1693: ELSE
1694: UPDATE hz_dqm_sync_interface SET staged_flag = 'Y' WHERE rowid = l_rowid(i);
1695: END IF;
1696: EXCEPTION WHEN OTHERS THEN

Line 1694: UPDATE hz_dqm_sync_interface SET staged_flag = 'Y' WHERE rowid = l_rowid(i);

1690: END IF;
1691: IF l_operation(i) = 'C' THEN
1692: DELETE FROM hz_dqm_sync_interface WHERE rowid = l_rowid(i) ;
1693: ELSE
1694: UPDATE hz_dqm_sync_interface SET staged_flag = 'Y' WHERE rowid = l_rowid(i);
1695: END IF;
1696: EXCEPTION WHEN OTHERS THEN
1697: NULL;
1698: END;

Line 1704: UPDATE hz_dqm_sync_interface SET error_data = l_sql_error_message, staged_flag = 'E' WHERE ROWID = l_rowid(i);

1700: EXCEPTION
1701: WHEN OTHERS THEN
1702: -- update staged_flag to 'E' if program generates an error.
1703: l_sql_error_message := SQLERRM;
1704: UPDATE hz_dqm_sync_interface SET error_data = l_sql_error_message, staged_flag = 'E' WHERE ROWID = l_rowid(i);
1705: END;
1706:
1707: COMMIT;
1708: END LOOP ;

Line 1717: WF_CORE.context('HZ_DQM_SYNC', 'REALTIME_SYNC', p_event.getEventName(), p_subscription_guid);

1713: END IF;
1714: EXCEPTION
1715: when others then
1716: IF p_subscription_guid IS NOT NULL THEN
1717: WF_CORE.context('HZ_DQM_SYNC', 'REALTIME_SYNC', p_event.getEventName(), p_subscription_guid);
1718: WF_EVENT.setErrorInfo(p_event, 'ERROR');
1719: END IF;
1720: return 'ERROR';
1721:

Line 1793: FROM HZ_DQM_SYNC_GT

1789: bool varchar2(1) := 'N';
1790:
1791: BEGIN
1792: SELECT 'Y' INTO bool
1793: FROM HZ_DQM_SYNC_GT
1794: WHERE ROWNUM = 1;
1795: IF bool <> 'Y' THEN
1796: bool := 'N';
1797: END IF;

Line 1818: l_sync_party_cur HZ_DQM_SYNC.SyncCurTyp;

1814: -- as part of code changes for Sync Performance Improvement Project.
1815:
1816: l_sql_error_message VARCHAR2(2000);
1817: l_do_exec boolean := TRUE;
1818: l_sync_party_cur HZ_DQM_SYNC.SyncCurTyp;
1819: l_sync_party_site_cur HZ_DQM_SYNC.SyncCurTyp;
1820: l_sync_contact_cur HZ_DQM_SYNC.SyncCurTyp;
1821: l_sync_cpt_cur HZ_DQM_SYNC.SyncCurTyp;
1822:

Line 1819: l_sync_party_site_cur HZ_DQM_SYNC.SyncCurTyp;

1815:
1816: l_sql_error_message VARCHAR2(2000);
1817: l_do_exec boolean := TRUE;
1818: l_sync_party_cur HZ_DQM_SYNC.SyncCurTyp;
1819: l_sync_party_site_cur HZ_DQM_SYNC.SyncCurTyp;
1820: l_sync_contact_cur HZ_DQM_SYNC.SyncCurTyp;
1821: l_sync_cpt_cur HZ_DQM_SYNC.SyncCurTyp;
1822:
1823: BEGIN

Line 1820: l_sync_contact_cur HZ_DQM_SYNC.SyncCurTyp;

1816: l_sql_error_message VARCHAR2(2000);
1817: l_do_exec boolean := TRUE;
1818: l_sync_party_cur HZ_DQM_SYNC.SyncCurTyp;
1819: l_sync_party_site_cur HZ_DQM_SYNC.SyncCurTyp;
1820: l_sync_contact_cur HZ_DQM_SYNC.SyncCurTyp;
1821: l_sync_cpt_cur HZ_DQM_SYNC.SyncCurTyp;
1822:
1823: BEGIN
1824:

Line 1821: l_sync_cpt_cur HZ_DQM_SYNC.SyncCurTyp;

1817: l_do_exec boolean := TRUE;
1818: l_sync_party_cur HZ_DQM_SYNC.SyncCurTyp;
1819: l_sync_party_site_cur HZ_DQM_SYNC.SyncCurTyp;
1820: l_sync_contact_cur HZ_DQM_SYNC.SyncCurTyp;
1821: l_sync_cpt_cur HZ_DQM_SYNC.SyncCurTyp;
1822:
1823: BEGIN
1824:
1825: log(' p_from_rec = '|| p_from_rec);

Line 1938: -- Delete from from hz_dqm_sync_interface table, all the range

1934: HZ_STAGE_MAP_TRANSFORM.open_sync_cpt_cursor ('U', p_from_rec, p_to_rec, l_sync_cpt_cur);
1935: log ('Calling HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points');
1936: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('U', 'DQM_SYNC', l_sync_cpt_cur);
1937:
1938: -- Delete from from hz_dqm_sync_interface table, all the range
1939: -- of records that are already processed
1940: DELETE FROM hz_dqm_sync_interface
1941: WHERE staged_flag = 'N'
1942: AND error_data IS NULL

Line 1940: DELETE FROM hz_dqm_sync_interface

1936: HZ_STAGE_MAP_TRANSFORM.sync_all_contact_points ('U', 'DQM_SYNC', l_sync_cpt_cur);
1937:
1938: -- Delete from from hz_dqm_sync_interface table, all the range
1939: -- of records that are already processed
1940: DELETE FROM hz_dqm_sync_interface
1941: WHERE staged_flag = 'N'
1942: AND error_data IS NULL
1943: AND sync_interface_num BETWEEN p_from_rec AND p_to_rec;
1944:

Line 2037: /* Delete records from HZ_DQM_SYNC_INTERFACE table if that record already exists in staged table*/

2033: -- First Phase
2034: IF ( req_data IS NULL) THEN
2035:
2036: --Start Bug:5407223---
2037: /* Delete records from HZ_DQM_SYNC_INTERFACE table if that record already exists in staged table*/
2038: log('Start Time for delete statements = ' || TO_CHAR(SYSDATE, 'MM-DD-YY HH24:MI:SS'));
2039: delete /*+ parallel(i) */ from hz_dqm_sync_interface i where entity='PARTY' and operation='C'
2040: and party_id in (select /*+ parallel_index(s) index_ffs(s) */ party_id from hz_staged_parties s );
2041: log (' After delete duplicate party entity records, time= '||TO_CHAR(SYSDATE, 'MM-DD-YY HH24:MI:SS'));

Line 2039: delete /+ parallel(i) / from hz_dqm_sync_interface i where entity='PARTY' and operation='C'

2035:
2036: --Start Bug:5407223---
2037: /* Delete records from HZ_DQM_SYNC_INTERFACE table if that record already exists in staged table*/
2038: log('Start Time for delete statements = ' || TO_CHAR(SYSDATE, 'MM-DD-YY HH24:MI:SS'));
2039: delete /*+ parallel(i) */ from hz_dqm_sync_interface i where entity='PARTY' and operation='C'
2040: and party_id in (select /*+ parallel_index(s) index_ffs(s) */ party_id from hz_staged_parties s );
2041: log (' After delete duplicate party entity records, time= '||TO_CHAR(SYSDATE, 'MM-DD-YY HH24:MI:SS'));
2042:
2043: delete /*+ parallel(i) */ from hz_dqm_sync_interface i where entity='PARTY_SITES' and operation='C'

Line 2043: delete /+ parallel(i) / from hz_dqm_sync_interface i where entity='PARTY_SITES' and operation='C'

2039: delete /*+ parallel(i) */ from hz_dqm_sync_interface i where entity='PARTY' and operation='C'
2040: and party_id in (select /*+ parallel_index(s) index_ffs(s) */ party_id from hz_staged_parties s );
2041: log (' After delete duplicate party entity records, time= '||TO_CHAR(SYSDATE, 'MM-DD-YY HH24:MI:SS'));
2042:
2043: delete /*+ parallel(i) */ from hz_dqm_sync_interface i where entity='PARTY_SITES' and operation='C'
2044: and record_id in (select /*+ parallel_index(s) index_ffs(s) */ party_site_id from hz_staged_party_sites s );
2045: log (' After delete duplicate party site entity records '||TO_CHAR(SYSDATE, 'MM-DD-YY HH24:MI:SS') );
2046:
2047: delete /*+ parallel(i) */ from hz_dqm_sync_interface i where entity='CONTACTS' and operation='C'

Line 2047: delete /+ parallel(i) / from hz_dqm_sync_interface i where entity='CONTACTS' and operation='C'

2043: delete /*+ parallel(i) */ from hz_dqm_sync_interface i where entity='PARTY_SITES' and operation='C'
2044: and record_id in (select /*+ parallel_index(s) index_ffs(s) */ party_site_id from hz_staged_party_sites s );
2045: log (' After delete duplicate party site entity records '||TO_CHAR(SYSDATE, 'MM-DD-YY HH24:MI:SS') );
2046:
2047: delete /*+ parallel(i) */ from hz_dqm_sync_interface i where entity='CONTACTS' and operation='C'
2048: and record_id in (select /*+ parallel_index(s) index_ffs(s) */ org_contact_id from hz_staged_contacts s );
2049: log (' After delete duplicate contact entity records = '||TO_CHAR(SYSDATE, 'MM-DD-YY HH24:MI:SS') );
2050:
2051: delete /*+ parallel(i) */ from hz_dqm_sync_interface i where entity='CONTACT_POINTS' and operation='C'

Line 2051: delete /+ parallel(i) / from hz_dqm_sync_interface i where entity='CONTACT_POINTS' and operation='C'

2047: delete /*+ parallel(i) */ from hz_dqm_sync_interface i where entity='CONTACTS' and operation='C'
2048: and record_id in (select /*+ parallel_index(s) index_ffs(s) */ org_contact_id from hz_staged_contacts s );
2049: log (' After delete duplicate contact entity records = '||TO_CHAR(SYSDATE, 'MM-DD-YY HH24:MI:SS') );
2050:
2051: delete /*+ parallel(i) */ from hz_dqm_sync_interface i where entity='CONTACT_POINTS' and operation='C'
2052: and record_id in (select /*+ parallel_index(s) index_ffs(s) */ contact_point_id from hz_staged_contact_points s );
2053: log (' After delete duplicate contact point entity records = '||TO_CHAR(SYSDATE, 'MM-DD-YY HH24:MI:SS') );
2054: log('End Time for delete statements = ' || TO_CHAR(SYSDATE, 'MM-DD-YY HH24:MI:SS'));
2055:

Line 2074: FROM hz_dqm_sync_interface

2070:
2071: -- Get range if any possible optimization could be done on the number of workers to
2072: -- be deployed
2073: SELECT min(sync_interface_num), max(sync_interface_num) into l_min_id, l_max_id
2074: FROM hz_dqm_sync_interface
2075: WHERE staged_flag = 'N';
2076: l_range := l_max_id - l_min_id;
2077:
2078: IF ( l_range <= l_num_of_workers) THEN

Line 2184: HZ_DQM_SYNC.set_index_transactional(enabled=>'Y');

2180: IF(L_REALTIME_SYNC_VALUE = 'Y') THEN
2181: OPEN c_non_indexed;
2182: FETCH c_non_indexed INTO l_index_count;
2183: if(c_non_indexed%FOUND) then
2184: HZ_DQM_SYNC.set_index_transactional(enabled=>'Y');
2185: end if;
2186: CLOSE c_non_indexed;
2187: END IF;
2188: --End of Bug No : 4915282

Line 2243: l_sync_party_cur HZ_DQM_SYNC.SyncCurTyp;

2239: x_msg_data OUT NOCOPY VARCHAR2
2240: )
2241: IS
2242:
2243: l_sync_party_cur HZ_DQM_SYNC.SyncCurTyp;
2244: l_sync_party_site_cur HZ_DQM_SYNC.SyncCurTyp;
2245: l_sync_contact_cur HZ_DQM_SYNC.SyncCurTyp;
2246: l_sync_cpt_cur HZ_DQM_SYNC.SyncCurTyp;
2247:

Line 2244: l_sync_party_site_cur HZ_DQM_SYNC.SyncCurTyp;

2240: )
2241: IS
2242:
2243: l_sync_party_cur HZ_DQM_SYNC.SyncCurTyp;
2244: l_sync_party_site_cur HZ_DQM_SYNC.SyncCurTyp;
2245: l_sync_contact_cur HZ_DQM_SYNC.SyncCurTyp;
2246: l_sync_cpt_cur HZ_DQM_SYNC.SyncCurTyp;
2247:
2248: BEGIN

Line 2245: l_sync_contact_cur HZ_DQM_SYNC.SyncCurTyp;

2241: IS
2242:
2243: l_sync_party_cur HZ_DQM_SYNC.SyncCurTyp;
2244: l_sync_party_site_cur HZ_DQM_SYNC.SyncCurTyp;
2245: l_sync_contact_cur HZ_DQM_SYNC.SyncCurTyp;
2246: l_sync_cpt_cur HZ_DQM_SYNC.SyncCurTyp;
2247:
2248: BEGIN
2249: -- Part of DQM Bulk Import Sync Peformance Improvements Project (REPURI). Bug 4884735.

Line 2246: l_sync_cpt_cur HZ_DQM_SYNC.SyncCurTyp;

2242:
2243: l_sync_party_cur HZ_DQM_SYNC.SyncCurTyp;
2244: l_sync_party_site_cur HZ_DQM_SYNC.SyncCurTyp;
2245: l_sync_contact_cur HZ_DQM_SYNC.SyncCurTyp;
2246: l_sync_cpt_cur HZ_DQM_SYNC.SyncCurTyp;
2247:
2248: BEGIN
2249: -- Part of DQM Bulk Import Sync Peformance Improvements Project (REPURI). Bug 4884735.
2250:

Line 2875: END HZ_DQM_SYNC;

2871: END LOOP;
2872:
2873: END ;
2874:
2875: END HZ_DQM_SYNC;
2876: