[jboss-svn-commits] JBL Code SVN: r6252 - labs/jbossesb/branches/JBESB_4_0_Beta1_maint/product/core/services/src/org/jboss/soa/esb/internal/core/objectstore
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Sat Sep 16 16:17:35 EDT 2006
Author: mohit309
Date: 2006-09-16 16:17:34 -0400 (Sat, 16 Sep 2006)
New Revision: 6252
Modified:
labs/jbossesb/branches/JBESB_4_0_Beta1_maint/product/core/services/src/org/jboss/soa/esb/internal/core/objectstore/DaoBatchTable.java
labs/jbossesb/branches/JBESB_4_0_Beta1_maint/product/core/services/src/org/jboss/soa/esb/internal/core/objectstore/DaoIndexTable.java
labs/jbossesb/branches/JBESB_4_0_Beta1_maint/product/core/services/src/org/jboss/soa/esb/internal/core/objectstore/DaoSnapTable.java
labs/jbossesb/branches/JBESB_4_0_Beta1_maint/product/core/services/src/org/jboss/soa/esb/internal/core/objectstore/DaoUidTable.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/internal/core/objectstore/DaoBatchTable.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_0_Beta1_maint/product/core/services/src/org/jboss/soa/esb/internal/core/objectstore/DaoBatchTable.java 2006-09-16 20:17:15 UTC (rev 6251)
+++ labs/jbossesb/branches/JBESB_4_0_Beta1_maint/product/core/services/src/org/jboss/soa/esb/internal/core/objectstore/DaoBatchTable.java 2006-09-16 20:17:34 UTC (rev 6252)
@@ -103,7 +103,7 @@
* @see DaoBatchTable#getPS(int)
* @see RowBatch
*/
- public int setInsValues(PreparedStatement p_PS,Object p_o)
+ public int setInsertValues(PreparedStatement p_PS,Object p_o)
throws Exception
{ try
{ if (! (p_o instanceof RowBatch)) throw
@@ -136,7 +136,7 @@
* @see DaoBatchTable#PS_GET_BATCH_ROWS
* @see RowBatch
*/
- public Object getFromRS (ResultSet p_oRS) throws Exception
+ public Object getFromResultSet(ResultSet p_oRS) throws Exception
{ try
{ RowBatch oRet = new RowBatch();
oRet.m_lBatch = p_oRS.getLong(1+BATCH_NUM);
Modified: labs/jbossesb/branches/JBESB_4_0_Beta1_maint/product/core/services/src/org/jboss/soa/esb/internal/core/objectstore/DaoIndexTable.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_0_Beta1_maint/product/core/services/src/org/jboss/soa/esb/internal/core/objectstore/DaoIndexTable.java 2006-09-16 20:17:15 UTC (rev 6251)
+++ labs/jbossesb/branches/JBESB_4_0_Beta1_maint/product/core/services/src/org/jboss/soa/esb/internal/core/objectstore/DaoIndexTable.java 2006-09-16 20:17:34 UTC (rev 6252)
@@ -119,9 +119,9 @@
*/
public static final int FIRST_FIELD = s_iFld++;
- public int setInsValues(PreparedStatement p_PS,Object p_o)
+ public int setInsertValues(PreparedStatement p_PS,Object p_o)
throws Exception
- { return setInsValues (p_PS,p_o,0); }
+ { return setInsertValues (p_PS,p_o,0); }
/**
* Set values for insert statement
* @param p_PS PreparedStatement - The prepared SQL statement for insert in this
@@ -137,7 +137,7 @@
* @see DaoIndexTable#getPS(int)
* @see DaoIndexTable#PS_INS_INDEX
*/
- public int setInsValues(PreparedStatement p_PS,Object p_o, int p_iNum)
+ public int setInsertValues(PreparedStatement p_PS,Object p_o, int p_iNum)
throws Exception
{ try
{ if (! (p_o instanceof BobjStdDTO)) throw
@@ -222,7 +222,7 @@
* @see DaoIndexTable#PS_SEL_INDEX
* @see ObjLocator
*/
- public Object getFromRS (ResultSet p_oRS) throws Exception
+ public Object getFromResultSet (ResultSet p_oRS) throws Exception
{ try
{
long lUid = p_oRS.getLong(1+OBJECT_UID);
@@ -273,10 +273,10 @@
public PreparedStatement getPS (int p_i) throws Exception
{ try
{ switch (p_i)
- { case PS_INS_INDEX: return getInsIndex(p_i);
- case PS_SEL_INDEX: return getSelIndex(p_i);
- case PS_RMV_INDEX: return getRmvIndex(p_i);
- case PS_UPD_INDEX: return getUpdIndex(p_i);
+ { case PS_INS_INDEX: return getInsertIndex(p_i);
+ case PS_SEL_INDEX: return getSelectIndex(p_i);
+ case PS_RMV_INDEX: return getRemoveIndex(p_i);
+ case PS_UPD_INDEX: return getUpdateIndex(p_i);
}
;
throw new Exception("Invalid Index "+p_i);
@@ -287,28 +287,28 @@
}
} //__________________________________
- private PreparedStatement getInsIndex(int p_i) throws Exception
+ private PreparedStatement getInsertIndex(int p_i) throws Exception
{ if (null == m_oaPS[p_i])
m_oaPS[p_i] = m_oConn.prepareStatement(getInsertStatement());
return m_oaPS[p_i];
} //__________________________________
- private PreparedStatement getSelIndex(int p_i) throws Exception
+ private PreparedStatement getSelectIndex(int p_i) throws Exception
{ if (null == m_oaPS[p_i])
{ StringBuffer sb = new StringBuffer(getSelectStatement())
- .append(" where ").append(getFldName(OBJECT_UID)).append(" = ? ");
+ .append(" where ").append(getFieldName(OBJECT_UID)).append(" = ? ");
m_oaPS[p_i] = m_oConn.prepareStatement(sb.toString());
}
return m_oaPS[p_i];
} //__________________________________
- private PreparedStatement getRmvIndex(int p_i) throws Exception
+ private PreparedStatement getRemoveIndex(int p_i) throws Exception
{ if (null == m_oaPS[p_i])
m_oaPS[p_i] = m_oConn.prepareStatement(getDeleteStatement());
return m_oaPS[p_i];
} //__________________________________
- private PreparedStatement getUpdIndex(int p_i) throws Exception
+ private PreparedStatement getUpdateIndex(int p_i) throws Exception
{ if (null == m_oaPS[p_i])
m_oaPS[p_i] = m_oConn.prepareStatement(getUpdateStatement());
return m_oaPS[p_i];
Modified: labs/jbossesb/branches/JBESB_4_0_Beta1_maint/product/core/services/src/org/jboss/soa/esb/internal/core/objectstore/DaoSnapTable.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_0_Beta1_maint/product/core/services/src/org/jboss/soa/esb/internal/core/objectstore/DaoSnapTable.java 2006-09-16 20:17:15 UTC (rev 6251)
+++ labs/jbossesb/branches/JBESB_4_0_Beta1_maint/product/core/services/src/org/jboss/soa/esb/internal/core/objectstore/DaoSnapTable.java 2006-09-16 20:17:34 UTC (rev 6252)
@@ -159,7 +159,7 @@
* @see DaoSnapTable#PS_INS_SNAP
* @see BusinessObject
*/
- public int setInsValues(PreparedStatement p_PS,Object p_o)
+ public int setInsertValues(PreparedStatement p_PS,Object p_o)
throws Exception
{ try
{ if (! (p_o instanceof BobjStdDTO)) throw
@@ -198,7 +198,7 @@
* @see DaoSnapTable#PS_UPD_SNAP
* @see BobjStdDTO
*/
- public void setUpdValues(PreparedStatement p_PS,Object p_o)
+ public void setUpdateValues(PreparedStatement p_PS,Object p_o)
throws Exception
{ try
{ if (! (p_o instanceof BobjStdDTO)) throw
@@ -291,7 +291,7 @@
* @see DaoSnapTable#PS_SEL_4UPD
* @see BobjStdDTO
*/
- public Object getFromRS (ResultSet p_oRS) throws Exception
+ public Object getFromResultSet (ResultSet p_oRS) throws Exception
{ try
{ long lUid = p_oRS.getLong(1+UID_SNAP);
String sXml = (m_oST.isEncrypted())
@@ -343,14 +343,14 @@
* during the prepareStatement() invocation
* @return PreparedStatement
*/
- public PreparedStatement getPS (int p_i) throws Exception
+ public PreparedStatement getPreparedStatement (int p_i) throws Exception
{ try
{ switch (p_i)
- { case PS_INS_SNAP: return getInsSnap(p_i);
- case PS_SEL_SNAP: return getSelSnap(p_i);
- case PS_RMV_SNAP: return getRmvSnap(p_i);
- case PS_UPD_SNAP: return getUpdSnap(p_i);
- case PS_SEL_4UPD: return getSel4UpdSnap(p_i);
+ { case PS_INS_SNAP: return getInsertSnap(p_i);
+ case PS_SEL_SNAP: return getSelectSnap(p_i);
+ case PS_RMV_SNAP: return getRemoveSnap(p_i);
+ case PS_UPD_SNAP: return getUpdateSnap(p_i);
+ case PS_SEL_4UPD: return getSelectForUpdateSnap(p_i);
}
;
throw new Exception("Invalid Index "+p_i);
@@ -361,37 +361,37 @@
}
} //__________________________________
- private PreparedStatement getInsSnap(int p_i) throws Exception
+ private PreparedStatement getInsertSnap(int p_i) throws Exception
{ if (null == m_oaPS[p_i])
m_oaPS[p_i] = m_oConn.prepareStatement(getInsertStatement());
return m_oaPS[p_i];
} //__________________________________
- private PreparedStatement getSelSnap(int p_i) throws Exception
+ private PreparedStatement getSelectSnap(int p_i) throws Exception
{ if (null == m_oaPS[p_i])
{ StringBuffer sb = new StringBuffer(getSelectStatement())
- .append(" where ").append(getFldName(UID_SNAP)).append(" = ? ");
+ .append(" where ").append(getFieldName(UID_SNAP)).append(" = ? ");
m_oaPS[p_i] = m_oConn.prepareStatement(sb.toString());
}
return m_oaPS[p_i];
} //__________________________________
- private PreparedStatement getRmvSnap(int p_i) throws Exception
+ private PreparedStatement getRemoveSnap(int p_i) throws Exception
{ if (null == m_oaPS[p_i])
m_oaPS[p_i] = m_oConn.prepareStatement(getDeleteStatement());
return m_oaPS[p_i];
} //__________________________________
- private PreparedStatement getUpdSnap(int p_i) throws Exception
+ private PreparedStatement getUpdateSnap(int p_i) throws Exception
{ if (null == m_oaPS[p_i])
m_oaPS[p_i] = m_oConn.prepareStatement(getUpdateStatement());
return m_oaPS[p_i];
} //__________________________________
- private PreparedStatement getSel4UpdSnap(int p_i) throws Exception
+ private PreparedStatement getSelectForUpdateSnap(int p_i) throws Exception
{ if (null == m_oaPS[p_i])
{ StringBuffer sb = new StringBuffer(getSelectStatement())
- .append(" where ").append(getFldName(UID_SNAP)).append(" = ? ")
+ .append(" where ").append(getFieldName(UID_SNAP)).append(" = ? ")
.append(" for update");
m_oaPS[p_i] = m_oConn.prepareStatement(sb.toString());
}
Modified: labs/jbossesb/branches/JBESB_4_0_Beta1_maint/product/core/services/src/org/jboss/soa/esb/internal/core/objectstore/DaoUidTable.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_0_Beta1_maint/product/core/services/src/org/jboss/soa/esb/internal/core/objectstore/DaoUidTable.java 2006-09-16 20:17:15 UTC (rev 6251)
+++ labs/jbossesb/branches/JBESB_4_0_Beta1_maint/product/core/services/src/org/jboss/soa/esb/internal/core/objectstore/DaoUidTable.java 2006-09-16 20:17:34 UTC (rev 6252)
@@ -127,7 +127,7 @@
* class should be handled ONLY by the Rosetta Administrator
* @return int - It will never return a value
*/
- public int setInsValues(PreparedStatement p_PS, Object p_o)
+ public int setInsertValues(PreparedStatement p_PS, Object p_o)
throws Exception {
String sErr = "No Inserts to UID table";
m_oLogger.error(sErr);
@@ -142,7 +142,7 @@
* @throws Exception
* @return Object
*/
- public Object getFromRS(ResultSet p_oRS) throws Exception {
+ public Object getFromResultSet(ResultSet p_oRS) throws Exception {
return null;
} // ________________________________
@@ -193,7 +193,7 @@
private PreparedStatement getSeq4Upd(int p_i) throws Exception {
if (null == m_oaPS[p_i]) {
StringBuffer sb = new StringBuffer(getSelectStatement()).append(
- " where ").append(getFldName(SEQ_NAME)).append(
+ " where ").append(getFieldName(SEQ_NAME)).append(
" = ? for update");
m_oaPS[p_i] = getConn().prepareStatement(sb.toString());
}
@@ -203,9 +203,9 @@
private PreparedStatement updateLastUsed(int p_i) throws Exception {
if (null == m_oaPS[p_i]) {
StringBuffer sb = new StringBuffer("update ").append(m_sTableName)
- .append(" set ").append(getFldName(LAST_USED_UID)).append(
+ .append(" set ").append(getFieldName(LAST_USED_UID)).append(
" = ?").append(" where ").append(
- getFldName(SEQ_NAME)).append(" = ?");
+ getFieldName(SEQ_NAME)).append(" = ?");
m_oaPS[p_i] = getConn().prepareStatement(sb.toString());
}
return m_oaPS[p_i];
@@ -261,7 +261,7 @@
PS = getPS(DaoUidTable.PS_UPDATE_LAST_USED);
PS.setLong(1, lNewLast);
PS.setString(2, p_sSeqName);
- getConn().execUpdWait(PS, 10);
+ getConn().execUpdateWait(PS, 10);
getConn().commit();
More information about the jboss-svn-commits
mailing list