Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- var dbConn = globalMap.get('tes55');
- if (dbConn == null || !dbConn.getConnection().isValid(1))
- {
- var dbConn = DatabaseConnectionFactory.createDatabaseConnection('oracle.jdbc.driver.OracleDriver','jdbc:oracle:thin:@10.123.117.203:1521/UAT','intg','intg');
- dbConn.getConnection().setNetworkTimeout(java.util.concurrent.Executors.newFixedThreadPool(1), 30000);
- globalMap.put('tes55',dbConn);
- }
- dbConn.setAutoCommit(false);
- try{
- var x="select IH_HL7_OUM_ID, MESSAGE_ID, frame_text from ideal.EHS_Acks_MESSAGES s WHERE (message_type = 'S12' or message_type = 'S15' or message_type = 'A04' or message_type = 'A11') and rownum<=2";
- var rs=dbConn.getConnection().createStatement().executeQuery(x);
- var msgs=new java.util.ArrayList();
- while(rs.next()){
- var IH_HL7_OUM_ID=rs.getString("IH_HL7_OUM_ID");
- var MESSAGE_ID =rs.getString("MESSAGE_ID");
- var frame_text =rs.getString("frame_text");
- // logger.info(MESSAGE_ID);
- //logger.info(IH_HL7_OUM_ID);
- // logger.info(frame_text);
- msgs.add(frame_text);
- //map.set(frame_text);
- var query="update ih_hl7_outbound_messages set IS_SENT= 2 where MESSAGE_ID ="+MESSAGE_ID+" and id<="+IH_HL7_OUM_ID;
- var update=dbConn.executeUpdate(query);
- //logger.info(update);
- dbConn.commit();
- //logger.info(query);
- }
- rs.close();
- return msgs;
- }
- catch(exp)
- {
- returned_response = ResponseFactory.getQueuedResponse("Failed to execute the query " + "nReason: " + exp.message);
- logger.error(exp.message);
- alerts.sendAlert("nnMessage ID: " +$('msgID') + "nMessage type: " +$('msgtype')+"nException: "+exp.message +"nMessage :n"+msgs.add(frame_text));
- try{dbConn.close();}catch(ignore){logger.info("Close Connection: "+ignore.message);}
- }
- finally
- {
- try{rs.close();}catch(ignore){logger.info("Close Cursor: "+ignore.message);}
- }
- return returned_response;
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement