Commit 3d072bce authored by mchaudhari's avatar mchaudhari

Add confirm method with connection parameter


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@94246 ce508802-f39f-4f6c-b175-0d175dae99d5
parent de357feb
...@@ -8,6 +8,7 @@ package ibase.webitm.ejb.fin.adv; ...@@ -8,6 +8,7 @@ package ibase.webitm.ejb.fin.adv;
import java.rmi.RemoteException; import java.rmi.RemoteException;
import java.sql.*; import java.sql.*;
import ibase.webitm.ejb.*; import ibase.webitm.ejb.*;
import ibase.system.config.*; import ibase.system.config.*;
import javax.ejb.Stateless; import javax.ejb.Stateless;
...@@ -27,7 +28,15 @@ public class JvConfirm extends ActionHandlerEJB implements JvConfirmLocal,JvCon ...@@ -27,7 +28,15 @@ public class JvConfirm extends ActionHandlerEJB implements JvConfirmLocal,JvCon
{ {
public String confirm(String tranId,String xtraParams, String forcedFlag) throws RemoteException,ITMException public String confirm(String tranId,String xtraParams, String forcedFlag) throws RemoteException,ITMException
{ {
Connection conn = null; Connection conn=null;
String errString="";
errString=confirm(tranId,xtraParams,forcedFlag,conn);
System.out.println("errString----"+errString);
return errString;
}
public String confirm(String tranId,String xtraParams,String forcedFlag,Connection conn) throws RemoteException,ITMException
{
//Connection conn = null;
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
ResultSet rs = null; ResultSet rs = null;
String sql = ""; String sql = "";
...@@ -35,15 +44,18 @@ public class JvConfirm extends ActionHandlerEJB implements JvConfirmLocal,JvCon ...@@ -35,15 +44,18 @@ public class JvConfirm extends ActionHandlerEJB implements JvConfirmLocal,JvCon
String confirm = ""; String confirm = "";
String errString = "" ; String errString = "" ;
boolean isLocal = false;
ITMDBAccessEJB itmDBAccessEJB = null; ITMDBAccessEJB itmDBAccessEJB = null;
try try
{ {
itmDBAccessEJB = new ITMDBAccessEJB(); itmDBAccessEJB = new ITMDBAccessEJB();
if(conn==null) {
connDriver = new ConnDriver(); connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM"); conn = connDriver.getConnectDB("DriverITM");
connDriver = null; connDriver = null;
conn.setAutoCommit(false); conn.setAutoCommit(false);
isLocal = true;
}
sql = "select confirmed,site_code from journal where tran_id = ?"; sql = "select confirmed,site_code from journal where tran_id = ?";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
...@@ -85,10 +97,12 @@ public class JvConfirm extends ActionHandlerEJB implements JvConfirmLocal,JvCon ...@@ -85,10 +97,12 @@ public class JvConfirm extends ActionHandlerEJB implements JvConfirmLocal,JvCon
{ {
if(errString.indexOf("CONFSUCCES") > -1) if(errString.indexOf("CONFSUCCES") > -1)
{ {
if(isLocal)
conn.commit(); conn.commit();
} }
else else
{ {
if(isLocal)
conn.rollback(); conn.rollback();
} }
} }
...@@ -102,8 +116,10 @@ public class JvConfirm extends ActionHandlerEJB implements JvConfirmLocal,JvCon ...@@ -102,8 +116,10 @@ public class JvConfirm extends ActionHandlerEJB implements JvConfirmLocal,JvCon
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
} }
if(isLocal && conn != null){
conn.close(); conn.close();
} }
}
catch(Exception e) catch(Exception e)
{ {
System.out.println("Exception : "+e);e.printStackTrace(); System.out.println("Exception : "+e);e.printStackTrace();
......
...@@ -15,5 +15,6 @@ import javax.ejb.Local; // added for ejb3 ...@@ -15,5 +15,6 @@ import javax.ejb.Local; // added for ejb3
public interface JvConfirmLocal extends ActionHandlerLocal//,EJBObject public interface JvConfirmLocal extends ActionHandlerLocal//,EJBObject
{ {
public String confirm(String tranID, String xtraParams, String forcedFlag) throws RemoteException,ITMException; public String confirm(String tranID, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
public String confirm(String tranId,String xtraParams,String forcedFlag,Connection conn) throws RemoteException,ITMException;
} }
...@@ -16,4 +16,5 @@ import javax.ejb.Remote; // added for ejb3 ...@@ -16,4 +16,5 @@ import javax.ejb.Remote; // added for ejb3
public interface JvConfirmRemote extends ActionHandlerRemote//, EJBObject public interface JvConfirmRemote extends ActionHandlerRemote//, EJBObject
{ {
public String confirm(String tranID, String xtraParams, String forcedFlag) throws RemoteException,ITMException; public String confirm(String tranID, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
public String confirm(String tranId,String xtraParams,String forcedFlag,Connection conn) throws RemoteException,ITMException;
} }
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