Camel Apache SQL

Question

I am learning to use Apache Camel.

So far I've been trying to create execute a very simple SQL request which seems to not be working. I hope any of you can tell me what is wrong with the code.

Thank you for any potential input.

public class CamelMain {
 public static void main(String... args) throws Exception {
 Main camelMain = new Main();
 camelMain.configure().addRoutesBuilder(createBasicRoute());
 DriverManagerDataSource dataSource = new DriverManagerDataSource();
 dataSource.setDriverClassName("org.postgresql.Driver");
 dataSource.setUrl("jdbc:postgresql://localhost:9201/dbname");
 dataSource.setUsername("username");
 dataSource.setPassword("password");
 camelMain.bind("myDataSource",dataSource);
 camelMain.run(args);
}
static RouteBuilder createBasicRoute() {
 return new RouteBuilder() {
 @Override
 public void configure() {
 from("direct:query")
 .to("sql:insert into FileDetailTable (filename, Status, createdAt) values ('test', 'test', 'test')?dataSource=#myDataSource");
 }
 };
}

}

Answer 1

can u remove # symbol and try again

.to("sql:insert into FileDetailTable (filename, Status, createdAt) values ('test', 'test', 'test')?dataSource=myDataSource");

if u get still error can your try this example

main method

https://github.com/erayerdem/camel-test/blob/master/src/main/java/com/learncamel/routes/Test.java

postgresql route

https://github.com/erayerdem/camel-test/blob/master/src/main/java/com/learncamel/routes/PostgresRoute.java