[jboss-svn-commits] JBL Code SVN: r15581 - in labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb: listeners and 1 other directories.

[jboss-svn-commits at lists.jboss.org]

Author: tcunning
Date: 2007-10-04 11:30:49 -0400 (Thu, 04 Oct 2007)
New Revision: 15581

Modified:
   labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/addressing/eprs/JDBCEpr.java
   labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/listeners/ListenerTagNames.java
   labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/listeners/config/mappers/SqlListenerMapper.java
Log:
bug:JBESB-1071
Add support for whereCondition and orderBy.


Modified: labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/addressing/eprs/JDBCEpr.java
===================================================================
--- labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/addressing/eprs/JDBCEpr.java	2007-10-04 15:30:14 UTC (rev 15580)
+++ labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/addressing/eprs/JDBCEpr.java	2007-10-04 15:30:49 UTC (rev 15581)
@@ -54,10 +54,12 @@
 	public static final String URL_TAG = "URL";
 
 	public static final String TABLE_NAME_TAG 			= "tablename";
+	public static final String ORDER_BY_TAG				= "orderBy";
 	public static final String MESSAGE_ID_COLUMN_TAG 	= "message_id_column";
 	public static final String STATUS_COLUMN_TAG 		= "status_column";
 	public static final String DATA_COLUMN_TAG 			= "message_column";
 	public static final String TIMESTAMP_COLUMN_TAG 	= "insert_timestamp_column";
+	public static final String WHERE_CONDITION_TAG 		= "whereCondition";
 	public static final String POST_DEL_TAG				= "postDelete";
 	public static final String ERROR_DEL_TAG			= "errorDelete";
 	

Modified: labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/listeners/ListenerTagNames.java
===================================================================
--- labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/listeners/ListenerTagNames.java	2007-10-04 15:30:14 UTC (rev 15580)
+++ labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/listeners/ListenerTagNames.java	2007-10-04 15:30:49 UTC (rev 15581)
@@ -109,7 +109,6 @@
     
     /** SQL related  */
     public static final String SQL_ROW_DATA_TAG				= "sqlRowData";
-
     public static final String SQL_TABLE_NAME_TAG			= "tableName";
     public static final String SQL_SELECT_FIELDS_TAG		= "selectFields";
     public static final String SQL_KEY_FIELDS_TAG			= "keyFields";

Modified: labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/listeners/config/mappers/SqlListenerMapper.java
===================================================================
--- labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/listeners/config/mappers/SqlListenerMapper.java	2007-10-04 15:30:14 UTC (rev 15580)
+++ labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/listeners/config/mappers/SqlListenerMapper.java	2007-10-04 15:30:49 UTC (rev 15581)
@@ -106,6 +106,8 @@
 		toElement.setAttribute(JDBCEpr.USERNAME_TAG, provider.getUsername());
 		toElement.setAttribute(JDBCEpr.PASSWORD_TAG, provider.getPassword());
 		toElement.setAttribute(JDBCEpr.TABLE_NAME_TAG, messageFilter.getTablename());
+		toElement.setAttribute(JDBCEpr.WHERE_CONDITION_TAG, messageFilter.getWhereCondition());
+		toElement.setAttribute(JDBCEpr.ORDER_BY_TAG, messageFilter.getOrderBy());
 		toElement.setAttribute(JDBCEpr.MESSAGE_ID_COLUMN_TAG, messageFilter.getMessageIdColumn());
 		toElement.setAttribute(JDBCEpr.DATA_COLUMN_TAG, messageFilter.getMessageColumn());
 		toElement.setAttribute(JDBCEpr.STATUS_COLUMN_TAG, String.valueOf(messageFilter.getStatusColumn()));