Commit d77b99a9 authored by kmandhre's avatar kmandhre

change the method signature for connection object


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@95663 ce508802-f39f-4f6c-b175-0d175dae99d5
parent d90cd5ad
...@@ -11,6 +11,7 @@ import ibase.system.config.*; ...@@ -11,6 +11,7 @@ import ibase.system.config.*;
import java.rmi.RemoteException; import java.rmi.RemoteException;
import java.util.*; import java.util.*;
import java.sql.*; import java.sql.*;
import org.w3c.dom.*; import org.w3c.dom.*;
...@@ -46,7 +47,7 @@ public String process(String xmlString, String xmlString2, String windowName, St ...@@ -46,7 +47,7 @@ public String process(String xmlString, String xmlString2, String windowName, St
detailDom = genericUtility.parseString(xmlString2); detailDom = genericUtility.parseString(xmlString2);
System.out.println("detailDom" + detailDom); System.out.println("detailDom" + detailDom);
} }
retStr = process(headerDom, detailDom, windowName, xtraParams); retStr = process(headerDom, detailDom, windowName, xtraParams,null,true);
} }
catch (Exception e) catch (Exception e)
{ {
...@@ -57,9 +58,9 @@ public String process(String xmlString, String xmlString2, String windowName, St ...@@ -57,9 +58,9 @@ public String process(String xmlString, String xmlString2, String windowName, St
return retStr; return retStr;
}//END OF PROCESS (1) }//END OF PROCESS (1)
public String process(Document headerDom, Document detailDom, String windowName, String xtraParams) throws RemoteException,ITMException public String process(Document headerDom, Document detailDom, String windowName, String xtraParams ,Connection conn, boolean connStatus) throws RemoteException,ITMException
{ {
Connection conn = null; //Connection conn = null;
String resultString = "", errString = ""; String resultString = "", errString = "";
boolean isError = false; boolean isError = false;
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
...@@ -83,10 +84,15 @@ public String process(Document headerDom, Document detailDom, String windowName, ...@@ -83,10 +84,15 @@ public String process(Document headerDom, Document detailDom, String windowName,
chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"termId"); chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"termId");
try try
{ {
ConnDriver connDriver = new ConnDriver(); System.out.println("conn::"+conn);
conn = connDriver.getConnectDB("DriverITM"); if(conn == null)
connDriver = null; {
conn.setAutoCommit(false); ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
connDriver = null;
conn.setAutoCommit(false);
connStatus = true;
}
acctPrdFr = genericUtility.getColumnValue("acct_prd__fr",headerDom ); acctPrdFr = genericUtility.getColumnValue("acct_prd__fr",headerDom );
acctPrdTo = genericUtility.getColumnValue("acct_prd__to",headerDom ); acctPrdTo = genericUtility.getColumnValue("acct_prd__to",headerDom );
...@@ -379,17 +385,23 @@ public String process(Document headerDom, Document detailDom, String windowName, ...@@ -379,17 +385,23 @@ public String process(Document headerDom, Document detailDom, String windowName,
} }
else else
{ {
conn.commit(); if(connStatus)
System.out.println("commiting connection............."); {
conn.commit();
System.out.println("commiting connection.............");
}
if(errString.equals("")) if(errString.equals(""))
{ {
errString = "PROCSUCC"; errString = "PROCSUCC";
} }
resultString = itmDBAccessEJB.getErrorString("",errString,userId); resultString = itmDBAccessEJB.getErrorString("",errString,userId);
} }
if(conn != null && connStatus)
{
conn.close(); conn.close();
conn = null; conn = null;
}
} }
} }
catch(SQLException sqle) catch(SQLException sqle)
......
...@@ -364,7 +364,7 @@ public class JvYearEndPrc extends ProcessEJB implements JvYearEndPrcLocal,JvYear ...@@ -364,7 +364,7 @@ public class JvYearEndPrc extends ProcessEJB implements JvYearEndPrcLocal,JvYear
} }
else else
{*/ {*/
retString = sundryTransferPrc.process(argDom, null, "sundrybal_xfr", xtraParams); retString = sundryTransferPrc.process(argDom, null, "sundrybal_xfr", xtraParams,conn,false);
//} //}
System.out.println("retString PRC::"+retString); System.out.println("retString PRC::"+retString);
...@@ -405,7 +405,7 @@ public class JvYearEndPrc extends ProcessEJB implements JvYearEndPrcLocal,JvYear ...@@ -405,7 +405,7 @@ public class JvYearEndPrc extends ProcessEJB implements JvYearEndPrcLocal,JvYear
} }
else else
{*/ {*/
retString = glTransferPrc.process(argDom, null, "acctbal_xfr", xtraParams); retString = glTransferPrc.process(argDom, null, "acctbal_xfr", xtraParams,conn,false);
//} //}
System.out.println("trans retString prc::"+retString); System.out.println("trans retString prc::"+retString);
......
...@@ -8,9 +8,11 @@ package ibase.webitm.ejb.fin; ...@@ -8,9 +8,11 @@ package ibase.webitm.ejb.fin;
import ibase.webitm.utility.*; import ibase.webitm.utility.*;
import ibase.webitm.ejb.*; import ibase.webitm.ejb.*;
import ibase.system.config.*; import ibase.system.config.*;
import java.rmi.RemoteException; import java.rmi.RemoteException;
import java.util.*; import java.util.*;
import java.sql.*; import java.sql.*;
import org.w3c.dom.*; import org.w3c.dom.*;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import javax.ejb.Stateless; // added for ejb3 import javax.ejb.Stateless; // added for ejb3
...@@ -30,6 +32,10 @@ public String process(String xmlString, String xmlString2, String windowName, St ...@@ -30,6 +32,10 @@ public String process(String xmlString, String xmlString2, String windowName, St
Document detailDom = null; Document detailDom = null;
Document headerDom = null; Document headerDom = null;
String retStr = ""; String retStr = "";
/*Connection conn = null;
ConnDriver connDriver = null;
*/
boolean isConn= false;
System.out.println("Process method called......"); System.out.println("Process method called......");
try try
{ {
...@@ -43,7 +49,10 @@ public String process(String xmlString, String xmlString2, String windowName, St ...@@ -43,7 +49,10 @@ public String process(String xmlString, String xmlString2, String windowName, St
detailDom = genericUtility.parseString(xmlString2); detailDom = genericUtility.parseString(xmlString2);
System.out.println("detailDom" + detailDom); System.out.println("detailDom" + detailDom);
} }
retStr = process(headerDom, detailDom, windowName, xtraParams); /*connDriver = new ConnDriver();
conn = connDriver.getConnectDB("Driver");
conn.setAutoCommit(false);*/
retStr = process(headerDom, detailDom, windowName, xtraParams, null,isConn );
} }
catch (Exception e) catch (Exception e)
{ {
...@@ -54,9 +63,9 @@ public String process(String xmlString, String xmlString2, String windowName, St ...@@ -54,9 +63,9 @@ public String process(String xmlString, String xmlString2, String windowName, St
return retStr; return retStr;
}//END OF PROCESS (1) }//END OF PROCESS (1)
public String process(Document headerDom, Document detailDom, String windowName, String xtraParams) throws RemoteException,ITMException public String process(Document headerDom, Document detailDom, String windowName, String xtraParams ,Connection conn, boolean connStatus) throws RemoteException,ITMException
{ {
Connection conn = null; //Connection conn = null;
String resultString = "", errString = ""; String resultString = "", errString = "";
boolean isError = false; boolean isError = false;
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
...@@ -82,10 +91,15 @@ public String process(Document headerDom, Document detailDom, String windowName, ...@@ -82,10 +91,15 @@ public String process(Document headerDom, Document detailDom, String windowName,
chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"termId"); chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"termId");
try try
{ {
ConnDriver connDriver = new ConnDriver(); System.out.println("conn::"+conn);
conn = connDriver.getConnectDB("DriverITM"); if (conn==null)
connDriver = null; {
conn.setAutoCommit(false); ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
connDriver = null;
conn.setAutoCommit(false);
connStatus = true;
}
acctPrdFr = genericUtility.getColumnValue("acct_prd__fr",headerDom ); acctPrdFr = genericUtility.getColumnValue("acct_prd__fr",headerDom );
acctPrdTo = genericUtility.getColumnValue("acct_prd__to",headerDom ); acctPrdTo = genericUtility.getColumnValue("acct_prd__to",headerDom );
...@@ -402,17 +416,23 @@ public String process(Document headerDom, Document detailDom, String windowName, ...@@ -402,17 +416,23 @@ public String process(Document headerDom, Document detailDom, String windowName,
} }
else else
{ {
conn.commit(); if(connStatus)
System.out.println("commiting connection............."); {
conn.commit();
System.out.println("commiting connection.............");
}
if(errString.equals("")) if(errString.equals(""))
{ {
errString = "PROCSUCC"; errString = "PROCSUCC";
} }
resultString = itmDBAccessEJB.getErrorString("",errString,userId); resultString = itmDBAccessEJB.getErrorString("",errString,userId);
} }
conn.close(); if(conn!=null && connStatus)
conn = null; {
conn.close();
conn = null;
}
} }
} }
catch(SQLException sqle) catch(SQLException sqle)
......
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