Kgc 2025 conformance

fetch-test-cases.bat

@@ -0,0 +1,61 @@
+@echo off
+
+set "targetDir=target"
+
+echo Creating target directory...
+if not exist "%targetDir%" mkdir "%targetDir%"
+if errorlevel 1 goto error
+
+cd "%targetDir%"
+if errorlevel 1 goto error
+
+echo Cloning https://github.com/kg-construct/rml-core
+git clone https://github.com/kg-construct/rml-core
+if errorlevel 1 goto error
+
+echo Cloning rhttps://github.com/kg-construct/rml-cc
+git clone https://github.com/kg-construct/rml-cc
+if errorlevel 1 goto error
+
+echo Cloning https://github.com/kg-construct/rml-io
+git clone https://github.com/kg-construct/rml-io
+if errorlevel 1 goto error
+
+echo Cloning rhttps://github.com/kg-construct/rml-fnml
+git clone https://github.com/kg-construct/rml-fnml
+if errorlevel 1 goto error
+
+echo Cloning https://github.com/kg-construct/rml-lv
+git clone https://github.com/kg-construct/rml-lv
+if errorlevel 1 goto error
+
+echo Cloning rhttps://github.com/kg-construct/rml-star
+git clone https://github.com/kg-construct/rml-star
+if errorlevel 1 goto error
+
+echo All repositories cloned successfully into the target directory!
+
+echo Copying test-case directories to ..\src\test\resources
+xcopy .\rml-core\test-cases ..\src\test\resources\rml-core /E /I /Y
+xcopy .\rml-cc\test-cases ..\src\test\resources\rml-cc /E /I /Y
+xcopy .\target\rml-io\test-cases ..\src\test\resources\rml-io /E /I /Y
+xcopy .\rml-lv\test-cases ..\src\test\resources\rml-lv /E /I /Y
+xcopy .\rml-fnml\test-cases ..\src\test\resources\rml-fnml /E /I /Y
+xcopy .\rml-star\test-cases ..\src\test\resources\rml-star /E /I /Y
+
+rmdir /S /Q .\rml-core
+rmdir /S /Q .\rml-cc
+rmdir /S /Q .\rml-io
+rmdir /S /Q .\rml-lv
+rmdir /S /Q .\rml-fnml
+rmdir /S /Q .\rml-star
+
+goto end
+
+:error
+echo Error occurred.
+echo Check the repository URLs and your internet connection.
+echo or verify that you have permissions to create and write to the target directory.
+
+:end
+pause

fetch-test-cases.sh

@@ -0,0 +1,72 @@
+#!/usr/bin/env bash
+set -Eeuo pipefail
+
+# --- config ---
+target_dir="target"
+resources_dir="src/test/resources"
+shapes_resources_dir="src/main/resources/shapes"
+repos=(
+  "rml-core"
+  "rml-cc"
+  "rml-io"
+  "rml-fnml"
+  "rml-lv"
+  "rml-star"
+)
+
+trap 'echo; echo "Error occurred."; echo "• Check the repository URLs and your internet connection."; echo "• Verify you have permissions to create/write to \"$target_dir\"."; exit 1' ERR
+
+# Check prerequisites
+command -v git >/dev/null 2>&1 || { echo "git is required but not found in PATH."; exit 1; }
+
+echo "Creating $target_dir directory..."
+mkdir -p "$target_dir"
+
+echo "Entering $target_dir..."
+cd "$target_dir"
+
+# Clone all repositories
+for repo in "${repos[@]}"; do
+  echo "Cloning https://github.com/kg-construct/$repo ..."
+  git clone "https://github.com/kg-construct/$repo"
+done
+
+echo "All repositories cloned successfully into $target_dir"
+
+# Copy test-cases into ../src/test/resources/<repo>
+echo "Copying test-case directories to ../$resources_dir ..."
+for repo in "${repos[@]}"; do
+  src="$repo/test-cases"
+  dest="../$resources_dir/$repo"
+  if [[ -d "$src" ]]; then
+    mkdir -p "$dest"
+    # -a to preserve attrs; -r for recursive; --no-target-directory not needed here
+    cp -a "$src/." "$dest/"
+    echo "• Copied $src -> $dest"
+  else
+    echo "• Skipped $repo (no test-cases directory found)"
+  fi
+done
+
+# Copy shapes into ../src/main/resources/<repo>
+echo "Copying shapes directories to ../$shapes_resources_dir ..."
+for repo in "${repos[@]}"; do
+  src="$repo/shapes"
+  dest="../$shapes_resources_dir/$repo"
+  if [[ -d "$src" ]]; then
+    mkdir -p "$dest"
+    # -a to preserve attrs; -r for recursive; --no-target-directory not needed here
+    cp -a "$src/." "$dest/"
+    echo "• Copied $src -> $dest"
+  else
+    echo "• Skipped $repo (no shapes directory found)"
+  fi
+done
+
+# Remove cloned repositories
+echo "Cleaning up cloned repositories..."
+for repo in "${repos[@]}"; do
+  rm -rf "./$repo"
+done
+
+echo "Done."

pom.xml

@@ -2,7 +2,7 @@
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
     <modelVersion>4.0.0</modelVersion>
-    <groupId>com.github.kg-construct</groupId>
+    <groupId>io.github.kg-construct</groupId>
     <artifactId>BURP</artifactId>
     <version>0.1.2</version>
     <name>Basic and Unassuming RML Processor</name>
@@ -220,6 +220,12 @@
             <scope>test</scope>
         </dependency>
         <dependency>
+			<groupId>org.junit.jupiter</groupId>
+			<artifactId>junit-jupiter-params</artifactId>
+			<version>5.10.2</version>
+			<scope>test</scope>
+		</dependency>
+		<dependency>
             <groupId>org.testcontainers</groupId>
             <artifactId>junit-jupiter</artifactId>
             <version>1.19.5</version>

src/main/java/burp/Main.java

@@ -68,11 +68,13 @@ public static int doMain(String[] args) {
 		}
 	}
 
-	private static Dataset generate(List<TriplesMap> triplesmaps, String baseIRI) {
+	private static Dataset generate(List<TriplesMap> triplesmaps, String givenBaseIRI) {
 		Dataset ds = DatasetFactory.create();
 
 		// Execute the triples maps
 		for (TriplesMap tm : triplesmaps) {
+			String baseIRI = tm.baseIRI == null ? givenBaseIRI : tm.baseIRI;
+
 			// Let sm be the subject map of the triples map
 			SubjectMap sm = tm.subjectMap;
 

src/main/java/burp/ls/CSVSource.java

@@ -1,18 +1,16 @@
 package burp.ls;
 
 import java.io.FileReader;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
+import java.io.StringWriter;
+import java.util.*;
+import java.util.stream.Collectors;
 
 import com.opencsv.CSVParserBuilder;
 import com.opencsv.CSVReader;
 import com.opencsv.CSVReaderBuilder;
 
 import burp.model.Iteration;
+import com.opencsv.CSVWriter;
 
 class CSVSource extends FileBasedLogicalSource {
 
@@ -23,7 +21,7 @@ class CSVSource extends FileBasedLogicalSource {
 	public Iterator<Iteration> iterator() {
 		try {
 			if (iterations == null) {
-				iterations = new ArrayList<Iteration>();
+				iterations = new ArrayList<>();
 
 				FileReader fr = new FileReader(getDecompressedFile(), encoding);
 
@@ -64,7 +62,8 @@ public Iterator<Iteration> iterator() {
 
 class CSVIteration extends Iteration {
 
-	private Map<String, String> map = new HashMap<String, String>();
+    // Use a LinkedHashMap to preserve a correspondence between keys and values
+	private final Map<String, String> map = new LinkedHashMap<>();
 
 	protected CSVIteration(String[] header, String[] rec, Set<Object> nulls) {
 		super(nulls);
@@ -76,28 +75,34 @@ protected CSVIteration(String[] header, String[] rec, Set<Object> nulls) {
 
 	@Override
 	public List<Object> getValuesFor(String reference) {
-		List<Object> l = new ArrayList<Object>();
+		List<Object> l = new ArrayList<>();
 		if(!map.containsKey(reference))
 			throw new RuntimeException("Attribute " + reference + " does not exist.");
 
 		String o = map.get(reference);
-		if(!nulls.contains(o))
+		if(nulls == null || !nulls.contains(o))
 			l.add(o);
 
 		return l;
 	}
 
 	@Override
 	public List<String> getStringsFor(String reference) {
-		List<String> l = new ArrayList<String>();
-		if(!map.containsKey(reference))
-			throw new RuntimeException("Attribute " + reference + " does not exist.");
-
-		String o = map.get(reference);
-		if(!nulls.contains(o))
-			l.add(o);
-
-		return l;
+		return getValuesFor(reference).stream().map(Object::toString).collect(Collectors.toList());
 	}
-
+
+    @Override
+    public String asString() {
+        StringWriter stringWriter = new StringWriter();
+        try (CSVWriter writer = new CSVWriter(stringWriter)) {
+            String[] header = map.keySet().toArray(new String[0]);
+            writer.writeNext(header);
+            String[] rec = map.values().toArray(new String[0]);
+            writer.writeNext(rec);
+        } catch(Exception e) {
+            throw new RuntimeException("Error representing CSV iteration as CSV.");
+        }
+        return stringWriter.toString();
+    }
+
 }

src/main/java/burp/ls/FileBasedLogicalSource.java

@@ -15,7 +15,6 @@ abstract class FileBasedLogicalSource extends LogicalSource {
 
 	protected List<Iteration> iterations = null;
 	public String file;
-	public String iterator;
 	public Charset encoding = StandardCharsets.UTF_8;
 	public Resource compression = RML.none;
 

src/main/java/burp/ls/JSONSource.java

@@ -21,17 +21,20 @@
 
 class JSONSource extends FileBasedLogicalSource {
 
-	private static Configuration c = Configuration.builder().mappingProvider(new JacksonMappingProvider())
-			.jsonProvider(new JacksonJsonProvider()).build().addOptions(Option.ALWAYS_RETURN_LIST);
+	public static final Configuration configuration = Configuration.builder()
+            .mappingProvider(new JacksonMappingProvider())
+			.jsonProvider(new JacksonJsonProvider())
+            .build()
+            .addOptions(Option.ALWAYS_RETURN_LIST);
 
 	@Override
 	public Iterator<Iteration> iterator() {
 		try {
 			if (iterations == null) {
-				iterations = new ArrayList<Iteration>();
+				iterations = new ArrayList<>();
 				String contents = Files.readString(Paths.get(getDecompressedFile()), encoding);
 
-				List<Map<String, Object>> nodes = JsonPath.using(c).parse(contents).read(iterator);
+				List<Map<String, Object>> nodes = JsonPath.using(configuration).parse(contents).read(iterator);
 				for (Map<String, Object> n : nodes) {
 					iterations.add(new JSONIteration(JSONObject.toJSONString(n), nulls));
 				}
@@ -47,34 +50,22 @@ public Iterator<Iteration> iterator() {
 class JSONIteration extends Iteration {
 
 	private DocumentContext doc = null;
-
-	private static Configuration c = Configuration
-			.builder()
-            .mappingProvider(new JacksonMappingProvider())
-            .jsonProvider(new JacksonJsonProvider())
-            .build()
-            .addOptions(Option.ALWAYS_RETURN_LIST)
-			;
-
+
 	protected JSONIteration(String json, Set<Object> nulls) {
 		super(nulls);
-
-		doc = JsonPath.using(c).parse(json);
+		doc = JsonPath.using(JSONSource.configuration).parse(json);
 	}
 
 	@Override
 	public List<Object> getValuesFor(String reference) {
-		// We need to explicitly convert the objects
-		// to strings because RML has not worked out
-		// "6.6.1 Automatically deriving datatypes" yet
-		List<Object> l2 = new ArrayList<Object>();
+		List<Object> l2 = new ArrayList<>();
 		try {
 			List<Object> l = doc.read(reference);
 			for(Object o : l) {
 				if (o instanceof List<?>)
 					throw new RuntimeException("Data error: reference retrieved an array");
-				if (o != null && !nulls.contains(o))
-					l2.add(o.toString());
+				if (o != null && (nulls == null || !nulls.contains(o)))
+					l2.add(o);
 			}
 		} catch (PathNotFoundException e) {
 			// No data, silently ignore
@@ -85,16 +76,13 @@ public List<Object> getValuesFor(String reference) {
 
 	@Override
 	public List<String> getStringsFor(String reference) {
-		// We need to explicitly convert the objects
-		// to strings (when they are null) because 
-		// this JSONPath library is... difficult.
-		List<String> l2 = new ArrayList<String>();
+		List<String> l2 = new ArrayList<>();
 		try {
 			List<Object> l = doc.read(reference);
 			for(Object o : l) {
 				if (o instanceof List<?>)
 					throw new RuntimeException("Data error: reference retrieved an array");
-				if (o != null && !nulls.contains(o))
+                if (o != null && (nulls == null || !nulls.contains(o)))
 					l2.add(o.toString());
 			}
 		} catch (PathNotFoundException e) {
@@ -103,5 +91,10 @@ public List<String> getStringsFor(String reference) {
 		}
 		return l2;
 	}
-
+
+    @Override
+    public String asString() {
+        return doc.jsonString();
+    }
+
 }