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_PARTY_STAGE dependencies on HZ_STAGED_PARTIES

Line 372: where object_name = 'HZ_STAGED_PARTIES' and OBJECT_TYPE = 'TABLE' and owner = l_owner1;

368: l_temp VARCHAR2(255);
369: BEGIN
370: IF (fnd_installation.GET_APP_INFO('AR',l_status,l_temp,l_owner1)) THEN
371: select owner into l_owner from sys.all_objects
372: where object_name = 'HZ_STAGED_PARTIES' and OBJECT_TYPE = 'TABLE' and owner = l_owner1;
373: END IF;
374: log('Deleting existing staged data');
375: log('Truncating HZ_STAGED_PARTIES .. ', FALSE);
376: EXECUTE IMMEDIATE 'TRUNCATE TABLE '||l_owner||'.HZ_STAGED_PARTIES';

Line 375: log('Truncating HZ_STAGED_PARTIES .. ', FALSE);

371: select owner into l_owner from sys.all_objects
372: where object_name = 'HZ_STAGED_PARTIES' and OBJECT_TYPE = 'TABLE' and owner = l_owner1;
373: END IF;
374: log('Deleting existing staged data');
375: log('Truncating HZ_STAGED_PARTIES .. ', FALSE);
376: EXECUTE IMMEDIATE 'TRUNCATE TABLE '||l_owner||'.HZ_STAGED_PARTIES';
377: log('Done');
378:
379: log('Truncating HZ_STAGED_PARTY_SITES .. ', FALSE);

Line 376: EXECUTE IMMEDIATE 'TRUNCATE TABLE '||l_owner||'.HZ_STAGED_PARTIES';

372: where object_name = 'HZ_STAGED_PARTIES' and OBJECT_TYPE = 'TABLE' and owner = l_owner1;
373: END IF;
374: log('Deleting existing staged data');
375: log('Truncating HZ_STAGED_PARTIES .. ', FALSE);
376: EXECUTE IMMEDIATE 'TRUNCATE TABLE '||l_owner||'.HZ_STAGED_PARTIES';
377: log('Done');
378:
379: log('Truncating HZ_STAGED_PARTY_SITES .. ', FALSE);
380: EXECUTE IMMEDIATE 'TRUNCATE TABLE '||l_owner||'.HZ_STAGED_PARTY_SITES';

Line 1063: AND i.INDEX_NAME = decode(a.entity_name,'PARTY','HZ_STAGED_PARTIES',

1059: FROM sys.all_indexes i, hz_trans_attributes_vl a, hz_trans_functions_vl f
1060: WHERE f.attribute_id = a.attribute_id
1061: AND i.owner = l_owner1
1062: AND f.index_required_flag in ('Y','T')
1063: AND i.INDEX_NAME = decode(a.entity_name,'PARTY','HZ_STAGED_PARTIES',
1064: 'PARTY_SITES','HZ_STAGED_PARTY_SITES','CONTACTS','HZ_STAGED_CONTACTS',
1065: 'CONTACT_POINTS','HZ_STAGED_CONTACT_POINTS')||'_N'||f.function_id) LOOP
1066: EXECUTE IMMEDIATE 'DROP INDEX '||IDX.idx_name;
1067: END LOOP;

Line 1234: SELECT decode(p_entity,'PARTY','HZ_STAGED_PARTIES',

1230: WHEN NO_DATA_FOUND THEN
1231: l_next_misc_section := l_num_primary;
1232: END;
1233:
1234: SELECT decode(p_entity,'PARTY','HZ_STAGED_PARTIES',
1235: 'PARTY_SITES','HZ_STAGED_PARTIES',
1236: 'CONTACTS','HZ_STAGED_CONTACTS',
1237: 'CONTACT_POINTS','HZ_STAGED_CONTACT_POINTS','DUMMY')
1238: INTO l_table_name

Line 1235: 'PARTY_SITES','HZ_STAGED_PARTIES',

1231: l_next_misc_section := l_num_primary;
1232: END;
1233:
1234: SELECT decode(p_entity,'PARTY','HZ_STAGED_PARTIES',
1235: 'PARTY_SITES','HZ_STAGED_PARTIES',
1236: 'CONTACTS','HZ_STAGED_CONTACTS',
1237: 'CONTACT_POINTS','HZ_STAGED_CONTACT_POINTS','DUMMY')
1238: INTO l_table_name
1239: from DUAL;

Line 1389: outandlog('The estimated disk space required for HZ_STAGED_PARTIES = ' || reco_staging_parties || 'MB' );

1385: reco_staging_contact_points := ceil(get_size('HZ_CONTACT_POINTS') * 2.0 * safety_factor);
1386: reco_index_size := 0.85 * (reco_staging_parties + reco_staging_party_sites + reco_staging_contacts + reco_staging_contact_points);
1387: reco_staging_size := reco_staging_parties + reco_staging_party_sites + reco_staging_contacts + reco_staging_contact_points + reco_index_size;
1388:
1389: outandlog('The estimated disk space required for HZ_STAGED_PARTIES = ' || reco_staging_parties || 'MB' );
1390: outandlog('The estimated disk space required for HZ_STAGED_PARTY_SITES = ' ||reco_staging_party_sites || 'MB' );
1391: outandlog('The estimated disk space required for HZ_STAGED_CONTACTS = ' ||reco_staging_contacts || 'MB' );
1392: outandlog('The estimated disk space required for HZ_STAGED_CONTACT_POINTS = ' || reco_staging_contact_points || 'MB' );
1393: outandlog('The estimated disk space required by text indexes = ' ||reco_index_size || 'MB' );

Line 1399: gather_stats(l_index_owner, 'HZ_STAGED_PARTIES');

1395: outandlog('The estimated total disk space required for staging = ' ||reco_staging_size || 'MB' );
1396: outandlog('NEWLINE');
1397: ELSIF l_command = 'ANALYZE_STAGED_TABLES' THEN
1398: outandlog('Staged tables being analyzed');
1399: gather_stats(l_index_owner, 'HZ_STAGED_PARTIES');
1400: gather_stats(l_index_owner, 'HZ_STAGED_PARTY_SITES');
1401: gather_stats(l_index_owner, 'HZ_STAGED_CONTACTS');
1402: gather_stats(l_index_owner, 'HZ_STAGED_CONTACT_POINTS');
1403: outandlog('Staged tables analyzed, End Time : '|| TO_CHAR(SYSDATE, 'MM-DD-YY HH24:MI:SS'));

Line 2163: SELECT 1 INTO T FROM HZ_STAGED_PARTIES

2159: END LOOP;
2160:
2161: l_req_id := 1;
2162: BEGIN
2163: SELECT 1 INTO T FROM HZ_STAGED_PARTIES
2164: WHERE ROWNUM=1
2165: AND CONTAINS (concat_col, 'dummy_string')>0;
2166: EXCEPTION
2167: WHEN NO_DATA_FOUND THEN

Line 3410: from hz_staged_parties;

3406: create_btree_indexes ('PARTY');
3407: BEGIN
3408: select min(party_id), max(party_id)
3409: into l_min_id, l_max_id
3410: from hz_staged_parties;
3411: WHILE (l_min_id <= l_max_id )
3412: LOOP
3413: select party_id into tmp
3414: from (

Line 3417: from hz_staged_parties

3413: select party_id into tmp
3414: from (
3415: select party_id, rownum rnum
3416: from ( SELECT party_id
3417: from hz_staged_parties
3418: where party_id>l_min_id
3419: and rownum<1001 ) a )
3420: where rnum = 1000;
3421: update hz_staged_parties set d_ps = 'SYNC', d_ct = 'SYNC', d_cpt = 'SYNC', concat_col = concat_col

Line 3421: update hz_staged_parties set d_ps = 'SYNC', d_ct = 'SYNC', d_cpt = 'SYNC', concat_col = concat_col

3417: from hz_staged_parties
3418: where party_id>l_min_id
3419: and rownum<1001 ) a )
3420: where rnum = 1000;
3421: update hz_staged_parties set d_ps = 'SYNC', d_ct = 'SYNC', d_cpt = 'SYNC', concat_col = concat_col
3422: where party_id between l_min_id and tmp;
3423: AD_CTX_DDL.sync_index(l_index_owner|| '.hz_stage_parties_t1');
3424: FND_Concurrent.af_commit;
3425: l_min_id:=tmp+1;

Line 3429: update hz_staged_parties set concat_col = concat_col,

3425: l_min_id:=tmp+1;
3426: END LOOP;
3427: EXCEPTION
3428: WHEN NO_DATA_FOUND THEN
3429: update hz_staged_parties set concat_col = concat_col,
3430: d_ps = 'SYNC', d_ct = 'SYNC', d_cpt = 'SYNC'
3431: where party_id between l_min_id and l_max_id ;
3432: AD_CTX_DDL.sync_index(l_index_owner ||'.hz_stage_parties_t1');
3433: FND_Concurrent.af_commit;

Line 3448: from hz_staged_parties;

3444: IF (new_primary_trans('PARTY')) THEN
3445: BEGIN
3446: select min(party_id), max(party_id)
3447: into l_min_id, l_max_id
3448: from hz_staged_parties;
3449: WHILE (l_min_id <= l_max_id )
3450: LOOP
3451: select party_id into tmp
3452: from (

Line 3455: from hz_staged_parties

3451: select party_id into tmp
3452: from (
3453: select party_id, rownum rnum
3454: from ( SELECT party_id
3455: from hz_staged_parties
3456: where party_id>l_min_id
3457: and rownum<1001 ) a )
3458: where rnum = 1000;
3459: update hz_staged_parties set concat_col = concat_col

Line 3459: update hz_staged_parties set concat_col = concat_col

3455: from hz_staged_parties
3456: where party_id>l_min_id
3457: and rownum<1001 ) a )
3458: where rnum = 1000;
3459: update hz_staged_parties set concat_col = concat_col
3460: where party_id between l_min_id and tmp;
3461: FND_FILE.put_line(FND_FILE.log, 'Attempting to SYNC the hz_stage_parties_t1 index');
3462: AD_CTX_DDL.sync_index(l_index_owner|| '.hz_stage_parties_t1');
3463: FND_FILE.put_line(FND_FILE.log, 'SYNC of the hz_stage_parties_t1 index successful');

Line 3469: update hz_staged_parties set concat_col = concat_col

3465: l_min_id:=tmp+1;
3466: END LOOP;
3467: EXCEPTION
3468: WHEN NO_DATA_FOUND THEN
3469: update hz_staged_parties set concat_col = concat_col
3470: where party_id between l_min_id and l_max_id ;
3471: FND_FILE.put_line(FND_FILE.log, 'Attempting to SYNC the hz_stage_parties_t1 index');
3472: AD_CTX_DDL.sync_index(l_index_owner ||'.hz_stage_parties_t1');
3473: FND_FILE.put_line(FND_FILE.log, 'SYNC of the hz_stage_parties_t1 index successful');

Line 3711: log(' Creating hz_stage_parties_t1 on hz_staged_parties.');

3707:
3708: l_section_grp := g_schema_name || '.HZ_DQM_PARTY_GRP';
3709:
3710: IF l_command <> 'STAGE_NEW_TRANSFORMATIONS' THEN
3711: log(' Creating hz_stage_parties_t1 on hz_staged_parties.');
3712: log(' Index Memory ' || p_idx_mem);
3713: log(' Starting at ' || to_char(SYSDATE, 'HH24:MI:SS') );
3714:
3715: EXECUTE IMMEDIATE 'CREATE INDEX ' || l_index_owner || '.hz_stage_parties_t1 ON ' ||l_index_owner ||

Line 3716: '.hz_staged_parties(concat_col) indextype is ctxsys.context ' ||

3712: log(' Index Memory ' || p_idx_mem);
3713: log(' Starting at ' || to_char(SYSDATE, 'HH24:MI:SS') );
3714:
3715: EXECUTE IMMEDIATE 'CREATE INDEX ' || l_index_owner || '.hz_stage_parties_t1 ON ' ||l_index_owner ||
3716: '.hz_staged_parties(concat_col) indextype is ctxsys.context ' ||
3717: 'parameters (''storage '||g_schema_name || '.HZ_DQM_STORAGE datastore '||g_schema_name || '.hz_party_ds ' ||
3718: 'SECTION GROUP '||l_section_grp||' STOPLIST CTXSYS.EMPTY_STOPLIST LEXER '||g_schema_name || '.dqm_lexer memory ' || p_idx_mem || ''')'||case when(l_parallel_degree>1) then l_parallel_str else ' '
3719: END;
3720: ELSE

Line 3721: log(' Attempting to drop and create hz_stage_parties_t1 on hz_staged_parties with new transformations.');

3717: 'parameters (''storage '||g_schema_name || '.HZ_DQM_STORAGE datastore '||g_schema_name || '.hz_party_ds ' ||
3718: 'SECTION GROUP '||l_section_grp||' STOPLIST CTXSYS.EMPTY_STOPLIST LEXER '||g_schema_name || '.dqm_lexer memory ' || p_idx_mem || ''')'||case when(l_parallel_degree>1) then l_parallel_str else ' '
3719: END;
3720: ELSE
3721: log(' Attempting to drop and create hz_stage_parties_t1 on hz_staged_parties with new transformations.');
3722: log(' Index Memory ' || p_idx_mem);
3723: log(' Starting at ' || to_char(SYSDATE, 'HH24:MI:SS') );
3724:
3725: BEGIN

Line 3735: '.hz_staged_parties(concat_col) indextype is ctxsys.context ' ||

3731: NULL;
3732:
3733: END ;
3734: EXECUTE IMMEDIATE 'CREATE INDEX ' || l_index_owner || '.hz_stage_parties_t1 ON ' ||l_index_owner ||
3735: '.hz_staged_parties(concat_col) indextype is ctxsys.context ' ||
3736: 'parameters (''storage '||g_schema_name || '.HZ_DQM_STORAGE datastore '||g_schema_name || '.hz_party_ds ' ||
3737: 'SECTION GROUP '||l_section_grp||' STOPLIST CTXSYS.EMPTY_STOPLIST LEXER '||g_schema_name || '.dqm_lexer memory ' || p_idx_mem || ''')'||case when(l_parallel_degree>1) then l_parallel_str else ' '
3738: END;
3739: log('Done creating hz_stage_parties_t1');

Line 4180: l(' UPDATE HZ_STAGED_PARTIES SET ');

4176: END LOOP;
4177:
4178: IF l_update_str IS NOT NULL THEN
4179: IF p_entity = 'PARTY' THEN
4180: l(' UPDATE HZ_STAGED_PARTIES SET ');
4181: l(' ' || l_update_str);
4182: l(' WHERE party_id = p_record_id;');
4183: ELSIF p_entity = 'PARTY_SITES' THEN
4184: l(' UPDATE HZ_STAGED_PARTY_SITES SET ');

Line 4557: l(' SELECT '||proc_cols||' FROM '||uname||'.HZ_STAGED_PARTIES WHERE ROWID=rid;');

4553: l(' RETURN NULL;');
4554: l(' END;');
4555: ELSE
4556: l(' CURSOR P IS');
4557: l(' SELECT '||proc_cols||' FROM '||uname||'.HZ_STAGED_PARTIES WHERE ROWID=rid;');
4558: l(' val CLOB;');
4559: l(' BEGIN');
4560: l(' val:=null;');
4561: l(' FOR rec in P LOOP');

Line 5359: l(' log (''Inserting Data into HZ_STAGED_PARTIES...'',FALSE); ');

5355: l(' l_en := H_P_PARTY_ID.COUNT; ');
5356: l('');
5357: l(' IF p_operation = ''C'' THEN ');
5358: l(' BEGIN ');
5359: l(' log (''Inserting Data into HZ_STAGED_PARTIES...'',FALSE); ');
5360: l(' FORALL I in l_st..l_en SAVE EXCEPTIONS ');
5361: l(' INSERT INTO HZ_STAGED_PARTIES (');
5362: l(' PARTY_ID');
5363: l(' ,STATUS');

Line 5361: l(' INSERT INTO HZ_STAGED_PARTIES (');

5357: l(' IF p_operation = ''C'' THEN ');
5358: l(' BEGIN ');
5359: l(' log (''Inserting Data into HZ_STAGED_PARTIES...'',FALSE); ');
5360: l(' FORALL I in l_st..l_en SAVE EXCEPTIONS ');
5361: l(' INSERT INTO HZ_STAGED_PARTIES (');
5362: l(' PARTY_ID');
5363: l(' ,STATUS');
5364: l(' ,D_PS');
5365: l(' ,D_CT');

Line 5414: l(' log (''Updating Data in HZ_STAGED_PARTIES...'',FALSE); ');

5410: l(' END LOOP; ');
5411: l(' END; ');
5412: l(' ELSIF p_operation = ''U'' THEN ');
5413: l(' BEGIN ');
5414: l(' log (''Updating Data in HZ_STAGED_PARTIES...'',FALSE); ');
5415: l(' FORALL I in l_st..l_en SAVE EXCEPTIONS ');
5416: l(' UPDATE HZ_STAGED_PARTIES SET ');
5417: l(' status =H_STATUS(I) ');
5418: l(' ,concat_col = concat_col ');

Line 5416: l(' UPDATE HZ_STAGED_PARTIES SET ');

5412: l(' ELSIF p_operation = ''U'' THEN ');
5413: l(' BEGIN ');
5414: l(' log (''Updating Data in HZ_STAGED_PARTIES...'',FALSE); ');
5415: l(' FORALL I in l_st..l_en SAVE EXCEPTIONS ');
5416: l(' UPDATE HZ_STAGED_PARTIES SET ');
5417: l(' status =H_STATUS(I) ');
5418: l(' ,concat_col = concat_col ');
5419:
5420: FOR I IN 1..255 LOOP

Line 5748: l(' AND NOT EXISTS (select 1 FROM HZ_STAGED_PARTIES sp ');

5744: END LOOP;
5745:
5746: l(' FROM HZ_PARTIES p, HZ_ORGANIZATION_PROFILES op ');
5747: l(' WHERE p.rowid BETWEEN p_start_rowid and p_end_rowid ');
5748: l(' AND NOT EXISTS (select 1 FROM HZ_STAGED_PARTIES sp ');
5749: l(' WHERE sp.party_id = p.party_id) ' );
5750: l(' AND p.party_id = op.party_id ');
5751: l(' AND op.effective_end_date is NULL ');
5752: l(' AND p.PARTY_TYPE =''ORGANIZATION''; ');

Line 5763: l(' AND NOT EXISTS (select 1 FROM HZ_STAGED_PARTIES sp ');

5759: END IF;
5760: END LOOP;
5761: l(' FROM HZ_PARTIES p, HZ_PERSON_PROFILES pe ');
5762: l(' WHERE p.rowid BETWEEN p_start_rowid and p_end_rowid ');
5763: l(' AND NOT EXISTS (select 1 FROM HZ_STAGED_PARTIES sp ');
5764: l(' WHERE sp.party_id = p.party_id) ' );
5765: l(' AND p.party_id = pe.party_id ');
5766: l(' AND pe.effective_end_date is NULL ');
5767: l(' AND p.PARTY_TYPE =''PERSON''; ');

Line 5778: l(' AND NOT EXISTS (select 1 FROM HZ_STAGED_PARTIES sp ');

5774: END IF;
5775: END LOOP;
5776: l(' FROM HZ_PARTIES p ');
5777: l(' WHERE p.rowid BETWEEN p_start_rowid and p_end_rowid ');
5778: l(' AND NOT EXISTS (select 1 FROM HZ_STAGED_PARTIES sp ');
5779: l(' WHERE sp.party_id = p.party_id) ' );
5780: l(' AND p.party_type <> ''PERSON'' ');
5781: l(' AND p.party_type <> ''ORGANIZATION'' ');
5782: l(' AND p.party_type <> ''PARTY_RELATIONSHIP''; ');

Line 5894: l(' INSERT INTO HZ_STAGED_PARTIES (');

5890: l(' l_en := H_P_PARTY_ID.COUNT; ');
5891: l(' LOOP ');
5892: l(' BEGIN ');
5893: l(' FORALL I in l_st..l_en');
5894: l(' INSERT INTO HZ_STAGED_PARTIES (');
5895: l(' PARTY_ID');
5896: l(' ,STATUS');
5897: FOR I IN 1..255 LOOP
5898: IF l_forall_list(I) <> 'N' THEN

Line 5924: l(' UPDATE HZ_STAGED_PARTIES SET ');

5920: l(' insert_stage_contacts;');
5921: l(' insert_stage_party_sites;');
5922: l(' insert_stage_contact_pts;');
5923: l(' FORALL I in H_P_PARTY_ID.FIRST..H_P_PARTY_ID.LAST');
5924: l(' UPDATE HZ_STAGED_PARTIES SET ');
5925: l(' D_PS = H_PS_DEN(I),');
5926: l(' D_CT = H_CT_DEN(I),');
5927: l(' D_CPT = H_CPT_DEN(I)');
5928: l(' WHERE PARTY_ID = H_P_PARTY_ID(I);');

Line 6056: l(' INSERT INTO HZ_STAGED_PARTIES (');

6052: l(' WHILE (l_tryins OR l_tryupd) LOOP');
6053: l(' IF l_tryins THEN');
6054: l(' BEGIN');
6055: l(' l_tryins:=FALSE;');
6056: l(' INSERT INTO HZ_STAGED_PARTIES (');
6057: l(' PARTY_ID');
6058: l(' ,STATUS');
6059: l(' ,D_PS');
6060: l(' ,D_CT');

Line 6089: l(' UPDATE HZ_STAGED_PARTIES SET ');

6085: l(' END IF;');
6086: l(' IF l_tryupd THEN');
6087: l(' BEGIN');
6088: l(' l_tryupd:=FALSE;');
6089: l(' UPDATE HZ_STAGED_PARTIES SET ');
6090: l(' status =H_STATUS(1) ');
6091: l(' ,concat_col = concat_col ');
6092: FOR I IN 1..255 LOOP
6093: IF l_forall_list(I) <> 'N' THEN

Line 6273: l(' INSERT INTO HZ_STAGED_PARTIES (');

6269: l(' WHILE (l_tryins OR l_tryupd) LOOP');
6270: l(' IF l_tryins THEN');
6271: l(' BEGIN');
6272: l(' l_tryins:=FALSE;');
6273: l(' INSERT INTO HZ_STAGED_PARTIES (');
6274: l(' PARTY_ID');
6275: l(' ,STATUS');
6276: l(' ,D_PS');
6277: l(' ,D_CT');

Line 6307: l(' UPDATE HZ_STAGED_PARTIES SET ');

6303: l('');
6304: l(' IF l_tryupd THEN');
6305: l(' BEGIN');
6306: l(' l_tryupd:=FALSE;');
6307: l(' UPDATE HZ_STAGED_PARTIES SET ');
6308: l(' concat_col = concat_col ');
6309: l(' ,status =H_STATUS(1) ');
6310: FOR I IN 1..255 LOOP
6311: IF l_forall_list(I) <> 'N' THEN

Line 6850: l(' -- Update HZ_STAGED_PARTIES, if corresponding child entity records ');

6846: l(' END; ');
6847: l(' END IF;');
6848: l('');
6849: l(' IF l_last_fetch THEN');
6850: l(' -- Update HZ_STAGED_PARTIES, if corresponding child entity records ');
6851: l(' -- PARTY_SITES (in this case), have been inserted/updated ');
6852: l('');
6853: l(' log (''Updating D_PS column to SYNC in HZ_STAGED_PARTIES table for all related records...'',FALSE); ');
6854: l(' --Fix for bug 5048604, to update concat_col during update of denorm column ');

Line 6853: l(' log (''Updating D_PS column to SYNC in HZ_STAGED_PARTIES table for all related records...'',FALSE); ');

6849: l(' IF l_last_fetch THEN');
6850: l(' -- Update HZ_STAGED_PARTIES, if corresponding child entity records ');
6851: l(' -- PARTY_SITES (in this case), have been inserted/updated ');
6852: l('');
6853: l(' log (''Updating D_PS column to SYNC in HZ_STAGED_PARTIES table for all related records...'',FALSE); ');
6854: l(' --Fix for bug 5048604, to update concat_col during update of denorm column ');
6855: l(' FORALL I IN H_PARTY_SITE_ID.FIRST..H_PARTY_SITE_ID.LAST ');
6856: l(' UPDATE HZ_STAGED_PARTIES set ');
6857: l(' D_PS = ''SYNC'' ');

Line 6856: l(' UPDATE HZ_STAGED_PARTIES set ');

6852: l('');
6853: l(' log (''Updating D_PS column to SYNC in HZ_STAGED_PARTIES table for all related records...'',FALSE); ');
6854: l(' --Fix for bug 5048604, to update concat_col during update of denorm column ');
6855: l(' FORALL I IN H_PARTY_SITE_ID.FIRST..H_PARTY_SITE_ID.LAST ');
6856: l(' UPDATE HZ_STAGED_PARTIES set ');
6857: l(' D_PS = ''SYNC'' ');
6858: l(' ,CONCAT_COL = CONCAT_COL ');
6859: l(' WHERE PARTY_ID = H_PS_PARTY_ID(I); ');
6860: l(' log (''Done''); ');

Line 7386: l(' UPDATE HZ_STAGED_PARTIES set ');

7382: l(' END;');
7383: l(' END IF;');
7384: l(' END LOOP;');
7385: l(' --Fix for bug 5048604, to update concat_col during update of denorm column ');
7386: l(' UPDATE HZ_STAGED_PARTIES set ');
7387: l(' D_PS = ''SYNC'' ');
7388: l(' ,CONCAT_COL = CONCAT_COL ');
7389: l(' WHERE PARTY_ID = H_PARTY_ID(1); ');
7390: l(' END;');

Line 7579: l(' UPDATE HZ_STAGED_PARTIES set');

7575: l(' END IF;');
7576: l(' END LOOP;');
7577: l('');
7578: l(' --Fix for bug 5048604, to update concat_col during update of denorm column ');
7579: l(' UPDATE HZ_STAGED_PARTIES set');
7580: l(' D_PS = ''SYNC''');
7581: l(' ,CONCAT_COL = CONCAT_COL ');
7582: l(' WHERE PARTY_ID = H_PARTY_ID(1);');
7583: l('');

Line 8159: l(' -- Update HZ_STAGED_PARTIES, if corresponding child entity records ');

8155: l(' END; ');
8156: l(' END IF;');
8157: l('');
8158: l(' IF l_last_fetch THEN');
8159: l(' -- Update HZ_STAGED_PARTIES, if corresponding child entity records ');
8160: l(' -- CONTACTS (in this case), have been inserted/updated ');
8161: l('');
8162: l(' log (''Updating D_CT column to SYNC in HZ_STAGED_PARTIES table for all related records...'',FALSE); ');
8163: l(' --Fix for bug 5048604, to update concat_col during update of denorm column ');

Line 8162: l(' log (''Updating D_CT column to SYNC in HZ_STAGED_PARTIES table for all related records...'',FALSE); ');

8158: l(' IF l_last_fetch THEN');
8159: l(' -- Update HZ_STAGED_PARTIES, if corresponding child entity records ');
8160: l(' -- CONTACTS (in this case), have been inserted/updated ');
8161: l('');
8162: l(' log (''Updating D_CT column to SYNC in HZ_STAGED_PARTIES table for all related records...'',FALSE); ');
8163: l(' --Fix for bug 5048604, to update concat_col during update of denorm column ');
8164: l(' FORALL I IN H_ORG_CONTACT_ID.FIRST..H_ORG_CONTACT_ID.LAST ');
8165: l(' UPDATE HZ_STAGED_PARTIES set ');
8166: l(' D_CT = ''SYNC'' ');

Line 8165: l(' UPDATE HZ_STAGED_PARTIES set ');

8161: l('');
8162: l(' log (''Updating D_CT column to SYNC in HZ_STAGED_PARTIES table for all related records...'',FALSE); ');
8163: l(' --Fix for bug 5048604, to update concat_col during update of denorm column ');
8164: l(' FORALL I IN H_ORG_CONTACT_ID.FIRST..H_ORG_CONTACT_ID.LAST ');
8165: l(' UPDATE HZ_STAGED_PARTIES set ');
8166: l(' D_CT = ''SYNC'' ');
8167: l(' ,CONCAT_COL = CONCAT_COL ');
8168: l(' WHERE PARTY_ID = H_C_PARTY_ID(I); ');
8169: l(' log (''Done''); ');

Line 8699: l(' UPDATE HZ_STAGED_PARTIES set');

8695: l(' END;');
8696: l(' END IF;');
8697: l(' END LOOP;');
8698: l(' --Fix for bug 5048604, to update concat_col during update of denorm column ');
8699: l(' UPDATE HZ_STAGED_PARTIES set');
8700: l(' D_CT = ''SYNC''');
8701: l(' ,CONCAT_COL = CONCAT_COL ');
8702: l(' WHERE PARTY_ID = H_PARTY_ID(1);');
8703: l(' END;');

Line 8871: l(' UPDATE HZ_STAGED_PARTIES set');

8867: l(' END IF;');
8868: l(' END LOOP;');
8869: l('');
8870: l(' --Fix for bug 5048604, to update concat_col during update of denorm column ');
8871: l(' UPDATE HZ_STAGED_PARTIES set');
8872: l(' D_CT = ''SYNC''');
8873: l(' ,CONCAT_COL = CONCAT_COL ');
8874: l(' WHERE PARTY_ID = H_PARTY_ID(1);');
8875: l('');

Line 9432: l(' -- Update HZ_STAGED_PARTIES, if corresponding child entity records ');

9428: l(' END; ');
9429: l(' END IF;');
9430: l('');
9431: l(' IF l_last_fetch THEN');
9432: l(' -- Update HZ_STAGED_PARTIES, if corresponding child entity records ');
9433: l(' -- CONTACT_POINTS (in this case), have been inserted/updated ');
9434: l('');
9435: l(' log (''Updating D_CPT column to SYNC in HZ_STAGED_PARTIES table for all related records...'',FALSE); ');
9436: l(' --Fix for bug 5048604, to update concat_col during update of denorm column ');

Line 9435: l(' log (''Updating D_CPT column to SYNC in HZ_STAGED_PARTIES table for all related records...'',FALSE); ');

9431: l(' IF l_last_fetch THEN');
9432: l(' -- Update HZ_STAGED_PARTIES, if corresponding child entity records ');
9433: l(' -- CONTACT_POINTS (in this case), have been inserted/updated ');
9434: l('');
9435: l(' log (''Updating D_CPT column to SYNC in HZ_STAGED_PARTIES table for all related records...'',FALSE); ');
9436: l(' --Fix for bug 5048604, to update concat_col during update of denorm column ');
9437: l(' FORALL I IN H_CONTACT_POINT_ID.FIRST..H_CONTACT_POINT_ID.LAST ');
9438: l(' UPDATE HZ_STAGED_PARTIES set ');
9439: l(' D_CPT = ''SYNC'' ');

Line 9438: l(' UPDATE HZ_STAGED_PARTIES set ');

9434: l('');
9435: l(' log (''Updating D_CPT column to SYNC in HZ_STAGED_PARTIES table for all related records...'',FALSE); ');
9436: l(' --Fix for bug 5048604, to update concat_col during update of denorm column ');
9437: l(' FORALL I IN H_CONTACT_POINT_ID.FIRST..H_CONTACT_POINT_ID.LAST ');
9438: l(' UPDATE HZ_STAGED_PARTIES set ');
9439: l(' D_CPT = ''SYNC'' ');
9440: l(' ,CONCAT_COL = CONCAT_COL ');
9441: l(' WHERE PARTY_ID = H_CPT_PARTY_ID(I); ');
9442: l(' log (''Done''); ');

Line 9974: l(' UPDATE HZ_STAGED_PARTIES set');

9970: l(' END;');
9971: l(' END IF;');
9972: l(' END LOOP;');
9973: l(' --Fix for bug 5048604, to update concat_col during update of denorm column ');
9974: l(' UPDATE HZ_STAGED_PARTIES set');
9975: l(' D_CPT = ''SYNC''');
9976: l(' ,CONCAT_COL = CONCAT_COL ');
9977: l(' WHERE PARTY_ID = H_PARTY_ID(1);');
9978: l(' END;');

Line 10197: l(' UPDATE HZ_STAGED_PARTIES set');

10193: l(' END IF;');
10194: l(' END LOOP;');
10195: l('');
10196: l(' --Fix for bug 5048604, to update concat_col during update of denorm column ');
10197: l(' UPDATE HZ_STAGED_PARTIES set');
10198: l(' D_CPT = ''SYNC''');
10199: l(' ,CONCAT_COL = CONCAT_COL ');
10200: l(' WHERE PARTY_ID = H_PARTY_ID(1);');
10201: l('');

Line 10358: l(' FROM HZ_STAGED_PARTIES s, HZ_PARTIES p, HZ_ORGANIZATION_PROFILES op ');

10354: FOR I in 1..l_org_select.COUNT LOOP
10355: l(' ,' || l_org_select(I));
10356: END LOOP;
10357:
10358: l(' FROM HZ_STAGED_PARTIES s, HZ_PARTIES p, HZ_ORGANIZATION_PROFILES op ');
10359: l(' WHERE s.PARTY_ID = p.PARTY_ID ');
10360: l(' AND mod(p.PARTY_ID, p_num_workers) = p_worker_number ');
10361: l(' AND p.party_id = op.party_id ');
10362: l(' AND op.effective_end_date is NULL; ');

Line 10369: l(' FROM HZ_STAGED_PARTIES s,HZ_PARTIES p, HZ_PERSON_PROFILES pe ');

10365: l(' SELECT p.PARTY_ID ');
10366: FOR I in 1..l_per_select.COUNT LOOP
10367: l(' ,' || l_per_select(I));
10368: END LOOP;
10369: l(' FROM HZ_STAGED_PARTIES s,HZ_PARTIES p, HZ_PERSON_PROFILES pe ');
10370: l(' WHERE s.PARTY_ID = p.PARTY_ID ');
10371: l(' AND mod(p.PARTY_ID, p_num_workers) = p_worker_number ');
10372: l(' AND p.party_id = pe.party_id ');
10373: l(' AND pe.effective_end_date is NULL; ');

Line 10380: l(' FROM HZ_STAGED_PARTIES s, HZ_PARTIES p ');

10376: l(' SELECT p.PARTY_ID ');
10377: FOR I in 1..l_oth_select.COUNT LOOP
10378: l(' ,' || l_oth_select(I));
10379: END LOOP;
10380: l(' FROM HZ_STAGED_PARTIES s, HZ_PARTIES p ');
10381: l(' WHERE s.PARTY_ID = p.PARTY_ID ');
10382: l(' AND mod(p.PARTY_ID, p_num_workers) = p_worker_number ');
10383: l(' AND p.party_type <> ''PERSON'' ');
10384: l(' AND p.party_type <> ''ORGANIZATION'' ');

Line 10459: l(' UPDATE HZ_STAGED_PARTIES SET ');

10455: END LOOP;
10456: l(' END LOOP;');
10457:
10458: l(' FORALL I in H_PARTY_ID.FIRST..H_PARTY_ID.LAST');
10459: l(' UPDATE HZ_STAGED_PARTIES SET ');
10460: FIRST:=TRUE;
10461: FOR I IN 1..255 LOOP
10462: IF l_forall_list(I) <> 'N' THEN
10463: IF (FIRST) THEN

Line 10709: -- ADD CODE FOR UPDATING HZ_STAGED_PARTIES IF THERE ARE ANY NEW CONTACT DENORM ATTRIBUTES

10705: END IF;
10706: END LOOP;
10707:
10708: l(' WHERE ORG_CONTACT_ID = H_ORG_CONTACT_ID(I)');
10709: -- ADD CODE FOR UPDATING HZ_STAGED_PARTIES IF THERE ARE ANY NEW CONTACT DENORM ATTRIBUTES
10710: IF get_missing_denorm_attrib_cols('CONTACTS') IS NOT NULL
10711: THEN
10712: l('RETURNING PARTY_ID, ');
10713: l(get_missing_denorm_attrib_cols('CONTACTS'));

Line 10715: -- AND UPDATE THESE PARTY IDS IN HZ_STAGED_PARTIES, BY APPENDING TO THE D_CT COLUMNS

10711: THEN
10712: l('RETURNING PARTY_ID, ');
10713: l(get_missing_denorm_attrib_cols('CONTACTS'));
10714: -- THIS BULK COLLECT WILL CHOSE THE PARTY ID COLUMNS OF THE ROWS THAT ARE UPDATED
10715: -- AND UPDATE THESE PARTY IDS IN HZ_STAGED_PARTIES, BY APPENDING TO THE D_CT COLUMNS
10716: -- VALUES FROM THE NEW DENORM ATTRIBUTE COLUMNS
10717: l('BULK COLLECT INTO H_DENORM_PARTY_ID, H_DENORM_VALUE ;');
10718: l('LOOP');
10719: l('BEGIN');

Line 10721: l(' UPDATE HZ_STAGED_PARTIES');

10717: l('BULK COLLECT INTO H_DENORM_PARTY_ID, H_DENORM_VALUE ;');
10718: l('LOOP');
10719: l('BEGIN');
10720: l(' FORALL I IN H_ROW_OFFSET..H_DENORM_PARTY_ID.COUNT');
10721: l(' UPDATE HZ_STAGED_PARTIES');
10722: l(' SET D_CT = D_CT||'' ''||H_DENORM_VALUE(I)');
10723: l(' WHERE PARTY_ID = H_DENORM_PARTY_ID(I) AND D_CT <> ''SYNC'' ;');
10724: l('EXIT ;');
10725: l('EXCEPTION');

Line 10728: l(' UPDATE HZ_STAGED_PARTIES');

10724: l('EXIT ;');
10725: l('EXCEPTION');
10726: l('WHEN OTHERS THEN');
10727: l(' H_ROW_OFFSET := H_ROW_OFFSET+SQL%ROWCOUNT;');
10728: l(' UPDATE HZ_STAGED_PARTIES');
10729: l(' SET D_CT = ''SYNC'' ');
10730: l(' WHERE PARTY_ID = H_DENORM_PARTY_ID(H_ROW_OFFSET) ;');
10731: l(' H_ROW_OFFSET := H_ROW_OFFSET+1 ;');
10732: l('END ;');

Line 10789: l(' UPDATE HZ_STAGED_PARTIES');

10785:
10786: l('LOOP');
10787: l('BEGIN');
10788: l(' FORALL I IN H_ROW_OFFSET..H_DENORM_PARTY_ID.COUNT');
10789: l(' UPDATE HZ_STAGED_PARTIES');
10790: l(' SET D_CT = D_CT||'' ''||H_DENORM_VALUE(I)');
10791: l(' WHERE PARTY_ID = H_DENORM_PARTY_ID(I) AND D_CT <> ''SYNC'' ;');
10792: l('EXIT ;');
10793: l('EXCEPTION');

Line 10796: l(' UPDATE HZ_STAGED_PARTIES');

10792: l('EXIT ;');
10793: l('EXCEPTION');
10794: l('WHEN OTHERS THEN');
10795: l(' H_ROW_OFFSET := H_ROW_OFFSET+SQL%ROWCOUNT;');
10796: l(' UPDATE HZ_STAGED_PARTIES');
10797: l(' SET D_CT = ''SYNC'' ');
10798: l(' WHERE PARTY_ID = H_DENORM_PARTY_ID(H_ROW_OFFSET) ;');
10799: l(' H_ROW_OFFSET := H_ROW_OFFSET+1 ;');
10800: l('END ;');

Line 11036: -- ADD CODE FOR UPDATING HZ_STAGED_PARTIES IF THERE ARE ANY NEW PARTY SITE DENORM ATTRIBUTES

11032: END IF;
11033: END LOOP;
11034: l(' WHERE PARTY_SITE_ID=H_PARTY_SITE_ID(I)');
11035:
11036: -- ADD CODE FOR UPDATING HZ_STAGED_PARTIES IF THERE ARE ANY NEW PARTY SITE DENORM ATTRIBUTES
11037: IF get_missing_denorm_attrib_cols('PARTY_SITES') IS NOT NULL
11038: THEN
11039: l('RETURNING PARTY_ID, ');
11040: l(get_missing_denorm_attrib_cols('PARTY_SITES'));

Line 11042: -- AND UPDATE THESE PARTY IDS IN HZ_STAGED_PARTIES, BY APPENDING TO THE D_PS COLUMNS

11038: THEN
11039: l('RETURNING PARTY_ID, ');
11040: l(get_missing_denorm_attrib_cols('PARTY_SITES'));
11041: -- THIS BULK COLLECT WILL CHOSE THE PARTY ID COLUMNS OF THE ROWS THAT ARE UPDATED
11042: -- AND UPDATE THESE PARTY IDS IN HZ_STAGED_PARTIES, BY APPENDING TO THE D_PS COLUMNS
11043: -- VALUES FROM THE NEW DENORM ATTRIBUTE COLUMNS
11044: l('BULK COLLECT INTO H_DENORM_PARTY_ID, H_DENORM_VALUE ;');
11045: l('LOOP');
11046: l('BEGIN');

Line 11048: l(' UPDATE HZ_STAGED_PARTIES');

11044: l('BULK COLLECT INTO H_DENORM_PARTY_ID, H_DENORM_VALUE ;');
11045: l('LOOP');
11046: l('BEGIN');
11047: l(' FORALL I IN H_ROW_OFFSET..H_DENORM_PARTY_ID.COUNT');
11048: l(' UPDATE HZ_STAGED_PARTIES');
11049: l(' SET D_PS = D_PS||'' ''||H_DENORM_VALUE(I)');
11050: l(' WHERE PARTY_ID = H_DENORM_PARTY_ID(I) AND D_PS <> ''SYNC'' ;');
11051: l('EXIT ;');
11052: l('EXCEPTION');

Line 11055: l(' UPDATE HZ_STAGED_PARTIES');

11051: l('EXIT ;');
11052: l('EXCEPTION');
11053: l('WHEN OTHERS THEN');
11054: l(' H_ROW_OFFSET := H_ROW_OFFSET+SQL%ROWCOUNT;');
11055: l(' UPDATE HZ_STAGED_PARTIES');
11056: l(' SET D_PS = ''SYNC'' ');
11057: l(' WHERE PARTY_ID = H_DENORM_PARTY_ID(H_ROW_OFFSET) ;');
11058: l(' H_ROW_OFFSET := H_ROW_OFFSET+1;');
11059: l('END ; ');

Line 11114: l(' UPDATE HZ_STAGED_PARTIES');

11110:
11111: l('LOOP');
11112: l('BEGIN');
11113: l(' FORALL I IN H_ROW_OFFSET..H_DENORM_PARTY_ID.COUNT');
11114: l(' UPDATE HZ_STAGED_PARTIES');
11115: l(' SET D_PS = D_PS||'' ''||H_DENORM_VALUE(I)');
11116: l(' WHERE PARTY_ID = H_DENORM_PARTY_ID(I) AND D_PS <> ''SYNC'' ;');
11117: l('EXIT ;');
11118: l('EXCEPTION');

Line 11121: l(' UPDATE HZ_STAGED_PARTIES');

11117: l('EXIT ;');
11118: l('EXCEPTION');
11119: l('WHEN OTHERS THEN');
11120: l(' H_ROW_OFFSET := H_ROW_OFFSET+SQL%ROWCOUNT;');
11121: l(' UPDATE HZ_STAGED_PARTIES');
11122: l(' SET D_PS = ''SYNC'' ');
11123: l(' WHERE PARTY_ID = H_DENORM_PARTY_ID(H_ROW_OFFSET) ;');
11124: l(' H_ROW_OFFSET := H_ROW_OFFSET+1 ;');
11125: l('END ;');

Line 11352: -- ADD CODE FOR UPDATING HZ_STAGED_PARTIES IF THERE ARE ANY NEW CONTACT POINT DENORM ATTRIBUTES

11348: END IF;
11349: END LOOP;
11350: l(' WHERE CONTACT_POINT_ID = H_CONTACT_POINT_ID(I)');
11351:
11352: -- ADD CODE FOR UPDATING HZ_STAGED_PARTIES IF THERE ARE ANY NEW CONTACT POINT DENORM ATTRIBUTES
11353: IF get_missing_denorm_attrib_cols('CONTACT_POINTS') IS NOT NULL
11354: THEN
11355: l('RETURNING PARTY_ID, ');
11356: l(get_missing_denorm_attrib_cols('CONTACT_POINTS'));

Line 11358: -- AND UPDATE THESE PARTY IDS IN HZ_STAGED_PARTIES, BY APPENDING TO THE D_CPT COLUMNS

11354: THEN
11355: l('RETURNING PARTY_ID, ');
11356: l(get_missing_denorm_attrib_cols('CONTACT_POINTS'));
11357: -- THIS BULK COLLECT WILL CHOSE THE PARTY ID COLUMNS OF THE ROWS THAT ARE UPDATED
11358: -- AND UPDATE THESE PARTY IDS IN HZ_STAGED_PARTIES, BY APPENDING TO THE D_CPT COLUMNS
11359: -- VALUES FROM THE NEW DENORM ATTRIBUTE COLUMNS
11360: l('BULK COLLECT INTO H_DENORM_PARTY_ID, H_DENORM_VALUE ;');
11361: l('LOOP');
11362: l('BEGIN');

Line 11364: l(' UPDATE HZ_STAGED_PARTIES');

11360: l('BULK COLLECT INTO H_DENORM_PARTY_ID, H_DENORM_VALUE ;');
11361: l('LOOP');
11362: l('BEGIN');
11363: l(' FORALL I IN H_ROW_OFFSET..H_DENORM_PARTY_ID.COUNT');
11364: l(' UPDATE HZ_STAGED_PARTIES');
11365: l(' SET D_CPT = D_CPT||'' ''||H_DENORM_VALUE(I)');
11366: l(' WHERE PARTY_ID = H_DENORM_PARTY_ID(I) AND D_CPT <> ''SYNC'' ;');
11367: l('EXIT ;');
11368: l('EXCEPTION');

Line 11371: l(' UPDATE HZ_STAGED_PARTIES');

11367: l('EXIT ;');
11368: l('EXCEPTION');
11369: l('WHEN OTHERS THEN');
11370: l(' H_ROW_OFFSET := H_ROW_OFFSET+SQL%ROWCOUNT;');
11371: l(' UPDATE HZ_STAGED_PARTIES');
11372: l(' SET D_CPT = ''SYNC'' ');
11373: l(' WHERE PARTY_ID = H_DENORM_PARTY_ID(H_ROW_OFFSET) ;');
11374: l(' H_ROW_OFFSET := H_ROW_OFFSET+1 ;');
11375: l('END ;');

Line 11429: l(' UPDATE HZ_STAGED_PARTIES');

11425:
11426: l('LOOP');
11427: l('BEGIN');
11428: l(' FORALL I IN H_ROW_OFFSET..H_DENORM_PARTY_ID.COUNT');
11429: l(' UPDATE HZ_STAGED_PARTIES');
11430: l(' SET D_CPT = D_CPT||'' ''||H_DENORM_VALUE(I)');
11431: l(' WHERE PARTY_ID = H_DENORM_PARTY_ID(I) AND D_CPT <> ''SYNC'' ;');
11432: l('EXIT ;');
11433: l('EXCEPTION');

Line 11436: l(' UPDATE HZ_STAGED_PARTIES');

11432: l('EXIT ;');
11433: l('EXCEPTION');
11434: l('WHEN OTHERS THEN');
11435: l(' H_ROW_OFFSET := H_ROW_OFFSET+SQL%ROWCOUNT;');
11436: l(' UPDATE HZ_STAGED_PARTIES');
11437: l(' SET D_CPT = ''SYNC'' ');
11438: l(' WHERE PARTY_ID = H_DENORM_PARTY_ID(H_ROW_OFFSET) ;');
11439: l(' H_ROW_OFFSET := H_ROW_OFFSET+1 ;');
11440: l('END ;');

Line 11464: SELECT decode(a.entity_name,'PARTY','HZ_STAGED_PARTIES',

11460: IS
11461: l_index_owner VARCHAR2(255);
11462:
11463: CURSOR indexes_reqd IS
11464: SELECT decode(a.entity_name,'PARTY','HZ_STAGED_PARTIES',
11465: 'PARTY_SITES','HZ_STAGED_PARTY_SITES','CONTACTS','HZ_STAGED_CONTACTS',
11466: 'CONTACT_POINTS','HZ_STAGED_CONTACT_POINTS')||'_N0'||substrb(staged_attribute_column,3) index_name,
11467: decode(a.entity_name,'PARTY','HZ_STAGED_PARTIES',
11468: 'PARTY_SITES','HZ_STAGED_PARTY_SITES','CONTACTS','HZ_STAGED_CONTACTS',

Line 11467: decode(a.entity_name,'PARTY','HZ_STAGED_PARTIES',

11463: CURSOR indexes_reqd IS
11464: SELECT decode(a.entity_name,'PARTY','HZ_STAGED_PARTIES',
11465: 'PARTY_SITES','HZ_STAGED_PARTY_SITES','CONTACTS','HZ_STAGED_CONTACTS',
11466: 'CONTACT_POINTS','HZ_STAGED_CONTACT_POINTS')||'_N0'||substrb(staged_attribute_column,3) index_name,
11467: decode(a.entity_name,'PARTY','HZ_STAGED_PARTIES',
11468: 'PARTY_SITES','HZ_STAGED_PARTY_SITES','CONTACTS','HZ_STAGED_CONTACTS',
11469: 'CONTACT_POINTS','HZ_STAGED_CONTACT_POINTS') table_name,
11470: decode(a.entity_name,'PARTY','HZ_SRCH_PARTIES',
11471: 'PARTY_SITES','HZ_SRCH_PSITES','CONTACTS','HZ_SRCH_CONTACTS',