Added method sparqlConstructRemote allowing CONSTRUCT queries returni…

…ng RDF/XML
samuell · Sep 14, 2010 · 73fb23e · egonw · Sep 16, 2010 · samuell
1 parent 5a1ab12
commit 73fb23e
Show file tree

Hide file tree

Showing 2 changed files with 37 additions and 0 deletions.
diff --git a/plugins/net.bioclipse.rdf/src/net/bioclipse/rdf/business/IRDFManager.java b/plugins/net.bioclipse.rdf/src/net/bioclipse/rdf/business/IRDFManager.java
@@ -188,6 +188,16 @@ public void saveRDFNTriple(IRDFStore store, String fileName)
     public IStringMatrix sparqlRemote(String url, String SPARQL)
         throws BioclipseException;
 
+    @Recorded
+    @PublishedMethod(
+        params = "String url, String SPARQL",
+        methodSummary = "Queries a remote SPARQL endpoint and returns RDF/XML. " +
+        		        "Assumes that the query is creating an RDF graph with the " +
+        		        "CONSTRUCT keyword"
+    )
+    public String sparqlConstructRemote(String url, String SPARQL)
+        throws BioclipseException;
+
     @Recorded
     @PublishedMethod(
         params = "IRDFStore targetStore, IRDFStore sourceStore",

diff --git a/plugins/net.bioclipse.rdf/src/net/bioclipse/rdf/business/RDFManager.java b/plugins/net.bioclipse.rdf/src/net/bioclipse/rdf/business/RDFManager.java
@@ -18,10 +18,13 @@
  ******************************************************************************/
 package net.bioclipse.rdf.business;
 
+import java.io.BufferedOutputStream;
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
 import java.io.IOException;
 import java.io.InputStream;
+import java.io.OutputStream;
+import java.io.StringWriter;
 import java.net.URL;
 import java.net.URLConnection;
 import java.util.ArrayList;
@@ -382,6 +385,30 @@ public StringMatrix sparqlRemote(
         return table;
     }
 
+    public String sparqlConstructRemote(
+            String serviceURL,
+            String sparqlQueryString, IProgressMonitor monitor) {
+         if (monitor == null)
+             monitor = new NullProgressMonitor();
+
+         monitor.beginTask("Sparqling the remote service..", 100);
+         Query query = QueryFactory.create(sparqlQueryString);
+         QueryExecution qexec = QueryExecutionFactory.sparqlService(serviceURL, query);
+         monitor.worked(80);
+
+         String rdfxml = "";
+         try {
+             Model results = qexec.execConstruct();
+             StringWriter sw = new StringWriter();
+             results.write(sw, "RDF/XML");             
+             rdfxml = sw.toString();
+         } finally {
+             qexec.close();
+         }
+         monitor.worked(20);
+         return rdfxml;
+     }
+
     public IRDFStore importRDFa(IRDFStore store, String url,
             IProgressMonitor monitor)
     throws IOException, BioclipseException, CoreException {