использование данных из интеграции верблюда Jdbc - PullRequest
Новая
       29

использование данных из интеграции верблюда Jdbc

0 голосов
/ 09 марта 2019

У меня есть следующий фрагмент кода, который извлекает данные из базы данных MySQL: 

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");
}

Прямо сейчас я просто печатаю его на консоль, но я действительно хочу получить JSON через пружинный контроллер mvc rest, который будет вызываться из моего веб-приложения, поэтому я подумал, что мне нужен bean-компонент для хранения данные, и тогда я смогу добраться до моей точки.

Но мне интересно, как я могу это сделать, если я собираюсь использовать более одной базы данных, и каждая из них может иметь различную структуру, например одна может иметь идентификатор, имя, описание, а другая имеет больше полей и другую структуру, поэтому чего можно добиться каким-либо образом?

я пытаюсь интегрировать мое веб-приложение с более чем одной базой данных, но все будут получать такие же данные, как продукт.

...