svn commit: r1099228 - /camel/trunk/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepository.java

[cmueller]

Author: cmueller
Date: Tue May  3 20:16:18 2011
New Revision: 1099228

URL: http://svn.apache.org/viewvc?rev=1099228&view=rev
Log:
CAMEL-3936: JdbcAggregationRepository count (*) is not working with MySQL 5.0

Modified:
    
camel/trunk/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepository.java

Modified: 
camel/trunk/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepository.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepository.java?rev=1099228&r1=1099227&r2=1099228&view=diff
==============================================================================
--- 
camel/trunk/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepository.java
 (original)
+++ 
camel/trunk/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepository.java
 Tue May  3 20:16:18 2011
@@ -129,7 +129,7 @@ public class JdbcAggregationRepository e
                     String update = "UPDATE " + getRepositoryName() + " SET " 
+ EXCHANGE + " = ? WHERE " + ID + " = ?";
 
                     boolean present = jdbcTemplate.queryForInt(
-                            "SELECT COUNT (*) FROM " + getRepositoryName() + " 
WHERE " + ID + " = ?", key) != 0;
+                            "SELECT COUNT(*) FROM " + getRepositoryName() + " 
WHERE " + ID + " = ?", key) != 0;
                     sql = present ? update : insert;
 
                     // Recover existing exchange with that ID