Skip to content

B
business-java
Commit 9e93a144 authored by rtiwari's avatar rtiwari
Browse files
Options

TAKE CARE SQL STATEMENT FOR DB2 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@94078 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 68a5dfd9
Hide whitespace changes
Inline Side-by-side
Showing with 88 additions and 3 deletions
webitm-dis/ibase/webitm/ejb/dis/DistOrderAmdIC.java
View file @ 9e93a144
/**
For DB2 database condition added in sql statement - by ritesh on 03/dec/13 for supreme.
*/
package ibase.webitm.ejb.dis; package ibase.webitm.ejb.dis;
import java.rmi.RemoteException; import java.rmi.RemoteException;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
...@@ -11,6 +14,8 @@ import org.w3c.dom.Node; ...@@ -11,6 +14,8 @@ import org.w3c.dom.Node;
import org.w3c.dom.NodeList; import org.w3c.dom.NodeList;
//import javax.ejb.SessionBean;//commented for ejb3 //import javax.ejb.SessionBean;//commented for ejb3
import javax.ejb.CreateException; import javax.ejb.CreateException;
import ibase.utility.CommonConstants;
import ibase.webitm.utility.ITMException; import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.GenericUtility; import ibase.webitm.utility.GenericUtility;
import ibase.system.config.ConnDriver; import ibase.system.config.ConnDriver;
...@@ -129,6 +134,11 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal ...@@ -129,6 +134,11 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal
{ {
sql = " SELECT COUNT(*) FROM distorder WHERE dist_order = ? "; sql = " SELECT COUNT(*) FROM distorder WHERE dist_order = ? ";
if ("db2".equalsIgnoreCase(CommonConstants.DB_NAME ) || "mysql".equalsIgnoreCase(CommonConstants.DB_NAME ))
{
sql = sql + " for update ";
}System.out.println(" executing sql :: "+sql);
pstmt = conn.prepareStatement( sql ); pstmt = conn.prepareStatement( sql );
pstmt.setString(1,distOrder.trim()); pstmt.setString(1,distOrder.trim());
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
...@@ -152,6 +162,10 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal ...@@ -152,6 +162,10 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal
else{ else{
sql = " SELECT COUNT(*) FROM DISTORDER WHERE DIST_ORDER = ? AND STATUS NOT IN ('X','C') "; sql = " SELECT COUNT(*) FROM DISTORDER WHERE DIST_ORDER = ? AND STATUS NOT IN ('X','C') ";
if ("db2".equalsIgnoreCase(CommonConstants.DB_NAME ) || "mysql".equalsIgnoreCase(CommonConstants.DB_NAME ))
{
sql = sql + " for update ";
}System.out.println(" executing sql :: "+sql);
pstmt = conn.prepareStatement( sql ); pstmt = conn.prepareStatement( sql );
pstmt.setString(1,distOrder.trim()); pstmt.setString(1,distOrder.trim());
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
...@@ -182,6 +196,11 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal ...@@ -182,6 +196,11 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal
if( purOrder != null && purOrder.trim().length() > 0 ) if( purOrder != null && purOrder.trim().length() > 0 )
{ {
sql = " SELECT COUNT(*) FROM porddet WHERE purc_order = ? "; sql = " SELECT COUNT(*) FROM porddet WHERE purc_order = ? ";
if ("db2".equalsIgnoreCase(CommonConstants.DB_NAME ) || "mysql".equalsIgnoreCase(CommonConstants.DB_NAME ))
{
sql = sql + " for update ";
}System.out.println(" executing sql :: "+sql);
pstmt = conn.prepareStatement( sql ); pstmt = conn.prepareStatement( sql );
pstmt.setString(1,purOrder.trim()); pstmt.setString(1,purOrder.trim());
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
...@@ -267,6 +286,10 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal ...@@ -267,6 +286,10 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal
{ {
// SQL CHANGE BY RITESH FOR DI3HSUP004 // SQL CHANGE BY RITESH FOR DI3HSUP004
sql = " SELECT COUNT(*) FROM distorder_det WHERE dist_order = ? and line_no = ? "; sql = " SELECT COUNT(*) FROM distorder_det WHERE dist_order = ? and line_no = ? ";
if ("db2".equalsIgnoreCase(CommonConstants.DB_NAME ) || "mysql".equalsIgnoreCase(CommonConstants.DB_NAME ))
{
sql = sql + " for update ";
}System.out.println(" executing sql :: "+sql);
pstmt = conn.prepareStatement( sql ); pstmt = conn.prepareStatement( sql );
pstmt.setString(1,distOrder.trim()); pstmt.setString(1,distOrder.trim());
pstmt.setInt(2,Integer.parseInt(lineNoOrder.trim())); pstmt.setInt(2,Integer.parseInt(lineNoOrder.trim()));
...@@ -288,6 +311,10 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal ...@@ -288,6 +311,10 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal
} }
sql = " SELECT COUNT(*) FROM distorder_det WHERE dist_order = ? and line_no = ? and status = 'O' "; sql = " SELECT COUNT(*) FROM distorder_det WHERE dist_order = ? and line_no = ? and status = 'O' ";
if ("db2".equalsIgnoreCase(CommonConstants.DB_NAME ) || "mysql".equalsIgnoreCase(CommonConstants.DB_NAME ))
{
sql = sql + " for update ";
}System.out.println(" executing sql :: "+sql);
pstmt = conn.prepareStatement( sql ); pstmt = conn.prepareStatement( sql );
pstmt.setString(1,distOrder.trim()); pstmt.setString(1,distOrder.trim());
pstmt.setInt(2,Integer.parseInt(lineNoOrder.trim())); pstmt.setInt(2,Integer.parseInt(lineNoOrder.trim()));
...@@ -326,6 +353,10 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal ...@@ -326,6 +353,10 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal
if( taxClass != null && taxClass.trim().length() > 0 ) if( taxClass != null && taxClass.trim().length() > 0 )
{ {
sql = " SELECT COUNT(*) FROM taxclass WHERE tax_class = ? "; sql = " SELECT COUNT(*) FROM taxclass WHERE tax_class = ? ";
if ("db2".equalsIgnoreCase(CommonConstants.DB_NAME ) || "mysql".equalsIgnoreCase(CommonConstants.DB_NAME ))
{
sql = sql + " for update ";
}System.out.println(" executing sql :: "+sql);
pstmt = conn.prepareStatement( sql ); pstmt = conn.prepareStatement( sql );
pstmt.setString(1,taxClass.trim()); pstmt.setString(1,taxClass.trim());
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
...@@ -352,6 +383,10 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal ...@@ -352,6 +383,10 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal
if( taxChap != null && taxChap.trim().length() > 0 ) if( taxChap != null && taxChap.trim().length() > 0 )
{ {
sql = " SELECT COUNT(*) FROM taxchap WHERE tax_chap = ? "; sql = " SELECT COUNT(*) FROM taxchap WHERE tax_chap = ? ";
if ("db2".equalsIgnoreCase(CommonConstants.DB_NAME ) || "mysql".equalsIgnoreCase(CommonConstants.DB_NAME ))
{
sql = sql + " for update ";
}System.out.println(" executing sql :: "+sql);
pstmt = conn.prepareStatement( sql ); pstmt = conn.prepareStatement( sql );
pstmt.setString(1,taxChap.trim()); pstmt.setString(1,taxChap.trim());
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
...@@ -379,6 +414,10 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal ...@@ -379,6 +414,10 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal
if( taxEnv != null && taxEnv.trim().length() > 0 ) if( taxEnv != null && taxEnv.trim().length() > 0 )
{ {
sql = " SELECT COUNT(*) FROM taxenv WHERE tax_env = ? "; sql = " SELECT COUNT(*) FROM taxenv WHERE tax_env = ? ";
if ("db2".equalsIgnoreCase(CommonConstants.DB_NAME ) || "mysql".equalsIgnoreCase(CommonConstants.DB_NAME ))
{
sql = sql + " for update ";
}System.out.println(" executing sql :: "+sql);
pstmt = conn.prepareStatement( sql ); pstmt = conn.prepareStatement( sql );
pstmt.setString(1,taxEnv.trim()); pstmt.setString(1,taxEnv.trim());
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
...@@ -537,6 +576,10 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal ...@@ -537,6 +576,10 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal
{ {
String siteDescr = null; String siteDescr = null;
sql = " select descr from site WHERE site_code = ? "; sql = " select descr from site WHERE site_code = ? ";
if ("db2".equalsIgnoreCase(CommonConstants.DB_NAME ) || "mysql".equalsIgnoreCase(CommonConstants.DB_NAME ))
{
sql = sql + " for update ";
}System.out.println(" executing sql :: "+sql);
vPStmt = conn.prepareStatement( sql ); vPStmt = conn.prepareStatement( sql );
vPStmt.setString(1,loginSite.trim()); vPStmt.setString(1,loginSite.trim());
vRs = vPStmt.executeQuery(); vRs = vPStmt.executeQuery();
...@@ -655,6 +698,10 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal ...@@ -655,6 +698,10 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal
+" AND DIST.SITE_CODE__SHIP = S1.SITE_CODE(+) " +" AND DIST.SITE_CODE__SHIP = S1.SITE_CODE(+) "
+" AND DIST.SITE_CODE__DLV = S2.SITE_CODE(+) " +" AND DIST.SITE_CODE__DLV = S2.SITE_CODE(+) "
+" AND DIST.SITE_CODE__BIL = S3.SITE_CODE(+) "; +" AND DIST.SITE_CODE__BIL = S3.SITE_CODE(+) ";
if ("db2".equalsIgnoreCase(CommonConstants.DB_NAME ) || "mysql".equalsIgnoreCase(CommonConstants.DB_NAME ))
{
vSql = vSql + " for update ";
}System.out.println(" Executing vSql "+vSql);
vPStmt = conn.prepareStatement( vSql ); vPStmt = conn.prepareStatement( vSql );
vPStmt.setString(1,distOrder.trim()); vPStmt.setString(1,distOrder.trim());
...@@ -876,7 +923,12 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal ...@@ -876,7 +923,12 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal
qtyOrder = genericUtility.getColumnValue( "qty_order", dom ); qtyOrder = genericUtility.getColumnValue( "qty_order", dom );
rate = genericUtility.getColumnValue( "rate", dom ); rate = genericUtility.getColumnValue( "rate", dom );
vSql = " select status from distorder where dist_order = ? "; vSql = " select status from distorder where dist_order = ? ";
vPStmt = conn.prepareStatement( vSql ); if ("db2".equalsIgnoreCase(CommonConstants.DB_NAME ) || "mysql".equalsIgnoreCase(CommonConstants.DB_NAME ))
{
vSql = vSql + " for update ";
}System.out.println(" executing vSql :: "+vSql);
vPStmt = conn.prepareStatement( vSql );
vPStmt.setString(1,distOrder.trim()); vPStmt.setString(1,distOrder.trim());
vRs = vPStmt.executeQuery(); vRs = vPStmt.executeQuery();
if( vRs.next() ) if( vRs.next() )
...@@ -963,7 +1015,12 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal ...@@ -963,7 +1015,12 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal
+" WHERE DIST_ORDER = ? " +" WHERE DIST_ORDER = ? "
+" and line_no = ? " +" and line_no = ? "
+" and DET.ITEM_CODE = I.ITEM_CODE(+) " ; +" and DET.ITEM_CODE = I.ITEM_CODE(+) " ;
if ("db2".equalsIgnoreCase(CommonConstants.DB_NAME ) || "mysql".equalsIgnoreCase(CommonConstants.DB_NAME ))
{
vSql = vSql + " for update ";
}System.out.println(" executing vSql :: "+vSql);
vPStmt = conn.prepareStatement( vSql ); vPStmt = conn.prepareStatement( vSql );
vPStmt.setString(1,distOrder.trim()); vPStmt.setString(1,distOrder.trim());
vPStmt.setInt(2,Integer.parseInt(lineNoOrder.trim())); vPStmt.setInt(2,Integer.parseInt(lineNoOrder.trim()));
......
webitm-dis/ibase/webitm/ejb/dis/adv/DistOrderAmdConf.java
View file @ 9e93a144
/**
For DB2 database condition added in sql statement - by ritesh on 03/dec/13 for supreme.
*/
package ibase.webitm.ejb.dis.adv; package ibase.webitm.ejb.dis.adv;
import java.sql.*; import java.sql.*;
...@@ -68,6 +71,10 @@ public class DistOrderAmdConf extends ActionHandlerEJB implements DistOrderAmdCo ...@@ -68,6 +71,10 @@ public class DistOrderAmdConf extends ActionHandlerEJB implements DistOrderAmdCo
if( errString == null || errString.trim().length() == 0 ) if( errString == null || errString.trim().length() == 0 )
{ {
sql = " select count( 1 ) cnt from distordamd where amd_no = ? AND CONFIRMED = 'Y' "; sql = " select count( 1 ) cnt from distordamd where amd_no = ? AND CONFIRMED = 'Y' ";
if ("db2".equalsIgnoreCase(CommonConstants.DB_NAME ) || "mysql".equalsIgnoreCase(CommonConstants.DB_NAME ))
{
sql = sql + " for update ";
}System.out.println("executing Sql "+sql);
pstmt = conn.prepareStatement( sql ); pstmt = conn.prepareStatement( sql );
pstmt.setString(1,tranId.trim()); pstmt.setString(1,tranId.trim());
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
...@@ -111,6 +118,10 @@ public class DistOrderAmdConf extends ActionHandlerEJB implements DistOrderAmdCo ...@@ -111,6 +118,10 @@ public class DistOrderAmdConf extends ActionHandlerEJB implements DistOrderAmdCo
+" distordamd " +" distordamd "
+" where " +" where "
+" amd_no = ? "; +" amd_no = ? ";
if ("db2".equalsIgnoreCase(CommonConstants.DB_NAME ) || "mysql".equalsIgnoreCase(CommonConstants.DB_NAME ))
{
sql = sql + " for update ";
}System.out.println("executing Sql "+sql);
pstmt = conn.prepareStatement( sql ); pstmt = conn.prepareStatement( sql );
pstmt.setString(1,tranId.trim()); pstmt.setString(1,tranId.trim());
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
...@@ -132,6 +143,10 @@ public class DistOrderAmdConf extends ActionHandlerEJB implements DistOrderAmdCo ...@@ -132,6 +143,10 @@ public class DistOrderAmdConf extends ActionHandlerEJB implements DistOrderAmdCo
pstmt = null; pstmt = null;
sql = " select count( 1 ) cnt from distorder where dist_order = ? AND CONFIRMED = 'Y' "; sql = " select count( 1 ) cnt from distorder where dist_order = ? AND CONFIRMED = 'Y' ";
if ("db2".equalsIgnoreCase(CommonConstants.DB_NAME ) || "mysql".equalsIgnoreCase(CommonConstants.DB_NAME ))
{
sql = sql + " for update ";
}System.out.println("executing Sql "+sql);
pstmt = conn.prepareStatement( sql ); pstmt = conn.prepareStatement( sql );
pstmt.setString(1,distOrder.trim()); pstmt.setString(1,distOrder.trim());
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
...@@ -162,6 +177,7 @@ public class DistOrderAmdConf extends ActionHandlerEJB implements DistOrderAmdCo ...@@ -162,6 +177,7 @@ public class DistOrderAmdConf extends ActionHandlerEJB implements DistOrderAmdCo
+" trans_mode = ?, " +" trans_mode = ?, "
+" emp_code__aprv = ? " +" emp_code__aprv = ? "
+" where dist_order = ? "; +" where dist_order = ? ";
pstmt = conn.prepareStatement( sql ); pstmt = conn.prepareStatement( sql );
pstmt.setString(1,purcOrder.trim()); pstmt.setString(1,purcOrder.trim());
...@@ -209,6 +225,10 @@ public class DistOrderAmdConf extends ActionHandlerEJB implements DistOrderAmdCo ...@@ -209,6 +225,10 @@ public class DistOrderAmdConf extends ActionHandlerEJB implements DistOrderAmdCo
+" in( select dist_order, line_no " +" in( select dist_order, line_no "
+" from distorder_det dist " +" from distorder_det dist "
+" where trim( dist.dist_order) = trim(hdr.dist_order) )"; +" where trim( dist.dist_order) = trim(hdr.dist_order) )";
if ("db2".equalsIgnoreCase(CommonConstants.DB_NAME ) || "mysql".equalsIgnoreCase(CommonConstants.DB_NAME ))
{
sql = sql + " for update ";
}System.out.println("executing Sql "+sql);
pstmt = conn.prepareStatement( sql ); pstmt = conn.prepareStatement( sql );
pstmt.setString(1,tranId.trim()); pstmt.setString(1,tranId.trim());
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
...@@ -248,6 +268,7 @@ public class DistOrderAmdConf extends ActionHandlerEJB implements DistOrderAmdCo ...@@ -248,6 +268,7 @@ public class DistOrderAmdConf extends ActionHandlerEJB implements DistOrderAmdCo
+" ,status = ? " // added by ritesh on 20/dec/13 FOR DI3HSUP004 +" ,status = ? " // added by ritesh on 20/dec/13 FOR DI3HSUP004
+" where dist_order = ? " +" where dist_order = ? "
+" and line_no = ? " ; +" and line_no = ? " ;
pstmt = conn.prepareStatement( sql ); pstmt = conn.prepareStatement( sql );
pstmt.setString(1,distOrderamd.trim()); pstmt.setString(1,distOrderamd.trim());
pstmt.setString(2,lineNoDistord.trim()); pstmt.setString(2,lineNoDistord.trim());
...@@ -287,6 +308,10 @@ public class DistOrderAmdConf extends ActionHandlerEJB implements DistOrderAmdCo ...@@ -287,6 +308,10 @@ public class DistOrderAmdConf extends ActionHandlerEJB implements DistOrderAmdCo
+" in( select dist_order " +" in( select dist_order "
+" from distorder_det dist " +" from distorder_det dist "
+" where trim( dist.dist_order) = trim(hdr.dist_order) )"; +" where trim( dist.dist_order) = trim(hdr.dist_order) )";
if ("db2".equalsIgnoreCase(CommonConstants.DB_NAME ) || "mysql".equalsIgnoreCase(CommonConstants.DB_NAME ))
{
sql = sql + " for update ";
}System.out.println("executing Sql "+sql);
pstmt = conn.prepareStatement( sql ); pstmt = conn.prepareStatement( sql );
pstmt.setString(1,tranId.trim()); pstmt.setString(1,tranId.trim());
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
...@@ -305,7 +330,10 @@ public class DistOrderAmdConf extends ActionHandlerEJB implements DistOrderAmdCo ...@@ -305,7 +330,10 @@ public class DistOrderAmdConf extends ActionHandlerEJB implements DistOrderAmdCo
taxEnv = rs.getString( "tax_env" ) == null ? "" : rs.getString( "tax_env" ); taxEnv = rs.getString( "tax_env" ) == null ? "" : rs.getString( "tax_env" );
sql = " select (max(line_no) + 1) line_no from distorder_det where dist_order = ? "; sql = " select (max(line_no) + 1) line_no from distorder_det where dist_order = ? ";
if ("db2".equalsIgnoreCase(CommonConstants.DB_NAME ) || "mysql".equalsIgnoreCase(CommonConstants.DB_NAME ))
{
sql = sql + " for update ";
}System.out.println("executing Sql "+sql);
pstmt = conn.prepareStatement( sql ); pstmt = conn.prepareStatement( sql );
pstmt.setString(1,distOrder.trim()); pstmt.setString(1,distOrder.trim());
rs1 = pstmt.executeQuery(); rs1 = pstmt.executeQuery();
......
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