The following lines contain the word 'select', 'insert', 'update' or 'delete':
l_qry := 'select '''||p_user_name||''' user_name,'''||to_char(p_tranid)
||''' tran_id, '''||p_error_msg||''' ERROR_DESCRIPTION ,'
||''''||p_pubitem||''' pub_item ,'''||p_sequence||''' SEQUENCE '
||' from dual';
/*l_qry := 'select DEVICE_USER_NAME user_name,DEFERRED_TRAN_ID tran_id ,'
||'ERROR_DESCRIPTION ,OBJECT_NAME pub_item,SEQUENCE '
||'from asg_deferred_traninfo where CREATION_DATE >= to_date('''
||to_char(p_start_time,'mm-dd-yyyy hh24:mi:ss')
||''',''mm-dd-yyyy hh24:mi:ss'') ';*/
select asg_events_s.nextval into l_seq from dual;
SELECT resource_id
FROM asg_user
WHERE user_name = p_user_name;
select nvl(fnd_profile.value_specific('ASG_ENABLE_UPLOAD_EVENTS'),'N')
into l_prof_value from dual;
UPDATE asg_deferred_traninfo
SET failures = failures +1, error_description = l_error_msg,
last_update_date = SYSDATE
WHERE device_user_name = p_user_name AND
deferred_tran_id = p_tranid AND
object_name = p_pubitem AND
sequence = p_sequence;
INSERT INTO asg_deferred_traninfo (DEVICE_USER_NAME,
RESOURCE_ID,
DEFERRED_TRAN_ID,
MOBILE_ERROR_ID,
ERROR_DESCRIPTION,
OBJECT_NAME,
SEQUENCE,
STATUS,
SYNC_TIME,
FAILURES,
LAST_UPDATE_DATE,
LAST_UPDATED_BY,
CREATION_DATE,
CREATED_BY)
VALUES (p_user_name,
l_resource_id,
p_tranid,
NULL,
l_error_msg,
p_pubitem,
p_sequence,
1,
NULL,
1,
SYSDATE,
1,
SYSDATE,
1);
UPDATE asg_users_inqinfo
SET deferred = 'Y', processed = 'I',
last_update_date = SYSDATE, last_updated_by = 1
WHERE device_user_name = p_user_name AND
tranid = p_tranid;
sql_string := 'DELETE FROM '|| asg_base.G_OLITE_SCHEMA ||
'.' || inq_tbl_name ||
' WHERE clid$$cs = :1 AND ' ||
' tranid$$ =:2';
DELETE FROM asg_deferred_traninfo
WHERE device_user_name = p_user_name AND
deferred_tran_id = p_tranid AND
object_name = p_pubitem;
'Deleted deferred rows for user: '||
p_user_name ||
' tranid: ' || p_tranid || ' publication item: ' ||
p_pubitem,
'asg_defer',g_stmt_level);
PROCEDURE delete_deferred_row_internal(p_user_name IN VARCHAR2,
p_tranid IN NUMBER,
p_pubitem IN VARCHAR2,
p_sequence IN NUMBER,
x_return_status OUT NOCOPY VARCHAR2)
IS
inq_tbl_name VARCHAR2(30);
sql_string := 'DELETE FROM ' || asg_base.G_OLITE_SCHEMA ||
'.' || inq_tbl_name ||
' WHERE clid$$cs = :1 AND ' ||
' tranid$$ = :2 AND ' ||
' seqno$$ = :3';
asg_helper.log('delete_deferred_row_internal: SQL Command: ' || sql_string,
'asg_defer',g_stmt_level);
asg_helper.log('delete_deferred_row_internal: Exception: ',
'asg_defer', g_err_level);
DELETE FROM asg_deferred_traninfo
WHERE device_user_name = p_user_name AND
deferred_tran_id = p_tranid AND
object_name = p_pubitem AND
sequence = p_sequence;
asg_helper.log('delete_deferred_row_internal: Exception: ' || SQLERRM,
'asg_defer', g_err_level);
asg_helper.log('delete_deferred_row_internal: ' ||
'Deleted a deferred row for user: '||
p_user_name ||
' tranid: ' || p_tranid || ' publication item: ' ||
p_pubitem || ' and sequence: ' || p_sequence,
'asg_defer',g_stmt_level);
END delete_deferred_row_internal;
PROCEDURE delete_deferred_row(p_user_name IN VARCHAR2,
p_tranid IN NUMBER,
p_pubitem IN VARCHAR2,
p_sequence IN NUMBER,
x_return_status OUT NOCOPY VARCHAR2)
IS
l_deferred_row VARCHAR2(1);
asg_helper.log('delete_deferred_row: Row is not deferred. Returning...',
'asg_defer',g_err_level);
delete_deferred_row_internal(p_user_name, p_tranid, p_pubitem,
p_sequence, x_return_status);
END delete_deferred_row;
asg_apply.delete_row(p_user_name, p_tranid, p_pubitem, p_sequence,
x_return_status);
SELECT device_user_name
FROM asg_users_inqinfo
WHERE device_user_name = p_user_name AND
tranid = p_tranid AND
deferred <> 'N';
SELECT device_user_name
FROM asg_deferred_traninfo
WHERE device_user_name = p_user_name AND
deferred_tran_id = p_tranid AND
object_name = p_pubitem AND
sequence = p_sequence;
UPDATE asg_users_inqinfo
SET deferred = 'D'
WHERE device_user_name = p_user_name AND
tranid = p_tranid;
SELECT count(*) count
FROM asg_deferred_traninfo
WHERE device_user_name = p_user_name AND
deferred_tran_id = p_tranid;
delete_deferred_row(p_user_name, p_tranid, p_pubitem,
p_sequence, x_return_status);
UPDATE asg_users_inqinfo
SET deferred = 'D'
WHERE device_user_name = p_user_name AND
tranid = p_tranid;
SELECT distinct a.wrapper_name, a.name
FROM asg_pub a, asg_pub_item b, asg_deferred_traninfo c
WHERE device_user_name = p_user_name AND
deferred_tran_id = p_tranid AND
c.object_name = b.name AND
b.pub_name = a.name
ORDER BY a.name;
SELECT count(*) count
FROM asg_deferred_traninfo
WHERE device_user_name = p_user_name AND
deferred_tran_id = p_tranid AND
status <> 0;
SELECT user_id INTO l_user_id
FROM asg_user
WHERE user_name = p_user_name;
SELECT responsibility_id, app_id INTO l_resp_id, l_app_id
FROM asg_user_pub_resps
WHERE user_name = p_user_name AND
pub_name = l_pubname;
UPDATE asg_users_inqinfo
SET deferred = 'S'
WHERE device_user_name = p_user_name AND
tranid = p_tranid;
UPDATE asg_users_inqarchive
SET processed = 'Y', deferred = 'Y',
last_update_date = SYSDATE, last_updated_by = 1
WHERE device_user_name = p_user_name AND
tranid = p_tranid;
DELETE FROM asg_users_inqinfo
WHERE device_user_name = p_user_name AND tranid = p_tranid;
PROCEDURE delete_deferred(p_status OUT NOCOPY VARCHAR2,
p_message OUT NOCOPY VARCHAR2)
IS
CURSOR c_deferred_lines
IS
select distinct object_name
from asg_deferred_traninfo;
asg_helper.log('delete_deferred: Entering asg_defer.delete_deferred.',
'asg_defer',g_stmt_level);
asg_helper.log('delete_deferred: Processing object: ' || cdl.object_name,
'asg_defer',g_stmt_level);
l_sql := 'DELETE FROM asg_deferred_traninfo ' ||
'WHERE object_name = :1 AND ' ||
'(device_user_name, deferred_tran_id, sequence) NOT IN ' ||
' (SELECT clid$$cs, tranid$$, seqno$$ ' ||
' FROM ' || l_inq_table_name || ' )';
asg_helper.log('delete_deferred: SQL Command: ' || l_sql,
'asg_defer',g_stmt_level);
asg_helper.log('delete_deferred: : Deleted ' || l_row_count || ' row(s)',
'asg_defer',g_stmt_level);
DELETE FROM asg_users_inqinfo
WHERE (device_user_name, tranid) NOT IN
(SELECT device_user_name, deferred_tran_id
FROM asg_deferred_traninfo);
asg_helper.log('delete_deferred: Exiting asg_defer.delete_deferred.',
'asg_defer',g_stmt_level);
asg_helper.log('delete_deferred: Error Message: ' || SQLERRM,
'asg_defer',g_stmt_level);
END delete_deferred;