DBA Data[Home] [Help]

APPS.HZ_PARTY_STAGE dependencies on HZ_STAGED_CONTACTS

Line 156: and b.staged_attribute_table = 'HZ_STAGED_CONTACTS'

152: where a.entity_name = 'CONTACTS'
153: and nvl(a.denorm_flag,'N') = 'Y'
154: and a.attribute_id = b.attribute_id
155: and nvl( b.active_flag, 'Y') = 'Y'
156: and b.staged_attribute_table = 'HZ_STAGED_CONTACTS'
157: )
158: LOOP
159: row_count := row_count + 1 ;
160: IF row_count > 1

Line 274: and b.staged_attribute_table = 'HZ_STAGED_CONTACTS'

270: where a.entity_name = 'CONTACTS'
271: and nvl(a.denorm_flag,'N') = 'Y'
272: and a.attribute_id = b.attribute_id
273: and nvl( b.active_flag, 'Y') = 'Y'
274: and b.staged_attribute_table = 'HZ_STAGED_CONTACTS'
275:
276: )
277: LOOP
278: -- if any attribute columns do not exist in the preference

Line 383: log('Truncating HZ_STAGED_CONTACTS .. ', FALSE);

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';
385: log('Done');
386:
387: log('Truncating HZ_STAGED_CONTACT_POINTS .. ', FALSE);

Line 384: EXECUTE IMMEDIATE 'TRUNCATE TABLE '||l_owner||'.HZ_STAGED_CONTACTS';

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';
385: log('Done');
386:
387: log('Truncating HZ_STAGED_CONTACT_POINTS .. ', FALSE);
388: EXECUTE IMMEDIATE 'TRUNCATE TABLE '||l_owner||'.HZ_STAGED_CONTACT_POINTS';

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 1236: 'CONTACTS','HZ_STAGED_CONTACTS',

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;
1240:

Line 1391: outandlog('The estimated disk space required for HZ_STAGED_CONTACTS = ' ||reco_staging_contacts || 'MB' );

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

Line 1401: gather_stats(l_index_owner, 'HZ_STAGED_CONTACTS');

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;
1405:

Line 2238: SELECT 1 INTO T FROM HZ_STAGED_CONTACTS

2234: END IF;
2235: END;
2236:
2237: BEGIN
2238: SELECT 1 INTO T FROM HZ_STAGED_CONTACTS
2239: WHERE ROWNUM=1
2240: AND CONTAINS (concat_col, 'dummy_string')>0;
2241: EXCEPTION
2242: WHEN NO_DATA_FOUND THEN

Line 3543: from hz_staged_contacts;

3539: IF (new_primary_trans('CONTACTS')) THEN
3540: BEGIN
3541: select min(org_contact_id), max(org_contact_id)
3542: into l_min_id, l_max_id
3543: from hz_staged_contacts;
3544: WHILE (l_min_id <= l_max_id )
3545: LOOP
3546: select org_contact_id into tmp
3547: from (

Line 3550: from hz_staged_contacts

3546: select org_contact_id into tmp
3547: from (
3548: select org_contact_id, rownum rnum
3549: from ( SELECT org_contact_id
3550: from hz_staged_contacts
3551: where org_contact_id > l_min_id
3552: and rownum<1001 ) a )
3553: where rnum = 1000;
3554: update hz_staged_contacts set concat_col = concat_col

Line 3554: update hz_staged_contacts set concat_col = concat_col

3550: from hz_staged_contacts
3551: where org_contact_id > l_min_id
3552: and rownum<1001 ) a )
3553: where rnum = 1000;
3554: update hz_staged_contacts set concat_col = concat_col
3555: where org_contact_id between l_min_id and tmp;
3556: FND_FILE.put_line(FND_FILE.log, 'Attempting to SYNC the hz_stage_contact_t1 index');
3557: AD_CTX_DDL.sync_index(l_index_owner||'.hz_stage_contact_t1');
3558: FND_FILE.put_line(FND_FILE.log, 'SYNC of the hz_stage_contact_t1 index successful');

Line 3564: update hz_staged_contacts set concat_col = concat_col

3560: l_min_id:=tmp+1;
3561: END LOOP;
3562: EXCEPTION
3563: WHEN NO_DATA_FOUND THEN
3564: update hz_staged_contacts set concat_col = concat_col
3565: where org_contact_id between l_min_id and l_max_id ;
3566: FND_FILE.put_line(FND_FILE.log, 'Attempting to SYNC the hz_stage_contact_t1 index');
3567: AD_CTX_DDL.sync_index(l_index_owner||'.hz_stage_contact_t1');
3568: FND_FILE.put_line(FND_FILE.log, 'SYNC of the hz_stage_contact_t1 index successful');

Line 3902: log(' Creating hz_stage_contact_t1 on hz_staged_contacts. ');

3898:
3899: l_section_grp := g_schema_name || '.HZ_DQM_CONTACT_GRP';
3900:
3901: IF l_command <> 'STAGE_NEW_TRANSFORMATIONS' THEN
3902: log(' Creating hz_stage_contact_t1 on hz_staged_contacts. ');
3903: log(' Index Memory ' || p_idx_mem);
3904: log(' Starting at ' || to_char(SYSDATE, 'HH24:MI:SS'));
3905:
3906: EXECUTE IMMEDIATE 'CREATE INDEX ' || l_index_owner || '.hz_stage_contact_t1 ON ' ||l_index_owner ||

Line 3907: '.hz_staged_contacts(concat_col) indextype is ctxsys.context ' ||

3903: log(' Index Memory ' || p_idx_mem);
3904: log(' Starting at ' || to_char(SYSDATE, 'HH24:MI:SS'));
3905:
3906: EXECUTE IMMEDIATE 'CREATE INDEX ' || l_index_owner || '.hz_stage_contact_t1 ON ' ||l_index_owner ||
3907: '.hz_staged_contacts(concat_col) indextype is ctxsys.context ' ||
3908: 'parameters (''storage '||g_schema_name || '.HZ_DQM_STORAGE datastore '||g_schema_name || '.hz_contact_ds ' ||
3909: '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 ' '
3910: END;
3911: ELSE

Line 3912: log(' Attempting to drop and create hz_stage_contact_t1 on hz_staged_contacts with new transformations.');

3908: 'parameters (''storage '||g_schema_name || '.HZ_DQM_STORAGE datastore '||g_schema_name || '.hz_contact_ds ' ||
3909: '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 ' '
3910: END;
3911: ELSE
3912: log(' Attempting to drop and create hz_stage_contact_t1 on hz_staged_contacts with new transformations.');
3913: log(' Index Memory ' || p_idx_mem);
3914: log(' Starting at ' || to_char(SYSDATE, 'HH24:MI:SS') );
3915:
3916: BEGIN

Line 3927: '.hz_staged_contacts(concat_col) indextype is ctxsys.context ' ||

3923:
3924: END ;
3925:
3926: EXECUTE IMMEDIATE 'CREATE INDEX ' || l_index_owner || '.hz_stage_contact_t1 ON ' ||l_index_owner ||
3927: '.hz_staged_contacts(concat_col) indextype is ctxsys.context ' ||
3928: 'parameters (''storage '||g_schema_name || '.HZ_DQM_STORAGE datastore '||g_schema_name || '.hz_contact_ds ' ||
3929: '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 ' '
3930: END;
3931: log('Created hz_stage_contact_t1');

Line 4188: l(' UPDATE HZ_STAGED_CONTACTS SET ');

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 ');
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 ');

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

4592: l(' RETURN NULL;');
4593: l(' END;');
4594: ELSE
4595: l(' CURSOR P IS');
4596: l(' SELECT '||proc_cols||' FROM '||uname||'.HZ_STAGED_CONTACTS WHERE ROWID=rid;');
4597: l(' val CLOB;');
4598: l(' BEGIN');
4599: l(' val:=null;');
4600: l(' FOR rec in P LOOP');

Line 4669: l(' FROM '||uname||'.HZ_STAGED_CONTACTS');

4665: l(' '||l_attr ||'||'' ''||');
4666: END LOOP;
4667: CLOSE l_ent_cur;
4668: l(' '' ''');
4669: l(' FROM '||uname||'.HZ_STAGED_CONTACTS');
4670: l(' WHERE party_id = cp_party_id;');
4671: l(' l_buffer VARCHAR2(4000);');
4672: l(' l_den_ct VARCHAR2(2000);');
4673: l(' BEGIN');

Line 8067: l(' log (''Inserting Data into HZ_STAGED_CONTACTS...'',FALSE); ');

8063: l(' l_en := H_ORG_CONTACT_ID.COUNT; ');
8064: l('');
8065: l(' IF p_operation = ''C'' THEN ');
8066: l(' BEGIN ');
8067: l(' log (''Inserting Data into HZ_STAGED_CONTACTS...'',FALSE); ');
8068: l(' FORALL I in l_st..l_en SAVE EXCEPTIONS ');
8069: l(' INSERT INTO HZ_STAGED_CONTACTS (');
8070: l(' ORG_CONTACT_ID');
8071: l(' ,PARTY_ID');

Line 8069: l(' INSERT INTO HZ_STAGED_CONTACTS (');

8065: l(' IF p_operation = ''C'' THEN ');
8066: l(' BEGIN ');
8067: l(' log (''Inserting Data into HZ_STAGED_CONTACTS...'',FALSE); ');
8068: l(' FORALL I in l_st..l_en SAVE EXCEPTIONS ');
8069: l(' INSERT INTO HZ_STAGED_CONTACTS (');
8070: l(' ORG_CONTACT_ID');
8071: l(' ,PARTY_ID');
8072: l(' ,STATUS_FLAG '); --Propagating Bug 4299785 fix to sync modifications
8073: FOR I IN 1..255 LOOP

Line 8115: l(' log (''Updating Data in HZ_STAGED_CONTACTS...'',FALSE); ');

8111: l(' END LOOP; ');
8112: l(' END; ');
8113: l(' ELSIF p_operation = ''U'' THEN ');
8114: l(' BEGIN ');
8115: l(' log (''Updating Data in HZ_STAGED_CONTACTS...'',FALSE); ');
8116: l(' FORALL I in l_st..l_en SAVE EXCEPTIONS ');
8117: l(' UPDATE HZ_STAGED_CONTACTS SET ');
8118: l(' concat_col = concat_col');
8119: l(' ,status_flag = H_STATUS(I)'); --Propagating Bug 4299785 fix to sync modifications

Line 8117: l(' UPDATE HZ_STAGED_CONTACTS SET ');

8113: l(' ELSIF p_operation = ''U'' THEN ');
8114: l(' BEGIN ');
8115: l(' log (''Updating Data in HZ_STAGED_CONTACTS...'',FALSE); ');
8116: l(' FORALL I in l_st..l_en SAVE EXCEPTIONS ');
8117: l(' UPDATE HZ_STAGED_CONTACTS SET ');
8118: l(' concat_col = concat_col');
8119: l(' ,status_flag = H_STATUS(I)'); --Propagating Bug 4299785 fix to sync modifications
8120:
8121: FOR I IN 1..255 LOOP

Line 8518: l(' INSERT INTO HZ_STAGED_CONTACTS (');

8514: l(' l_en := H_C_PARTY_ID.COUNT; ');
8515: l(' LOOP ');
8516: l(' BEGIN ');
8517: l(' FORALL I in l_st..l_en');
8518: l(' INSERT INTO HZ_STAGED_CONTACTS (');
8519: l(' ORG_CONTACT_ID');
8520: l(' ,PARTY_ID');
8521: l(' ,STATUS_FLAG '); --Bug No: 4299785
8522:

Line 8641: l(' INSERT INTO HZ_STAGED_CONTACTS (');

8637: l(' WHILE (l_tryins OR l_tryupd) LOOP');
8638: l(' IF l_tryins THEN');
8639: l(' BEGIN');
8640: l(' l_tryins:=FALSE;');
8641: l(' INSERT INTO HZ_STAGED_CONTACTS (');
8642: l(' ORG_CONTACT_ID');
8643: l(' ,PARTY_ID');
8644: l(' ,STATUS_FLAG '); --Bug No: 4299785
8645:

Line 8672: l(' UPDATE HZ_STAGED_CONTACTS SET ');

8668: l(' END IF;');
8669: l(' IF l_tryupd THEN');
8670: l(' BEGIN');
8671: l(' l_tryupd:=FALSE;');
8672: l(' UPDATE HZ_STAGED_CONTACTS SET ');
8673: l(' concat_col = concat_col');
8674: l(' ,status_flag = H_STATUS(1)'); --Bug No: 4299785
8675:
8676: FOR I IN 1..255 LOOP

Line 8811: l(' INSERT INTO HZ_STAGED_CONTACTS (');

8807: l(' WHILE (l_tryins OR l_tryupd) LOOP');
8808: l(' IF l_tryins THEN');
8809: l(' BEGIN');
8810: l(' l_tryins:=FALSE;');
8811: l(' INSERT INTO HZ_STAGED_CONTACTS (');
8812: l(' ORG_CONTACT_ID');
8813: l(' ,PARTY_ID');
8814: l(' ,STATUS_FLAG'); --Bug No: 4299785
8815:

Line 8843: l(' UPDATE HZ_STAGED_CONTACTS SET ');

8839: l('');
8840: l(' IF l_tryupd THEN');
8841: l(' BEGIN');
8842: l(' l_tryupd:=FALSE;');
8843: l(' UPDATE HZ_STAGED_CONTACTS SET ');
8844: l(' concat_col = concat_col');
8845: l(' ,status_flag = H_STATUS(1) ');--Bug No: 4299785
8846:
8847: FOR I IN 1..255 LOOP

Line 10605: l(' FROM HZ_STAGED_CONTACTS s, HZ_ORG_CONTACTS oc, ');

10601: l(' SELECT oc.ORG_CONTACT_ID ');
10602: FOR I in 1..l_select.COUNT LOOP
10603: l(' ,' || l_select(I));
10604: END LOOP;
10605: l(' FROM HZ_STAGED_CONTACTS s, HZ_ORG_CONTACTS oc, ');
10606: l(' HZ_RELATIONSHIPS r, HZ_PERSON_PROFILES pp');
10607: l(' WHERE mod(s.PARTY_ID, p_num_workers) = p_worker_number ');
10608: l(' AND s.ORG_CONTACT_ID=oc.ORG_CONTACT_ID');
10609: l(' AND oc.party_relationship_id = r.relationship_id ');

Line 10694: l(' UPDATE HZ_STAGED_CONTACTS SET ');

10690: END LOOP;
10691: l(' END LOOP;');
10692:
10693: l(' FORALL I in H_ORG_CONTACT_ID.FIRST..H_ORG_CONTACT_ID.LAST');
10694: l(' UPDATE HZ_STAGED_CONTACTS SET ');
10695: FIRST:=TRUE;
10696: FOR I IN 1..255 LOOP
10697: IF l_forall_list(I) <> 'N' THEN
10698: IF (FIRST) THEN

Line 10759: l(' FROM HZ_STAGED_CONTACTS ct');

10755: l(' BEGIN');
10756: l(' open x_contact_cur FOR');
10757: l(' SELECT ct.PARTY_ID,');
10758: l(get_missing_denorm_attrib_cols('CONTACTS'));
10759: l(' FROM HZ_STAGED_CONTACTS ct');
10760: l(' WHERE mod(ct.PARTY_ID, p_num_workers) = p_worker_number ; ');
10761: l(' END;');
10762:
10763: l('');

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,