Интеграция баз данных и создание сервисов RESTful в EAP с помощью Fuse и CDI

Мы поговорили о том, как начать разработку приложения в EAP с использованием Java DSL, и наиболее интересно, как использовать инфраструктуру CDI в JavaEE. И в этом посте мы продолжим этот пример немного дальше, покажем вам, как интегрировать с базами данных и Java-бинами в приложение, создать сервлет и, наконец, настроить веб-сервис RESTful.

Для этого проекта обмена валюты я сохранил обменный курс в базе данных h2. Мы собираемся отобразить полный курс обмена на веб-странице, предоставленной веб-службой restful, и предоставить сервлет, который принимает сумму денег и валюту для обмена, отправляет их обратно на сервер, вычисляет и возвращает результат. Итак, вот что я собираюсь сделать

• База данных
• Java Bean
• Servlet
• Restful Web Services

База данных

Конечно, мы хотим использовать источники данных в EAP. Итак, во-первых, создайте источник данных в EAP. Убедитесь, что вы запустили JBoss EAP. Перейдите к Конфигурации, выберите Соединитель, а затем к источникам данных.

• Имя: MyCamelDS
• Имя JNDI: java: jboss / datasources / MyCamelDS

 Выберите драйвер, который мы будем использовать, и это h2 в этом случае,

Введите

• URL соединения: jdbc: h2: файл: ~ / h2 / fuseoneap; AUTO_SERVER = TRUE
• Имя пользователя: sa
• Пароль: 

Измените минимальный и максимальный размер пула на 1 и 10. Затем включите источник данных MyCamelDS.

И вот мы, источник данных готов!

Затем мы можем использовать платформу CDI для поиска источника данных в JNDI. Итак, создайте CDI Producer, в CDI он создает объект, который может быть внедрен, и который мы собираемся добавить источником данных в наш верблюжий контекст.

public class DatasourceProducer {
  @Resource(lookup= "java:jboss/datasources/MyCamelDS")
  DataSource dataSource;

  @Produces
  @Named("MyCamelDS")
  public DataSource getDataSource() {
    return dataSource;  
  }
}

  from("direct:getCurrencies").routeId("allcurrencies")
  .to("sql:select * from currencyexchange?dataSource=MyCamelDS")
  .marshal()
  .json(JsonLibrary.Jackson);

  @Named("currencyconvertor")
  public class CurrencyConvertor {
    public double convertUSD(double amt, ArrayList<Map<String, Object>> data){
      Double rate = (Double)data.get(0).get("rate");
      return amt*rate;
    }
  }

from("direct:getCurrency").routeId("covertcurrency")
  .log("Got currency: ${headers.amt} and amt${headers.currency} ")
  .choice()
    .when()
      .header("currency")
      .to("sql:select * from currencyexchange where currencycode = :#currency?dataSource=MyCamelDS")
      .log("exchange rate ====> ${body[0][rate]}")
      .to("bean:currencyconvertor?method=convertUSD(${headers.amt},${body})")
  .otherwise()
    .log("nothing to lookup")
     .transform().constant("nothing to lookup");

 <servlet>
    <servlet-name>camel</servlet-name>
    <servlet-class>org.apache.camel.component.servlet.CamelHttpTransportServlet</servlet-class>
    <load-on-startup>1</load-on-startup>
  </servlet>

  <servlet-mapping>
    <servlet-name>camel</servlet-name>
    <url-pattern>/services/*</url-pattern>
  </servlet-mapping>

    from("servlet:///currency?servletName=camel&matchOnUriPrefix=true")
  .routeId("servletCurrency")
  .to("direct:getCurrency");

  restConfiguration().component("servlet")
      .contextPath("/camel").port(8080).bindingMode(RestBindingMode.json);

  rest("/currenciesrest")
      .get()
      .produces(MediaType.APPLICATION_JSON)
      .to("direct:getCurrencies");