DBA Data[Home] [Help]

APPS.ASG_DOWNLOAD dependencies on ASG_DELETE_QUEUE

Line 43: l_qry := 'select '||l_pkstr||' from asg_delete_queue where qid = :1';

39: l_pkstr := l_pkstr||'||'||''',''||'||'ATTRIBUTE'||i||'';
40: end if;
41: end loop;
42: --dbms_output.put_line('str: '||l_pkstr);
43: l_qry := 'select '||l_pkstr||' from asg_delete_queue where qid = :1';
44: execute immediate l_qry into l_res using p_qid;
45: --dbms_output.put_line('ret PK: '||l_res);
46: return l_res;
47: end get_pk;

Line 71: ' from asg_system_dirty_queue sdq,asg_delete_queue dq '||

67: ' UNION ALL '||
68: ' select client_id,pub_item,access_id,dml_type, '||
69: ' transaction_id , asg_download.get_pk(pub_item,sdq.qid) pk_val, '||
70: ' sysdate synch_time '||
71: ' from asg_system_dirty_queue sdq,asg_delete_queue dq '||
72: ' where download_flag=''Y'' and client_id=asg_base.get_user_name'||
73: ' and transaction_id = asg_base.get_current_tranid '||
74: ' and dml_type = 0 '||
75: ' and pub_item in ( select item_id from asg_pub_item '||

Line 136: ' from asg_system_dirty_queue sdq,asg_delete_queue dq '||

132: ' select client_id,pub_item,access_id,dml_type, '||
133: ' transaction_id last_tran_id,asg_base.get_current_tranid '||
134: ' curr_tran_id, asg_download.get_pk(pub_item,sdq.qid) pk_val, '||
135: ' sysdate synch_time '||
136: ' from asg_system_dirty_queue sdq,asg_delete_queue dq '||
137: ' where download_flag=''Y'' and client_id=asg_base.get_user_name'||
138: ' and transaction_id <= asg_base.get_last_tranid '||
139: ' and dml_type = 0 '||
140: ' and pub_item in ( select item_id from asg_pub_item '||

Line 284: * in asg_delete_queue */

280: END isFirstSync;
281:
282:
283: /** Function to Capture the PK of a Deleted Record
284: * in asg_delete_queue */
285: FUNCTION storeDeletedPK ( p_pub_item IN VARCHAR2,
286: p_accessList IN access_list,
287: p_qidList IN qid_list
288: ) RETURN BOOLEAN IS

Line 334: DBMS_SQL.PARSE (l_cur_id, 'INSERT INTO asg_delete_queue '

330:
331: l_cur_id := DBMS_SQL.OPEN_CURSOR;
332:
333: IF ( (l_access_owner IS NULL) AND (l_access_name IS NULL) ) THEN
334: DBMS_SQL.PARSE (l_cur_id, 'INSERT INTO asg_delete_queue '
335: || '(qid, creation_date, created_by, '
336: || 'last_update_date, last_updated_by '
337: || l_att_col_list
338: || ') SELECT :1, sysdate, '

Line 343: DBMS_SQL.PARSE (l_cur_id, 'INSERT INTO asg_delete_queue '

339: || '1, sysdate, 1, '||l_pk_list
340: || ' FROM '||l_base_owner||'.'||l_base_object
341: || ' WHERE access_id = :2', DBMS_SQL.v7);
342: ELSE
343: DBMS_SQL.PARSE (l_cur_id, 'INSERT INTO asg_delete_queue '
344: || ' (qid, creation_date, '
345: || 'created_by, last_update_date, '
346: || 'last_updated_by '||l_att_col_list
347: || ') SELECT :1, sysdate, '

Line 370: * in asg_delete_queue given the PK List */

366: END storeDeletedPK;
367:
368:
369: /** Function to Capture the PK of a Deleted Record
370: * in asg_delete_queue given the PK List */
371: FUNCTION storeDeletedPK ( p_pub_item IN VARCHAR2,
372: p_qid IN NUMBER,
373: p_pkvalList IN pk_list
374: ) RETURN BOOLEAN IS

Line 394: l_dml := 'INSERT INTO asg_delete_queue (qid, creation_date, '

390: l_att_col_list := l_att_col_list || ', attribute'||i;
391: l_pk_val_list := l_pk_val_list || ',''' || p_pkvalList(i) || '''';
392: END LOOP;
393:
394: l_dml := 'INSERT INTO asg_delete_queue (qid, creation_date, '
395: || 'created_by, last_update_date, last_updated_by '
396: || l_att_col_list || ') VALUES '
397: || ' ( ' || p_qid || ', sysdate, 1, sysdate, 1 '||l_pk_val_list
398: || ')';

Line 414: * in asg_delete_queue - For Reject Record */

410: END storeDeletedPK;
411:
412:
413: /** Function to store the PK of a Deleted Record
414: * in asg_delete_queue - For Reject Record */
415: FUNCTION storeDeletedPK ( p_pub_item IN VARCHAR2,
416: p_client_name IN VARCHAR2,
417: p_tran_id IN NUMBER,
418: p_seq_no IN NUMBER,

Line 457: l_dml := 'INSERT INTO asg_delete_queue (qid, creation_date, '

453: l_inq_name := 'CFM$'||p_pub_item;
454: END IF;
455: log ('Inqueue is '||l_inq_owner||'.'||l_inq_name);
456:
457: l_dml := 'INSERT INTO asg_delete_queue (qid, creation_date, '
458: || 'created_by, last_update_date, last_updated_by '||l_att_col_list
459: || ') SELECT :1, sysdate, '
460: || '1, sysdate, 1, '||l_pk_list
461: || ' FROM '||l_inq_owner||'.'||l_inq_name

Line 1325: DBMS_SQL.PARSE (l_cur, 'DELETE FROM asg_delete_queue '

1321:
1322: log(' After Delete SDQ : '||to_char(sysdate,'dd-mon-yyyy hh24:mi:ss'));
1323: IF (l_qid_tmp_list.COUNT > 0) THEN
1324: l_cur := DBMS_SQL.OPEN_CURSOR;
1325: DBMS_SQL.PARSE (l_cur, 'DELETE FROM asg_delete_queue '
1326: || ' WHERE qid in (:2)', DBMS_SQL.v7);
1327: DBMS_SQL.BIND_ARRAY (l_cur, ':2', l_qid_tmp_list, 1,
1328: l_qid_tmp_list.COUNT);
1329: l_cur_rc := DBMS_SQL.EXECUTE ( l_cur );

Line 1552: DELETE FROM asg_delete_queue

1548: log('Not raising download events since the profile '
1549: ||' ASG_ENABLE_DELIVERY_EVENTS is not set to ''Y''');
1550: end if;
1551: /* Clean the Delete Queue */
1552: DELETE FROM asg_delete_queue
1553: WHERE qid IN (SELECT qid
1554: FROM asg_system_dirty_queue
1555: WHERE client_id = g_clientid AND
1556: transaction_id <= g_last_tranid );

Line 1580: DELETE FROM asg_delete_queue

1576: BEGIN
1577:
1578: /* Clean the Delete Queue */
1579: log('PurgeSDQ for '||p_clientid);
1580: DELETE FROM asg_delete_queue
1581: WHERE qid IN (SELECT qid
1582: FROM asg_system_dirty_queue
1583: WHERE client_id = p_clientid);
1584:

Line 1834: -- delete from asg_delete_queue

1830: l_dml VARCHAR2(1000);
1831: l_count NUMBER;
1832: PRAGMA AUTONOMOUS_TRANSACTION;
1833: begin
1834: -- delete from asg_delete_queue
1835: l_dml := 'Delete /*+ INDEX(asg_delete_queue ASG_DELETE_QUEUE_U1) */ from '||
1836: ' asg_delete_queue where qid in '||
1837: ' ( Select qid from '||
1838: ' ( select qid, pub_item, access_id, dml_type, '||

Line 1835: l_dml := 'Delete /*+ INDEX(asg_delete_queue ASG_DELETE_QUEUE_U1) */ from '||

1831: l_count NUMBER;
1832: PRAGMA AUTONOMOUS_TRANSACTION;
1833: begin
1834: -- delete from asg_delete_queue
1835: l_dml := 'Delete /*+ INDEX(asg_delete_queue ASG_DELETE_QUEUE_U1) */ from '||
1836: ' asg_delete_queue where qid in '||
1837: ' ( Select qid from '||
1838: ' ( select qid, pub_item, access_id, dml_type, '||
1839: ' count(*) over (partition by pub_item, access_id, dml_type)'||

Line 1836: ' asg_delete_queue where qid in '||

1832: PRAGMA AUTONOMOUS_TRANSACTION;
1833: begin
1834: -- delete from asg_delete_queue
1835: l_dml := 'Delete /*+ INDEX(asg_delete_queue ASG_DELETE_QUEUE_U1) */ from '||
1836: ' asg_delete_queue where qid in '||
1837: ' ( Select qid from '||
1838: ' ( select qid, pub_item, access_id, dml_type, '||
1839: ' count(*) over (partition by pub_item, access_id, dml_type)'||
1840: ' as total_rows, '||

Line 2206: DELETE /*+ INDEX(asg_delete_queue ASG_DELETE_QUEUE_U1) */ FROM

2202: l_dormant_rec.user_name||' and publication :'||
2203: l_dormant_rec.pub_name,
2204: 'asg_download',FND_LOG.LEVEL_STATEMENT);
2205: BEGIN
2206: DELETE /*+ INDEX(asg_delete_queue ASG_DELETE_QUEUE_U1) */ FROM
2207: asg_delete_queue
2208: WHERE qid IN
2209: ( SELECT qid
2210: FROM asg_system_dirty_queue

Line 2207: asg_delete_queue

2203: l_dormant_rec.pub_name,
2204: 'asg_download',FND_LOG.LEVEL_STATEMENT);
2205: BEGIN
2206: DELETE /*+ INDEX(asg_delete_queue ASG_DELETE_QUEUE_U1) */ FROM
2207: asg_delete_queue
2208: WHERE qid IN
2209: ( SELECT qid
2210: FROM asg_system_dirty_queue
2211: WHERE client_id = l_dormant_rec.user_name

Line 2266: p_message := 'Purging asg_system_dirty_queue and asg_delete_queue completed successfully.';

2262:
2263: log_concprogram('End SDQ purge ','asg_download',
2264: FND_LOG.LEVEL_STATEMENT);
2265: p_status := 'Fine';
2266: p_message := 'Purging asg_system_dirty_queue and asg_delete_queue completed successfully.';
2267:
2268: EXCEPTION
2269: WHEN OTHERS THEN
2270: p_status := 'Error';