svn commit: r1376047 - /jena/trunk/jena-arq/src/main/java/org/openjena/riot/WebReader.java

[an...@apache.org]

Author: andy
Date: Wed Aug 22 13:48:28 2012
New Revision: 1376047

URL: http://svn.apache.org/viewvc?rev=1376047&view=rev
Log:
Fix: reading into datasets.

Modified:
    jena/trunk/jena-arq/src/main/java/org/openjena/riot/WebReader.java

Modified: jena/trunk/jena-arq/src/main/java/org/openjena/riot/WebReader.java
URL: http://svn.apache.org/viewvc/jena/trunk/jena-arq/src/main/java/org/openjena/riot/WebReader.java?rev=1376047&r1=1376046&r2=1376047&view=diff
==============================================================================
--- jena/trunk/jena-arq/src/main/java/org/openjena/riot/WebReader.java (original)
+++ jena/trunk/jena-arq/src/main/java/org/openjena/riot/WebReader.java Wed Aug 22 13:48:28 2012
@@ -32,10 +32,13 @@ import static org.openjena.riot.WebConte
 import static org.openjena.riot.WebContent.contentTypeTurtleAlt1 ;
 import static org.openjena.riot.WebContent.contentTypeTurtleAlt2 ;
 
+import java.io.FileInputStream ;
+import java.io.IOException ;
 import java.io.InputStream ;
 import java.util.HashMap ;
 import java.util.Map ;
 
+import org.openjena.atlas.io.IO ;
 import org.openjena.atlas.lib.Sink ;
 import org.openjena.atlas.web.TypedInputStream ;
 
@@ -103,8 +106,12 @@ public class WebReader
     
     private static TypedInputStream open(String uri, Lang lang)
     {
+        // Partial/
+        try {
+        InputStream in = new FileInputStream(uri) ; 
         // **** A FileManager that deals in TypedStreams properly (copy/rewrite)
-        return new TypedInputStream(null, null/*Content-Type*/, null/*charset*/) ;
+        return new TypedInputStream(in, lang.getContentType()/*Content-Type*/, null/*charset*/) ;
+    } catch (IOException ex) { IO.exception(ex) ; return null ; }
     }
     
     // -----------------------