Commit a2626d02 authored by kmandhre's avatar kmandhre

handle connection commit and close


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@95082 ce508802-f39f-4f6c-b175-0d175dae99d5
parent c88f29d8
...@@ -33,13 +33,14 @@ public class RcpBackflushConfirm extends ActionHandlerEJB implements RcpBackflus ...@@ -33,13 +33,14 @@ public class RcpBackflushConfirm extends ActionHandlerEJB implements RcpBackflus
String retString = ""; String retString = "";
Connection conn = null; Connection conn = null;
ConnDriver connDriver = null; ConnDriver connDriver = null;
boolean isConn= false;
try try
{ {
connDriver = new ConnDriver(); connDriver = new ConnDriver();
conn = connDriver.getConnectDB("Driver"); conn = connDriver.getConnectDB("Driver");
conn.setAutoCommit(false); conn.setAutoCommit(false);
retString = confirmRcpBackflush( tranID, xtraParams, forcedFlag,conn); retString = confirmRcpBackflush( tranID, xtraParams, forcedFlag,conn,isConn);
} }
catch(Exception exception) catch(Exception exception)
...@@ -49,7 +50,7 @@ public class RcpBackflushConfirm extends ActionHandlerEJB implements RcpBackflus ...@@ -49,7 +50,7 @@ public class RcpBackflushConfirm extends ActionHandlerEJB implements RcpBackflus
return retString; return retString;
} }
public String confirmRcpBackflush( String tranID, String xtraParams,String forcedFlag,Connection conn) throws RemoteException,ITMException public String confirmRcpBackflush( String tranID, String xtraParams,String forcedFlag,Connection conn, boolean connStatus ) throws RemoteException,ITMException
{ {
//Connection conn=null; //Connection conn=null;
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
...@@ -70,6 +71,7 @@ public class RcpBackflushConfirm extends ActionHandlerEJB implements RcpBackflus ...@@ -70,6 +71,7 @@ public class RcpBackflushConfirm extends ActionHandlerEJB implements RcpBackflus
connDriver = new ConnDriver(); connDriver = new ConnDriver();
conn = connDriver.getConnectDB("Driver"); conn = connDriver.getConnectDB("Driver");
conn.setAutoCommit(false); conn.setAutoCommit(false);
connStatus = true;
} }
finCommon = new FinCommon(); finCommon = new FinCommon();
...@@ -116,7 +118,7 @@ public class RcpBackflushConfirm extends ActionHandlerEJB implements RcpBackflus ...@@ -116,7 +118,7 @@ public class RcpBackflushConfirm extends ActionHandlerEJB implements RcpBackflus
} }
System.out.println("errorString @@#---->>["+errString+"]"); System.out.println("errorString @@#---->>["+errString+"]");
// System.out.println("isError---->>["+isError+"]"); // System.out.println("isError---->>["+isError+"]");
if(errString !=null && errString.trim().length() == 0) if(errString !=null && errString.trim().length() == 0 && connStatus)
{ {
conn.commit(); conn.commit();
errString = itmDBAccessEJB.getErrorString("","VTCONFIRM","","",conn); errString = itmDBAccessEJB.getErrorString("","VTCONFIRM","","",conn);
...@@ -154,7 +156,7 @@ public class RcpBackflushConfirm extends ActionHandlerEJB implements RcpBackflus ...@@ -154,7 +156,7 @@ public class RcpBackflushConfirm extends ActionHandlerEJB implements RcpBackflus
if(rs1 != null){rs1.close();rs1 = null;} if(rs1 != null){rs1.close();rs1 = null;}
if(pstmt != null){pstmt.close();pstmt = null; if(pstmt != null){pstmt.close();pstmt = null;
} }
if(conn!=null) if(conn!=null && connStatus)
{ {
conn.close(); conn.close();
conn = null; conn = null;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment