[jboss-svn-commits] JBL Code SVN: r6253 - labs/jbossesb/branches/JBESB_4_0_Beta1_maint/product/core/services/src/org/jboss/soa/esb/services/beans
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Sat Sep 16 16:17:50 EDT 2006
Author: mohit309
Date: 2006-09-16 16:17:49 -0400 (Sat, 16 Sep 2006)
New Revision: 6253
Modified:
labs/jbossesb/branches/JBESB_4_0_Beta1_maint/product/core/services/src/org/jboss/soa/esb/services/beans/BatchHandlerBean.java
labs/jbossesb/branches/JBESB_4_0_Beta1_maint/product/core/services/src/org/jboss/soa/esb/services/beans/PersistHandlerBean.java
Log:
Corrected method names to reflect full logical names
Modified: labs/jbossesb/branches/JBESB_4_0_Beta1_maint/product/core/services/src/org/jboss/soa/esb/services/beans/BatchHandlerBean.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_0_Beta1_maint/product/core/services/src/org/jboss/soa/esb/services/beans/BatchHandlerBean.java 2006-09-16 20:17:34 UTC (rev 6252)
+++ labs/jbossesb/branches/JBESB_4_0_Beta1_maint/product/core/services/src/org/jboss/soa/esb/services/beans/BatchHandlerBean.java 2006-09-16 20:17:49 UTC (rev 6253)
@@ -195,9 +195,9 @@
oDto.setSnapDate(sSnapDt);
// Insert Snap row
- PreparedStatement PSins = getDaoSnap(oStore).getPS(DaoSnapTable.PS_INS_SNAP);
- m_oDaoSnap.setInsValues(PSins,oDto);
- try { m_oDataConn.execUpdWait(PSins,10); }
+ PreparedStatement PSins = getDaoSnap(oStore).getPreparedStatement(DaoSnapTable.PS_INS_SNAP);
+ m_oDaoSnap.setInsertValues(PSins,oDto);
+ try { m_oDataConn.execUpdateWait(PSins,10); }
catch (Exception e) { m_oLogger.error(e.getMessage()); }
// Insert row in all index tables
@@ -205,8 +205,8 @@
for (int i1=0; i1<saa.length; i1++)
{ m_oDaoIndex = getDaoIndex(oStore.getLocatorTable(i1));
PSins = m_oDaoIndex.getPS(DaoIndexTable.PS_INS_INDEX);
- m_oDaoIndex.setInsValues(PSins,oDto,i1);
- try { m_oDataConn.execUpdWait(PSins,10); }
+ m_oDaoIndex.setInsertValues(PSins,oDto,i1);
+ try { m_oDataConn.execUpdateWait(PSins,10); }
catch (Exception e) { m_oLogger.error(e.getMessage()); }
}
}
@@ -216,7 +216,7 @@
PreparedStatement PSdel = getDaoBatch(BobjStore.getBatchTableName())
.getPS(DaoBatchTable.PS_DELETE_BATCH);
PSdel.setLong(1,p_oBP.getBatchNum());
- m_oDataConn.execUpdWait(PSdel,10);
+ m_oDataConn.execUpdateWait(PSdel,10);
p_oBP.setField (BatchProcess.ATTRIB.commitStamp,Long.toString(lNow));
p_oBP.setStamp (lNow);
@@ -226,15 +226,15 @@
// Update snap table with proper timestamp
m_oDaoSnap = null;
- PreparedStatement PSupd = getDaoSnap(oStore).getPS(DaoSnapTable.PS_UPD_SNAP);
- getDaoSnap(oStore).setUpdValues(PSupd,p_oBP);
- m_oDataConn.execUpdWait(PSupd,10);
+ PreparedStatement PSupd = getDaoSnap(oStore).getPreparedStatement(DaoSnapTable.PS_UPD_SNAP);
+ getDaoSnap(oStore).setUpdateValues(PSupd,p_oBP);
+ m_oDataConn.execUpdateWait(PSupd,10);
// Update index table with proper timestamp
m_oDaoIndex = null;
PSupd = getDaoIndex(oStore.getLocatorTable()).getPS(DaoIndexTable.PS_UPD_INDEX);
getDaoIndex(oStore.getLocatorTable()).setUpdValues(PSupd,p_oBP);
- m_oDataConn.execUpdWait(PSupd,10);
+ m_oDataConn.execUpdateWait(PSupd,10);
} //__________________________________
@@ -277,8 +277,8 @@
{ RowBatch oRow = new RowBatch(m_lBatchNum,++m_iSeq,0,p_s);
getDaoBatch(BobjStore.getBatchTableName());
PreparedStatement PS = m_oDaoBatch.getPS(DaoBatchTable.PS_INS_BATCHROW);
- m_oDaoBatch.setInsValues(PS,oRow);
- m_oDataConn.execUpdWait(PS,1);
+ m_oDaoBatch.setInsertValues(PS,oRow);
+ m_oDataConn.execUpdateWait(PS,1);
m_oDataConn.commit();
return m_iSeq;
}
Modified: labs/jbossesb/branches/JBESB_4_0_Beta1_maint/product/core/services/src/org/jboss/soa/esb/services/beans/PersistHandlerBean.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_0_Beta1_maint/product/core/services/src/org/jboss/soa/esb/services/beans/PersistHandlerBean.java 2006-09-16 20:17:34 UTC (rev 6252)
+++ labs/jbossesb/branches/JBESB_4_0_Beta1_maint/product/core/services/src/org/jboss/soa/esb/services/beans/PersistHandlerBean.java 2006-09-16 20:17:49 UTC (rev 6253)
@@ -234,7 +234,7 @@
{ String sFldVal = saCurr[i2];
PS.setString(iFld++,(null == sFldVal)?"":sFldVal);
}
- m_oDataConn.execUpdWait(PS,1);
+ m_oDataConn.execUpdateWait(PS,1);
}
return oaRet;
@@ -247,7 +247,7 @@
try
{ PreparedStatement PS = getDaoIndex(p_oSt,i1).getPS(DaoIndexTable.PS_RMV_INDEX);
PS.setLong(1,p_lUid);
- m_oDataConn.execUpdWait(PS,5);
+ m_oDataConn.execUpdateWait(PS,5);
}
catch (Exception e)
{ m_oLogger.warn("doDelLocator() FAILED <"+e.getMessage()+">");
@@ -256,14 +256,14 @@
private void doDelOneSnap (BobjStore p_oSt,long p_lUid) throws Exception
{ if (p_lUid < 1) return;
- PreparedStatement PS = getDaoSnap(p_oSt).getPS(DaoSnapTable.PS_RMV_SNAP);
+ PreparedStatement PS = getDaoSnap(p_oSt).getPreparedStatement(DaoSnapTable.PS_RMV_SNAP);
PS.setLong(1,p_lUid);
- m_oDataConn.execUpdWait(PS,5);
+ m_oDataConn.execUpdateWait(PS,5);
} //__________________________________
private void doRmvSnapshot (BobjStore p_oSt,long p_lUid) throws Exception
{
- PreparedStatement PS = getDaoSnap(p_oSt).getPS(DaoSnapTable.PS_SEL_4UPD);
+ PreparedStatement PS = getDaoSnap(p_oSt).getPreparedStatement(DaoSnapTable.PS_SEL_4UPD);
PS.setLong(1,p_lUid);
ResultSet rs = m_oDataConn.execQueryWait(PS,30);
if (! rs.next()) throw new Exception("Non existing Snapshot");
@@ -301,21 +301,21 @@
p_oDto.setSnapDate(s_oY4md.format(new Date(lNow)));
BobjStore oSt = BobjStore.getStore(p_oDto);
- PreparedStatement PS = getDaoSnap(oSt).getPS(DaoSnapTable.PS_INS_SNAP);
- getDaoSnap(oSt).setInsValues(PS,p_oDto);
+ PreparedStatement PS = getDaoSnap(oSt).getPreparedStatement(DaoSnapTable.PS_INS_SNAP);
+ getDaoSnap(oSt).setInsertValues(PS,p_oDto);
- m_oDataConn.execUpdWait(PS,1);
+ m_oDataConn.execUpdateWait(PS,1);
int iQlocs = oSt.allLocatorTables().length;
for (int i1=0; i1<iQlocs; i1++)
{ DaoIndexTable oDao = getDaoIndex(oSt,i1);
PS = oDao.getPS(DaoIndexTable.PS_INS_INDEX);
- oDao.setInsValues(PS,p_oDto);
- try { m_oDataConn.execUpdWait(PS,1); }
+ oDao.setInsertValues(PS,p_oDto);
+ try { m_oDataConn.execUpdateWait(PS,1); }
catch (Exception e)
{ PS = oDao.getPS(DaoIndexTable.PS_UPD_INDEX);
oDao.setUpdValues(PS,p_oDto);
- m_oDataConn.execUpdWait(PS,10);
+ m_oDataConn.execUpdateWait(PS,10);
}
}
@@ -331,15 +331,15 @@
PreparedStatement PSupd = oDao.getPS(DaoIndexTable.PS_UPD_INDEX);
oDao.setUpdValues(PSupd, p_oDto);
- m_oDataConn.execUpdWait(PSupd,10);
+ m_oDataConn.execUpdateWait(PSupd,10);
} //__________________________________
private BobjStdDTO doGetSnapshot (BobjStore p_oSt,long p_lUid) throws Exception
- { PreparedStatement PS = getDaoSnap(p_oSt).getPS(DaoSnapTable.PS_SEL_SNAP);
+ { PreparedStatement PS = getDaoSnap(p_oSt).getPreparedStatement(DaoSnapTable.PS_SEL_SNAP);
PS.setLong(1,p_lUid);
ResultSet rs = m_oDataConn.execQueryWait(PS,30);
if (! rs.next()) throw new Exception("Non existing Snapshot");
- BobjStdDTO oRet = (BobjStdDTO)getDaoSnap(p_oSt).getFromRS(rs);
+ BobjStdDTO oRet = (BobjStdDTO)getDaoSnap(p_oSt).getFromResultSet(rs);
return oRet;
} //__________________________________
More information about the jboss-svn-commits
mailing list