Changeset 670:f443dfe30f78


Ignore:
Timestamp:
10/30/12 21:37:56 (6 years ago)
Author:
Babis Nikolaou <charnik@…>
Branch:
default
Message:

completed implementation of query() method for StrabonEndpoint?

Location:
endpoint/src/main/java/eu/earthobservatory/org/StrabonEndpoint/client
Files:
2 edited

Legend:

Unmodified
Added
Removed
  • endpoint/src/main/java/eu/earthobservatory/org/StrabonEndpoint/client/SpatialEndpoint.java

    r669 r670  
    1010package eu.earthobservatory.org.StrabonEndpoint.client; 
    1111 
     12import java.io.IOException; 
    1213import java.net.URL; 
    1314 
     15import org.openrdf.query.resultio.stSPARQLQueryResultFormat; 
    1416import org.openrdf.rio.RDFFormat; 
    1517 
     
    2325public interface SpatialEndpoint { 
    2426 
    25         public String query(String sparqlQuery, String format); 
     27        public String query(String sparqlQuery, stSPARQLQueryResultFormat format) throws IOException; 
    2628         
    2729        public boolean store(String data, RDFFormat format); 
  • endpoint/src/main/java/eu/earthobservatory/org/StrabonEndpoint/client/StrabonEndpoint.java

    r669 r670  
    1010package eu.earthobservatory.org.StrabonEndpoint.client; 
    1111 
     12import java.io.IOException; 
    1213import java.net.URL; 
    1314 
    1415import org.apache.commons.httpclient.HttpMethod; 
     16import org.apache.commons.httpclient.HttpStatus; 
    1517import org.apache.commons.httpclient.methods.PostMethod; 
     18import org.openrdf.query.resultio.stSPARQLQueryResultFormat; 
    1619import org.openrdf.rio.RDFFormat; 
    1720 
     
    2932 
    3033        @Override 
    31         public String query(String sparqlQuery, String format) { 
     34        public String query(String sparqlQuery, stSPARQLQueryResultFormat format) throws IOException { 
    3235                // create a post method to execute 
    33                 HttpMethod post = new PostMethod(getConnectionURL()); 
     36                HttpMethod method = new PostMethod(getConnectionURL()); 
    3437                 
    3538                // set the query parameter 
    36                 post.getParams().setParameter("query", sparqlQuery); 
     39                method.getParams().setParameter("query", sparqlQuery); 
    3740                 
    3841                // set the accept format 
    39                 post.setRequestHeader("Accept", "???"); 
     42                method.setRequestHeader("Accept", format.getDefaultMIMEType()); 
    4043                 
    41                 return null; 
     44                try { 
     45                        // execute the method 
     46                        int statusCode = hc.executeMethod(method); 
     47 
     48                        // check the status code 
     49                        if (statusCode != HttpStatus.SC_OK) { 
     50                                System.err.println("Method failed: " + method.getStatusLine()); 
     51                        } 
     52 
     53                        // Read the response body. 
     54                        byte[] responseBody = method.getResponseBody(); 
     55 
     56                        // Deal with the response. 
     57                        // Use caution: ensure correct character encoding and is not binary 
     58                        // data 
     59                        return new String(responseBody); 
     60 
     61                } catch (IOException e) { 
     62                        throw e; 
     63                         
     64                } finally { 
     65                        // release the connection. 
     66                        method.releaseConnection(); 
     67                } 
    4268        } 
    4369 
Note: See TracChangeset for help on using the changeset viewer.