Skip to content

B
business-java
Commit 099402ea authored by rtiwari's avatar rtiwari
Browse files
Options

DIST_ORDER ITEM CHANGE SQL CHANGED FOR DB2 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@94100 ce508802-f39f-4f6c-b175-0d175dae99d5
parent cc2f424b
Hide whitespace changes
Inline Side-by-side
Showing with 40 additions and 56 deletions
webitm-dis/ibase/webitm/ejb/dis/DistOrderAmdIC.java
View file @ 099402ea
/**
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;
...@@ -134,10 +131,6 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal ...@@ -134,10 +131,6 @@ 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());
...@@ -162,10 +155,7 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal ...@@ -162,10 +155,7 @@ 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();
...@@ -196,10 +186,6 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal ...@@ -196,10 +186,6 @@ 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());
...@@ -286,10 +272,6 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal ...@@ -286,10 +272,6 @@ 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()));
...@@ -311,10 +293,6 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal ...@@ -311,10 +293,6 @@ 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()));
...@@ -353,10 +331,6 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal ...@@ -353,10 +331,6 @@ 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();
...@@ -383,10 +357,6 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal ...@@ -383,10 +357,6 @@ 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();
...@@ -414,10 +384,6 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal ...@@ -414,10 +384,6 @@ 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();
...@@ -576,11 +542,7 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal ...@@ -576,11 +542,7 @@ 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 )) vPStmt = conn.prepareStatement(sql);
{
sql = sql + " for update ";
}System.out.println(" executing sql :: "+sql);
vPStmt = conn.prepareStatement( sql );
vPStmt.setString(1,loginSite.trim()); vPStmt.setString(1,loginSite.trim());
vRs = vPStmt.executeQuery(); vRs = vPStmt.executeQuery();
if( vRs.next() ) if( vRs.next() )
...@@ -698,12 +660,30 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal ...@@ -698,12 +660,30 @@ 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 )) // added by ritesh on 07/jan/13 for supreme start
if ("db2".equalsIgnoreCase(CommonConstants.DB_NAME ))
{ {
vSql = vSql + " for update "; vSql = "SELECT DIST.ORDER_DATE,DIST.SITE_CODE__SHIP,S1.DESCR A_DESCR,S1.ADD1 A_ADD1, "
}System.out.println(" Executing vSql "+vSql); +" S1.ADD2 A_ADD2,S1.CITY A_CITY,S1.PIN A_PIN,S1.STATE_CODE A_STATE_CODE, "
+" DIST.SITE_CODE__DLV,S2.DESCR B_DESCR,S2.ADD1 B_ADD1,S2.ADD2 B_ADD2, "
vPStmt = conn.prepareStatement( vSql ); +" S2.CITY B_CITY,S2.PIN B_PIN,S2.STATE_CODE B_STATE_CODE, "
+" DIST.SHIP_DATE,DIST.DUE_DATE,DIST.REMARKS,DIST.DIST_ROUTE,DIST.PRICE_LIST, "
+" DIST.TARGET_WGT,DIST.TARGET_VOL,DIST.LOC_CODE__GIT,DIST.PROJ_CODE, "
+" DIST.MRP_RUN_ID,DIST.SALE_ORDER, DIST.REMARKS1, "
+" DIST.REMARKS2,DIST.CURR_CODE,DIST.ORDER_TYPE,DIST.LOC_CODE__CONS, "
+" DIST.SUNDRY_TYPE,DIST.SUNDRY_CODE,DIST.AUTO_RECEIPT,DIST.TRAN_TYPE,DIST.SALES_PERS, "
+" DIST.LOC_CODE__GITBF,DIST.CUST_CODE__DLV,DIST.DLV_TO,DIST.DLV_ADD1,DIST.DLV_ADD2, "
+" DIST.DLV_ADD3,DIST.DLV_CITY,DIST.STATE_CODE__DLV,DIST.COUNT_CODE__DLV,DIST.DLV_PIN, "
+" DIST.STAN_CODE,DIST.TEL1__DLV,DIST.TEL2__DLV,DIST.TEL3__DLV,DIST.FAX__DLV,DIST.AVALIABLE_YN, "
+" DIST.PURC_ORDER,DIST.TOT_AMT,DIST.TAX_AMT,DIST.NET_AMT,DIST.TRAN_SER,DIST.PARENT__TRAN_ID, "
+" DIST.REV__TRAN,DIST.PRICE_LIST__CLG,DIST.SORD_NO,DIST.POLICY_NO,DIST.LOC_CODE__DAMAGED, "
+" DIST.SITE_CODE__BIL, DIST. TRANS_MODE,S3.DESCR C_DESCR,S3.ADD1 C_ADD1,S3.ADD2 C_ADD2, "
+" DIST.TRANS_MODE,S3.CITY C_CITY,S3.PIN C_PIN,S3.STATE_CODE C_STATE_CODE "
+" FROM DISTORDER DIST left outer join SITE S3 on DIST.SITE_CODE__BIL = S3.SITE_CODE ,SITE S1 ,SITE S2 "
+" WHERE DIST.DIST_ORDER = ? AND DIST.SITE_CODE__SHIP = S1.SITE_CODE AND DIST.SITE_CODE__DLV = S2.SITE_CODE ";
}
// added by ritesh on 07/jan/13 for supreme end
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() )
...@@ -791,7 +771,6 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal ...@@ -791,7 +771,6 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal
cStateCode = vRs.getString( "C_STATE_CODE" ); cStateCode = vRs.getString( "C_STATE_CODE" );
sundryCode = vRs.getString( "SUNDRY_CODE" ); sundryCode = vRs.getString( "SUNDRY_CODE" );
tranMode = vRs.getString( "TRANS_MODE" ); tranMode = vRs.getString( "TRANS_MODE" );
} }
vRs.close(); vRs.close();
vRs = null; vRs = null;
...@@ -923,10 +902,6 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal ...@@ -923,10 +902,6 @@ 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 = ? ";
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());
...@@ -1014,13 +989,22 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal ...@@ -1014,13 +989,22 @@ public class DistOrderAmdIC extends ValidatorEJB implements DistOrderAmdICLocal
+" FROM DISTORDER_DET DET, ITEM I " +" FROM DISTORDER_DET DET, ITEM I "
+" 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(+) " ;
// added by ritesh on 07/jan/13 for supreme start
if ("db2".equalsIgnoreCase(CommonConstants.DB_NAME ) || "mysql".equalsIgnoreCase(CommonConstants.DB_NAME )) if ("db2".equalsIgnoreCase(CommonConstants.DB_NAME ))
{ {
vSql = vSql + " for update "; vSql = " SELECT DET.TRAN_ID__DEMAND, DET.SALE_ORDER, DET.QTY_ORDER,DET.ITEM_CODE, I.DESCR, DET.QTY_CONFIRM, DET.QTY_RECEIVED, DET.QTY_SHIPPED, "
}System.out.println(" executing vSql :: "+vSql); +" DET.DUE_DATE, DET.TAX_CLASS, DET.TAX_CHAP, DET.TAX_ENV, DET.UNIT, DET.LINE_NO__SORD,DET.CUST_SPEC__NO, "
+" DET.RATE, DET.QTY_RETURN, DET.RATE_CLG, DET.DISCOUNT, DET.REMARKS, DET.TOT_AMT, DET.TAX_AMT, DET.NET_AMT, "
+" DET.OVER_SHIP_PERC, DET.RATE__CLG, DET.QTY_ALLOC, DET.DATE_ALLOC, DET.UNIT__ALT, DET.CONV__QTY__ALT, "
+" DET.QTY_ORDER__ALT, DET.SHIP_DATE, DET.PACK_INSTR, DET.CUST_ITEM__REF, DET.CUSTOM_DESCR, "
+" DET.REAS_CODE, DET.WORK_ORDER "
+" ,DET.STATUS "
+" FROM DISTORDER_DET DET left outer join ITEM I on DET.ITEM_CODE = I.ITEM_CODE "
+" WHERE DIST_ORDER = ? "
+" and line_no = ? ";
}
// added by ritesh on 07/jan/13 for supreme end
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()));
......
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