The following lines contain the word 'select', 'insert', 'update' or 'delete':
PROCEDURE update_master_flag(P_REQUEST_ID IN NUMBER,
P_SOURCE IN VARCHAR2,
p_column_name IN VARCHAR2,
p_id_list IN TYP_NEST_TAB_VARCHAR, p_upd_entire_tree_flag IN VARCHAR2);
PROCEDURE update_conflict_status(P_REQUEST_ID IN NUMBER,
P_SOURCE IN VARCHAR2);
PROCEDURE UPDATE_XSL_EXISTSNODE_STR ( P_REQUEST_ID IN NUMBER,
P_SOURCE IN VARCHAR2,
P_ATTR_NAME IN VARCHAR2,
P_ATTR_NEW_VALUE IN VARCHAR2,
P_PARENT_ATTR_NAME IN VARCHAR2,
P_UPDATE_XSL IN OUT NOCOPY VARCHAR2,
P_EXISTSNODE_STRING IN OUT NOCOPY VARCHAR2);
select NAME, code, REF, SOURCE
BULK COLLECT INTO
v_eo_name_List, v_eo_code_List, v_ref_eo_code_List, v_source_List
from (select extractValue(value(e),'/H/V[@N="EntityOccuranceName"]/text()') name,
extractValue(value(e),'/H/V[@N="EntityOccuranceCode"]/text()') code,
extractValue(value(e),'/H/V[@N="RefEntityOccuranceCode"]/text()') ref,
extractValue(value(e),'/H/S/text()') source,
to_number(extractValue(value(e),'/H/V[@N="SeqNum"]/text()')) seq_num
FROM az_requests d,TABLE(XMLSequence(extract(d.selection_set,'/EXT/H/V[@N="EntityOccuranceCode" and .="'||p_dependant_eo_code||'"]/..'))) e
where d.request_id=p_request_id AND d.request_type='T'
union all
select extractValue(value(e),'/H/V[@N="EntityOccuranceName"]/text()') name,
extractValue(value(e),'/H/V[@N="EntityOccuranceCode"]/text()') code,
extractValue(value(e),'/H/V[@N="RefEntityOccuranceCode"]/text()') ref,
extractValue(value(e),'/H/S/text()') source,
to_number(extractValue(value(e),'/H/V[@N="SeqNum"]/text()')) seq_num
FROM az_requests d,TABLE(XMLSequence(extract(d.selection_set,'/EXT/H[@A3="Y"]/V[@N="EntityOccuranceName" or @N="EntityOccuranceCode" or @N="RefEntityOccuranceCode"]/..'))) e
where d.request_id=p_request_id AND d.request_type='T' ) f
start with f.code=p_dependant_eo_code
connect by prior f.code=f.ref
order siblings by f.seq_num;
SELECT REQUIRED_API_ATTRIBUTE, DEPENDANT_API_ATTRIBUTE BULK COLLECT
INTO V_REQ_API_MAP_ATTR_NAME_LIST, V_DEP_API_MAP_ATTR_NAME_LIST
FROM AZ_API_DEPENDENCY_ATTRIBUTES
WHERE REQUIRED_API_CODE = P_REQUIRED_API_CODE
AND DEPENDANT_API_CODE = P_DEPENDANT_API_CODE;
SELECT ID BULK COLLECT
INTO V_PARENT_ID_LIST
FROM AZ_DIFF_RESULTS
WHERE REQUEST_ID = P_REQUEST_ID
AND SOURCE = P_REQUIRED_SOURCE
AND IS_TRANSFORMED = 'Y'
AND PARENT_ID =1; -- Newly added to ensure all top level VO's Childs are transformed
SELECT count (distinct (EXTRACTVALUE(VALUE(E), '/V/B/text()')))
into V_CHECK_TRFM_ALL_FLAG
FROM AZ_DIFF_RESULTS D,
TABLE(XMLSEQUENCE(EXTRACT(D.ATTR_DIFF, '/H/V'))) E
WHERE D.REQUEST_ID = P_REQUEST_ID
AND D.SOURCE = P_REQUIRED_SOURCE
AND D.IS_TRANSFORMED = 'Y'
AND D.TYPE <> -1
AND existsNode(VALUE(E),'/V[@A2="Y"]') = 1;
SELECT ID BULK COLLECT
INTO V_PARENT_ID_LIST
FROM AZ_DIFF_RESULTS
WHERE REQUEST_ID = P_REQUEST_ID
AND SOURCE = P_REQUIRED_SOURCE
AND IS_TRANSFORMED = 'Y'
AND PARENT_ID =1 ; -- Newly added to ensure all top level VO's Childs are transformed
SELECT ID BULK COLLECT
INTO V_PARENT_ID_LIST
FROM AZ_DIFF_RESULTS
WHERE REQUEST_ID = P_REQUEST_ID
AND SOURCE = P_REQUIRED_SOURCE
AND IS_TRANSFORMED = 'Y'
AND PARENT_ID =1 and rownum < 2;
SELECT EXTRACTVALUE(VALUE(E), '/V/@N'),
EXTRACTVALUE(VALUE(E), '/V/B/text()'),
EXTRACTVALUE(VALUE(E), '/V/A/text()') BULK COLLECT
INTO V_REQ_API_ATTR_NAME_LIST,
V_REQ_API_ATTR_NEW_VALUE_LIST,
V_REQ_API_ATTR_OLD_VALUE_LIST
FROM AZ_DIFF_RESULTS D,
TABLE(XMLSEQUENCE(EXTRACT(D.ATTR_DIFF, '/H/V'))) E
WHERE D.REQUEST_ID = P_REQUEST_ID
AND D.SOURCE = P_REQUIRED_SOURCE
AND D.IS_TRANSFORMED = 'Y'
AND D.ID = V_PARENT_ID_LIST(I)
AND D.TYPE <> -1
AND existsNode(VALUE(E),'/V[@A2="Y"]') = 1;
';
V_DEPENDANT_IDS_SQL := 'SELECT q.id FROM AZ_DIFF_RESULTS q ';
V_CHILD_XSL_STRING := V_CHILD_XSL_STRING ||'Y '||
V_REQ_API_ATTR_NEW_VALUE ||
' ';
V_CHILD_XSL_STRING := V_CHILD_XSL_STRING ||'Y '||
V_REQ_API_ATTR_NEW_VALUE ||
' ';
';
V_DEP_DETAIL_CHILD_IDS_SQL := V_DEP_DETAIL_CHILD_IDS_SQL || ' select id from' ;
V_DEP_DETAIL_CHILD_IDS_SQL := V_DEP_DETAIL_CHILD_IDS_SQL || ' select id, parent_id from ';
V_DEP_DETAIL_CHILD_IDS_SQL := V_DEP_DETAIL_CHILD_IDS_SQL || ' SELECT d.id id,';
V_TEMP_SQL := 'UPDATE az_diff_results q SET param3 = ''Y'', q.attr_diff = q.attr_diff.transform(xmltype('''||V_CONFLICT_XSL||''')).createSchemaBasedXml(''' ||
DIFF_SCHEMA_URL || ''') WHERE '|| ' q.id = ' || V_DEPENDANT_IDS_LIST(K)
||' AND q.request_id = '||P_REQUEST_ID||
' AND ' || V_EXISTSNODE_STRING || ' q.source = '''||p_dependant_source||'''';
select id BULK collect into V_CONFLICT_CHILD_IDS_LIST from (select id,parent_id from (SELECT d.id id,
d.parent_id parent_id
FROM az_diff_results d
WHERE d.request_id = P_REQUEST_ID
AND d.source = p_dependant_source
) f START WITH f.id = V_DEPENDANT_IDS_LIST(K) CONNECT BY PRIOR f.id = f.parent_id) ;
V_TEMP_SQL :='UPDATE az_diff_results q SET param3 = ''Y'', q.attr_diff = q.attr_diff.transform(xmltype('''||V_CONFLICT_XSL||''')).createSchemaBasedXml(''' ||
DIFF_SCHEMA_URL || ''') WHERE '|| ' q.id = ' || V_CONFLICT_CHILD_IDS_LIST(Y)
||' AND q.request_id = '||P_REQUEST_ID||
' AND '|| V_EXISTSNODE_STRING || ' q.source = '''||p_dependant_source||'''';
UPDATE_REGEN_REQD(P_REQUEST_ID, P_DEPENDANT_eo_code, p_dependant_source);
select id bulk collect into v_child_id_list
from az_diff_results where request_id=p_request_id and source=P_DEPENDANT_SOURCE
and param3 ='Y';
update_master_flag(p_request_id,P_DEPENDANT_SOURCE,'PARAM3',v_child_id_list,'Y');
update_conflict_status(p_request_id,P_DEPENDANT_SOURCE);
PROCEDURE UPDATE_REGEN_REQD(P_REQUEST_ID IN NUMBER,
P_DEPENDANT_eo_code IN VARCHAR2,
p_dependant_source IN VARCHAR2) IS
V_AUTO_SELECTED VARCHAR2(1);
SELECT EXTRACTVALUE(VALUE(E), '/H/@A2')
INTO V_AUTO_SELECTED
FROM AZ_REQUESTS D,
TABLE(XMLSEQUENCE(EXTRACT(D.SELECTION_SET,
'/EXT/H/V[@N="EntityOccuranceCode" and .="' || P_DEPENDANT_eo_code || '"]/..'))) E
WHERE D.REQUEST_ID = P_REQUEST_ID
AND D.REQUEST_TYPE = 'T';
SELECT COUNT(*)
INTO v_count
FROM az_diff_results
WHERE REQUEST_ID = P_REQUEST_ID
AND SOURCE = p_dependant_source
AND is_transformed='Y';
UPDATE AZ_REQUESTS D
SET D.SELECTION_SET = UPDATEXML(D.SELECTION_SET,
'/EXT/H[S="'||P_DEPENDANT_SOURCE||'"]/T/text()',v_count)
WHERE D.REQUEST_ID = P_REQUEST_ID
AND d.REQUEST_TYPE = 'T';
IF V_AUTO_SELECTED = 'Y' AND v_count>0 THEN
UPDATE AZ_REQUESTS D
SET D.SELECTION_SET = UPDATEXML(D.SELECTION_SET,
'/EXT/H/V[@N="EntityOccuranceCode" and .="' || P_DEPENDANT_eo_code || '"]/../@A4', 'Y')
WHERE D.REQUEST_ID = P_REQUEST_ID
AND D.REQUEST_TYPE = 'T';
ELSIF V_AUTO_SELECTED <> 'Y' AND v_count>0 THEN
SELECT EXTRACTVALUE(VALUE(E), '/H/V[@N="EntityOccuranceCode"]/text()'),
EXTRACTVALUE(VALUE(E), '/H/V[@N="RefEntityOccuranceCode"]/text()')
INTO V_EO_CODE, V_REF_EO_CODE
FROM AZ_REQUESTS D,
TABLE(XMLSEQUENCE(EXTRACT(D.SELECTION_SET,
'/EXT/H/V[@N="EntityOccuranceCode" and .="' || P_DEPENDANT_eo_code || '"]/..'))) E
WHERE D.REQUEST_ID = P_REQUEST_ID
AND D.REQUEST_TYPE = 'T';
SELECT EXTRACTVALUE(VALUE(E),
'/H/V[@N="EntityOccuranceCode"]/text()'),
EXTRACTVALUE(VALUE(E),
'/H/V[@N="RefEntityOccuranceCode"]/text()'),
EXTRACTVALUE(VALUE(E), '/H/@A2')
INTO V_EO_CODE, V_REF_EO_CODE, V_AUTO_SELECTED
FROM AZ_REQUESTS D,
TABLE(XMLSEQUENCE(EXTRACT(D.SELECTION_SET,
'/EXT/H/V[@N="EntityOccuranceCode" and .="' ||
V_REF_EO_CODE || '"]/..'))) E
WHERE D.REQUEST_ID = P_REQUEST_ID
AND D.REQUEST_TYPE = 'T';
IF V_AUTO_SELECTED = 'Y' THEN
UPDATE AZ_REQUESTS D
SET D.SELECTION_SET = UPDATEXML(D.SELECTION_SET,
'/EXT/H/V[@N="EntityOccuranceCode" and .="' ||
V_EO_CODE || '"]/../@A4',
'Y')
WHERE D.REQUEST_ID = P_REQUEST_ID
AND D.REQUEST_TYPE = 'T';
RAISE_ERROR_MSG(SQLCODE, SQLERRM, 'UPDATE_REGEN_REQD', 'procedure end');
END UPDATE_REGEN_REQD;
SELECT REQUIRED_API_ATTRIBUTE, DEPENDANT_API_ATTRIBUTE BULK COLLECT
INTO V_REQ_API_ATTR_LIST, V_DEP_API_ATTR_LIST
FROM AZ_API_DEPENDENCY_ATTRIBUTES
WHERE REQUIRED_API_CODE = P_REQUIRED_API_CODE
AND DEPENDANT_API_CODE = P_DEPENDANT_API_CODE;
V_UPDATE_XSL CLOB := '';
SELECT entity_occurance_code,
ref_entity_occurance_code,
SOURCE,
entity_code,
split_flag BULK COLLECT
INTO v_eo_code_list,
v_ref_eo_code_list,
v_source_list,
v_entity_code_list,
v_split_flag_list
FROM ( SELECT extractvalue(VALUE(e),
'/H/V[@N="EntityOccuranceName"]/text()'),
extractvalue(VALUE(e),
'/H/V[@N="EntityOccuranceCode"]/text()') entity_occurance_code,
extractvalue(VALUE(e),
'/H/V[@N="RefEntityOccuranceCode"]/text()') ref_entity_occurance_code,
extractvalue(VALUE(e),
'/H/V[@N="EntityCode"]/text()') entity_code,
extractvalue(VALUE(e),'/H/S/text()') SOURCE,
nvl(extractvalue(VALUE(e),'/H/@A3'),'N') split_flag
FROM az_requests d,
TABLE(xmlsequence(extract(d.selection_set,
'/EXT/H'))) e
WHERE existsnode(VALUE(e),
'/H/V[@N="EntityOccuranceName" or @N="EntityOccuranceCode" or @N="RefEntityOccuranceCode"]') = 1
AND
existsnode(VALUE(e),
'/H[@A2="Y" or @A3="Y" or @A1="Y"]') = 1
AND d.job_name = p_job_name
AND d.request_type = 'T'
AND d.user_id = p_user_id
)
START WITH SOURCE = p_source
CONNECT BY PRIOR entity_occurance_code = ref_entity_occurance_code;
SELECT extractvalue(VALUE(e),
'/V/@N'),
extract(VALUE(e),
'/V/text()').getstringval() BULK COLLECT
INTO v_attribute_name_list, v_attribute_value_list
FROM az_requests d,
TABLE(xmlsequence(extract(d.selection_set,
'/EXT/H/S[.="' || p_source ||
'"]/../V[@T="1"]'))) e
WHERE job_name = p_job_name
AND user_id = p_user_id
AND request_type = 'T';
V_UPDATE_XSL := '';
V_UPDATE_XSL := V_UPDATE_XSL ||'Y
'
||v_attribute_value_list(j)||' ';
IF LENGTH(V_UPDATE_XSL)>0
THEN
--LMATHUR -- added to prevent the varchar overflow for Xmltype
V_UPDATE_XSL := '
'||V_UPDATE_XSL;
V_UPDATE_XSL := V_UPDATE_XSL ||'
';
EXECUTE IMMEDIATE v_transform_all_sql using V_UPDATE_XSL;
select d.id bulk collect into V_CHILD_ID_LIST
from az_diff_results d where d.request_id=p_request_id and d.source=p_source
and d.param2 = 'Y';
update_master_flag(p_request_id,v_source_list(i),'IS_TRANSFORMED',v_child_id_list,'N');
V_UPDATE_XSL :='';
SELECT ID bulk collect into v_master_ids_trans_list FROM AZ_DIFF_RESULTS
WHERE REQUEST_ID = p_request_id
AND SOURCE = p_source AND parent_id = 1;
SELECT f.api_code
INTO v_parent_api_code
FROM az_requests d,
TABLE(xmlsequence(extract(d.selection_set,
'/EXT/H'))) e,
az_structure_apis_b f
WHERE existsnode(VALUE(e),
'/H/V[@N="EntityOccuranceName" or @N="EntityOccuranceCode" or @N="RefEntityOccuranceCode"]') = 1
-- AND existsnode(VALUE(e),
-- '/H/V[@N="SelectionFlag" and .="Y"]') = 1
AND extractvalue(VALUE(e),
'/H/V[@N="EntityOccuranceCode" and .="' ||
v_ref_eo_code_list(i) ||
'"]/../V[@N="EntityCode"]/text()') =
f.entity_code
AND extractvalue(d.selection_set,
'/EXT/H[N="SelectionSetsVO"]/V[@N="StructureCode"]/text()') =
f.structure_code
AND d.job_name = p_job_name
AND d.request_type = 'T'
AND d.user_id = p_user_id;
SELECT f.api_code
INTO v_current_api_code
FROM az_requests d,
TABLE(xmlsequence(extract(d.selection_set,
'/EXT/H'))) e,
az_structure_apis_b f
WHERE existsnode(VALUE(e),
'/H/V[@N="EntityOccuranceName" or @N="EntityOccuranceCode" or @N="RefEntityOccuranceCode"]') = 1
-- AND existsnode(VALUE(e),
-- '/H/V[@N="SelectionFlag" and .="Y"]') = 1
AND extractvalue(VALUE(e),
'/H/V[@N="EntityOccuranceCode" and .="' ||
v_eo_code_list(i) ||
'"]/../V[@N="EntityCode"]/text()') =
f.entity_code
AND extractvalue(d.selection_set,
'/EXT/H[N="SelectionSetsVO"]/V[@N="StructureCode"]/text()') =
f.structure_code
AND d.job_name = p_job_name
AND d.request_type = 'T'
AND d.user_id = p_user_id;
SELECT REQUIRED_API_ATTRIBUTE, DEPENDANT_API_ATTRIBUTE BULK COLLECT
INTO V_REQ_API_MAP_ATTR_NAME_LIST, V_DEP_API_MAP_ATTR_NAME_LIST
FROM AZ_API_DEPENDENCY_ATTRIBUTES
WHERE REQUIRED_API_CODE = v_parent_api_code
AND DEPENDANT_API_CODE = v_current_api_code;
UPDATE_XSL_EXISTSNODE_STR(p_request_id, v_ref_eo_code_list(i), v_child_attribute_name_list(v_child_count),v_attribute_value_list(j), v_attribute_name_list(j), V_UPDATE_XSL,V_EXISTSNODE_STRING);
UPDATE_XSL_EXISTSNODE_STR(p_request_id, v_ref_eo_code_list(i), v_attribute_name_list(j),v_attribute_value_list(j),v_attribute_name_list(j), V_UPDATE_XSL,V_EXISTSNODE_STRING);
IF LENGTH(V_UPDATE_XSL)>0
THEN
V_UPDATE_XSL := '
'||V_UPDATE_XSL;
V_UPDATE_XSL := V_UPDATE_XSL ||'
';
EXECUTE IMMEDIATE v_transform_all_sql using V_UPDATE_XSL;
select d.id bulk collect into V_CHILD_ID_LIST
from az_diff_results d where d.request_id=p_request_id and d.source=v_source_list(i)
and d.param2 = 'Y';
update_master_flag(p_request_id,v_source_list(i),'IS_TRANSFORMED',v_child_id_list,'N');
V_UPDATE_XSL :='';
update_regen_reqd(p_request_id,
v_eo_code_list(i),
v_source_list(i));
PROCEDURE UPDATE_XSL_EXISTSNODE_STR ( P_REQUEST_ID IN NUMBER,
P_SOURCE IN VARCHAR2,
P_ATTR_NAME IN VARCHAR2,
P_ATTR_NEW_VALUE IN VARCHAR2,
P_PARENT_ATTR_NAME IN VARCHAR2,
P_UPDATE_XSL IN OUT NOCOPY VARCHAR2,
P_EXISTSNODE_STRING IN OUT NOCOPY VARCHAR2) IS
v_child_attribute_value_list typ_nest_tab_varchar := typ_nest_tab_varchar();
P_UPDATE_XSL := P_UPDATE_XSL ||'Y
'
||P_ATTR_NEW_VALUE||' ';
END UPDATE_XSL_EXISTSNODE_STR;
'update az_diff_results e set e.param2 = ''Y'',';
V_TRANSFORM_SQL := V_TRANSFORM_SQL ||' e.attr_diff = (select d.attr_diff.transform( xmltype('' ';
' ';
v_transform_sql := v_transform_sql || ' ';
' ';
v_transform_all_sql := 'update az_diff_results e set e.param2 = ''Y'', e.attr_diff =e.attr_diff.transform( xmltype(:1';
SELECT EXTRACTVALUE(VALUE(E), '/V/@N'),
EXTRACTVALUE(VALUE(E), '/V/B/text()'),
EXTRACTVALUE(VALUE(E), '/V/A/text()') BULK COLLECT
INTO v_attr_name_list,
v_attr_new_value_list,
v_attr_old_value_list
FROM AZ_DIFF_RESULTS D,
TABLE(XMLSEQUENCE(EXTRACT(D.ATTR_DIFF, '/H/V'))) E
WHERE D.REQUEST_ID = p_request_id
AND D.SOURCE = p_source
AND D.param2 = 'Y'
AND D.ID = P_ID
AND D.TYPE <> -1
AND existsNode(VALUE(E),'/V[@A2="Y"]') = 1;
SELECT id BULK COLLECT INTO v_child_id_list
FROM
(SELECT d.id id,
d.parent_id parent_id
FROM az_diff_results d
WHERE d.request_id = p_request_id
AND d.source = p_source)
f START WITH f.id = P_ID CONNECT BY PRIOR f.id = f.parent_id
ORDER BY f.parent_id;
UPDATE az_diff_results d
SET d.attr_diff = updatexml(d.attr_diff, '/H/V[@N="'||v_attr_name_list(i)||'" and ./A/text()="'||v_attr_old_value_list(i)||'"]/B/text()',v_attr_new_value_list(i) )
WHERE existsnode(d.attr_diff, '/H/V[@N="'||v_attr_name_list(i)||'" and ./A/text()="'||v_attr_old_value_list(i)||'"]') = 1
AND d.request_id = p_request_id
AND d.source = p_source
AND d.id = v_child_id_list(j);
'||V_CONFLICT_XSL||
'
';
V_QUERY_STR := 'UPDATE az_diff_results d
SET d.attr_diff = d.attr_diff.transform(xmltype('''||V_CONFLICT_XSL||''') ).createSchemaBasedXML('''||p_diff_schema_url||''')
WHERE '||V_EXISTSNODE_STRING||'
AND d.request_id ='|| p_request_id||'
AND d.source ='''|| p_source||'''
AND d.id = '||v_child_id_list(j);
update_master_flag(p_request_id,p_source,'IS_TRANSFORMED',v_child_id_list,'N');
update_master_flag(p_request_id,p_source,'PARAM3',v_child_id_list,'Y');
update_conflict_status(p_request_id,P_SOURCE);
PROCEDURE update_master_flag(P_REQUEST_ID IN NUMBER,
P_SOURCE IN VARCHAR2,
p_column_name IN VARCHAR2,
p_id_list IN TYP_NEST_TAB_VARCHAR,
p_upd_entire_tree_flag IN VARCHAR2 ) IS
v_entire_tree_string varchar2(255) := ' k.parent_id = 1 AND ';
v_has_conflicts_sql := 'select ' || v_additional_where_clause || '
from az_diff_results d
WHERE d.request_id = '||p_request_id||'
AND d.source = '''||p_source||'''
AND d.id =' || p_id_list(i) || '';
EXECUTE IMMEDIATE 'UPDATE az_diff_results g
SET g.'||p_column_name||' = ''Y''
WHERE g.id in
(SELECT k.id
FROM
(SELECT parent_id, id, '||p_column_name||'
FROM
(SELECT d.parent_id, d.id, d.'||p_column_name||'
FROM az_diff_results d
WHERE d.request_id = '||p_request_id||'
AND d.source = '''||p_source||'''
AND d.parent_id >0) f
CONNECT BY PRIOR f.parent_id = f.id START WITH f.id = '||p_id_list(i)||') k
WHERE '||v_entire_tree_string||' (k.'||p_column_name||' IS NULL OR k.'||p_column_name||' <> ''Y''))
AND g.request_id = '||p_request_id||'
AND g.source = '''||p_source||'''';
END update_master_flag;
PROCEDURE update_conflict_status(P_REQUEST_ID IN NUMBER, P_SOURCE IN VARCHAR2) IS
v_count number := 0;
select count(1) into v_count from az_diff_results e where request_id= p_request_id
and source = p_source and existsnode(e.attr_diff,'/H/V[@A1="Y"]')=1;
select count(1) into v_count from az_diff_results e where request_id= p_request_id
and source = p_source and existsnode(e.attr_diff,'/H/V[@A1="Y" and (./A/text()=./B/text())]') = 1;
EXECUTE IMMEDIATE 'UPDATE az_requests g
SET g.selection_set = updateXML(g.selection_set, ''/EXT/H/V[@N="EntityOccuranceCode" and .="'|| P_SOURCE||'"]/../@A5'',decode('||v_count||',0,''Y'',''C'') )
WHERE g.request_id = '||p_request_id||' and request_type=''T''';
'UPDATE_CONFLICT_STATUS: Could not update the conflict status for Source:'||p_source,
'UPDATE_CONFLICT_STATUS');
END update_conflict_status;