Commit 646eddfe authored by ssurve's avatar ssurve

single commit, conn code change, pstmt and rs closed properly


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@96236 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 41ce2d23
...@@ -49,6 +49,7 @@ public class DissIssuePosSave extends ValidatorEJB implements DissIssuePosSave ...@@ -49,6 +49,7 @@ public class DissIssuePosSave extends ValidatorEJB implements DissIssuePosSave
GenericUtility genericUtility = GenericUtility.getInstance(); GenericUtility genericUtility = GenericUtility.getInstance();
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
String lotsl = "",siteCode=""; String lotsl = "",siteCode="";
boolean isLocalConn = false;
double quantity = 0; double quantity = 0;
ResultSet rs = null; ResultSet rs = null;
double amount = 0,netAmount=0,discAmount=0,taxAmount=0,noArt = 0; //net_amt =amount+tax_amt-disc_amt double amount = 0,netAmount=0,discAmount=0,taxAmount=0,noArt = 0; //net_amt =amount+tax_amt-disc_amt
...@@ -57,14 +58,14 @@ public class DissIssuePosSave extends ValidatorEJB implements DissIssuePosSave ...@@ -57,14 +58,14 @@ public class DissIssuePosSave extends ValidatorEJB implements DissIssuePosSave
{ {
conn = null; //conn = null;
if(conn == null){
ConnDriver connDriver = new ConnDriver(); ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM"); conn = connDriver.getConnectDB("DriverITM");
connDriver= null; connDriver= null;
isLocalConn = true;
}
conn.setAutoCommit(false); conn.setAutoCommit(false);
...@@ -100,7 +101,7 @@ public class DissIssuePosSave extends ValidatorEJB implements DissIssuePosSave ...@@ -100,7 +101,7 @@ public class DissIssuePosSave extends ValidatorEJB implements DissIssuePosSave
pstmt.setString( 2, siteCode); pstmt.setString( 2, siteCode);
pstmt.setString( 3, lotsl); pstmt.setString( 3, lotsl);
pstmt.executeUpdate(); pstmt.executeUpdate();
conn.commit(); //conn.commit();
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
...@@ -120,7 +121,7 @@ public class DissIssuePosSave extends ValidatorEJB implements DissIssuePosSave ...@@ -120,7 +121,7 @@ public class DissIssuePosSave extends ValidatorEJB implements DissIssuePosSave
//System.out.println("First sql ["+ sql + "] tranId [" + tranId + "]"); //System.out.println("First sql ["+ sql + "] tranId [" + tranId + "]");
pstmt.setString( 1, tranId ); pstmt.setString( 1, tranId );
pstmt.executeUpdate(); pstmt.executeUpdate();
conn.commit(); //conn.commit();
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
...@@ -187,7 +188,8 @@ public class DissIssuePosSave extends ValidatorEJB implements DissIssuePosSave ...@@ -187,7 +188,8 @@ public class DissIssuePosSave extends ValidatorEJB implements DissIssuePosSave
pstmt.executeUpdate(); pstmt.executeUpdate();
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
conn.commit();
//conn.commit();
} }
catch(Exception e) catch(Exception e)
...@@ -205,19 +207,29 @@ public class DissIssuePosSave extends ValidatorEJB implements DissIssuePosSave ...@@ -205,19 +207,29 @@ public class DissIssuePosSave extends ValidatorEJB implements DissIssuePosSave
e.printStackTrace(); e.printStackTrace();
throw new ITMException(e); throw new ITMException(e);
} }
finally finally
{ {
try try
{ {
if(pstmt != null)pstmt.close(); if(rs!=null){
pstmt = null; rs.close();
rs = null;
}
if(pstmt != null){
pstmt.close();
pstmt = null;
}
if(conn != null) if(isLocalConn){
{ if(conn != null)
conn.close(); {
conn.commit();
conn.close();
conn = null;
}
} }
}catch(Exception d) }catch(Exception d)
{ {
......
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