DBA Data[Home] [Help]

APPS.HZ_PARTY_STAGE dependencies on HZ_STAGED_PARTY_SITES

Line 128: and b.staged_attribute_table = 'HZ_STAGED_PARTY_SITES'

124: where a.entity_name = 'PARTY_SITES'
125: and nvl(a.denorm_flag,'N') = 'Y'
126: and a.attribute_id = b.attribute_id
127: and nvl( b.active_flag, 'Y') = 'Y'
128: and b.staged_attribute_table = 'HZ_STAGED_PARTY_SITES'
129: )
130: LOOP
131: row_count := row_count + 1 ;
132: IF row_count > 1

Line 234: and b.staged_attribute_table = 'HZ_STAGED_PARTY_SITES'

230: where a.entity_name = 'PARTY_SITES'
231: and nvl(a.denorm_flag,'N') = 'Y'
232: and a.attribute_id = b.attribute_id
233: and nvl( b.active_flag, 'Y') = 'Y'
234: and b.staged_attribute_table = 'HZ_STAGED_PARTY_SITES'
235:
236: )
237: LOOP
238: -- if any attribute columns do not exist in the preference

Line 379: log('Truncating HZ_STAGED_PARTY_SITES .. ', FALSE);

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';
381: log('Done');
382:
383: log('Truncating HZ_STAGED_CONTACTS .. ', FALSE);

Line 380: EXECUTE IMMEDIATE 'TRUNCATE TABLE '||l_owner||'.HZ_STAGED_PARTY_SITES';

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';
381: log('Done');
382:
383: log('Truncating HZ_STAGED_CONTACTS .. ', FALSE);
384: EXECUTE IMMEDIATE 'TRUNCATE TABLE '||l_owner||'.HZ_STAGED_CONTACTS';

Line 1052: 'PARTY_SITES','HZ_STAGED_PARTY_SITES','CONTACTS','HZ_STAGED_CONTACTS',

1048: WHERE f.attribute_id = a.attribute_id
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';

Line 1378: outandlog('The estimated disk space required for HZ_STAGED_PARTY_SITES = ' ||reco_staging_party_sites || 'MB' );

1374: reco_index_size := 0.85 * (reco_staging_parties + reco_staging_party_sites + reco_staging_contacts + reco_staging_contact_points);
1375: reco_staging_size := reco_staging_parties + reco_staging_party_sites + reco_staging_contacts + reco_staging_contact_points + reco_index_size;
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(' ');

Line 1388: gather_stats(l_index_owner, 'HZ_STAGED_PARTY_SITES');

1384: outandlog('NEWLINE');
1385: ELSIF l_command = 'ANALYZE_STAGED_TABLES' THEN
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;

Line 2182: SELECT 1 INTO T FROM HZ_STAGED_PARTY_SITES

2178: END IF;
2179: END;
2180:
2181: BEGIN
2182: SELECT 1 INTO T FROM HZ_STAGED_PARTY_SITES
2183: WHERE ROWNUM=1
2184: AND CONTAINS (concat_col, 'dummy_string')>0;
2185: EXCEPTION
2186: WHEN NO_DATA_FOUND THEN

Line 3375: from hz_staged_party_sites;

3371: IF (new_primary_trans('PARTY_SITES')) THEN
3372: BEGIN
3373: select min(party_site_id), max(party_site_id)
3374: into l_min_id, l_max_id
3375: from hz_staged_party_sites;
3376: WHILE (l_min_id <= l_max_id )
3377: LOOP
3378: select party_site_id into tmp
3379: from (

Line 3382: from hz_staged_party_sites

3378: select party_site_id into tmp
3379: from (
3380: select party_site_id, rownum rnum
3381: from ( SELECT party_site_id
3382: from hz_staged_party_sites
3383: where party_site_id > l_min_id
3384: and rownum<1001 ) a )
3385: where rnum = 1000;
3386: update hz_staged_party_sites set concat_col = concat_col

Line 3386: update hz_staged_party_sites set concat_col = concat_col

3382: from hz_staged_party_sites
3383: where party_site_id > l_min_id
3384: and rownum<1001 ) a )
3385: where rnum = 1000;
3386: update hz_staged_party_sites set concat_col = concat_col
3387: where party_id between l_min_id and tmp;
3388: FND_FILE.put_line(FND_FILE.log, 'Attempting to SYNC the hz_stage_party_sites_t1 index');
3389: AD_CTX_DDL.sync_index(l_index_owner ||'.hz_stage_party_sites_t1');
3390: FND_FILE.put_line(FND_FILE.log, 'SYNC of the hz_stage_party_sites_t1 index successful');

Line 3396: update hz_staged_party_sites set concat_col = concat_col

3392: l_min_id:=tmp+1;
3393: END LOOP;
3394: EXCEPTION
3395: WHEN NO_DATA_FOUND THEN
3396: update hz_staged_party_sites set concat_col = concat_col
3397: where party_site_id between l_min_id and l_max_id ;
3398: FND_FILE.put_line(FND_FILE.log, 'Attempting to SYNC the hz_stage_party_sites_t1 index');
3399: AD_CTX_DDL.sync_index(l_index_owner ||'.hz_stage_party_sites_t1');
3400: FND_FILE.put_line(FND_FILE.log, 'SYNC of the hz_stage_party_sites_t1 index successful');

Line 3685: log(' Creating hz_stage_party_sites_t1 on hz_staged_party_sites. ');

3681:
3682: l_section_grp := g_schema_name || '.HZ_DQM_PS_GRP';
3683:
3684: IF l_command <> 'STAGE_NEW_TRANSFORMATIONS' THEN
3685: log(' Creating hz_stage_party_sites_t1 on hz_staged_party_sites. ');
3686: log(' Index Memory ' || p_idx_mem);
3687: log(' Starting at ' || to_char(SYSDATE, 'HH24:MI:SS'));
3688:
3689: EXECUTE IMMEDIATE 'CREATE INDEX ' || l_index_owner || '.hz_stage_party_sites_t1 ON ' ||

Line 3690: 'hz_staged_party_sites(concat_col) indextype is ctxsys.context ' ||

3686: log(' Index Memory ' || p_idx_mem);
3687: log(' Starting at ' || to_char(SYSDATE, 'HH24:MI:SS'));
3688:
3689: EXECUTE IMMEDIATE 'CREATE INDEX ' || l_index_owner || '.hz_stage_party_sites_t1 ON ' ||
3690: 'hz_staged_party_sites(concat_col) indextype is ctxsys.context ' ||
3691: 'parameters (''storage '||g_schema_name || '.HZ_DQM_STORAGE datastore '||g_schema_name || '.hz_party_site_ds ' ||
3692: 'SECTION GROUP '||l_section_grp||' STOPLIST CTXSYS.EMPTY_STOPLIST LEXER '||g_schema_name || '.dqm_lexer memory ' || p_idx_mem || ''')';
3693: ELSE
3694: log(' Attempting to drop and create hz_stage_party_sites_t1 on hz_staged_party_sites with new transformations.');

Line 3694: log(' Attempting to drop and create hz_stage_party_sites_t1 on hz_staged_party_sites with new transformations.');

3690: 'hz_staged_party_sites(concat_col) indextype is ctxsys.context ' ||
3691: 'parameters (''storage '||g_schema_name || '.HZ_DQM_STORAGE datastore '||g_schema_name || '.hz_party_site_ds ' ||
3692: 'SECTION GROUP '||l_section_grp||' STOPLIST CTXSYS.EMPTY_STOPLIST LEXER '||g_schema_name || '.dqm_lexer memory ' || p_idx_mem || ''')';
3693: ELSE
3694: log(' Attempting to drop and create hz_stage_party_sites_t1 on hz_staged_party_sites with new transformations.');
3695: log(' Index Memory ' || p_idx_mem);
3696: log(' Starting at ' || to_char(SYSDATE, 'HH24:MI:SS') );
3697:
3698: -- DROP AND CREATE

Line 3707: 'hz_staged_party_sites(concat_col) indextype is ctxsys.context ' ||

3703: WHEN OTHERS THEN
3704: NULL;
3705: END ;
3706: EXECUTE IMMEDIATE 'CREATE INDEX ' || l_index_owner || '.hz_stage_party_sites_t1 ON ' ||
3707: 'hz_staged_party_sites(concat_col) indextype is ctxsys.context ' ||
3708: 'parameters (''storage '||g_schema_name || '.HZ_DQM_STORAGE datastore '||g_schema_name || '.hz_party_site_ds ' ||
3709: 'SECTION GROUP '||l_section_grp||' STOPLIST CTXSYS.EMPTY_STOPLIST LEXER '||g_schema_name || '.dqm_lexer memory ' || p_idx_mem || ''')';
3710: log('Done creating hz_stage_party_sites_t1');
3711: END IF;

Line 4056: l(' UPDATE HZ_STAGED_PARTY_SITES SET ');

4052: l(' UPDATE HZ_STAGED_PARTIES SET ');
4053: l(' ' || l_update_str);
4054: l(' WHERE party_id = p_record_id;');
4055: ELSIF p_entity = 'PARTY_SITES' THEN
4056: l(' UPDATE HZ_STAGED_PARTY_SITES SET ');
4057: l(' ' || l_update_str);
4058: l(' WHERE party_site_id = p_record_id;');
4059: ELSIF p_entity = 'CONTACTS' THEN
4060: l(' UPDATE HZ_STAGED_CONTACTS SET ');

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

4445: l(' RETURN NULL;');
4446: l(' END;');
4447: ELSE
4448: l(' CURSOR P IS');
4449: l(' SELECT '||proc_cols||' FROM '||uname||'.HZ_STAGED_PARTY_SITES WHERE ROWID=rid;');
4450: l(' val CLOB ;');
4451: l(' BEGIN');
4452: l(' val:=null;');
4453: l(' FOR rec in P LOOP');

Line 4510: l(' FROM '||uname||'.HZ_STAGED_PARTY_SITES');

4506: l(' '||l_attr ||'||'' ''||');
4507: END LOOP;
4508: CLOSE l_ent_cur;
4509: l(' '' ''');
4510: l(' FROM '||uname||'.HZ_STAGED_PARTY_SITES');
4511: l(' WHERE party_id = cp_party_id;');
4512: l(' l_buffer VARCHAR2(4000);');
4513: l(' l_den_ps VARCHAR2(2000);');
4514: l(' BEGIN');

Line 6599: l(' log (''Inserting Data into HZ_STAGED_PARTY_SITES...'',FALSE); ');

6595: l(' l_en := H_PARTY_SITE_ID.COUNT; ');
6596: l('');
6597: l(' IF p_operation = ''C'' THEN ');
6598: l(' BEGIN ');
6599: l(' log (''Inserting Data into HZ_STAGED_PARTY_SITES...'',FALSE); ');
6600: l(' FORALL I in l_st..l_en SAVE EXCEPTIONS ');
6601: l(' INSERT INTO HZ_STAGED_PARTY_SITES (');
6602: l(' PARTY_SITE_ID');
6603: l(' ,PARTY_ID');

Line 6601: l(' INSERT INTO HZ_STAGED_PARTY_SITES (');

6597: l(' IF p_operation = ''C'' THEN ');
6598: l(' BEGIN ');
6599: l(' log (''Inserting Data into HZ_STAGED_PARTY_SITES...'',FALSE); ');
6600: l(' FORALL I in l_st..l_en SAVE EXCEPTIONS ');
6601: l(' INSERT INTO HZ_STAGED_PARTY_SITES (');
6602: l(' PARTY_SITE_ID');
6603: l(' ,PARTY_ID');
6604: l(' ,ORG_CONTACT_ID');
6605: l(' ,STATUS_FLAG'); --Propagating Bug 4299785 fix to sync modifications

Line 6652: l(' log (''Updating Data in HZ_STAGED_PARTY_SITES...'',FALSE); ');

6648: l(' END LOOP; ');
6649: l(' END; ');
6650: l(' ELSIF p_operation = ''U'' THEN ');
6651: l(' BEGIN ');
6652: l(' log (''Updating Data in HZ_STAGED_PARTY_SITES...'',FALSE); ');
6653: l(' FORALL I in l_st..l_en SAVE EXCEPTIONS ');
6654: l(' UPDATE HZ_STAGED_PARTY_SITES SET ');
6655: l(' concat_col = concat_col');
6656: l(' ,status_flag = H_STATUS(I)'); --Propagating Bug 4299785 fix to sync modifications

Line 6654: l(' UPDATE HZ_STAGED_PARTY_SITES SET ');

6650: l(' ELSIF p_operation = ''U'' THEN ');
6651: l(' BEGIN ');
6652: l(' log (''Updating Data in HZ_STAGED_PARTY_SITES...'',FALSE); ');
6653: l(' FORALL I in l_st..l_en SAVE EXCEPTIONS ');
6654: l(' UPDATE HZ_STAGED_PARTY_SITES SET ');
6655: l(' concat_col = concat_col');
6656: l(' ,status_flag = H_STATUS(I)'); --Propagating Bug 4299785 fix to sync modifications
6657:
6658: FOR I IN 1..255 LOOP

Line 7051: l(' INSERT INTO HZ_STAGED_PARTY_SITES (');

7047: l(' l_en := H_PS_PARTY_ID.COUNT; ');
7048: l(' LOOP ');
7049: l(' BEGIN ');
7050: l(' FORALL I in l_st..l_en');
7051: l(' INSERT INTO HZ_STAGED_PARTY_SITES (');
7052: l(' PARTY_SITE_ID');
7053: l(' ,PARTY_ID');
7054: l(' ,ORG_CONTACT_ID');
7055: l(' ,STATUS_FLAG'); --Bug No: 4299785

Line 7172: l(' INSERT INTO HZ_STAGED_PARTY_SITES (');

7168: l(' WHILE (l_tryins OR l_tryupd) LOOP');
7169: l(' IF l_tryins THEN');
7170: l(' BEGIN');
7171: l(' l_tryins:=FALSE;');
7172: l(' INSERT INTO HZ_STAGED_PARTY_SITES (');
7173: l(' PARTY_SITE_ID');
7174: l(' ,PARTY_ID');
7175: l(' ,ORG_CONTACT_ID');
7176: l(' ,STATUS_FLAG'); --Bug No: 4299785

Line 7205: l(' UPDATE HZ_STAGED_PARTY_SITES SET ');

7201: l(' END IF;');
7202: l(' IF l_tryupd THEN');
7203: l(' BEGIN');
7204: l(' l_tryupd:=FALSE;');
7205: l(' UPDATE HZ_STAGED_PARTY_SITES SET ');
7206: l(' concat_col = concat_col');
7207: l(' ,status_flag = H_STATUS(1)'); --Bug No: 4299785
7208:
7209: FOR I IN 1..255 LOOP

Line 7363: l(' INSERT INTO HZ_STAGED_PARTY_SITES (');

7359: l(' WHILE (l_tryins OR l_tryupd) LOOP');
7360: l(' IF l_tryins THEN');
7361: l(' BEGIN');
7362: l(' l_tryins:=FALSE;');
7363: l(' INSERT INTO HZ_STAGED_PARTY_SITES (');
7364: l(' PARTY_SITE_ID');
7365: l(' ,PARTY_ID');
7366: l(' ,ORG_CONTACT_ID');
7367: l(' ,STATUS_FLAG'); --Bug No: 4299785

Line 7397: l(' UPDATE HZ_STAGED_PARTY_SITES SET ');

7393: l('');
7394: l(' IF l_tryupd THEN');
7395: l(' BEGIN');
7396: l(' l_tryupd:=FALSE;');
7397: l(' UPDATE HZ_STAGED_PARTY_SITES SET ');
7398: l(' concat_col = concat_col');
7399: l(' ,status_flag = H_STATUS(1)'); --Bug No: 4299785
7400:
7401: FOR I IN 1..255 LOOP

Line 10786: l(' FROM HZ_PARTY_SITES ps, HZ_STAGED_PARTY_SITES s, HZ_LOCATIONS l ');

10782: l(' SELECT ps.PARTY_SITE_ID ');
10783: FOR I in 1..l_select.COUNT LOOP
10784: l(' ,' || l_select(I));
10785: END LOOP;
10786: l(' FROM HZ_PARTY_SITES ps, HZ_STAGED_PARTY_SITES s, HZ_LOCATIONS l ');
10787: l(' WHERE mod(s.PARTY_ID, p_num_workers) = p_worker_number ');
10788: l(' AND ps.party_site_id = s.party_site_id ');
10789: l(' AND ps.party_id = s.party_id ');
10790: l(' AND ps.location_id = l.location_id; ');

Line 10868: l(' UPDATE HZ_STAGED_PARTY_SITES SET');

10864: END IF;
10865: END LOOP;
10866: l(' END LOOP;');
10867: l(' FORALL I in H_PARTY_SITE_ID.FIRST..H_PARTY_SITE_ID.LAST');
10868: l(' UPDATE HZ_STAGED_PARTY_SITES SET');
10869: FIRST := TRUE;
10870: FOR I IN 1..255 LOOP
10871: IF l_forall_list(I) <> 'N' THEN
10872: IF (FIRST) THEN

Line 10931: l(' FROM HZ_STAGED_PARTY_SITES ps');

10927: l(' BEGIN');
10928: l(' open x_party_site_cur FOR');
10929: l(' SELECT ps.PARTY_ID,');
10930: l(get_missing_denorm_attrib_cols('PARTY_SITES'));
10931: l(' FROM HZ_STAGED_PARTY_SITES ps');
10932: l(' WHERE mod(ps.PARTY_ID, p_num_workers) = p_worker_number ; ');
10933: l(' END;');
10934:
10935: l(' PROCEDURE update_stage_party_sites ( ');

Line 11311: 'PARTY_SITES','HZ_STAGED_PARTY_SITES','CONTACTS','HZ_STAGED_CONTACTS',

11307: l_index_owner VARCHAR2(255);
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,

Line 11314: 'PARTY_SITES','HZ_STAGED_PARTY_SITES','CONTACTS','HZ_STAGED_CONTACTS',

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',
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,