[Home] [Help]
215: IF L_PARTY_ID.COUNT=0 AND l_last_fetch THEN
216: EXIT;
217: END IF;
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);
364: IF L_PARTY_ID.COUNT=0 AND l_last_fetch THEN
365: EXIT;
366: END IF;
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);
1337: WHERE party_id = p_from_id;
1338:
1339: IF l_party_type <> 'PARTY_RELATIONSHIP' THEN
1340: BEGIN
1341: UPDATE HZ_STAGED_PARTIES
1342: SET STATUS = 'M'
1343: WHERE party_id = p_from_id;
1344: EXCEPTION
1345: WHEN NO_DATA_FOUND THEN
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'
2044: and record_id in (select /*+ parallel_index(s) index_ffs(s) */ party_site_id from hz_staged_party_sites s );