[Home] [Help]
The following lines contain the word 'select', 'insert', 'update' or 'delete':
select count(*) into l_count
from hz_dup_set_parties
where dup_set_id = P_DUP_SET_ID
and merge_flag = 'N' ;
select count(*) into l_count
from hz_dup_set_parties
where dup_set_id = P_DUP_SET_ID
and dup_party_id <> p_winner_party_id;
select score
from hz_dup_set_parties
where dup_set_id = l_dup_set_id
and dup_party_id = l_winner_party_id;
select dup_party_id, score
from hz_dup_set_parties
where dup_set_id = l_dup_set_id
and decode(p_state, 'S', merge_flag, 'E', 'N') = 'N'
and dup_party_id <> l_winner_party_id;
select hz_merge_batch_s.nextval into l_new_dup_set_id from dual;
insert into hz_dup_sets(winner_party_id, dup_batch_id, dup_set_id, status, merge_type,
object_version_number, created_by, creation_date, last_update_login, last_update_date, last_updated_by)
values( p_winner_party_id, p_new_dup_batch_id, l_new_dup_set_id, 'SYSBATCH', 'PARTY_MERGE',
1,
HZ_UTILITY_V2PUB.CREATED_BY,
HZ_UTILITY_V2PUB.CREATION_DATE, HZ_UTILITY_V2PUB.LAST_UPDATE_LOGIN,
HZ_UTILITY_V2PUB.LAST_UPDATE_DATE,
HZ_UTILITY_V2PUB.LAST_UPDATED_BY);
insert into hz_dup_set_parties(dup_party_id, dup_set_id, merge_flag, score, created_by,
creation_date, last_update_login, last_update_date, last_updated_by,dup_set_batch_id) --Bug No: 4244529
values (p_winner_party_id, l_new_dup_set_id, 'N', l_w_score, HZ_UTILITY_V2PUB.CREATED_BY,
HZ_UTILITY_V2PUB.CREATION_DATE, HZ_UTILITY_V2PUB.LAST_UPDATE_LOGIN,
HZ_UTILITY_V2PUB.LAST_UPDATE_DATE, HZ_UTILITY_V2PUB.LAST_UPDATED_BY,p_new_dup_batch_id) ; --Bug No: 4244529
insert into hz_dup_set_parties(dup_party_id, dup_set_id, merge_flag, score, created_by,
creation_date, last_update_login, last_update_date, last_updated_by,dup_set_batch_id) --Bug No: 4244529
values (l_dup_party_id(I), l_new_dup_set_id, 'N', l_score(I), HZ_UTILITY_V2PUB.CREATED_BY,
HZ_UTILITY_V2PUB.CREATION_DATE, HZ_UTILITY_V2PUB.LAST_UPDATE_LOGIN,
HZ_UTILITY_V2PUB.LAST_UPDATE_DATE, HZ_UTILITY_V2PUB.LAST_UPDATED_BY,p_new_dup_batch_id) ; --Bug No: 4244529
procedure delete_non_am_dup_set(p_dup_set_id number, p_all_cnt number, p_non_am_cnt number) is
begin
if p_all_cnt = p_non_am_cnt -- no automerge candidates in the set
then
DELETE FROM HZ_DUP_SETS
where DUP_SET_ID = p_DUP_SET_ID;
delete from hz_dup_set_parties
where dup_set_id = p_dup_set_id;
select 'Y'
from hz_dup_sets
where dup_batch_id = p_dup_batch_id
and status = 'SYSBATCH'
and rownum = 1;
SELECT object_version_number
FROM hz_dup_sets
WHERE dup_set_id = cp_dup_set_id;
select count(*)
from hz_parties p, hz_dup_set_parties mp
where p.party_id = mp.dup_party_id
and mp.dup_set_id = cp_dup_set_id
and p.status = 'A'
and nvl(mp.merge_flag,'Y') = 'Y';
select a.dup_batch_name, a.match_rule_id,
decode(a.request_type, 'SYSTEM_GENERATED', 'SYSTEM_AUTOMERGE', 'IMPORT', 'IMPORT_AUTOMERGE'), a.request_type, b.automerge_flag
into l_batch_name, l_match_rule_id, l_req_type, l_request_type, l_automerge_flag
from hz_dup_batch a, hz_match_rules_b b
where a.dup_batch_id = p_dup_batch_id
and a.match_rule_id = b.match_rule_id;
OPEN c1 FOR SELECT dup_set_id, winner_party_id
FROM hz_dup_sets
WHERE dup_batch_id = p_dup_batch_id
and status = 'SYSBATCH';
l_prof_value := nvl(fnd_profile.value('HZ_AUTOMERGE_WINNER_SELECT_RULE'), 'KEEP_EARLIEST_CREATED'); -- creae new profile and change code accordingly
l_sql_stmt1 := 'select dup_party_id
from hz_dup_set_parties a, hz_parties b
where a.dup_set_id = :1
and a.dup_party_id = b.party_id
and nvl(merge_flag, ''Y'') = ''Y''
and rownum = 1
order by b.creation_date asc ' ;
l_sql_stmt1 := 'select dup_party_id
from hz_dup_set_parties a, hz_parties b
where a.dup_set_id = :1
and a.dup_party_id = b.party_id
and nvl(merge_flag, ''Y'') = ''Y''
and rownum = 1
order by b.creation_date desc ' ;
update hz_dup_batch
set dup_batch_name = 'AM: ' ||substr(l_batch_name, 1, 250)
where dup_batch_id = p_dup_batch_id;
select hz_dup_batch_s.nextval into l_new_dup_batch_id from dual;
insert into hz_dup_batch(dup_batch_id, dup_batch_name, match_rule_id, request_type,
created_by, creation_date, last_update_login, last_update_date,
last_updated_by, application_id)
values(l_new_dup_batch_id, l_batch_name, l_match_rule_id, l_req_type,
HZ_UTILITY_V2PUB.CREATED_BY, HZ_UTILITY_V2PUB.CREATION_DATE, HZ_UTILITY_V2PUB.LAST_UPDATE_LOGIN,
HZ_UTILITY_V2PUB.LAST_UPDATE_DATE, HZ_UTILITY_V2PUB.LAST_UPDATED_BY,
HZ_UTILITY_V2PUB.APPLICATION_ID);
update hz_dup_sets c
set c.winner_party_id = l_winner_party_id(I)
where c.dup_set_id = A_DUP_SET_ID(I);
update hz_dup_set_parties
set merge_flag = 'Y'
where dup_set_id = A_DUP_SET_ID(I)
and dup_party_id = l_winner_party_id(I); */
update hz_dup_sets set status = 'AM_QUEUE' where dup_set_id = A_DUP_SET_ID(I);
delete_non_am_dup_set(A_DUP_SET_ID(I), l_all_count, l_count);
update hz_dup_sets set status = 'AM_QUEUE' where dup_set_id = A_DUP_SET_ID(I);
update hz_dup_sets set status = 'CREATION_ERROR' where dup_set_id = A_DUP_SET_ID(I);
select count(*) into J
from hz_dup_sets
where status = 'AM_QUEUE'
and dup_batch_id = p_dup_batch_id;
FOR TX IN (select dup_set_id
from hz_dup_sets
where status = 'AM_QUEUE'
and rownum <= l_no_of_workers
and dup_batch_id = p_dup_batch_id)
LOOP
-- call party merge
-- log(' Calling party merge for following DUP_SET_ID = '|| TX.DUP_SET_ID);