Hello guys, I built the following camel route using spring dsl:
UserCSVToMySQL.xml <http://camel.465427.n5.nabble.com/file/n5735821/UserCSVToMySQL.xml> <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans"; xmlns:camel="http://camel.apache.org/schema/spring"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xmlns:osgi="http://www.springframework.org/schema/osgi"; xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd http://www.springframework.org/schema/osgi http://www.springframework.org/schema/spring-osgi.xsd";> <bean id="loaderDS" class="org.apache.commons.dbcp.BasicDataSource"> <property name="driverClassName" value="com.mysql.jdbc.Driver" /> <property name="url" value="jdbc:mysql://localhost:3306/sandbox-db"/> <property name="username" value="sanduser" /> <property name="password" value="sandpass" /> <property name="initialSize" value="5" /> <property name="maxIdle" value="5" /> <property name="maxActive" value="30" /> <property name="maxWait" value="10000" /> <property name="poolPreparedStatements" value="true" /> <property name="validationQuery" value="SELECT 1" /> </bean> <camel:camelContext id="CSVLoaderContext" trace="false"> <camel:route id="UserCSVToMYSQL"> <camel:from uri="file:/home/jedi/Java/Workspaces/FileSandbox?delete=true" /> <camel:split parallelProcessing="true" streaming="true"> <camel:tokenize token="\n" /> <camel:unmarshal> <camel:csv/> </camel:unmarshal> <camel:to uri="sql:INSERT INTO user(`id`,`external_user_id`,`first_name`,`last_name`,`email`,`active`) VALUES (#,#,#,#,#)?dataSourceRef=loaderDS"/> </camel:split> </camel:route> </camel:camelContext> </beans> but when I try to execute it keeps displaying the error: 21:12:53,677 | ERROR | read #46 - Split | DefaultErrorHandler | 95 - org.apache.camel.camel-core - 2.10.3 | Failed delivery for (MessageId: ID-ubuntu-32934-1374106272368-2-1 on ExchangeId: ID-ubuntu-32934-1374106272368-2-4370). Exhausted after delivery attempt: 1 caught: org.springframework.jdbc.UncategorizedSQLException: PreparedStatementCallback; uncategorized SQLException for SQL [INSERT INTO user(`id`,`external_user_id`,`first_name`,`last_name`,`email`,`active`) VALUES (?,?,?,?,?)]; SQL state [null]; error code [0]; Number of parameters mismatch. Expected: 5, was:1; nested exception is java.sql.SQLException: Number of parameters mismatch. Expected: 5, was:1 org.springframework.jdbc.UncategorizedSQLException: PreparedStatementCallback; uncategorized SQLException for SQL [INSERT INTO user(`id`,`external_user_id`,`first_name`,`last_name`,`email`,`active`) VALUES (?,?,?,?,?)]; SQL state [null]; error code [0]; Number of parameters mismatch. Expected: 5, was:1; nested exception is java.sql.SQLException: Number of parameters mismatch. Expected: 5, was:1 Looks like that camel-sql is not understanding the ArrayList that is coming to assign to each Insert parameter. Below I send you a couple of registers that I have in my csv file that: 0,firstname0,lastname0,[email protected],1 1,firstname1,lastname1,[email protected],1 2,firstname2,lastname2,[email protected],1 3,firstname3,lastname3,[email protected],1 4,firstname4,lastname4,[email protected],1 5,firstname5,lastname5,[email protected],1 6,firstname6,lastname6,[email protected],1 7,firstname7,lastname7,[email protected],1 8,firstname8,lastname8,[email protected],1 9,firstname9,lastname9,[email protected],1 10,firstname10,lastname10,[email protected],1 11,firstname11,lastname11,[email protected],1 12,firstname12,lastname12,[email protected],1 13,firstname13,lastname13,[email protected],1 14,firstname14,lastname14,[email protected],1 15,firstname15,lastname15,[email protected],1 16,firstname16,lastname16,[email protected],1 17,firstname17,lastname17,[email protected],1 18,firstname18,lastname18,[email protected],1 19,firstname19,lastname19,[email protected],1 20,firstname20,lastname20,[email protected],1 21,firstname21,lastname21,[email protected],1 22,firstname22,lastname22,[email protected],1 23,firstname23,lastname23,[email protected],1 24,firstname24,lastname24,[email protected],1 25,firstname25,lastname25,[email protected],1 26,firstname26,lastname26,[email protected],1 27,firstname27,lastname27,[email protected],1 28,firstname28,lastname28,[email protected],1 And my table structure is: delimiter $$ CREATE TABLE `user` ( `id` int(11) unsigned NOT NULL AUTO_INCREMENT, `external_user_id` int(10) unsigned NOT NULL, `first_name` varchar(45) CHARACTER SET latin1 NOT NULL, `last_name` varchar(45) CHARACTER SET latin1 DEFAULT NULL, `email` varchar(45) CHARACTER SET latin1 NOT NULL, `active` bit(1) DEFAULT b'1', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8$$ Do you have any ideas about how to solve this problem? Thanks and regards. -- View this message in context: http://camel.465427.n5.nabble.com/problem-processing-CSV-to-Database-camel-csv-and-camel-sql-tp5735821.html Sent from the Camel - Users mailing list archive at Nabble.com.
