camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cmuel...@apache.org
Subject svn commit: r1225946 - in /camel/trunk/components/camel-sql/src/test: java/org/apache/camel/processor/idempotent/jdbc/CustomizedJdbcMessageIdRepositoryTest.java resources/org/apache/camel/processor/idempotent/jdbc/customized-spring.xml
Date Fri, 30 Dec 2011 22:17:24 GMT
Author: cmueller
Date: Fri Dec 30 22:17:23 2011
New Revision: 1225946

URL: http://svn.apache.org/viewvc?rev=1225946&view=rev
Log:
CAMEL-4152: jdbc idempotent repository - table creation

Modified:
    camel/trunk/components/camel-sql/src/test/java/org/apache/camel/processor/idempotent/jdbc/CustomizedJdbcMessageIdRepositoryTest.java
    camel/trunk/components/camel-sql/src/test/resources/org/apache/camel/processor/idempotent/jdbc/customized-spring.xml

Modified: camel/trunk/components/camel-sql/src/test/java/org/apache/camel/processor/idempotent/jdbc/CustomizedJdbcMessageIdRepositoryTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-sql/src/test/java/org/apache/camel/processor/idempotent/jdbc/CustomizedJdbcMessageIdRepositoryTest.java?rev=1225946&r1=1225945&r2=1225946&view=diff
==============================================================================
--- camel/trunk/components/camel-sql/src/test/java/org/apache/camel/processor/idempotent/jdbc/CustomizedJdbcMessageIdRepositoryTest.java
(original)
+++ camel/trunk/components/camel-sql/src/test/java/org/apache/camel/processor/idempotent/jdbc/CustomizedJdbcMessageIdRepositoryTest.java
Fri Dec 30 22:17:23 2011
@@ -36,8 +36,8 @@ import org.springframework.transaction.s
 
 public class CustomizedJdbcMessageIdRepositoryTest extends CamelSpringTestSupport {
 
-    protected static final String SELECT_ALL_STRING = "SELECT messageId FROM CUSTOMIZED_CAMEL_MESSAGEPROCESSED
WHERE processorName = ?";
-    protected static final String DELETE_ALL_STRING = "DELETE FROM CUSTOMIZED_CAMEL_MESSAGEPROCESSED
WHERE processorName = ?";
+    protected static final String SELECT_ALL_STRING = "SELECT messageId FROM CUSTOMIZED_MESSAGE_REPOSITORY
WHERE processorName = ?";
+    protected static final String DELETE_ALL_STRING = "DELETE FROM CUSTOMIZED_MESSAGE_REPOSITORY
WHERE processorName = ?";
     protected static final String PROCESSOR_NAME = "myProcessorName";
 
     protected JdbcTemplate jdbcTemplate;

Modified: camel/trunk/components/camel-sql/src/test/resources/org/apache/camel/processor/idempotent/jdbc/customized-spring.xml
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-sql/src/test/resources/org/apache/camel/processor/idempotent/jdbc/customized-spring.xml?rev=1225946&r1=1225945&r2=1225946&view=diff
==============================================================================
--- camel/trunk/components/camel-sql/src/test/resources/org/apache/camel/processor/idempotent/jdbc/customized-spring.xml
(original)
+++ camel/trunk/components/camel-sql/src/test/resources/org/apache/camel/processor/idempotent/jdbc/customized-spring.xml
Fri Dec 30 22:17:23 2011
@@ -29,15 +29,17 @@
         <property name="password" value=""/>
     </bean>
     
+    <!-- START SNIPPET: e1 -->
     <bean id="messageIdRepository" class="org.apache.camel.processor.idempotent.jdbc.JdbcMessageIdRepository">
     	<constructor-arg ref="dataSource" />
     	<constructor-arg value="myProcessorName" />
-    	<property name="tableExistsString" value="SELECT 1 FROM CUSTOMIZED_CAMEL_MESSAGEPROCESSED
WHERE 1 = 0" />
-    	<property name="createString" value="CREATE TABLE CUSTOMIZED_CAMEL_MESSAGEPROCESSED
(processorName VARCHAR(255), messageId VARCHAR(100), createdAt DATETIME)" />
-    	<property name="queryString" value="SELECT COUNT(*) FROM CUSTOMIZED_CAMEL_MESSAGEPROCESSED
WHERE processorName = ? AND messageId = ?" />
-    	<property name="insertString" value="INSERT INTO CUSTOMIZED_CAMEL_MESSAGEPROCESSED
(processorName, messageId, createdAt) VALUES (?, ?, ?)" />
-    	<property name="deleteString" value="DELETE FROM CUSTOMIZED_CAMEL_MESSAGEPROCESSED
WHERE processorName = ? AND messageId = ?" />
+    	<property name="tableExistsString" value="SELECT 1 FROM CUSTOMIZED_MESSAGE_REPOSITORY
WHERE 1 = 0" />
+    	<property name="createString" value="CREATE TABLE CUSTOMIZED_MESSAGE_REPOSITORY (processorName
VARCHAR(255), messageId VARCHAR(100), createdAt DATETIME)" />
+    	<property name="queryString" value="SELECT COUNT(*) FROM CUSTOMIZED_MESSAGE_REPOSITORY
WHERE processorName = ? AND messageId = ?" />
+    	<property name="insertString" value="INSERT INTO CUSTOMIZED_MESSAGE_REPOSITORY (processorName,
messageId, createdAt) VALUES (?, ?, ?)" />
+    	<property name="deleteString" value="DELETE FROM CUSTOMIZED_MESSAGE_REPOSITORY WHERE
processorName = ? AND messageId = ?" />
     </bean>
+    <!-- END SNIPPET: e1 -->
     
     <camel:camelContext>
     	<camel:errorHandler id="deadLetterChannel" type="DeadLetterChannel" deadLetterUri="mock:error">



Mime
View raw message