DBA Data[Home] [Help]

APPS.HZ_PARTY_STAGE dependencies on HZ_STAGED_CONTACT_POINTS

Line 185: and b.staged_attribute_table = 'HZ_STAGED_CONTACT_POINTS'

181: where a.entity_name = 'CONTACT_POINTS'
182: and nvl(a.denorm_flag,'N') = 'Y'
183: and a.attribute_id = b.attribute_id
184: and nvl( b.active_flag, 'Y') = 'Y'
185: and b.staged_attribute_table = 'HZ_STAGED_CONTACT_POINTS'
186: )
187: LOOP
188: row_count := row_count + 1 ;
189: IF row_count > 1

Line 315: and b.staged_attribute_table = 'HZ_STAGED_CONTACT_POINTS'

311: where a.entity_name = 'CONTACT_POINTS'
312: and nvl(a.denorm_flag,'N') = 'Y'
313: and a.attribute_id = b.attribute_id
314: and nvl( b.active_flag, 'Y') = 'Y'
315: and b.staged_attribute_table = 'HZ_STAGED_CONTACT_POINTS'
316:
317: )
318: LOOP
319: -- if any attribute columns do not exist in the preference

Line 387: log('Truncating HZ_STAGED_CONTACT_POINTS .. ', FALSE);

383: log('Truncating HZ_STAGED_CONTACTS .. ', FALSE);
384: EXECUTE IMMEDIATE 'TRUNCATE TABLE '||l_owner||'.HZ_STAGED_CONTACTS';
385: log('Done');
386:
387: log('Truncating HZ_STAGED_CONTACT_POINTS .. ', FALSE);
388: EXECUTE IMMEDIATE 'TRUNCATE TABLE '||l_owner||'.HZ_STAGED_CONTACT_POINTS';
389: log('Done');
390:
391: log('Attempting to truncate HZ_DQM_SYNC_INTERFACE ..',FALSE);

Line 388: EXECUTE IMMEDIATE 'TRUNCATE TABLE '||l_owner||'.HZ_STAGED_CONTACT_POINTS';

384: EXECUTE IMMEDIATE 'TRUNCATE TABLE '||l_owner||'.HZ_STAGED_CONTACTS';
385: log('Done');
386:
387: log('Truncating HZ_STAGED_CONTACT_POINTS .. ', FALSE);
388: EXECUTE IMMEDIATE 'TRUNCATE TABLE '||l_owner||'.HZ_STAGED_CONTACT_POINTS';
389: log('Done');
390:
391: log('Attempting to truncate HZ_DQM_SYNC_INTERFACE ..',FALSE);
392: BEGIN

Line 1053: 'CONTACT_POINTS','HZ_STAGED_CONTACT_POINTS')||'_N'||f.function_id) LOOP

1049: AND i.owner = l_owner1
1050: AND f.index_required_flag in ('Y','T')
1051: AND i.INDEX_NAME = decode(a.entity_name,'PARTY','HZ_STAGED_PARTIES',
1052: 'PARTY_SITES','HZ_STAGED_PARTY_SITES','CONTACTS','HZ_STAGED_CONTACTS',
1053: 'CONTACT_POINTS','HZ_STAGED_CONTACT_POINTS')||'_N'||f.function_id) LOOP
1054: EXECUTE IMMEDIATE 'DROP INDEX '||IDX.idx_name;
1055: END LOOP;
1056: UPDATE hz_trans_functions_b set index_required_flag='N' where index_required_flag='T';
1057: END IF;

Line 1225: 'CONTACT_POINTS','HZ_STAGED_CONTACT_POINTS','DUMMY')

1221:
1222: SELECT decode(p_entity,'PARTY','HZ_STAGED_PARTIES',
1223: 'PARTY_SITES','HZ_STAGED_PARTIES',
1224: 'CONTACTS','HZ_STAGED_CONTACTS',
1225: 'CONTACT_POINTS','HZ_STAGED_CONTACT_POINTS','DUMMY')
1226: INTO l_table_name
1227: from DUAL;
1228:
1229: -- See if the intermedia index on the corresponding staging table for the entity

Line 1380: outandlog('The estimated disk space required for HZ_STAGED_CONTACT_POINTS = ' || reco_staging_contact_points || 'MB' );

1376:
1377: outandlog('The estimated disk space required for HZ_STAGED_PARTIES = ' || reco_staging_parties || 'MB' );
1378: outandlog('The estimated disk space required for HZ_STAGED_PARTY_SITES = ' ||reco_staging_party_sites || 'MB' );
1379: outandlog('The estimated disk space required for HZ_STAGED_CONTACTS = ' ||reco_staging_contacts || 'MB' );
1380: outandlog('The estimated disk space required for HZ_STAGED_CONTACT_POINTS = ' || reco_staging_contact_points || 'MB' );
1381: outandlog('The estimated disk space required by text indexes = ' ||reco_index_size || 'MB' );
1382: outandlog(' ');
1383: outandlog('The estimated total disk space required for staging = ' ||reco_staging_size || 'MB' );
1384: outandlog('NEWLINE');

Line 1390: gather_stats(l_index_owner, 'HZ_STAGED_CONTACT_POINTS');

1386: outandlog('Staged tables being analyzed');
1387: gather_stats(l_index_owner, 'HZ_STAGED_PARTIES');
1388: gather_stats(l_index_owner, 'HZ_STAGED_PARTY_SITES');
1389: gather_stats(l_index_owner, 'HZ_STAGED_CONTACTS');
1390: gather_stats(l_index_owner, 'HZ_STAGED_CONTACT_POINTS');
1391: outandlog('Staged tables analyzed, End Time : '|| TO_CHAR(SYSDATE, 'MM-DD-YY HH24:MI:SS'));
1392: END IF;
1393:
1394: IF l_command = 'STAGE_NEW_DENORM' THEN

Line 2262: SELECT 1 INTO T FROM HZ_STAGED_CONTACT_POINTS

2258: END IF;
2259: END;
2260:
2261: BEGIN
2262: SELECT 1 INTO T FROM HZ_STAGED_CONTACT_POINTS
2263: WHERE ROWNUM=1
2264: AND CONTAINS (concat_col, 'dummy_string')>0;
2265: EXCEPTION
2266: WHEN NO_DATA_FOUND THEN

Line 3471: from hz_staged_contact_points;

3467: IF (new_primary_trans('CONTACT_POINTS')) THEN
3468: BEGIN
3469: select min(contact_point_id), max(contact_point_id)
3470: into l_min_id, l_max_id
3471: from hz_staged_contact_points;
3472: WHILE (l_min_id <= l_max_id )
3473: LOOP
3474: select contact_point_id into tmp
3475: from (

Line 3478: from hz_staged_contact_points

3474: select contact_point_id into tmp
3475: from (
3476: select contact_point_id, rownum rnum
3477: from ( SELECT contact_point_id
3478: from hz_staged_contact_points
3479: where contact_point_id > l_min_id
3480: and rownum<1001 ) a )
3481: where rnum = 1000;
3482: update hz_staged_contact_points set concat_col = concat_col

Line 3482: update hz_staged_contact_points set concat_col = concat_col

3478: from hz_staged_contact_points
3479: where contact_point_id > l_min_id
3480: and rownum<1001 ) a )
3481: where rnum = 1000;
3482: update hz_staged_contact_points set concat_col = concat_col
3483: where contact_point_id between l_min_id and tmp;
3484: FND_FILE.put_line(FND_FILE.log, 'Attempting to SYNC the hz_stage_cpt_t1 index');
3485: AD_CTX_DDL.sync_index(l_index_owner||'.hz_stage_cpt_t1');
3486: FND_FILE.put_line(FND_FILE.log, 'SYNC of the hz_stage_cpt_t1 index successful');

Line 3492: update hz_staged_contact_points set concat_col = concat_col

3488: l_min_id:=tmp+1;
3489: END LOOP;
3490: EXCEPTION
3491: WHEN NO_DATA_FOUND THEN
3492: update hz_staged_contact_points set concat_col = concat_col
3493: where contact_point_id between l_min_id and l_max_id ;
3494: FND_FILE.put_line(FND_FILE.log, 'Attempting to SYNC the hz_stage_cpt_t1 index');
3495: AD_CTX_DDL.sync_index(l_index_owner||'.hz_stage_cpt_t1');
3496: FND_FILE.put_line(FND_FILE.log, 'SYNC of the hz_stage_cpt_t1 index successful');

Line 3874: log(' Creating hz_stage_cpt_t1 on hz_staged_contact_points. ');

3870:
3871: l_section_grp := g_schema_name || '.HZ_DQM_CPT_GRP';
3872:
3873: IF l_command <> 'STAGE_NEW_TRANSFORMATIONS' THEN
3874: log(' Creating hz_stage_cpt_t1 on hz_staged_contact_points. ');
3875: log(' Index Memory ' || p_idx_mem);
3876: log(' Starting at ' || to_char(SYSDATE, 'HH24:MI:SS'));
3877:
3878: EXECUTE IMMEDIATE 'CREATE INDEX ' || l_index_owner || '.hz_stage_cpt_t1 ON ' ||

Line 3879: 'hz_staged_contact_points(concat_col) indextype is ctxsys.context ' ||

3875: log(' Index Memory ' || p_idx_mem);
3876: log(' Starting at ' || to_char(SYSDATE, 'HH24:MI:SS'));
3877:
3878: EXECUTE IMMEDIATE 'CREATE INDEX ' || l_index_owner || '.hz_stage_cpt_t1 ON ' ||
3879: 'hz_staged_contact_points(concat_col) indextype is ctxsys.context ' ||
3880: 'parameters (''storage '||g_schema_name || '.HZ_DQM_STORAGE datastore '||g_schema_name || '.hz_contact_point_ds ' ||
3881: 'SECTION GROUP '||l_section_grp||' STOPLIST CTXSYS.EMPTY_STOPLIST LEXER '||g_schema_name || '.dqm_lexer memory ' || p_idx_mem || ''')';
3882: ELSE
3883: log(' Attempting to drop and create hz_stage_cpt_t1 on hz_staged_contact_points with new transformations.');

Line 3883: log(' Attempting to drop and create hz_stage_cpt_t1 on hz_staged_contact_points with new transformations.');

3879: 'hz_staged_contact_points(concat_col) indextype is ctxsys.context ' ||
3880: 'parameters (''storage '||g_schema_name || '.HZ_DQM_STORAGE datastore '||g_schema_name || '.hz_contact_point_ds ' ||
3881: 'SECTION GROUP '||l_section_grp||' STOPLIST CTXSYS.EMPTY_STOPLIST LEXER '||g_schema_name || '.dqm_lexer memory ' || p_idx_mem || ''')';
3882: ELSE
3883: log(' Attempting to drop and create hz_stage_cpt_t1 on hz_staged_contact_points with new transformations.');
3884: log(' Index Memory ' || p_idx_mem);
3885: log(' Starting at ' || to_char(SYSDATE, 'HH24:MI:SS') );
3886:
3887:

Line 3898: 'hz_staged_contact_points(concat_col) indextype is ctxsys.context ' ||

3894: NULL;
3895:
3896: END ;
3897: EXECUTE IMMEDIATE 'CREATE INDEX ' || l_index_owner || '.hz_stage_cpt_t1 ON ' ||
3898: 'hz_staged_contact_points(concat_col) indextype is ctxsys.context ' ||
3899: 'parameters (''storage '||g_schema_name || '.HZ_DQM_STORAGE datastore '||g_schema_name || '.hz_contact_point_ds ' ||
3900: 'SECTION GROUP '||l_section_grp||' STOPLIST CTXSYS.EMPTY_STOPLIST LEXER '||g_schema_name || '.dqm_lexer memory ' || p_idx_mem || ''')';
3901:
3902: log('Done creating hz_stage_contact_t1');

Line 4064: l(' UPDATE HZ_STAGED_CONTACT_POINTS SET ');

4060: l(' UPDATE HZ_STAGED_CONTACTS SET ');
4061: l(' ' || l_update_str);
4062: l(' WHERE org_contact_id = p_record_id;');
4063: ELSIF p_entity = 'CONTACT_POINTS' THEN
4064: l(' UPDATE HZ_STAGED_CONTACT_POINTS SET ');
4065: l(' ' || l_update_str);
4066: l(' WHERE contact_point_id = p_record_id;');
4067: END IF;
4068: END IF;

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

4484: l(' RETURN NULL;');
4485: l(' END;');
4486: ELSE
4487: l(' CURSOR P IS');
4488: l(' SELECT '||proc_cols||' FROM '||uname||'.HZ_STAGED_CONTACT_POINTS WHERE ROWID=rid;');
4489: l(' val CLOB;');
4490: l(' BEGIN');
4491: l(' val:=null;');
4492: l(' FOR rec in P LOOP');

Line 4570: l(' FROM '||uname||'.HZ_STAGED_CONTACT_POINTS');

4566: l(' '||l_attr ||'||'' ''||');
4567: END LOOP;
4568: CLOSE l_ent_cur;
4569: l(' '' ''');
4570: l(' FROM '||uname||'.HZ_STAGED_CONTACT_POINTS');
4571: l(' WHERE party_id = cp_party_id;');
4572: l(' l_buffer VARCHAR2(4000);');
4573: l(' l_den_cpt VARCHAR2(2000);');
4574: l(' BEGIN');

Line 9178: l(' log (''Inserting Data into HZ_STAGED_CONTACT_POINTS...'',FALSE); ');

9174: l(' l_en := H_CONTACT_POINT_ID.COUNT; ');
9175: l('');
9176: l(' IF p_operation = ''C'' THEN ');
9177: l(' BEGIN ');
9178: l(' log (''Inserting Data into HZ_STAGED_CONTACT_POINTS...'',FALSE); ');
9179: l(' FORALL I in l_st..l_en SAVE EXCEPTIONS ');
9180: l(' INSERT INTO HZ_STAGED_CONTACT_POINTS (');
9181: l(' CONTACT_POINT_ID');
9182: l(' ,PARTY_ID');

Line 9180: l(' INSERT INTO HZ_STAGED_CONTACT_POINTS (');

9176: l(' IF p_operation = ''C'' THEN ');
9177: l(' BEGIN ');
9178: l(' log (''Inserting Data into HZ_STAGED_CONTACT_POINTS...'',FALSE); ');
9179: l(' FORALL I in l_st..l_en SAVE EXCEPTIONS ');
9180: l(' INSERT INTO HZ_STAGED_CONTACT_POINTS (');
9181: l(' CONTACT_POINT_ID');
9182: l(' ,PARTY_ID');
9183: l(' ,PARTY_SITE_ID');
9184: l(' ,ORG_CONTACT_ID');

Line 9234: l(' log (''Updating Data in HZ_STAGED_CONTACT_POINTS...'',FALSE); ');

9230: l(' END LOOP; ');
9231: l(' END; ');
9232: l(' ELSIF p_operation = ''U'' THEN ');
9233: l(' BEGIN ');
9234: l(' log (''Updating Data in HZ_STAGED_CONTACT_POINTS...'',FALSE); ');
9235: l(' FORALL I in l_st..l_en SAVE EXCEPTIONS ');
9236: l(' UPDATE HZ_STAGED_CONTACT_POINTS SET ');
9237: l(' concat_col = concat_col');
9238: l(' ,status_flag = H_STATUS(I) ');--Propagating Bug 4299785 fix to sync modifications

Line 9236: l(' UPDATE HZ_STAGED_CONTACT_POINTS SET ');

9232: l(' ELSIF p_operation = ''U'' THEN ');
9233: l(' BEGIN ');
9234: l(' log (''Updating Data in HZ_STAGED_CONTACT_POINTS...'',FALSE); ');
9235: l(' FORALL I in l_st..l_en SAVE EXCEPTIONS ');
9236: l(' UPDATE HZ_STAGED_CONTACT_POINTS SET ');
9237: l(' concat_col = concat_col');
9238: l(' ,status_flag = H_STATUS(I) ');--Propagating Bug 4299785 fix to sync modifications
9239:
9240: FOR I IN 1..255 LOOP

Line 9640: l(' INSERT INTO HZ_STAGED_CONTACT_POINTS (');

9636: l(' l_en := H_CPT_PARTY_ID.COUNT; ');
9637: l(' LOOP ');
9638: l(' BEGIN ');
9639: l(' FORALL I in l_st..l_en');
9640: l(' INSERT INTO HZ_STAGED_CONTACT_POINTS (');
9641: l(' CONTACT_POINT_ID');
9642: l(' ,PARTY_ID');
9643: l(' ,PARTY_SITE_ID');
9644: l(' ,ORG_CONTACT_ID');

Line 9754: l(' INSERT INTO HZ_STAGED_CONTACT_POINTS (');

9750: l(' WHILE (l_tryins OR l_tryupd) LOOP');
9751: l(' IF l_tryins THEN');
9752: l(' BEGIN');
9753: l(' l_tryins:=FALSE;');
9754: l(' INSERT INTO HZ_STAGED_CONTACT_POINTS (');
9755: l(' CONTACT_POINT_ID');
9756: l(' ,PARTY_ID');
9757: l(' ,PARTY_SITE_ID');
9758: l(' ,ORG_CONTACT_ID');

Line 9793: l(' UPDATE HZ_STAGED_CONTACT_POINTS SET ');

9789: l(' END IF;');
9790: l(' IF l_tryupd THEN');
9791: l(' BEGIN');
9792: l(' l_tryupd:=FALSE;');
9793: l(' UPDATE HZ_STAGED_CONTACT_POINTS SET ');
9794: l(' concat_col = concat_col');
9795: l(' ,status_flag = H_STATUS(1) ');--Bug No: 4299785
9796:
9797: FOR I IN 1..255 LOOP

Line 9975: l(' INSERT INTO HZ_STAGED_CONTACT_POINTS (');

9971: l(' WHILE (l_tryins OR l_tryupd) LOOP');
9972: l(' IF l_tryins THEN');
9973: l(' BEGIN');
9974: l(' l_tryins:=FALSE;');
9975: l(' INSERT INTO HZ_STAGED_CONTACT_POINTS (');
9976: l(' CONTACT_POINT_ID');
9977: l(' ,PARTY_ID');
9978: l(' ,PARTY_SITE_ID');
9979: l(' ,ORG_CONTACT_ID');

Line 10015: l(' UPDATE HZ_STAGED_CONTACT_POINTS SET ');

10011: l('');
10012: l(' IF l_tryupd THEN');
10013: l(' BEGIN');
10014: l(' l_tryupd:=FALSE;');
10015: l(' UPDATE HZ_STAGED_CONTACT_POINTS SET ');
10016: l(' concat_col = concat_col');
10017: l(' ,status_flag = H_STATUS(1) '); --Bug No: 4299785
10018:
10019: FOR I IN 1..255 LOOP

Line 11100: l(' FROM HZ_CONTACT_POINTS cp, HZ_STAGED_CONTACT_POINTS s ');

11096: l(' SELECT cp.CONTACT_POINT_ID ');
11097: FOR I in 1..l_select.COUNT LOOP
11098: l(' ,' || l_select(I));
11099: END LOOP;
11100: l(' FROM HZ_CONTACT_POINTS cp, HZ_STAGED_CONTACT_POINTS s ');
11101: l(' WHERE mod(s.PARTY_ID, p_num_workers) = p_worker_number ');
11102: l(' AND cp.contact_point_id = s.contact_point_id ');
11103: l(' AND cp.owner_table_id = s.PARTY_ID ');
11104: l(' AND cp.OWNER_TABLE_NAME = ''HZ_PARTIES'' ');

Line 11184: l(' UPDATE HZ_STAGED_CONTACT_POINTS SET');

11180: END LOOP;
11181: l(' END LOOP;');
11182:
11183: l(' FORALL I in H_CONTACT_POINT_ID.FIRST..H_CONTACT_POINT_ID.LAST');
11184: l(' UPDATE HZ_STAGED_CONTACT_POINTS SET');
11185: FIRST:=TRUE;
11186: FOR I IN 1..255 LOOP
11187: IF l_forall_list(I) <> 'N' THEN
11188: IF (FIRST) THEN

Line 11246: l(' FROM HZ_STAGED_CONTACT_POINTS cpt');

11242: l(' BEGIN');
11243: l(' open x_contact_pt_cur FOR');
11244: l(' SELECT cpt.PARTY_ID,');
11245: l(get_missing_denorm_attrib_cols('CONTACT_POINTS'));
11246: l(' FROM HZ_STAGED_CONTACT_POINTS cpt');
11247: l(' WHERE mod(cpt.PARTY_ID, p_num_workers) = p_worker_number ; ');
11248: l(' END;');
11249:
11250: l(' PROCEDURE update_stage_contact_pts ( ');

Line 11312: 'CONTACT_POINTS','HZ_STAGED_CONTACT_POINTS')||'_N0'||substrb(staged_attribute_column,3) index_name,

11308:
11309: CURSOR indexes_reqd IS
11310: SELECT decode(a.entity_name,'PARTY','HZ_STAGED_PARTIES',
11311: 'PARTY_SITES','HZ_STAGED_PARTY_SITES','CONTACTS','HZ_STAGED_CONTACTS',
11312: 'CONTACT_POINTS','HZ_STAGED_CONTACT_POINTS')||'_N0'||substrb(staged_attribute_column,3) index_name,
11313: decode(a.entity_name,'PARTY','HZ_STAGED_PARTIES',
11314: 'PARTY_SITES','HZ_STAGED_PARTY_SITES','CONTACTS','HZ_STAGED_CONTACTS',
11315: 'CONTACT_POINTS','HZ_STAGED_CONTACT_POINTS') table_name,
11316: decode(a.entity_name,'PARTY','HZ_SRCH_PARTIES',

Line 11315: 'CONTACT_POINTS','HZ_STAGED_CONTACT_POINTS') table_name,

11311: 'PARTY_SITES','HZ_STAGED_PARTY_SITES','CONTACTS','HZ_STAGED_CONTACTS',
11312: 'CONTACT_POINTS','HZ_STAGED_CONTACT_POINTS')||'_N0'||substrb(staged_attribute_column,3) index_name,
11313: decode(a.entity_name,'PARTY','HZ_STAGED_PARTIES',
11314: 'PARTY_SITES','HZ_STAGED_PARTY_SITES','CONTACTS','HZ_STAGED_CONTACTS',
11315: 'CONTACT_POINTS','HZ_STAGED_CONTACT_POINTS') table_name,
11316: decode(a.entity_name,'PARTY','HZ_SRCH_PARTIES',
11317: 'PARTY_SITES','HZ_SRCH_PSITES','CONTACTS','HZ_SRCH_CONTACTS',
11318: 'CONTACT_POINTS','HZ_SRCH_CPTS')||'_N0'||substrb(staged_attribute_column,3) srch_index_name,
11319: decode(a.entity_name,'PARTY','HZ_SRCH_PARTIES',