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 1064: 'PARTY_SITES','HZ_STAGED_PARTY_SITES','CONTACTS','HZ_STAGED_CONTACTS',

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

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

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' );
1394: outandlog(' ');

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

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'));
1404: END IF;

Line 2198: SELECT 1 INTO T FROM HZ_STAGED_PARTY_SITES

2194: END IF;
2195: END;
2196:
2197: BEGIN
2198: SELECT 1 INTO T FROM HZ_STAGED_PARTY_SITES
2199: WHERE ROWNUM=1
2200: AND CONTAINS (concat_col, 'dummy_string')>0;
2201: EXCEPTION
2202: WHEN NO_DATA_FOUND THEN

Line 3495: from hz_staged_party_sites;

3491: IF (new_primary_trans('PARTY_SITES')) THEN
3492: BEGIN
3493: select min(party_site_id), max(party_site_id)
3494: into l_min_id, l_max_id
3495: from hz_staged_party_sites;
3496: WHILE (l_min_id <= l_max_id )
3497: LOOP
3498: select party_site_id into tmp
3499: from (

Line 3502: from hz_staged_party_sites

3498: select party_site_id into tmp
3499: from (
3500: select party_site_id, rownum rnum
3501: from ( SELECT party_site_id
3502: from hz_staged_party_sites
3503: where party_site_id > l_min_id
3504: and rownum<1001 ) a )
3505: where rnum = 1000;
3506: update hz_staged_party_sites set concat_col = concat_col

Line 3506: update hz_staged_party_sites set concat_col = concat_col

3502: from hz_staged_party_sites
3503: where party_site_id > l_min_id
3504: and rownum<1001 ) a )
3505: where rnum = 1000;
3506: update hz_staged_party_sites set concat_col = concat_col
3507: where party_id between l_min_id and tmp;
3508: FND_FILE.put_line(FND_FILE.log, 'Attempting to SYNC the hz_stage_party_sites_t1 index');
3509: AD_CTX_DDL.sync_index(l_index_owner ||'.hz_stage_party_sites_t1');
3510: FND_FILE.put_line(FND_FILE.log, 'SYNC of the hz_stage_party_sites_t1 index successful');

Line 3516: update hz_staged_party_sites set concat_col = concat_col

3512: l_min_id:=tmp+1;
3513: END LOOP;
3514: EXCEPTION
3515: WHEN NO_DATA_FOUND THEN
3516: update hz_staged_party_sites set concat_col = concat_col
3517: where party_site_id between l_min_id and l_max_id ;
3518: FND_FILE.put_line(FND_FILE.log, 'Attempting to SYNC the hz_stage_party_sites_t1 index');
3519: AD_CTX_DDL.sync_index(l_index_owner ||'.hz_stage_party_sites_t1');
3520: FND_FILE.put_line(FND_FILE.log, 'SYNC of the hz_stage_party_sites_t1 index successful');

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

3803:
3804: l_section_grp := g_schema_name || '.HZ_DQM_PS_GRP';
3805:
3806: IF l_command <> 'STAGE_NEW_TRANSFORMATIONS' THEN
3807: log(' Creating hz_stage_party_sites_t1 on hz_staged_party_sites. ');
3808: log(' Index Memory ' || p_idx_mem);
3809: log(' Starting at ' || to_char(SYSDATE, 'HH24:MI:SS'));
3810:
3811: EXECUTE IMMEDIATE 'CREATE INDEX ' || l_index_owner || '.hz_stage_party_sites_t1 ON ' ||l_index_owner ||

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

3808: log(' Index Memory ' || p_idx_mem);
3809: log(' Starting at ' || to_char(SYSDATE, 'HH24:MI:SS'));
3810:
3811: EXECUTE IMMEDIATE 'CREATE INDEX ' || l_index_owner || '.hz_stage_party_sites_t1 ON ' ||l_index_owner ||
3812: '.hz_staged_party_sites(concat_col) indextype is ctxsys.context ' ||
3813: 'parameters (''storage '||g_schema_name || '.HZ_DQM_STORAGE datastore '||g_schema_name || '.hz_party_site_ds ' ||
3814: '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 ' '
3815: END;
3816: ELSE

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

3813: 'parameters (''storage '||g_schema_name || '.HZ_DQM_STORAGE datastore '||g_schema_name || '.hz_party_site_ds ' ||
3814: '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 ' '
3815: END;
3816: ELSE
3817: log(' Attempting to drop and create hz_stage_party_sites_t1 on hz_staged_party_sites with new transformations.');
3818: log(' Index Memory ' || p_idx_mem);
3819: log(' Starting at ' || to_char(SYSDATE, 'HH24:MI:SS') );
3820:
3821: -- DROP AND CREATE

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

3826: WHEN OTHERS THEN
3827: NULL;
3828: END ;
3829: EXECUTE IMMEDIATE 'CREATE INDEX ' || l_index_owner || '.hz_stage_party_sites_t1 ON ' ||l_index_owner ||
3830: '.hz_staged_party_sites(concat_col) indextype is ctxsys.context ' ||
3831: 'parameters (''storage '||g_schema_name || '.HZ_DQM_STORAGE datastore '||g_schema_name || '.hz_party_site_ds ' ||
3832: '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 ' '
3833: END;
3834: log('Done creating hz_stage_party_sites_t1');

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

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 ');
4185: l(' ' || l_update_str);
4186: l(' WHERE party_site_id = p_record_id;');
4187: ELSIF p_entity = 'CONTACTS' THEN
4188: l(' UPDATE HZ_STAGED_CONTACTS SET ');

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

4573: l(' RETURN NULL;');
4574: l(' END;');
4575: ELSE
4576: l(' CURSOR P IS');
4577: l(' SELECT '||proc_cols||' FROM '||uname||'.HZ_STAGED_PARTY_SITES WHERE ROWID=rid;');
4578: l(' val CLOB ;');
4579: l(' BEGIN');
4580: l(' val:=null;');
4581: l(' FOR rec in P LOOP');

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

4634: l(' '||l_attr ||'||'' ''||');
4635: END LOOP;
4636: CLOSE l_ent_cur;
4637: l(' '' ''');
4638: l(' FROM '||uname||'.HZ_STAGED_PARTY_SITES');
4639: l(' WHERE party_id = cp_party_id;');
4640: l(' l_buffer VARCHAR2(4000);');
4641: l(' l_den_ps VARCHAR2(2000);');
4642: l(' BEGIN');

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

6749: l(' l_en := H_PARTY_SITE_ID.COUNT; ');
6750: l('');
6751: l(' IF p_operation = ''C'' THEN ');
6752: l(' BEGIN ');
6753: l(' log (''Inserting Data into HZ_STAGED_PARTY_SITES...'',FALSE); ');
6754: l(' FORALL I in l_st..l_en SAVE EXCEPTIONS ');
6755: l(' INSERT INTO HZ_STAGED_PARTY_SITES (');
6756: l(' PARTY_SITE_ID');
6757: l(' ,PARTY_ID');

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

6751: l(' IF p_operation = ''C'' THEN ');
6752: l(' BEGIN ');
6753: l(' log (''Inserting Data into HZ_STAGED_PARTY_SITES...'',FALSE); ');
6754: l(' FORALL I in l_st..l_en SAVE EXCEPTIONS ');
6755: l(' INSERT INTO HZ_STAGED_PARTY_SITES (');
6756: l(' PARTY_SITE_ID');
6757: l(' ,PARTY_ID');
6758: l(' ,ORG_CONTACT_ID');
6759: l(' ,STATUS_FLAG'); --Propagating Bug 4299785 fix to sync modifications

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

6802: l(' END LOOP; ');
6803: l(' END; ');
6804: l(' ELSIF p_operation = ''U'' THEN ');
6805: l(' BEGIN ');
6806: l(' log (''Updating Data in HZ_STAGED_PARTY_SITES...'',FALSE); ');
6807: l(' FORALL I in l_st..l_en SAVE EXCEPTIONS ');
6808: l(' UPDATE HZ_STAGED_PARTY_SITES SET ');
6809: l(' concat_col = concat_col');
6810: l(' ,status_flag = H_STATUS(I)'); --Propagating Bug 4299785 fix to sync modifications

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

6804: l(' ELSIF p_operation = ''U'' THEN ');
6805: l(' BEGIN ');
6806: l(' log (''Updating Data in HZ_STAGED_PARTY_SITES...'',FALSE); ');
6807: l(' FORALL I in l_st..l_en SAVE EXCEPTIONS ');
6808: l(' UPDATE HZ_STAGED_PARTY_SITES SET ');
6809: l(' concat_col = concat_col');
6810: l(' ,status_flag = H_STATUS(I)'); --Propagating Bug 4299785 fix to sync modifications
6811:
6812: FOR I IN 1..255 LOOP

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

7201: l(' l_en := H_PS_PARTY_ID.COUNT; ');
7202: l(' LOOP ');
7203: l(' BEGIN ');
7204: l(' FORALL I in l_st..l_en');
7205: l(' INSERT INTO HZ_STAGED_PARTY_SITES (');
7206: l(' PARTY_SITE_ID');
7207: l(' ,PARTY_ID');
7208: l(' ,ORG_CONTACT_ID');
7209: l(' ,STATUS_FLAG'); --Bug No: 4299785

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

7322: l(' WHILE (l_tryins OR l_tryupd) LOOP');
7323: l(' IF l_tryins THEN');
7324: l(' BEGIN');
7325: l(' l_tryins:=FALSE;');
7326: l(' INSERT INTO HZ_STAGED_PARTY_SITES (');
7327: l(' PARTY_SITE_ID');
7328: l(' ,PARTY_ID');
7329: l(' ,ORG_CONTACT_ID');
7330: l(' ,STATUS_FLAG'); --Bug No: 4299785

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

7355: l(' END IF;');
7356: l(' IF l_tryupd THEN');
7357: l(' BEGIN');
7358: l(' l_tryupd:=FALSE;');
7359: l(' UPDATE HZ_STAGED_PARTY_SITES SET ');
7360: l(' concat_col = concat_col');
7361: l(' ,status_flag = H_STATUS(1)'); --Bug No: 4299785
7362:
7363: FOR I IN 1..255 LOOP

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

7513: l(' WHILE (l_tryins OR l_tryupd) LOOP');
7514: l(' IF l_tryins THEN');
7515: l(' BEGIN');
7516: l(' l_tryins:=FALSE;');
7517: l(' INSERT INTO HZ_STAGED_PARTY_SITES (');
7518: l(' PARTY_SITE_ID');
7519: l(' ,PARTY_ID');
7520: l(' ,ORG_CONTACT_ID');
7521: l(' ,STATUS_FLAG'); --Bug No: 4299785

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

7547: l('');
7548: l(' IF l_tryupd THEN');
7549: l(' BEGIN');
7550: l(' l_tryupd:=FALSE;');
7551: l(' UPDATE HZ_STAGED_PARTY_SITES SET ');
7552: l(' concat_col = concat_col');
7553: l(' ,status_flag = H_STATUS(1)'); --Bug No: 4299785
7554:
7555: FOR I IN 1..255 LOOP

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

10936: l(' SELECT ps.PARTY_SITE_ID ');
10937: FOR I in 1..l_select.COUNT LOOP
10938: l(' ,' || l_select(I));
10939: END LOOP;
10940: l(' FROM HZ_PARTY_SITES ps, HZ_STAGED_PARTY_SITES s, HZ_LOCATIONS l ');
10941: l(' WHERE mod(s.PARTY_ID, p_num_workers) = p_worker_number ');
10942: l(' AND ps.party_site_id = s.party_site_id ');
10943: l(' AND ps.party_id = s.party_id ');
10944: l(' AND ps.location_id = l.location_id; ');

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

11018: END IF;
11019: END LOOP;
11020: l(' END LOOP;');
11021: l(' FORALL I in H_PARTY_SITE_ID.FIRST..H_PARTY_SITE_ID.LAST');
11022: l(' UPDATE HZ_STAGED_PARTY_SITES SET');
11023: FIRST := TRUE;
11024: FOR I IN 1..255 LOOP
11025: IF l_forall_list(I) <> 'N' THEN
11026: IF (FIRST) THEN

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

11081: l(' BEGIN');
11082: l(' open x_party_site_cur FOR');
11083: l(' SELECT ps.PARTY_ID,');
11084: l(get_missing_denorm_attrib_cols('PARTY_SITES'));
11085: l(' FROM HZ_STAGED_PARTY_SITES ps');
11086: l(' WHERE mod(ps.PARTY_ID, p_num_workers) = p_worker_number ; ');
11087: l(' END;');
11088:
11089: l(' PROCEDURE update_stage_party_sites ( ');

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

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',
11469: 'CONTACT_POINTS','HZ_STAGED_CONTACT_POINTS') table_name,

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

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',
11472: 'CONTACT_POINTS','HZ_SRCH_CPTS')||'_N0'||substrb(staged_attribute_column,3) srch_index_name,