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 1065: 'CONTACT_POINTS','HZ_STAGED_CONTACT_POINTS')||'_N'||f.function_id) LOOP

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;
1068: UPDATE hz_trans_functions_b set index_required_flag='N' where index_required_flag='T';
1069: END IF;

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

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;
1240:
1241: -- See if the intermedia index on the corresponding staging table for the entity

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

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' );
1394: outandlog(' ');
1395: outandlog('The estimated total disk space required for staging = ' ||reco_staging_size || 'MB' );
1396: outandlog('NEWLINE');

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

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'));
1404: END IF;
1405:
1406: IF l_command = 'STAGE_NEW_DENORM' THEN

Line 2278: SELECT 1 INTO T FROM HZ_STAGED_CONTACT_POINTS

2274: END IF;
2275: END;
2276:
2277: BEGIN
2278: SELECT 1 INTO T FROM HZ_STAGED_CONTACT_POINTS
2279: WHERE ROWNUM=1
2280: AND CONTAINS (concat_col, 'dummy_string')>0;
2281: EXCEPTION
2282: WHEN NO_DATA_FOUND THEN

Line 3591: from hz_staged_contact_points;

3587: IF (new_primary_trans('CONTACT_POINTS')) THEN
3588: BEGIN
3589: select min(contact_point_id), max(contact_point_id)
3590: into l_min_id, l_max_id
3591: from hz_staged_contact_points;
3592: WHILE (l_min_id <= l_max_id )
3593: LOOP
3594: select contact_point_id into tmp
3595: from (

Line 3598: from hz_staged_contact_points

3594: select contact_point_id into tmp
3595: from (
3596: select contact_point_id, rownum rnum
3597: from ( SELECT contact_point_id
3598: from hz_staged_contact_points
3599: where contact_point_id > l_min_id
3600: and rownum<1001 ) a )
3601: where rnum = 1000;
3602: update hz_staged_contact_points set concat_col = concat_col

Line 3602: update hz_staged_contact_points set concat_col = concat_col

3598: from hz_staged_contact_points
3599: where contact_point_id > l_min_id
3600: and rownum<1001 ) a )
3601: where rnum = 1000;
3602: update hz_staged_contact_points set concat_col = concat_col
3603: where contact_point_id between l_min_id and tmp;
3604: FND_FILE.put_line(FND_FILE.log, 'Attempting to SYNC the hz_stage_cpt_t1 index');
3605: AD_CTX_DDL.sync_index(l_index_owner||'.hz_stage_cpt_t1');
3606: FND_FILE.put_line(FND_FILE.log, 'SYNC of the hz_stage_cpt_t1 index successful');

Line 3612: update hz_staged_contact_points set concat_col = concat_col

3608: l_min_id:=tmp+1;
3609: END LOOP;
3610: EXCEPTION
3611: WHEN NO_DATA_FOUND THEN
3612: update hz_staged_contact_points set concat_col = concat_col
3613: where contact_point_id between l_min_id and l_max_id ;
3614: FND_FILE.put_line(FND_FILE.log, 'Attempting to SYNC the hz_stage_cpt_t1 index');
3615: AD_CTX_DDL.sync_index(l_index_owner||'.hz_stage_cpt_t1');
3616: FND_FILE.put_line(FND_FILE.log, 'SYNC of the hz_stage_cpt_t1 index successful');

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

3996:
3997: l_section_grp := g_schema_name || '.HZ_DQM_CPT_GRP';
3998:
3999: IF l_command <> 'STAGE_NEW_TRANSFORMATIONS' THEN
4000: log(' Creating hz_stage_cpt_t1 on hz_staged_contact_points. ');
4001: log(' Index Memory ' || p_idx_mem);
4002: log(' Starting at ' || to_char(SYSDATE, 'HH24:MI:SS'));
4003:
4004: EXECUTE IMMEDIATE 'CREATE INDEX ' || l_index_owner || '.hz_stage_cpt_t1 ON ' ||l_index_owner ||

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

4001: log(' Index Memory ' || p_idx_mem);
4002: log(' Starting at ' || to_char(SYSDATE, 'HH24:MI:SS'));
4003:
4004: EXECUTE IMMEDIATE 'CREATE INDEX ' || l_index_owner || '.hz_stage_cpt_t1 ON ' ||l_index_owner ||
4005: '.hz_staged_contact_points(concat_col) indextype is ctxsys.context ' ||
4006: 'parameters (''storage '||g_schema_name || '.HZ_DQM_STORAGE datastore '||g_schema_name || '.hz_contact_point_ds ' ||
4007: '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 ' '
4008: END;
4009: ELSE

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

4006: 'parameters (''storage '||g_schema_name || '.HZ_DQM_STORAGE datastore '||g_schema_name || '.hz_contact_point_ds ' ||
4007: '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 ' '
4008: END;
4009: ELSE
4010: log(' Attempting to drop and create hz_stage_cpt_t1 on hz_staged_contact_points with new transformations.');
4011: log(' Index Memory ' || p_idx_mem);
4012: log(' Starting at ' || to_char(SYSDATE, 'HH24:MI:SS') );
4013:
4014:

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

4021: NULL;
4022:
4023: END ;
4024: EXECUTE IMMEDIATE 'CREATE INDEX ' || l_index_owner || '.hz_stage_cpt_t1 ON ' ||l_index_owner ||
4025: '.hz_staged_contact_points(concat_col) indextype is ctxsys.context ' ||
4026: 'parameters (''storage '||g_schema_name || '.HZ_DQM_STORAGE datastore '||g_schema_name || '.hz_contact_point_ds ' ||
4027: '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 ' '
4028: END;
4029:

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

4188: l(' UPDATE HZ_STAGED_CONTACTS SET ');
4189: l(' ' || l_update_str);
4190: l(' WHERE org_contact_id = p_record_id;');
4191: ELSIF p_entity = 'CONTACT_POINTS' THEN
4192: l(' UPDATE HZ_STAGED_CONTACT_POINTS SET ');
4193: l(' ' || l_update_str);
4194: l(' WHERE contact_point_id = p_record_id;');
4195: END IF;
4196: END IF;

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

4612: l(' RETURN NULL;');
4613: l(' END;');
4614: ELSE
4615: l(' CURSOR P IS');
4616: l(' SELECT '||proc_cols||' FROM '||uname||'.HZ_STAGED_CONTACT_POINTS WHERE ROWID=rid;');
4617: l(' val CLOB;');
4618: l(' BEGIN');
4619: l(' val:=null;');
4620: l(' FOR rec in P LOOP');

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

4694: l(' '||l_attr ||'||'' ''||');
4695: END LOOP;
4696: CLOSE l_ent_cur;
4697: l(' '' ''');
4698: l(' FROM '||uname||'.HZ_STAGED_CONTACT_POINTS');
4699: l(' WHERE party_id = cp_party_id;');
4700: l(' l_buffer VARCHAR2(4000);');
4701: l(' l_den_cpt VARCHAR2(2000);');
4702: l(' BEGIN');

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

9328: l(' l_en := H_CONTACT_POINT_ID.COUNT; ');
9329: l('');
9330: l(' IF p_operation = ''C'' THEN ');
9331: l(' BEGIN ');
9332: l(' log (''Inserting Data into HZ_STAGED_CONTACT_POINTS...'',FALSE); ');
9333: l(' FORALL I in l_st..l_en SAVE EXCEPTIONS ');
9334: l(' INSERT INTO HZ_STAGED_CONTACT_POINTS (');
9335: l(' CONTACT_POINT_ID');
9336: l(' ,PARTY_ID');

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

9330: l(' IF p_operation = ''C'' THEN ');
9331: l(' BEGIN ');
9332: l(' log (''Inserting Data into HZ_STAGED_CONTACT_POINTS...'',FALSE); ');
9333: l(' FORALL I in l_st..l_en SAVE EXCEPTIONS ');
9334: l(' INSERT INTO HZ_STAGED_CONTACT_POINTS (');
9335: l(' CONTACT_POINT_ID');
9336: l(' ,PARTY_ID');
9337: l(' ,PARTY_SITE_ID');
9338: l(' ,ORG_CONTACT_ID');

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

9384: l(' END LOOP; ');
9385: l(' END; ');
9386: l(' ELSIF p_operation = ''U'' THEN ');
9387: l(' BEGIN ');
9388: l(' log (''Updating Data in HZ_STAGED_CONTACT_POINTS...'',FALSE); ');
9389: l(' FORALL I in l_st..l_en SAVE EXCEPTIONS ');
9390: l(' UPDATE HZ_STAGED_CONTACT_POINTS SET ');
9391: l(' concat_col = concat_col');
9392: l(' ,status_flag = H_STATUS(I) ');--Propagating Bug 4299785 fix to sync modifications

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

9386: l(' ELSIF p_operation = ''U'' THEN ');
9387: l(' BEGIN ');
9388: l(' log (''Updating Data in HZ_STAGED_CONTACT_POINTS...'',FALSE); ');
9389: l(' FORALL I in l_st..l_en SAVE EXCEPTIONS ');
9390: l(' UPDATE HZ_STAGED_CONTACT_POINTS SET ');
9391: l(' concat_col = concat_col');
9392: l(' ,status_flag = H_STATUS(I) ');--Propagating Bug 4299785 fix to sync modifications
9393:
9394: FOR I IN 1..255 LOOP

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

9790: l(' l_en := H_CPT_PARTY_ID.COUNT; ');
9791: l(' LOOP ');
9792: l(' BEGIN ');
9793: l(' FORALL I in l_st..l_en');
9794: l(' INSERT INTO HZ_STAGED_CONTACT_POINTS (');
9795: l(' CONTACT_POINT_ID');
9796: l(' ,PARTY_ID');
9797: l(' ,PARTY_SITE_ID');
9798: l(' ,ORG_CONTACT_ID');

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

9904: l(' WHILE (l_tryins OR l_tryupd) LOOP');
9905: l(' IF l_tryins THEN');
9906: l(' BEGIN');
9907: l(' l_tryins:=FALSE;');
9908: l(' INSERT INTO HZ_STAGED_CONTACT_POINTS (');
9909: l(' CONTACT_POINT_ID');
9910: l(' ,PARTY_ID');
9911: l(' ,PARTY_SITE_ID');
9912: l(' ,ORG_CONTACT_ID');

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

9943: l(' END IF;');
9944: l(' IF l_tryupd THEN');
9945: l(' BEGIN');
9946: l(' l_tryupd:=FALSE;');
9947: l(' UPDATE HZ_STAGED_CONTACT_POINTS SET ');
9948: l(' concat_col = concat_col');
9949: l(' ,status_flag = H_STATUS(1) ');--Bug No: 4299785
9950:
9951: FOR I IN 1..255 LOOP

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

10125: l(' WHILE (l_tryins OR l_tryupd) LOOP');
10126: l(' IF l_tryins THEN');
10127: l(' BEGIN');
10128: l(' l_tryins:=FALSE;');
10129: l(' INSERT INTO HZ_STAGED_CONTACT_POINTS (');
10130: l(' CONTACT_POINT_ID');
10131: l(' ,PARTY_ID');
10132: l(' ,PARTY_SITE_ID');
10133: l(' ,ORG_CONTACT_ID');

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

10165: l('');
10166: l(' IF l_tryupd THEN');
10167: l(' BEGIN');
10168: l(' l_tryupd:=FALSE;');
10169: l(' UPDATE HZ_STAGED_CONTACT_POINTS SET ');
10170: l(' concat_col = concat_col');
10171: l(' ,status_flag = H_STATUS(1) '); --Bug No: 4299785
10172:
10173: FOR I IN 1..255 LOOP

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

11250: l(' SELECT cp.CONTACT_POINT_ID ');
11251: FOR I in 1..l_select.COUNT LOOP
11252: l(' ,' || l_select(I));
11253: END LOOP;
11254: l(' FROM HZ_CONTACT_POINTS cp, HZ_STAGED_CONTACT_POINTS s ');
11255: l(' WHERE mod(s.PARTY_ID, p_num_workers) = p_worker_number ');
11256: l(' AND cp.contact_point_id = s.contact_point_id ');
11257: l(' AND cp.owner_table_id = s.PARTY_ID ');
11258: l(' AND cp.OWNER_TABLE_NAME = ''HZ_PARTIES'' ');

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

11334: END LOOP;
11335: l(' END LOOP;');
11336:
11337: l(' FORALL I in H_CONTACT_POINT_ID.FIRST..H_CONTACT_POINT_ID.LAST');
11338: l(' UPDATE HZ_STAGED_CONTACT_POINTS SET');
11339: FIRST:=TRUE;
11340: FOR I IN 1..255 LOOP
11341: IF l_forall_list(I) <> 'N' THEN
11342: IF (FIRST) THEN

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

11396: l(' BEGIN');
11397: l(' open x_contact_pt_cur FOR');
11398: l(' SELECT cpt.PARTY_ID,');
11399: l(get_missing_denorm_attrib_cols('CONTACT_POINTS'));
11400: l(' FROM HZ_STAGED_CONTACT_POINTS cpt');
11401: l(' WHERE mod(cpt.PARTY_ID, p_num_workers) = p_worker_number ; ');
11402: l(' END;');
11403:
11404: l(' PROCEDURE update_stage_contact_pts ( ');

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

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',
11469: 'CONTACT_POINTS','HZ_STAGED_CONTACT_POINTS') table_name,
11470: decode(a.entity_name,'PARTY','HZ_SRCH_PARTIES',

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

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',
11472: 'CONTACT_POINTS','HZ_SRCH_CPTS')||'_N0'||substrb(staged_attribute_column,3) srch_index_name,
11473: decode(a.entity_name,'PARTY','HZ_SRCH_PARTIES',