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">
