public static void main(String[] args) throws Exception {
    MysqlDataSource ds = new MysqlDataSource();
    ds.setUrl("jdbc:mysql://localhost:3306/db");
    ds.setUser("root");
    ds.setPassword("root");

    SimpleRegistry registry = new SimpleRegistry();
    registry.put("datasource", ds);

    CamelContext ctx = new DefaultCamelContext(registry);
    ctx.addRoutes(new RouteBuilder() {

        @Override
        public void configure() throws Exception {

            from("direct:start").to("jdbc:datasource").bean(new ResultHandler(), "printResult");

        }
    });

    ctx.start();

    ProducerTemplate template = ctx.createProducerTemplate();
    template.sendBody("direct:start", "SELECT * FROM products");
}