Skip to content

B
business-java
Commit 42ae420d authored by manohar's avatar manohar
Browse files
Options

unclosed resutlset, statement closed 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@91130 ce508802-f39f-4f6c-b175-0d175dae99d5
parent ccbdd695
Hide whitespace changes
Inline Side-by-side
Showing with 93 additions and 42 deletions
webitm-dis/ibase/webitm/ejb/dis/SaleContractRelease.java
View file @ 42ae420d
...@@ -159,7 +159,11 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -159,7 +159,11 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
count = rs.getInt("COUNT"); count = rs.getInt("COUNT");
System.out.println("CONRACT_NO count is ::- "+count ); System.out.println("CONRACT_NO count is ::- "+count );
} }
rs.close();
rs = null;
stmt.close();
stmt = null;
if(count == 0) if(count == 0)
{ {
writeLog(filePtr,"contract_no NOT FOUND IN SCONTRACT ",true); writeLog(filePtr,"contract_no NOT FOUND IN SCONTRACT ",true);
...@@ -194,8 +198,10 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -194,8 +198,10 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
System.out.println("CUST_CODE count is ::- "+count ); System.out.println("CUST_CODE count is ::- "+count );
writeLog(filePtr,"Count:-"+count,true); writeLog(filePtr,"Count:-"+count,true);
} }
rs.close(); rs.close();
stmt.close(); rs = null;
stmt.close();
stmt = null;
if(count == 0) if(count == 0)
...@@ -226,7 +232,9 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -226,7 +232,9 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
} }
rs.close(); rs.close();
stmt.close(); stmt.close();
rs = null;
stmt = null;
sql = "SELECT COUNT(1) AS COUNT FROM SCONTRACT WHERE CUST_CODE = '"+custCode+"' and CONTRACT_NO = '"+contractNo+"'" ; sql = "SELECT COUNT(1) AS COUNT FROM SCONTRACT WHERE CUST_CODE = '"+custCode+"' and CONTRACT_NO = '"+contractNo+"'" ;
writeLog(filePtr,"Detecting Record Exist In SCONTRACT ["+sql+"]",true); writeLog(filePtr,"Detecting Record Exist In SCONTRACT ["+sql+"]",true);
stmt = conn.createStatement(); stmt = conn.createStatement();
...@@ -237,7 +245,10 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -237,7 +245,10 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
writeLog(filePtr,"Count[2]:::"+count2,true); writeLog(filePtr,"Count[2]:::"+count2,true);
System.out.println("Count[2]::: ::- "+count2 ); System.out.println("Count[2]::: ::- "+count2 );
} }
rs.close();
rs = null;
stmt.close();
stmt = null;
if(count1==0 && count2==0) if(count1==0 && count2==0)
{ {
writeLog(filePtr,"CUSTOMER_CODE NOT FOUND IN CUSTOMER ",true); writeLog(filePtr,"CUSTOMER_CODE NOT FOUND IN CUSTOMER ",true);
...@@ -266,7 +277,11 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -266,7 +277,11 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
if(rs.next()) if(rs.next())
{ {
confirmed = rs.getString(1); confirmed = rs.getString(1);
} }
rs.close();
rs = null;
stmt.close();
stmt = null;
System.out.println("confirmed = "+confirmed ); System.out.println("confirmed = "+confirmed );
if(confirmed.trim().equalsIgnoreCase("N")) if(confirmed.trim().equalsIgnoreCase("N"))
{ {
...@@ -372,7 +387,11 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -372,7 +387,11 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
retTabSepStrBuff.append(rs.getString(30)==null?"":rs.getString(30)).append("\t"); retTabSepStrBuff.append(rs.getString(30)==null?"":rs.getString(30)).append("\t");
//RATE__CLG //RATE__CLG
retTabSepStrBuff.append(rs.getDouble(31)).append("\n"); retTabSepStrBuff.append(rs.getDouble(31)).append("\n");
}//while }//while
rs.close();
rs = null;
pstmt.close();
pstmt = null;
}//try }//try
catch (SQLException e) catch (SQLException e)
{ {
...@@ -608,7 +627,9 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -608,7 +627,9 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
{ {
itemSer = ""; itemSer = "";
} }
} }
rs.close();
rs = null;
stmt.close(); stmt.close();
stmt = null; stmt = null;
} }
...@@ -649,7 +670,9 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -649,7 +670,9 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
tele2 = rs.getString(11); tele2 = rs.getString(11);
tele3 = rs.getString(12); tele3 = rs.getString(12);
fax = rs.getString(13); fax = rs.getString(13);
} }
rs.close();
rs = null;
stmt.close(); stmt.close();
stmt = null; stmt = null;
}//try }//try
...@@ -672,7 +695,6 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -672,7 +695,6 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
try try
{ {
//Inserting vlues in SORDER //Inserting vlues in SORDER
//saleOrder = generateTranTd("w_sorder",tranDate,siteCode,contractType);
saleOrder = generateTranTd("w_sorder",tranDate,siteCode,contractType, conn); saleOrder = generateTranTd("w_sorder",tranDate,siteCode,contractType, conn);
System.out.println("saleOrder....::- "+saleOrder); System.out.println("saleOrder....::- "+saleOrder);
...@@ -829,8 +851,11 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -829,8 +851,11 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
// end of code on 2/27/2009 by manazir // end of code on 2/27/2009 by manazir
int count = pstmt.executeUpdate(); int count = pstmt.executeUpdate();
System.out.println("No of records inserted into sorder........."+count); System.out.println("No of records inserted into sorder........."+count);
pstmt.clearParameters(); pstmt.clearParameters();
} pstmt.close();
pstmt = null;
}
catch (SQLException ex) catch (SQLException ex)
{ {
System.out.println("Exception ::" +sql+ ex.getMessage() + ":"); System.out.println("Exception ::" +sql+ ex.getMessage() + ":");
...@@ -1195,7 +1220,10 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -1195,7 +1220,10 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
pstmt.setTimestamp(2,orderDate); pstmt.setTimestamp(2,orderDate);
cnt = pstmt.executeUpdate(); cnt = pstmt.executeUpdate();
System.out.println("No of records updated in SCONTRACTDET for rel_qty is : "+cnt); System.out.println("No of records updated in SCONTRACTDET for rel_qty is : "+cnt);
pstmt.clearParameters(); writeLog(filePtr," No of records updated in SCONTRACTDET for rel_qty is "+cnt,true);
pstmt.clearParameters();
pstmt.close();
pstmt = null;
} }
catch (SQLException ex) catch (SQLException ex)
{ {
...@@ -1208,7 +1236,9 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -1208,7 +1236,9 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
sql = "UPDATE SCONTRACTDET SET BAL_QTY_STDUOM = QUANTITY__STDUOM - CASE WHEN REL_QTY IS NULL THEN 0 ELSE REL_QTY END " sql = "UPDATE SCONTRACTDET SET BAL_QTY_STDUOM = QUANTITY__STDUOM - CASE WHEN REL_QTY IS NULL THEN 0 ELSE REL_QTY END "
+ "WHERE CONTRACT_NO = '"+contractNo+"' AND LINE_NO = '"+line_No+"'"; + "WHERE CONTRACT_NO = '"+contractNo+"' AND LINE_NO = '"+line_No+"'";
stmt = conn.createStatement(); stmt = conn.createStatement();
cnt = stmt.executeUpdate(sql); cnt = stmt.executeUpdate(sql);
stmt.close();
stmt = null;
System.out.println("No of records updated in SCONTRACTDET for bal_qty_stduom is : "+cnt); System.out.println("No of records updated in SCONTRACTDET for bal_qty_stduom is : "+cnt);
} }
catch (SQLException ex) catch (SQLException ex)
...@@ -1247,7 +1277,9 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -1247,7 +1277,9 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
if(rs.next()) if(rs.next())
{ {
itemDescr = rs.getString(1); itemDescr = rs.getString(1);
} }
rs.close();
rs = null;
stmt.close(); stmt.close();
stmt = null; stmt = null;
//21-09-2006 wasim end //21-09-2006 wasim end
...@@ -1268,7 +1300,9 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -1268,7 +1300,9 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
{ {
siteCode = rs.getString("SITE_CODE"); siteCode = rs.getString("SITE_CODE");
dspDate = rs.getTimestamp("DSP_DATE"); dspDate = rs.getTimestamp("DSP_DATE");
} }
rs.close();
rs = null;
stmt.close(); stmt.close();
stmt = null; stmt = null;
// end 09-08-2006 manoharan // end 09-08-2006 manoharan
...@@ -1367,7 +1401,9 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -1367,7 +1401,9 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
cnt = pstmt.executeUpdate(); cnt = pstmt.executeUpdate();
writeLog(filePtr,"No of records inserted in SORDDET is : "+cnt,true); writeLog(filePtr,"No of records inserted in SORDDET is : "+cnt,true);
System.out.println("No of records inserted in SORDDET is : "+cnt); System.out.println("No of records inserted in SORDDET is : "+cnt);
pstmt.clearParameters(); pstmt.clearParameters();
pstmt.close();
pstmt = null;
}//try }//try
catch (SQLException ex) catch (SQLException ex)
{ {
...@@ -1419,7 +1455,9 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -1419,7 +1455,9 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
pstmt.setDouble(1,ordAmtHdr); pstmt.setDouble(1,ordAmtHdr);
pstmt.setDouble(2,taxAmtHdr); pstmt.setDouble(2,taxAmtHdr);
pstmt.setDouble(3,totAmtHdr); pstmt.setDouble(3,totAmtHdr);
cnt = pstmt.executeUpdate(); cnt = pstmt.executeUpdate();
pstmt.close();
pstmt = null;
System.out.println("No of records updated in SORDER is : "+cnt); System.out.println("No of records updated in SORDER is : "+cnt);
} }
catch (SQLException ex) catch (SQLException ex)
...@@ -1490,7 +1528,6 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -1490,7 +1528,6 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
}//process() }//process()
//private String generateTranTd(String windowName,String orderDate,String siteCode)throws Exception //private String generateTranTd(String windowName,String orderDate,String siteCode)throws Exception
//ADDED ORDER_TYPE BY RAJENDRA ON 21/12/07 //ADDED ORDER_TYPE BY RAJENDRA ON 21/12/07
//private String generateTranTd(String windowName,String orderDate,String siteCode,String orderType )throws Exception
private String generateTranTd(String windowName,String orderDate,String siteCode,String orderType, Connection conn )throws Exception private String generateTranTd(String windowName,String orderDate,String siteCode,String orderType, Connection conn )throws Exception
{ {
//ConnDriver connDriver = new ConnDriver(); //ConnDriver connDriver = new ConnDriver();
...@@ -1515,7 +1552,11 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -1515,7 +1552,11 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
keyString = rs.getString(1); keyString = rs.getString(1);
keyCol = rs.getString(2); keyCol = rs.getString(2);
tranSer1 = rs.getString(3); tranSer1 = rs.getString(3);
} }
rs.close();
rs = null;
stmt.close();
stmt = null;
System.out.println("keyString :"+keyString); System.out.println("keyString :"+keyString);
System.out.println("keyCol :"+keyCol); System.out.println("keyCol :"+keyCol);
System.out.println("tranSer1 :"+tranSer1); System.out.println("tranSer1 :"+tranSer1);
...@@ -1557,7 +1598,7 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -1557,7 +1598,7 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
conn = null; conn = null;
} }
catch(Exception se){} catch(Exception se){}
}//*/ }// */
return tranId; return tranId;
}//generateTranTd() }//generateTranTd()
...@@ -1592,12 +1633,14 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -1592,12 +1633,14 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
Document itemDoc = GenericUtility.getInstance().parseString(valueXmlString.toString()); Document itemDoc = GenericUtility.getInstance().parseString(valueXmlString.toString());
Node currRecordNode = itemDoc.getElementsByTagName("Detail2").item(0); Node currRecordNode = itemDoc.getElementsByTagName("Detail2").item(0);
// 19/05/09 manoharan old signature call commented and new signature called
//TaxCalculation taxCal = new TaxCalculation(); //TaxCalculation taxCal = new TaxCalculation();
TaxCalculation taxCal = new TaxCalculation("sorder"); TaxCalculation taxCal = new TaxCalculation("sorder");
writeLog(filePtr,"CurrNode:::(Before (appendOrReplaceTaxesNode)"+currRecordNode,true); // end 19/05/09 manoharan
writeLog(filePtr,"CurrNode:::(Before (appendOrReplaceTaxesNode)"+serializeDom(currRecordNode),true);
appendOrReplaceTaxesNode(currRecordNode); appendOrReplaceTaxesNode(currRecordNode);
writeLog(filePtr,"CurrNode:::(After (appendOrReplaceTaxesNode)"+currRecordNode,true); writeLog(filePtr,"CurrNode:::(After (appendOrReplaceTaxesNode)"+serializeDom(currRecordNode),true);
NodeList currRecordChildList = currRecordNode.getChildNodes(); NodeList currRecordChildList = currRecordNode.getChildNodes();
int childListLength = currRecordChildList.getLength(); int childListLength = currRecordChildList.getLength();
...@@ -1611,17 +1654,22 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -1611,17 +1654,22 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
} }
taxCal.setUpdatedTaxDom(currTaxNode); taxCal.setUpdatedTaxDom(currTaxNode);
taxCal.setTaxDom(currTaxNode); taxCal.setTaxDom(currTaxNode);
writeLog(filePtr,"(currRecordNode)>>>"+serializeDom(currRecordNode),true);
writeLog(filePtr,"(currTaxNode)>>>"+serializeDom(currTaxNode),true);
//taxCal.setDataNode(currRecordNode);///old //taxCal.setDataNode(currRecordNode);///old
String domId = Integer.toString(ctr); String domId = Integer.toString(ctr);
taxCal.setDataNode(currRecordNode,"2",domId); taxCal.setDataNode(currRecordNode,"2",domId);
writeLog(filePtr,"After:::(setDataNode)"+currRecordNode,true); writeLog(filePtr,"After:::(setDataNode)"+serializeDom(currRecordNode),true);
//commented by rajendra on 21/12/07 //commented by rajendra on 21/12/07
writeLog(filePtr,"Calling tax calculation................",true);
//String retStr = taxCal.taxCalc("S-ORD", tranId,tranDate,"rate__stduom", "quantity__stduom", currCode,siteCode); //String retStr = taxCal.taxCalc("S-ORD", tranId,tranDate,"rate__stduom", "quantity__stduom", currCode,siteCode);
tranRateCol = "rate__stduom"; tranRateCol = "rate__stduom";
tranQtyCol = "quantity__stduom" ; tranQtyCol = "quantity__stduom";
String retStr = taxCal.taxCalc("S-ORD", tranId,tranDate,"rate__stduom", "quantity__stduom", tranRateCol, tranQtyCol, currCode, siteCode); String retStr = taxCal.taxCalc("S-ORD", tranId,tranDate,"rate__stduom", "quantity__stduom", tranRateCol, tranQtyCol, currCode, siteCode);
System.out.println("CurrentTaxNode ::"+serializeDom(currTaxNode)); writeLog(filePtr,"Returned from taxcalc................[" +retStr + "]" ,true);
System.out.println("CurrentRecordNode ::"+serializeDom(currRecordNode)); //System.out.println("CurrentTaxNode ::"+serializeDom(currTaxNode));
//System.out.println("CurrentRecordNode ::"+serializeDom(currRecordNode));
taxAmount = GenericUtility.getInstance().getColumnValueFromNode("tax_amt",currRecordNode); taxAmount = GenericUtility.getInstance().getColumnValueFromNode("tax_amt",currRecordNode);
//taxAmt = Double.parseDouble(taxAmount); //taxAmt = Double.parseDouble(taxAmount);
...@@ -1630,7 +1678,8 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -1630,7 +1678,8 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
{ {
if (currRecordChildList.item(i).getNodeName().equalsIgnoreCase("Taxes")) if (currRecordChildList.item(i).getNodeName().equalsIgnoreCase("Taxes"))
{ {
currTaxNode = currRecordChildList.item(i); currTaxNode = currRecordChildList.item(i);
//writeLog(filePtr,"Saving Data for ["+ i + "] "+ serializeDom(currTaxNode),true);
saveData(currTaxNode,conn); saveData(currTaxNode,conn);
} }
} }
...@@ -1787,7 +1836,7 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -1787,7 +1836,7 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
rs=pstmt.executeQuery(); rs=pstmt.executeQuery();
ResultSetMetaData rsmd = rs.getMetaData(); ResultSetMetaData rsmd = rs.getMetaData();
int noOfColumn =rsmd.getColumnCount(); int noOfColumn =rsmd.getColumnCount();
writeLog(filePtr,"T A B L E S T R U C T U R E(TAXTRAN)",true); //writeLog(filePtr,"T A B L E S T R U C T U R E(TAXTRAN)",true);
for( i=1;i<=noOfColumn;i++) for( i=1;i<=noOfColumn;i++)
{ {
...@@ -1795,7 +1844,7 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -1795,7 +1844,7 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
String colName = rsmd.getColumnName(i); String colName = rsmd.getColumnName(i);
String colType = rsmd.getColumnTypeName(i); String colType = rsmd.getColumnTypeName(i);
writeLog(filePtr,"COLUMN_NAME["+colName+"] "+"COLUMN_TYPE["+colType+"]",true); //writeLog(filePtr,"COLUMN_NAME["+colName+"] "+"COLUMN_TYPE["+colType+"]",true);
columnAndTypeMap.put(colName.toUpperCase().trim(),colType.toUpperCase().trim()); columnAndTypeMap.put(colName.toUpperCase().trim(),colType.toUpperCase().trim());
if(i==noOfColumn) if(i==noOfColumn)
{ {
...@@ -1811,7 +1860,7 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -1811,7 +1860,7 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
} }
taxtranSql = "INSERT INTO TAXTRAN (" +fieldNameBuff.toString()+") VALUES ("+fieldValueBuff.toString()+")"; taxtranSql = "INSERT INTO TAXTRAN (" +fieldNameBuff.toString()+") VALUES ("+fieldValueBuff.toString()+")";
writeLog(filePtr,"taxtranSql**************"+taxtranSql,true); //writeLog(filePtr,"taxtranSql**************"+taxtranSql,true);
rs.close(); rs.close();
pstmt.close(); pstmt.close();
...@@ -1833,11 +1882,11 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -1833,11 +1882,11 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
String ColValue =taxfield.item(j).getFirstChild().getNodeValue().trim(); String ColValue =taxfield.item(j).getFirstChild().getNodeValue().trim();
if(!ColValue.equalsIgnoreCase("null")) if(!ColValue.equalsIgnoreCase("null"))
xmlFldTypeMap.put(fieldName.toUpperCase().trim(),ColValue); xmlFldTypeMap.put(fieldName.toUpperCase().trim(),ColValue);
writeLog(filePtr,"FROM XML COLUMN_NAME["+fieldName+"] COLUMN_TYPE["+ColValue+"]",true); //writeLog(filePtr,"FROM XML COLUMN_NAME["+fieldName+"] COLUMN_TYPE["+ColValue+"]",true);
} }
} }
String[] totColInQry = fieldNameBuff.toString().split(","); String[] totColInQry = fieldNameBuff.toString().split(",");
writeLog(filePtr,"Total Column in taxtran:::["+totColInQry.length+"]" ,true); //writeLog(filePtr,"Total Column in taxtran:::["+totColInQry.length+"]" ,true);
for(int j =0;j<totColInQry.length;j++) for(int j =0;j<totColInQry.length;j++)
{ {
...@@ -1854,12 +1903,12 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -1854,12 +1903,12 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
if(xmlFldTypeMap.containsKey(column.toUpperCase())) if(xmlFldTypeMap.containsKey(column.toUpperCase()))
{ {
writeLog(filePtr,"Found in Dom["+column+"]" ,true); //writeLog(filePtr,"Found in Dom["+column+"]" ,true);
String dataValue = xmlFldTypeMap.get(column.toUpperCase()).toString(); String dataValue = xmlFldTypeMap.get(column.toUpperCase()).toString();
if((dataType.toUpperCase().equalsIgnoreCase("CHAR"))||(dataType.toUpperCase().equalsIgnoreCase("VARCHAR2"))||(dataType.toUpperCase().equalsIgnoreCase("VARCHAR"))) if((dataType.toUpperCase().equalsIgnoreCase("CHAR"))||(dataType.toUpperCase().equalsIgnoreCase("VARCHAR2"))||(dataType.toUpperCase().equalsIgnoreCase("VARCHAR")))
{ {
writeLog(filePtr,"setting String value===>"+dataValue+"<===["+prepCount+"]" ,true); //writeLog(filePtr,"setting String value===>"+dataValue+"<===["+prepCount+"]" ,true);
if (column.equalsIgnoreCase("line_no") ) if (column.equalsIgnoreCase("line_no") )
{ {
String line_No = ((" "+dataValue).substring((" "+dataValue).length()-3)); String line_No = ((" "+dataValue).substring((" "+dataValue).length()-3));
...@@ -1872,33 +1921,33 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -1872,33 +1921,33 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
} }
else if ((dataType.toUpperCase().equalsIgnoreCase("NUMBER")) || (dataType.toUpperCase().equalsIgnoreCase("DECIMAL"))) else if ((dataType.toUpperCase().equalsIgnoreCase("NUMBER")) || (dataType.toUpperCase().equalsIgnoreCase("DECIMAL")))
{ {
writeLog(filePtr,"setting Number value===>"+dataValue+"<===["+prepCount+"]" ,true); //writeLog(filePtr,"setting Number value===>"+dataValue+"<===["+prepCount+"]" ,true);
pstmt.setDouble(prepCount, Double.valueOf(dataValue).doubleValue()); pstmt.setDouble(prepCount, Double.valueOf(dataValue).doubleValue());
} }
else if ((dataType.toUpperCase().equalsIgnoreCase("DATE"))||(dataType.toUpperCase().equalsIgnoreCase("TIMESTAMP"))) else if ((dataType.toUpperCase().equalsIgnoreCase("DATE"))||(dataType.toUpperCase().equalsIgnoreCase("TIMESTAMP")))
{ {
writeLog(filePtr,"setting String NULL===>["+prepCount+"]" ,true); //writeLog(filePtr,"setting String NULL===>["+prepCount+"]" ,true);
pstmt.setNull(prepCount, java.sql.Types.TIMESTAMP); pstmt.setNull(prepCount, java.sql.Types.TIMESTAMP);
} }
} }
else else
{ {
writeLog(filePtr,"Not Found in Dom{"+column+"}" ,true); //writeLog(filePtr,"Not Found in Dom{"+column+"}" ,true);
if((dataType.toUpperCase().equalsIgnoreCase("CHAR"))||(dataType.toUpperCase().equalsIgnoreCase("VARCHAR"))||(dataType.toUpperCase().equalsIgnoreCase("VARCHAR2"))) if((dataType.toUpperCase().equalsIgnoreCase("CHAR"))||(dataType.toUpperCase().equalsIgnoreCase("VARCHAR"))||(dataType.toUpperCase().equalsIgnoreCase("VARCHAR2")))
{ {
writeLog(filePtr,"setting String NULL===>["+prepCount+"]" ,true); //writeLog(filePtr,"setting String NULL===>["+prepCount+"]" ,true);
pstmt.setNull(prepCount, java.sql.Types.VARCHAR); pstmt.setNull(prepCount, java.sql.Types.VARCHAR);
} }
else if((dataType.toUpperCase().equalsIgnoreCase("NUMBER"))|| (dataType.toUpperCase().equalsIgnoreCase("DECIMAL"))) else if((dataType.toUpperCase().equalsIgnoreCase("NUMBER"))|| (dataType.toUpperCase().equalsIgnoreCase("DECIMAL")))
{ {
writeLog(filePtr,"setting String NULL===>["+prepCount+"]" ,true); //writeLog(filePtr,"setting String NULL===>["+prepCount+"]" ,true);
pstmt.setNull(prepCount, java.sql.Types.DOUBLE); pstmt.setNull(prepCount, java.sql.Types.DOUBLE);
} }
else if ((dataType.toUpperCase().equalsIgnoreCase("DATE"))||(dataType.toUpperCase().equalsIgnoreCase("TIMESTAMP"))) else if ((dataType.toUpperCase().equalsIgnoreCase("DATE"))||(dataType.toUpperCase().equalsIgnoreCase("TIMESTAMP")))
{ {
writeLog(filePtr,"setting String NULL===>["+prepCount+"]" ,true); //writeLog(filePtr,"setting String NULL===>["+prepCount+"]" ,true);
pstmt.setNull(prepCount, java.sql.Types.TIMESTAMP); pstmt.setNull(prepCount, java.sql.Types.TIMESTAMP);
} }
} }
...@@ -1907,7 +1956,9 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea ...@@ -1907,7 +1956,9 @@ public class SaleContractRelease extends ProcessEJB implements SaleContractRelea
} }
pstmt.addBatch(); pstmt.addBatch();
} }
pstmt.executeBatch(); pstmt.executeBatch();
pstmt.close();
pstmt = null;
} }
catch(SQLException se) catch(SQLException se)
{ {
......
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