The following lines contain the word 'select', 'insert', 'update' or 'delete':
SELECT distinct CUSTOMER_MERGE_HEADER_ID
,yt.COMMISSION_HEADER_ID
,yt.CUSTOMER_ID
,yt.BILL_TO_ADDRESS_ID
,yt.SHIP_TO_ADDRESS_ID
FROM CN_COMMISSION_HEADERS_ALL yt, ra_customer_merges m
WHERE (
yt.CUSTOMER_ID = m.DUPLICATE_ID
OR ((yt.BILL_TO_ADDRESS_ID = m.DUPLICATE_ADDRESS_ID)
AND
(m.duplicate_site_code = 'BILL_TO'))
OR ((yt.SHIP_TO_ADDRESS_ID = m.DUPLICATE_ADDRESS_ID)
AND
(m.duplicate_site_code = 'SHIP_TO'))
) AND ( m.process_flag = 'N' OR l_custmerge_profile_value = 'N')
AND m.request_id = req_id
AND m.set_number = set_num
;
SELECT distinct customer_id
FROM ra_customer_merges
WHERE set_number = set_num
AND request_id = req_id
AND duplicate_id = p_duplicate_cust_id;
SELECT distinct customer_address_id
FROM ra_customer_merges
WHERE set_number = set_num
AND request_id = req_id
AND duplicate_address_id = p_duplicate_addr_id;
SELECT distinct customer_site_id
FROM ra_customer_merges
WHERE set_number = set_num
AND request_id = req_id
AND duplicate_site_id = p_duplicate_site_id;
INSERT INTO HZ_CUSTOMER_MERGE_LOG
(
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID,
NUM_COL1_ORIG,
NUM_COL1_NEW,
NUM_COL2_ORIG,
NUM_COL2_NEW,
NUM_COL3_ORIG,
NUM_COL3_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
) VALUES ( HZ_CUSTOMER_MERGE_LOG_s.nextval,
'CN_COMMISSION_HEADERS',
MERGE_HEADER_ID_LIST(I),
PRIMARY_KEY_ID_LIST(I),
NUM_COL1_ORIG_LIST(I),
NUM_COL1_NEW_LIST(I),
NUM_COL2_ORIG_LIST(I),
NUM_COL2_NEW_LIST(I),
NUM_COL3_ORIG_LIST(I),
NUM_COL3_NEW_LIST(I),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
);
UPDATE CN_COMMISSION_HEADERS_ALL yt SET
CUSTOMER_ID=NUM_COL1_NEW_LIST(I)
,BILL_TO_ADDRESS_ID=NUM_COL2_NEW_LIST(I)
,SHIP_TO_ADDRESS_ID=NUM_COL3_NEW_LIST(I)
, LAST_UPDATE_DATE=SYSDATE
, last_updated_by=arp_standard.profile.user_id
, last_update_login=arp_standard.profile.last_update_login
WHERE COMMISSION_HEADER_ID=PRIMARY_KEY_ID_LIST(I)
;
arp_message.set_name('AR','AR_ROWS_UPDATED');
SELECT distinct CUSTOMER_MERGE_HEADER_ID
,yt.COMM_LINES_API_ID
,yt.CUSTOMER_ID
,yt.BILL_TO_ADDRESS_ID
,yt.SHIP_TO_ADDRESS_ID
FROM CN_COMM_LINES_API_ALL yt, ra_customer_merges m
WHERE (
yt.CUSTOMER_ID = m.DUPLICATE_ID
OR ((yt.BILL_TO_ADDRESS_ID = m.DUPLICATE_ADDRESS_ID)
AND
(m.duplicate_site_code = 'BILL_TO'))
OR ((yt.SHIP_TO_ADDRESS_ID = m.DUPLICATE_ADDRESS_ID)
AND
(m.duplicate_site_code = 'SHIP_TO'))
) AND ( m.process_flag = 'N' OR l_custmerge_profile_value = 'N')
AND m.request_id = req_id
AND m.set_number = set_num;
SELECT distinct customer_id
FROM ra_customer_merges
WHERE set_number = set_num
AND request_id = req_id
AND DUPLICATE_ID = p_duplicate_cust_id;
SELECT distinct customer_address_id
FROM ra_customer_merges
WHERE set_number = set_num
AND request_id = req_id
AND duplicate_address_id = p_duplicate_addr_id;
SELECT distinct customer_site_id
FROM ra_customer_merges
WHERE set_number = set_num
AND request_id = req_id
AND duplicate_site_id = p_duplicate_site_id;
INSERT INTO HZ_CUSTOMER_MERGE_LOG
(
MERGE_LOG_ID,
TABLE_NAME,
MERGE_HEADER_ID,
PRIMARY_KEY_ID,
NUM_COL1_ORIG,
NUM_COL1_NEW,
NUM_COL2_ORIG,
NUM_COL2_NEW,
NUM_COL3_ORIG,
NUM_COL3_NEW,
ACTION_FLAG,
REQUEST_ID,
CREATED_BY,
CREATION_DATE,
LAST_UPDATE_LOGIN,
LAST_UPDATE_DATE,
LAST_UPDATED_BY
) VALUES ( HZ_CUSTOMER_MERGE_LOG_s.nextval,
'CN_COMM_LINES_API',
MERGE_HEADER_ID_LIST(I),
PRIMARY_KEY_ID_LIST(I),
NUM_COL1_ORIG_LIST(I),
NUM_COL1_NEW_LIST(I),
NUM_COL2_ORIG_LIST(I),
NUM_COL2_NEW_LIST(I),
NUM_COL3_ORIG_LIST(I),
NUM_COL3_NEW_LIST(I),
'U',
req_id,
hz_utility_pub.CREATED_BY,
hz_utility_pub.CREATION_DATE,
hz_utility_pub.LAST_UPDATE_LOGIN,
hz_utility_pub.LAST_UPDATE_DATE,
hz_utility_pub.LAST_UPDATED_BY
);
UPDATE CN_COMM_LINES_API_ALL yt SET
CUSTOMER_ID=NUM_COL1_NEW_LIST(I)
,BILL_TO_ADDRESS_ID=NUM_COL2_NEW_LIST(I)
,SHIP_TO_ADDRESS_ID=NUM_COL3_NEW_LIST(I)
, LAST_UPDATE_DATE=SYSDATE
, last_updated_by=arp_standard.profile.user_id
, last_update_login=arp_standard.profile.last_update_login
WHERE COMM_LINES_API_ID=PRIMARY_KEY_ID_LIST(I)
;
arp_message.set_name('AR','AR_ROWS_UPDATED');
Insert into CN_CUST_MERGE_INTERFACE
(
request_id
,set_number
,process_mode
,STATUS
)
values
(req_id
,set_num
,process_mode
,'I'
);
SELECT request_id,set_number,process_mode
FROM CN_CUST_MERGE_INTERFACE
WHERE STATUS='I';
UPDATE CN_CUST_MERGE_INTERFACE
SET STATUS='C'
WHERE request_id=c1.request_id;