Advanced adapter usage and mashup

Overview

Now that basic usage of different types of adapters has been covered, it is important to remember that adapters can be combined to make a procedure that uses different adapters to generate one processed result. You can combine several sources (different HTTP servers, SQL, etc).

In theory, from the client side, you could make several requests successively, one depending on the other. However, writing this logic on the server side could be faster and cleaner.

This tutorial covers the following topics:

• JavaScript adapter API
• Java adapter API
• Data mashup example
• Sample application

JavaScript API

Calling a JavaScript adapter procedure from a JavaScript adapter

WL.Server.invokeProcedure({ adapter : "AcmeBank", procedure : " getTransactions", parameters : [accountId, fromDate, toDate], });

Calling a Java adapter from a JavaScript adapter is not supported

Java API

Calling a Java adapter from a Java adapter

HttpUriRequest req = new HttpGet(MyAdapterProcedureURL);
org.apache.http.HttpResponse response = api.getAdaptersAPI().executeAdapterRequest(req);
JSONObject jsonObj = api.getAdaptersAPI().getResponseAsJSON(response);

Calling a JavaScript adapter procedure from a Java adapter

HttpUriRequest req = api.getAdaptersAPI().createJavascriptAdapterRequest(AdapterName, ProcedureName, [parameters]);
org.apache.http.HttpResponse response = api.getAdaptersAPI().executeAdapterRequest(req);
JSONObject jsonObj = api.getAdaptersAPI().getResponseAsJSON(response);

Data mashup example

• Cities Adapter:
  • Extract a list of cities from a “weather” database table.
  • The result contains the list of several cities around the world, their Yahoo! Weather identifier and some description.
• Weather Adapter:
  • Connect to the Yahoo! Weather Service.
  • Extract an updated weather forecast for each of the cities that are retrieved via the Cities adapter.

Mashup Sample Flow

1. Create a procedure / adapter call that create a request to Yahoo! Weather Service for each city and retrieves the corresponding data:
   
   (getCitiesListJS adapter) XML:

   <connectivity>
     <connectionPolicy xsi:type="http:HTTPConnectionPolicyType">
       <protocol>http</protocol>
       <domain>weather.yahooapis.com</domain>
       <port>80</port>
       ...
     </connectionPolicy>
   </connectivity>

   (getCitiesListJS adapter) JavaScript:

   function getYahooWeather(woeid) {
     var input = {
       method : 'get',
       returnedContentType : 'xml',
       path : 'forecastrss',
       parameters : {
         'w' : woeid,
         'u' : 'c' //celcius
       }
     };
     return WL.Server.invokeHttp(input);
   }

   (getCityWeatherJava adapter)

   @GET
   @Produces("application/json")
   public String get(@Context HttpServletResponse response, @QueryParam("cityId") String cityId) throws ClientProtocolException, IOException, IllegalStateException, SAXException {
     String returnValue = execute(new HttpGet("/forecastrss?w="+ cityId +"&u=c"), response);
     return returnValue;
   }
   
   private String execute(HttpUriRequest req, HttpServletResponse resultResponse) throws ClientProtocolException, IOException, IllegalStateException, SAXException {
     String strOut = null;
     HttpResponse RSSResponse = client.execute(host, req);
     ServletOutputStream os = resultResponse.getOutputStream();
     ... (Convert the retrieved XML to JSON here...)
   }

   
   
2. Create an SQL query and fetch the cities records from the database:
   
   (getCitiesListJS adapter)

   var getCitiesListStatement = WL.Server.createSQLStatement("select city, identifier, summary from weather;");
   function getCitiesList() {
     return WL.Server.invokeSQLStatement({
       preparedStatement : getCitiesListStatement,
       parameters : []
     });
   }

   
   (getCitiesListJava, getCitiesListJavaToJs adapters)

   PreparedStatement getAllCities = getSQLConnection().prepareStatement("select city, identifier, summary from weather");
   ResultSet rs = getAllCities.executeQuery();

   
   
3. Loop through the cities records and fetch the weather info for each city from Yahoo! Weather Service:
   
   (getCitiesListJS adapter)

   for (var i = 0; i < cityList.resultSet.length; i++) {
     var yahooWeatherData = getCityWeather(cityList.resultSet[i].identifier);
     ...
   }
   
   function getCityWeather(woeid){
     return WL.Server.invokeProcedure({
       adapter : 'getCityWeatherJS',
       procedure : 'getYahooWeather',
       parameters : [woeid]
     });
   }

   
   (getCitiesListJava adapter)

   while (rs.next()) {
     getWeatherInfoProcedureURL = "/getCityWeatherJava?cityId="+ URLEncoder.encode(rs.getString("identifier"), "UTF-8");
     HttpUriRequest req = new HttpGet(getWeatherInfoProcedureURL);
     org.apache.http.HttpResponse response = api.getAdaptersAPI().executeAdapterRequest(req);
     JSONObject jsonWeather = api.getAdaptersAPI().getResponseAsJSON(response);
     ...
   }

   
   (getCitiesListJavaToJs adapter)

   while (rs.next()) {
     HttpUriRequest req = api.getAdaptersAPI().createJavascriptAdapterRequest("getCityWeatherJS", "getYahooWeather",
                           URLEncoder.encode(rs.getString("identifier"), "UTF-8"));
     org.apache.http.HttpResponse response = api.getAdaptersAPI().executeAdapterRequest(req);
     JSONObject jsonWeather = api.getAdaptersAPI().getResponseAsJSON(response);
     ...
   }

   
   
4. Iterating through the retrieved rss feed to fetch only the weather description, put this values in a resultSet / JSONArray object and return it to the application:
   
   (getCitiesListJS adapter)

   ...
   if (yahooWeatherData.isSuccessful)
     cityList.resultSet[i].weather = yahooWeatherData.rss.channel.item.description;
   }
   return cityList;

   
   (getCitiesListJava, getCitiesListJavaToJs adapters)

   {
     ...
     JSONObject rss = (JSONObject) jsonWeather.get("rss");
     JSONObject channel = (JSONObject) rss.get("channel");
     JSONObject item = (JSONObject) channel.get("item");
     String cityWeatherSummary = (String) item.get("description");
   
     /* Putting the current city results into a JSONObject */
     JSONObject jsonObj = new JSONObject();
     jsonObj.put("city", rs.getString("city"));
     jsonObj.put("identifier", rs.getString("identifier"));
     jsonObj.put("summary", rs.getString("summary"));
     jsonObj.put("weather", cityWeatherSummary);
   
     jsonArr.add(jsonObj);
   }
   conn.close();
   return jsonArr.toString();

An example of city list in SQL is provided with the attached sample, under server/mobilefirstTraining.sql. Remember that SQL adapters require a JDBC connector driver, which must be downloaded separately by the developer and added to the server/lib folder of the project.

Sample application