[Home] [Help]
253: | |
254: | Purpose : Processes the query and XML for a given request ID. This |
255: | is called by MassRequstMonitor. Main functionalities are: |
256: | - Inserts record into jtf_fm_int_request_header table. |
257: | - Inserts record into jtf_fm_int_request_batches table. |
258: | - Creates partition and inserts records into |
259: | jtff_fm_int_request_lines table. |
260: | |
261: *---------------------------------------------------------------------------------*/
912: ELSE
913: RAISE e_too_many_bind_vars;
914: END IF;
915:
916: INSERT INTO jtf_fm_int_request_batches
917: ( request_id,
918: batch_id,
919: request_line_id_start,
920: request_line_id_end,
1213:
1214: /*---------------------------------------------------------------------------------*
1215: | Procedure Name : UPDATE_INSTANCE_STATUS |
1216: | |
1217: | Purpose : - Updates jtf_fm_int_request_batches - for batch status |
1218: | - Updates jtf_fm_int_request_header - for request status |
1219: | - Updates jtf_fm_status_all - for request status |
1220: | - Updates jtf_fm_request_history_all - for outcome code |
1221: | - Updates jtf_fm_email_stat - for email details |
1251: WHERE c.request_id = l_request_id ;
1252: BEGIN
1253: l_request_id := p_request_id;
1254:
1255: UPDATE jtf_fm_int_request_batches
1256: SET batch_status = p_status,
1257: last_update_date = SYSDATE
1258: WHERE request_id = p_request_id;
1259:
1260: UPDATE jtf_fm_int_request_header c
1261: SET c.request_status = 'READYTOLOG'
1262: WHERE c.request_id = p_request_id
1263: AND NOT EXISTS ( SELECT '1'
1264: FROM jtf_fm_int_request_batches a
1265: WHERE c.request_id = a.request_id
1266: AND a.batch_status IN ('AVAILABLE', 'NEW','ASSIGNED')
1267: );
1268: OPEN c_header;
1361:
1362: /*---------------------------------------------------------------------------------*
1363: | Procedure Name : CLEAN_UP_INSTANCE |
1364: | |
1365: | Purpose : - Updates jtf_fm_int_request_batches - for batch status |
1366: | |
1367: *---------------------------------------------------------------------------------*/
1368: PROCEDURE clean_up_instance( p_request_id IN NUMBER
1369: , p_server_id IN NUMBER
1372: , x_return_status OUT NOCOPY VARCHAR2
1373: , x_msg_count OUT NOCOPY NUMBER
1374: , x_msg_data OUT NOCOPY VARCHAR2) IS
1375: BEGIN
1376: UPDATE jtf_fm_int_request_batches
1377: SET batch_status = 'NEW',
1378: last_update_date = SYSDATE
1379: WHERE request_ID = p_request_id
1380: AND server_instance_id = p_instance_id;
1719: /*---------------------------------------------------------------------------------*
1720: | Procedure Name : GET_NEXT_BATCH |
1721: | |
1722: | Purpose : Selects from jtf_fm_int_request_lines , and |
1723: | - Updates jtf_fm_int_request_batches - for request status |
1724: | |
1725: *---------------------------------------------------------------------------------*/
1726: PROCEDURE get_next_batch ( p_request_id IN NUMBER
1727: , p_server_id IN NUMBER
1838: CURSOR c_batch IS
1839: SELECT rb.batch_id,
1840: rb.request_line_id_start ,
1841: rb.request_line_id_end
1842: FROM jtf_fm_int_request_batches rb
1843: WHERE rb.request_id = p_request_id
1844: AND rb.batch_status = 'AVAILABLE' ;
1845: l_batch_id NUMBER;
1846: l_request_line_id_start NUMBER;
2070: CLOSE c_batch;
2071:
2072: IF l_batch_id IS NOT NULL
2073: THEN
2074: UPDATE jtf_fm_int_request_batches rb
2075: SET rb.batch_status = 'INPROGRESS' ,
2076: last_update_date = SYSDATE,
2077: rb.SERVER_INSTANCE_ID = p_instance_id
2078: WHERE rb.request_id = p_request_id
2652: | Procedure Name : CLEAN_STALLED_REQUEST |
2653: | |
2654: | Purpose : Selects from jtf_fm_int_request_lines , and |
2655: | - Truncates partition for jtf_fm_int_request_lines |
2656: | - Deletes from jtf_fm_int_request_batches |
2657: | - Deletes from jtf_fm_int_request_header |
2658: | |
2659: *---------------------------------------------------------------------------------*/
2660: PROCEDURE clean_stalled_request ( p_request_id IN NUMBER
2684: END IF;
2685:
2686: --Deleting from batches table
2687: DELETE
2688: FROM jtf_fm_int_request_batches
2689: WHERE request_id = p_request_id
2690: AND batch_status = lc_status
2691: ;
2692: