QuaTor - QuaDer - Queries:

- Quator: Fix version name
- QuaDer: Created API configuration
- Queries demo

Author: JPugetGil

quads-creator/src/main/java/fr/vcity/RDFConverter.java

@@ -81,7 +81,7 @@ private void insertQuadsToMetadataDataset() {
         getStreamRDF(inputFileName, outputFile, graphURI)
                 .finish();
 
-        getMetadataStreamRDF(inputFileName, graphURI)
+        getMetadataStreamRDF(inputFile, graphURI)
                 .finish();
     }
 

quads-loader/src/main/java/fr/vcity/converg/controllers/QuadImportController.java

@@ -9,6 +9,7 @@
 import io.swagger.v3.oas.annotations.responses.ApiResponses;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import org.apache.jena.riot.RiotException;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
@@ -18,6 +19,10 @@
 @Tag(name = "Import API")
 @RequestMapping("/import")
 public class QuadImportController {
+
+    @Value("${quad.importer.enabled}")
+    boolean quadImporterEnabled;
+
     QuadImportService quadImportService;
 
     public QuadImportController(QuadImportService quadImportService) {
@@ -43,8 +48,12 @@ ResponseEntity<Integer> importModel(
             @RequestParam("file") MultipartFile file
     ) {
         try {
-            Integer indexVersion = quadImportService.importModel(file);
-            return ResponseEntity.ok(indexVersion);
+            if (quadImporterEnabled) {
+                Integer indexVersion = quadImportService.importModel(file);
+                return ResponseEntity.ok(indexVersion);
+            } else {
+                return ResponseEntity.ok(null);
+            }
         } catch (RiotException e) {
             return ResponseEntity
                     .badRequest()
@@ -70,7 +79,10 @@ ResponseEntity<Void> importMetadata(
             @RequestParam("file") MultipartFile file
     ) {
         try {
-            quadImportService.importMetadata(file);
+            if (quadImporterEnabled) {
+                quadImportService.importMetadata(file);
+            }
+
             return ResponseEntity.ok().build();
         } catch (RiotException e) {
             return ResponseEntity
@@ -88,6 +100,8 @@ ResponseEntity<Void> importMetadata(
     })
     @DeleteMapping(value = {"/metadata"})
     void removeMetadata() {
-        quadImportService.removeMetadata();
+        if (quadImporterEnabled) {
+            quadImportService.removeMetadata();
+        }
     }
 }

workflows/queries/blazegraph/blazegraph-0.rq

@@ -4,4 +4,4 @@ SELECT ?g ?s ?p ?o WHERE {
       ?s ?p ?o .
     }
     FILTER(?g != <https://github.com/VCityTeam/ConVer-G/Named-Graph#Metadata>)
-}
+}  LIMIT 1000

workflows/queries/blazegraph/blazegraph-1.rq

@@ -3,4 +3,4 @@ SELECT ?s ?p ?o WHERE {
     GRAPH <https://github.com/VCityTeam/ConVer-G/Named-Graph#Metadata> {
         ?s ?p ?o .
     }
-}
+} LIMIT 1000

workflows/queries/blazegraph/blazegraph-10.rq

@@ -0,0 +1,14 @@
+# Find the number of rating of reviews in each graph
+PREFIX bsbm: <http://www4.wiwiss.fu-berlin.de/bizer/bsbm/v01/vocabulary/>
+PREFIX vers: <https://github.com/VCityTeam/ConVer-G/Version#>
+
+SELECT ?graph (COUNT(?rating) as ?countrating) WHERE {
+  GRAPH ?vg {
+      ?s a bsbm:Review ;
+  			bsbm:rating3 ?rating .
+  }
+
+  GRAPH <https://github.com/VCityTeam/ConVer-G/Named-Graph#Metadata> {
+    ?vg vers:is-version-of ?graph .
+  }
+} GROUP BY ?graph

workflows/queries/blazegraph/blazegraph-11.rq

@@ -0,0 +1,14 @@
+# Find the number of rating of reviews in each graph
+PREFIX bsbm: <http://www4.wiwiss.fu-berlin.de/bizer/bsbm/v01/vocabulary/>
+PREFIX vers: <https://github.com/VCityTeam/ConVer-G/Version#>
+
+SELECT ?version (AVG(?rating) as ?avgrating) WHERE {
+  GRAPH ?vg {
+      ?s a bsbm:Review ;
+  			bsbm:rating3 ?rating .
+  }
+
+  GRAPH <https://github.com/VCityTeam/ConVer-G/Named-Graph#Metadata> {
+    ?vg vers:is-in-version ?version .
+  }
+} GROUP BY ?version

workflows/queries/blazegraph/blazegraph-5.rq

@@ -1,5 +1,5 @@
 # Query the graph store for all quads with a given subject and a join on the predicate and subject (object might be equal to object2)
-SELECT ?graph ?subject ?predicate ?object ?object2 WHERE {
+SELECT ?graph ?predicate ?object ?object2 WHERE {
     GRAPH ?graph {
       <http://www4.wiwiss.fu-berlin.de/bizer/bsbm/v01/instances/ProductFeature287> ?predicate ?object ,
         ?object2 .

workflows/queries/blazegraph/blazegraph-6.rq

@@ -1,6 +1,6 @@
 # Query the graph store for all quads in a specific versioned graph with a given subject and a join on the subject (predicate might be equal to predicate2 and object might be equal to object2)
 SELECT ?p ?o WHERE {
-    GRAPH <https://github.com/VCityTeam/ConVer-G/Versioned-Named-Graph#a156e4f5c5cb3dda5b72fb64c4264de925a10fbdefa8ae5b7066e69027edbd48> {
+    GRAPH <https://github.com/VCityTeam/ConVer-G/Versioned-Named-Graph#f9f46affceacefb7f493e84dd18206309777c31cdfa09d0b7e945961eac004b9> {
       <http://www4.wiwiss.fu-berlin.de/bizer/bsbm/v01/instances/ProductFeature287> ?p ?o ;
         ?p2 ?o2 .
     }

workflows/queries/blazegraph/blazegraph-7.rq

@@ -0,0 +1,11 @@
+# Give the graph name (metadata) of the versioned graph containing the product feature 287
+SELECT ?graph ?p ?o WHERE {
+    GRAPH ?vg {
+      <http://www4.wiwiss.fu-berlin.de/bizer/bsbm/v01/instances/ProductFeature287> ?p ?o ;
+        ?p2 ?o2 .
+    }
+
+    GRAPH <https://github.com/VCityTeam/ConVer-G/Named-Graph#Metadata> {
+         ?vg <https://github.com/VCityTeam/ConVer-G/Version#is-version-of> 	?graph .
+    }
+}

workflows/queries/blazegraph/blazegraph-8.rq

@@ -0,0 +1,11 @@
+# Give the graph name (metadata) of the versioned graph containing the product feature 287 and its type
+SELECT ?version ?p1 ?o1 ?type WHERE {
+    GRAPH ?vg {
+      <http://www4.wiwiss.fu-berlin.de/bizer/bsbm/v01/instances/ProductFeature287> ?p1 ?o1 ;
+        a ?type .
+    }
+
+    GRAPH <https://github.com/VCityTeam/ConVer-G/Named-Graph#Metadata> {
+         ?vg <https://github.com/VCityTeam/ConVer-G/Version#is-in-version> 	?version .
+    }
+}