From fa1d268b3627394eb2c27e512cf53f7fe10d80c7 Mon Sep 17 00:00:00 2001
From: Enrico Ottonello <enrico.ottonello@isti.cnr.it>
Date: Wed, 10 Jun 2020 11:53:37 +0200
Subject: [PATCH] added query to link data from collection level to records
 level

---
 .../sparql/collection_to_records_data.sparql  | 44 +++++++++++++++++++
 .../sparql/read_record_data.sparql            | 26 ++++++-----
 2 files changed, 58 insertions(+), 12 deletions(-)
 create mode 100644 dnet-ariadneplus-graphdb-publisher/src/main/resources/eu/dnetlib/ariadneplus/sparql/collection_to_records_data.sparql

diff --git a/dnet-ariadneplus-graphdb-publisher/src/main/resources/eu/dnetlib/ariadneplus/sparql/collection_to_records_data.sparql b/dnet-ariadneplus-graphdb-publisher/src/main/resources/eu/dnetlib/ariadneplus/sparql/collection_to_records_data.sparql
new file mode 100644
index 0000000..40d936f
--- /dev/null
+++ b/dnet-ariadneplus-graphdb-publisher/src/main/resources/eu/dnetlib/ariadneplus/sparql/collection_to_records_data.sparql
@@ -0,0 +1,44 @@
+PREFIX aocat: <https://www.ariadne-infrastructure.eu/resource/ao/cat/1.1/> 
+PREFIX skos: <http://www.w3.org/2004/02/skos/core#>
+PREFIX time: <http://www.w3.org/2006/time#>
+PREFIX ariadneplus: <https://ariadne-infrastructure.eu/aocat/>
+INSERT {
+    GRAPH <https://ariadne-infrastructure.eu/api_________::ariadne_plus::ads::271> {
+        ?record aocat:was_issued ?issued .
+        ?record aocat:was_modified ?modified .
+        ?record aocat:has_contributor ?contributor .
+        ?record aocat:has_responsible ?legalResponsible .
+        ?record aocat:has_owner ?owner .
+        ?record aocat:has_publisher ?publisher .
+        ?record aocat:has_access_rights ?accessRights .
+        ?record aocat:has_ARIADNE_subject ?archeologicalResourceType .
+    }
+}
+WHERE {
+	?record aocat:is_part_of ?collection .
+    ?collection aocat:was_issued ?issued .
+    ?collection aocat:was_modified ?modified .
+    ?collection aocat:has_contributor ?contributor .
+    ?contributor aocat:has_name ?contributorName .
+    ?collection aocat:has_responsible ?legalResponsible .
+    ?legalResponsible aocat:has_name ?legalResponsibleName .
+    ?collection aocat:has_owner ?owner .
+    ?owner aocat:has_name ?ownerName .
+    ?collection aocat:has_publisher ?publisher . 
+    ?publisher aocat:has_name ?publisherName .
+    ?collection aocat:has_access_rights ?accessRights .
+    ?collection  aocat:has_ARIADNE_subject ?archeologicalResourceType .    
+    ?archeologicalResourceType skos:prefLabel ?archeologicalResourceTypeName .
+    optional {
+        ?contributor aocat:has_email ?contributorEmail .
+    }
+    optional {
+        ?legalResponsible aocat:has_email ?legalResponsibleEmail .
+    }
+    optional {
+        ?owner aocat:has_email ?ownerEmail . 
+    }
+    optional {
+        ?publisher aocat:has_email ?publisherEmail .
+    }
+}
diff --git a/dnet-ariadneplus-graphdb-publisher/src/main/resources/eu/dnetlib/ariadneplus/sparql/read_record_data.sparql b/dnet-ariadneplus-graphdb-publisher/src/main/resources/eu/dnetlib/ariadneplus/sparql/read_record_data.sparql
index 2e94223..84b4730 100644
--- a/dnet-ariadneplus-graphdb-publisher/src/main/resources/eu/dnetlib/ariadneplus/sparql/read_record_data.sparql
+++ b/dnet-ariadneplus-graphdb-publisher/src/main/resources/eu/dnetlib/ariadneplus/sparql/read_record_data.sparql
@@ -58,7 +58,8 @@ CONSTRUCT {
 ?derivedSubject aoprop:source "Getty AAT" .
 ?record aoprop:aatSubjects ?derivedSubject .
 ?derivedSubject aoprop:id ?derivedSubject .      
-?derivedSubject aoprop:label ?derivedSubjectPrefLabel .     
+?derivedSubject aoprop:label ?derivedSubjectPrefLabel .
+?derivedSubject aoprop:lang ?aatSubjectsLang .
 ?record aoprop:title ?title .      
 ?record aoprop:description ?description .     
 ?record aoprop:language ?language .   
@@ -68,7 +69,7 @@ from  <https://ariadne-infrastructure.eu/ariadneplus::ads::aatplus>
 from  <https://ariadne-infrastructure.eu/ariadneplus::ads::periodo>
 from <https://ariadne-infrastructure.eu/ariadneplus::ads::periodoplus>
 from  <https://ariadne-infrastructure.eu/api_________::ariadne_plus::ads::271>
-where { 	
+where { 
     	?record	aocat:has_language / skos:prefLabel ?language .
     	?record	aocat:has_original_id ?originalId .
     	?record aocat:is_part_of ?partOf .
@@ -111,18 +112,18 @@ where {
 		select  * 
         where {
             ?record aocat:is_part_of ?collection .
-            ?collection aocat:was_issued ?issued .
-            ?collection aocat:was_modified ?modified .
-            ?collection aocat:has_contributor ?contributor .
+            ?record aocat:was_issued ?issued .
+            ?record aocat:was_modified ?modified .
+            ?record aocat:has_contributor ?contributor .
             ?contributor aocat:has_name ?contributorName .
-            ?collection aocat:has_responsible ?legalResponsible .
+            ?record aocat:has_responsible ?legalResponsible .
             ?legalResponsible aocat:has_name ?legalResponsibleName .
-            ?collection aocat:has_owner ?owner .
+            ?record aocat:has_owner ?owner .
             ?owner aocat:has_name ?ownerName .
-            ?collection aocat:has_publisher ?publisher . 
+            ?record aocat:has_publisher ?publisher . 
             ?publisher aocat:has_name ?publisherName .
-            ?collection aocat:has_access_rights ?accessRights .
-            ?collection  aocat:has_ARIADNE_subject ?archeologicalResourceType .    
+            ?record aocat:has_access_rights ?accessRights .
+            ?record  aocat:has_ARIADNE_subject ?archeologicalResourceType .    
             ?archeologicalResourceType skos:prefLabel ?archeologicalResourceTypeName .
             optional {
                 ?contributor aocat:has_email ?contributorEmail .
@@ -138,6 +139,7 @@ where {
             }
     	}
     	}
+    
     	{
         select * 
         where {
@@ -160,5 +162,5 @@ where {
             }
             }	
     	}
-    
-}
+    BIND (lang(?derivedSubjectPrefLabel) as ?aatSubjectsLang)
+}
\ No newline at end of file