Merge branch 'dev' into 'main'

Release: Sprint/2022 15 

See merge request !11

src/SQL2Linked/Implementations/ProjectStructuralData.cs

@@ -6,10 +6,133 @@ namespace SQL2Linked.Implementations
 {
     public class ProjectStructuralData : StructuralData<Project, ProjectModel>
     {
+        public readonly Uri org = new("http://www.w3.org/ns/org#");
+        public readonly Uri dcat = new("http://www.w3.org/ns/dcat#");
+        public readonly Uri dcterms = new("http://purl.org/dc/terms/");
+        public readonly Uri foaf = new("http://xmlns.com/foaf/0.1/");
+        public readonly Uri vcard = new("http://www.w3.org/2006/vcard/ns#");
+        public readonly Uri rdf = new("http://www.w3.org/1999/02/22-rdf-syntax-ns#");
+        public readonly Uri cosc = new("https://purl.org/coscine/");
+        private VisibilityModel VisibilityModel = new VisibilityModel();
+        private ProjectRoleModel ProjectRoleModel = new ProjectRoleModel();
+        private ProjectResourceModel ProjectResourceModel = new ProjectResourceModel();
+
         public override IEnumerable<IGraph> ConvertToLinkedData(IEnumerable<Project> entries)
         {
-            // ToDo: Implement
-            throw new NotImplementedException();
+            IEnumerable<Visibility> visibilities = VisibilityModel.GetAll();
+            IEnumerable<ProjectRole> projectRoles = ProjectRoleModel.GetAll();
+            IEnumerable<ProjectResource> projectResources = ProjectResourceModel.GetAll();
+
+            var graphs = new List<IGraph>();
+            string projectUrlPrefix = "https://hdl.handle.net/" + Prefix;
+
+            foreach (var entry in entries)
+            {
+                var projectGraphName = $"{projectUrlPrefix}/{entry.Id}";
+
+                var graph = new Graph();
+                graph.BaseUri = new Uri(projectGraphName);
+
+                AssertToGraphUriNode(graph, projectGraphName, rdf + "type", dcat + "Catalog");
+                Console.WriteLine($"For project '{entry.DisplayName}' will migrate triple '{projectGraphName} {rdf}type {dcat}Catalog'. ");
+
+                AssertToGraphUriNode(graph, projectGraphName, rdf + "type", org + "OrganizationalCollaboration");
+                Console.WriteLine($"For project '{entry.DisplayName}' will migrate triple '{projectGraphName} {rdf}type {org}OrganizationalCollaboration'. ");
+
+                AssertToGraphUriNode(graph, projectGraphName, rdf + "type", vcard + "Group");
+                Console.WriteLine($"For project '{entry.DisplayName}' will migrate triple '{projectGraphName} {rdf}type {vcard}Group'. ");
+
+                AssertToGraphLiteralNode(graph, projectGraphName, dcterms + "title", entry.ProjectName);
+                Console.WriteLine($"For project '{entry.DisplayName}' will migrate triple '{projectGraphName} {dcterms}title {entry.ProjectName}'. ");
+
+                AssertToGraphLiteralNode(graph, projectGraphName, dcterms + "description", entry.Description);
+                Console.WriteLine($"For project '{entry.DisplayName}' will migrate triple '{projectGraphName} {dcterms}description {entry.Description}'. ");
+
+                AssertToGraphLiteralNode(graph, projectGraphName, dcat + "startDate", entry.StartDate.ToString());
+                Console.WriteLine($"For project '{entry.DisplayName}' will migrate triple '{projectGraphName} {dcat}startDate {entry.StartDate}'. ");
+
+                AssertToGraphLiteralNode(graph, projectGraphName, dcat + "endDate", entry.EndDate.ToString());
+                Console.WriteLine($"For project '{entry.DisplayName}' will migrate triple '{projectGraphName} {dcat}endDate {entry.EndDate}'. ");
+
+                if (!string.IsNullOrWhiteSpace(entry.Keywords))
+                {
+                    var listKeywords = entry.Keywords.Split(';').ToList();
+                    foreach (var keyword in listKeywords)
+                    {
+                        AssertToGraphLiteralNode(graph, projectGraphName, dcterms + "subject", keyword);
+                        Console.WriteLine($"For project '{entry.DisplayName}' will migrate triple '{projectGraphName} {dcterms}subject {keyword}'. ");
+                    }
+                }
+
+                AssertToGraphLiteralNode(graph, projectGraphName, dcterms + "alternative", entry.DisplayName);
+                Console.WriteLine($"For project '{entry.DisplayName}' will migrate triple '{projectGraphName} {dcterms}alternative {entry.DisplayName}'. ");
+
+                AssertToGraphLiteralNode(graph, projectGraphName, dcterms + "rightsHolder", entry.PrincipleInvestigators);
+                Console.WriteLine($"For project '{entry.DisplayName}' will migrate triple '{projectGraphName} {dcterms}rightsHolder {entry.PrincipleInvestigators}'. ");
+
+                AssertToGraphLiteralNode(graph, projectGraphName, "https://schema.org/funding", entry.GrantId);
+                Console.WriteLine($"For project '{entry.DisplayName}' will migrate triple '{projectGraphName} https://schema.org/funding {entry.GrantId}'. ");
+
+                foreach (var visibility in visibilities)
+                {
+                    if (entry.VisibilityId == visibility.Id && visibility.DisplayName.Contains("Public"))
+                    {
+                        AssertToGraphUriNode(graph, projectGraphName, cosc + "terms/project#visibility", cosc + $"terms/visibility#public");
+                        Console.WriteLine($"For project '{entry.DisplayName}' will migrate triple '{projectGraphName} {cosc}terms/project#visibility {cosc}terms/visibility#public'. ");
+                        break;
+                    }
+                    else if (entry.VisibilityId == visibility.Id && visibility.DisplayName.Contains("Project Members"))
+                    {
+                        AssertToGraphUriNode(graph, projectGraphName, cosc + "terms/project#visibility", cosc + $"terms/visibility#projectMember");
+                        Console.WriteLine($"For project '{entry.DisplayName}' will migrate triple '{projectGraphName} {cosc}terms/project#visibility {cosc}terms/visibility#projectMember'. ");
+                        break;
+                    }
+                }
+
+                AssertToGraphLiteralNode(graph, projectGraphName, cosc + "terms/project#deleted", entry.Deleted.ToString(), new Uri("http://www.w3.org/2001/XMLSchema#boolean"));
+                Console.WriteLine($"For project '{entry.DisplayName}' will migrate triple '{projectGraphName} {cosc}terms/project#deleted {entry.Deleted}'. ");
+
+                AssertToGraphLiteralNode(graph, projectGraphName, cosc + "terms/project#slug", entry.Slug);
+                Console.WriteLine($"For project '{entry.DisplayName}' will migrate triple '{projectGraphName} {cosc}terms/project#slug {entry.Slug}'. ");
+
+                AssertToGraphUriNode(graph, projectGraphName, foaf + "homepage", projectGraphName);
+                Console.WriteLine($"For project '{entry.DisplayName}' will migrate triple '{projectGraphName} {foaf}homepage {projectGraphName}'. ");
+
+                foreach (var projectRole in projectRoles)
+                {
+                    if (entry.Id == projectRole.ProjectId)
+                    {
+                        AssertToGraphUriNode(graph, projectGraphName, vcard + "hasMember", cosc + "users/" + projectRole.UserId);
+                        Console.WriteLine($"For project '{entry.DisplayName}' will migrate triple '{projectGraphName} {vcard}hasMember {cosc}users/{projectRole.UserId}'. ");
+
+                        var blankNode = graph.CreateBlankNode();
+
+                        AssertToGraphBlankAndUriNode(graph, blankNode, rdf + "type", org + "Membership");
+                        Console.WriteLine($"For project '{entry.DisplayName}' will migrate triple '{blankNode} {rdf}type {org}Membership'. ");
+
+                        AssertToGraphBlankAndUriNode(graph, blankNode, org + "organization", projectGraphName);
+                        Console.WriteLine($"For project '{entry.DisplayName}' will migrate triple '{blankNode} {org}organization {projectGraphName}'. ");
+
+                        AssertToGraphBlankAndUriNode(graph, blankNode, org + "role", cosc + "roles/" + projectRole.RoleId);
+                        Console.WriteLine($"For project '{entry.DisplayName}' will migrate triple '{blankNode} {org}role {cosc}roles/{projectRole.RoleId}'. ");
+
+                        AssertToGraphBlankAndUriNode(graph, blankNode, org + "member", cosc + "users/" + projectRole.UserId);
+                        Console.WriteLine($"For project '{entry.DisplayName}' will migrate triple '{blankNode} {org}member {cosc}users/{projectRole.UserId}'. ");
+                    }
+                }
+
+                foreach (var projectResource in projectResources)
+                {
+                    if (entry.Id == projectResource.ProjectId)
+                    {
+                        AssertToGraphUriNode(graph, projectGraphName, dcat + "catalog", $"{projectUrlPrefix}/{projectResource.ResourceId}");
+                        Console.WriteLine($"For project '{entry.DisplayName}' will migrate triple '{projectGraphName} {dcat}catalog {projectUrlPrefix}/{projectResource.ResourceId}'. ");
+                    }
+                }
+
+                graphs.Add(graph);
+            }
+            return graphs;
         }
     }
 }
\ No newline at end of file

src/SQL2Linked/Implementations/ResourceStructuralData.cs

 using Coscine.Database.DataModel;
 using Coscine.Database.Models;
 using VDS.RDF;
+using VDS.RDF.Query;
 
 namespace SQL2Linked.Implementations
 {
     public class ResourceStructuralData : StructuralData<Resource, ResourceModel>
     {
+        public readonly Uri org = new("http://www.w3.org/ns/org#");
+        public readonly Uri dcat = new("http://www.w3.org/ns/dcat#");
+        public readonly Uri dcterms = new("http://purl.org/dc/terms/");
+        public readonly Uri acl = new("http://www.w3.org/ns/auth/acl#");
+        public readonly Uri foaf = new("http://xmlns.com/foaf/0.1/");
+        public readonly Uri pim = new("http://www.w3.org/ns/pim/space#");
+        public readonly Uri rdf = new("http://www.w3.org/1999/02/22-rdf-syntax-ns#");
+        public readonly Uri cosc = new("https://purl.org/coscine/");
+        private VisibilityModel VisibilityModel = new VisibilityModel();
+        private ProjectResourceModel ProjectResourceModel = new ProjectResourceModel();
+        private LicenseModel LicenseModel = new LicenseModel();
+
         public override IEnumerable<IGraph> ConvertToLinkedData(IEnumerable<Resource> entries)
         {
-            // ToDo: Implement
-            throw new NotImplementedException();
+            IEnumerable<Visibility> visibilities = VisibilityModel.GetAll();
+            IEnumerable<ProjectResource> projectResources = ProjectResourceModel.GetAll();
+            IEnumerable<License> licenses = LicenseModel.GetAll();
+
+            var graphs = new List<IGraph>();
+            string resourceUrlPrefix = "https://hdl.handle.net/" + Prefix;
+
+            foreach (var entry in entries)
+            {
+                var resourceGraphName = $"{resourceUrlPrefix}/{entry.Id}";
+
+                var graph = new Graph();
+                graph.BaseUri = new Uri(resourceGraphName);
+
+                AssertToGraphUriNode(graph, resourceGraphName, rdf + "type", dcat + "Catalog");
+                Console.WriteLine($"For resource '{entry.DisplayName}' will migrate triple '{resourceGraphName} {rdf}type {dcat}Catalog'. ");
+
+                AssertToGraphUriNode(graph, resourceGraphName, rdf + "type", pim + "Storage");
+                Console.WriteLine($"For resource '{entry.DisplayName}' will migrate triple '{resourceGraphName} {rdf}type {pim}Storage'. ");
+
+                AssertToGraphUriNode(graph, resourceGraphName, dcat + "service", cosc + $"resourcetype/{entry.TypeId}");
+                Console.WriteLine($"For resource '{entry.DisplayName}' will migrate triple '{resourceGraphName} {dcat}service {cosc}resourcetype/{entry.TypeId}'. ");
+
+                AssertToGraphLiteralNode(graph, resourceGraphName, dcterms + "title", entry.ResourceName);
+                Console.WriteLine($"For resource '{entry.DisplayName}' will migrate triple '{resourceGraphName} {dcterms}title {entry.ResourceName}'. ");
+
+                AssertToGraphLiteralNode(graph, resourceGraphName, dcterms + "alternative", entry.DisplayName);
+                Console.WriteLine($"For resource '{entry.DisplayName}' will migrate triple '{resourceGraphName} {dcterms}alternative {entry.DisplayName}'. ");
+
+                foreach (var visibility in visibilities)
+                {
+                    if (entry.VisibilityId == visibility.Id && visibility.DisplayName.Contains("Public"))
+                    {
+                        AssertToGraphUriNode(graph, resourceGraphName, cosc + "terms/resource#visibility", cosc + $"terms/visibility#public");
+                        Console.WriteLine($"For resource '{entry.DisplayName}' will migrate triple '{resourceGraphName} {cosc}terms/resource#visibility {cosc}terms/visibility#public'. ");
+                        break;
+                    }
+                    else if (entry.VisibilityId == visibility.Id && visibility.DisplayName.Contains("Project Members"))
+                    {
+                        AssertToGraphUriNode(graph, resourceGraphName, cosc + "terms/resource#visibility", cosc + $"terms/visibility#projectMember");
+                        Console.WriteLine($"For resource '{entry.DisplayName}' will migrate triple '{resourceGraphName} {cosc}terms/resource#visibility {cosc}terms/visibility#projectMember'. ");
+                        break;
+                    }
+                }
+
+                foreach (var license in licenses)
+                {
+                    if (entry.LicenseId == license.Id)
+                    {
+                        AssertToGraphLiteralNode(graph, resourceGraphName, dcterms + "license", license.DisplayName);
+                        Console.WriteLine($"For resource '{entry.DisplayName}' will migrate triple '{resourceGraphName} {dcterms}license {license.DisplayName}'. ");
+                        break;
+                    }
+                }
+
+                if (!string.IsNullOrWhiteSpace(entry.Keywords))
+                {
+                    var listKeywords = entry.Keywords.Split(';').ToList();
+                    foreach (var keyword in listKeywords)
+                    {
+                        AssertToGraphLiteralNode(graph, resourceGraphName, dcterms + "subject", keyword);
+                        Console.WriteLine($"For resource '{entry.DisplayName}' will migrate triple '{resourceGraphName} {dcterms}subject {keyword}'. ");
+                    }
+                }
+
+                AssertToGraphLiteralNode(graph, resourceGraphName, dcterms + "rights", entry.UsageRights);
+                Console.WriteLine($"For resource '{entry.DisplayName}' will migrate triple '{resourceGraphName} {dcterms}rights {entry.UsageRights}'. ");
+
+                AssertToGraphLiteralNode(graph, resourceGraphName, dcterms + "description", entry.Description);
+                Console.WriteLine($"For resource '{entry.DisplayName}' will migrate triple '{resourceGraphName} {dcterms}description {entry.Description}'. ");
+
+                AssertToGraphUriNode(graph, resourceGraphName, dcterms + "conformsTo", entry.ApplicationProfile);
+                Console.WriteLine($"For resource '{entry.DisplayName}' will migrate triple '{resourceGraphName} {dcterms}conformsTo {entry.ApplicationProfile}'. ");
+
+                AssertToGraphLiteralNode(graph, resourceGraphName, cosc + "terms/resource#fixedValues", entry.FixedValues);
+                Console.WriteLine($"For resource '{entry.DisplayName}' will migrate triple '{resourceGraphName} {cosc}terms/resource#fixedValues {entry.FixedValues}'. ");
+
+                AssertToGraphUriNode(graph, resourceGraphName, dcterms + "creator", cosc + $"users/{entry.Creator}");
+                Console.WriteLine($"For resource '{entry.DisplayName}' will migrate triple '{resourceGraphName} {dcterms}creator {cosc}users/{entry.Creator}'. ");
+
+                AssertToGraphLiteralNode(graph, resourceGraphName, cosc + "terms/resource#archived", entry.Archived.ToString(), new Uri("http://www.w3.org/2001/XMLSchema#boolean"));
+                Console.WriteLine($"For resource '{entry.DisplayName}' will migrate triple '{resourceGraphName} {cosc}terms/resource#archived {entry.Archived}'. ");
+
+                AssertToGraphUriNode(graph, resourceGraphName, foaf + "homepage", resourceGraphName);
+                Console.WriteLine($"For resource '{entry.DisplayName}' will migrate triple '{resourceGraphName} {foaf}homepage {resourceGraphName}'. ");
+
+                SparqlParameterizedString cmdString = new SparqlParameterizedString
+                {
+                    CommandText = "SELECT DISTINCT ?g " +
+                                    "WHERE {" +
+                                        "GRAPH ?g { ?s ?p ?o } . " +
+                                        "FILTER(STRSTARTS(STR(?s), \"" + resourceGraphName + "@\"))" +
+                                     "}"
+                };
+
+                var resultSet = QueryEndpoint.QueryWithResultSet(cmdString.ToString());
+
+                foreach (var result in resultSet)
+                {
+                    AssertToGraphUriNode(graph, resourceGraphName, dcat + "catalog", result[0].ToString());
+                    Console.WriteLine($"For resource '{entry.DisplayName}' will migrate triple '{resourceGraphName} {dcat}catalog {result[0].ToString()}'. ");
+                }
+
+                foreach (var projectResource in projectResources)
+                {
+                    if (entry.Id == projectResource.ResourceId)
+                    {
+                        var blankNode = graph.CreateBlankNode();
+
+                        AssertToGraphBlankAndUriNode(graph, blankNode, rdf + "type", acl + "Authorization");
+                        Console.WriteLine($"For resource '{entry.DisplayName}' will migrate triple '{blankNode} {rdf}type {acl}Authorization'. ");
+
+                        AssertToGraphBlankAndUriNode(graph, blankNode, acl + "agentGroup", $"{resourceUrlPrefix}/{projectResource.ProjectId}");
+                        Console.WriteLine($"For resource '{entry.DisplayName}' will migrate triple '{blankNode} {acl}agentGroup {resourceUrlPrefix}/{projectResource.ProjectId}'. ");
+
+                        AssertToGraphBlankAndUriNode(graph, blankNode, acl + "accessTo", resourceGraphName);
+                        Console.WriteLine($"For resource '{entry.DisplayName}' will migrate triple '{blankNode} {acl}accessTo {resourceGraphName}'. ");
+
+                        AssertToGraphBlankAndUriNode(graph, blankNode, acl + "mode", acl + "Control");
+                        Console.WriteLine($"For resource '{entry.DisplayName}' will migrate triple '{blankNode} {acl}accessTo {acl}Control'. ");
+                    }
+                }
+
+                graphs.Add(graph);
+            }
+
+            return graphs;
         }
     }
 }

src/SQL2Linked/Implementations/ResourceTypeStructuralData.cs

@@ -7,10 +7,9 @@ namespace SQL2Linked.Implementations
     public class ResourceTypeStructuralData : StructuralData<ResourceType, ResourceTypeModel>
     {
         public readonly string ResourceTypeUrlPrefix = "https://purl.org/coscine/resourcetype";
-        public readonly Uri RdfType = new("http://www.w3.org/1999/02/22-rdf-syntax-ns#type");
-        public readonly Uri DcatDataService = new ("http://www.w3.org/ns/dcat#DataService");
-        public readonly Uri dctermsTitle = new("http://purl.org/dc/terms/title");
-
+        public readonly Uri rdf = new("http://www.w3.org/1999/02/22-rdf-syntax-ns#");
+        public readonly Uri dcat = new("http://www.w3.org/ns/dcat#");
+        public readonly Uri dcterms = new("http://purl.org/dc/terms/");
         public override IEnumerable<IGraph> ConvertToLinkedData(IEnumerable<ResourceType> entries)
         {
        
@@ -22,43 +21,29 @@ namespace SQL2Linked.Implementations
                 var graph = RdfStoreConnector.GetGraph(resourceTypeGraphName);
 
                 // check if a triple with a dcat:DataService already exists in the resourcetype graph
-                var getTriplesDcatDataService = graph.GetTriplesWithObject(DcatDataService);
+                var getTriplesDcatDataService = graph.GetTriplesWithObject(new Uri(dcat + "DataService"));
 
                 if (!getTriplesDcatDataService.Any())
                 {
-                    graph.Assert(
-                        new Triple(
-                            graph.CreateUriNode(new Uri(resourceTypeGraphName)),
-                            graph.CreateUriNode(RdfType),
-                            graph.CreateUriNode(DcatDataService)
-                        )
-                    );
-
-                    Console.WriteLine($"For resource type '{entry.DisplayName}' will migrate triple '{graph.BaseUri}' a dcat:DataService. ");
+                    AssertToGraphUriNode(graph, resourceTypeGraphName, rdf + "type", dcat + "DataService");
+                    Console.WriteLine($"For resource type '{entry.DisplayName}' will migrate triple '{graph.BaseUri} {rdf}type {dcat}DataService'. ");
                 }
                 else
                 {
-                    Console.WriteLine($"For resource type '{entry.DisplayName}' will NOT migrate triple '{graph.BaseUri}' a dcat:DataService. ");
+                    Console.WriteLine($"For resource type '{entry.DisplayName}' will NOT migrate triple '{graph.BaseUri} {rdf}type {dcat}DataService'. ");
                 }
 
                 // check if a triple with dcterms:title '{entry.DisplayName}' already exists in the role graph
-                var getTriplesDctermsTitle = graph.GetTriplesWithPredicate(dctermsTitle);
+                var getTriplesDctermsTitle = graph.GetTriplesWithPredicate(new Uri(dcterms + "Title"));
 
                 if (!getTriplesDctermsTitle.Any())
                 {
-                    graph.Assert(
-                        new Triple(
-                            graph.CreateUriNode(new Uri(resourceTypeGraphName)),
-                            graph.CreateUriNode(dctermsTitle),
-                            graph.CreateLiteralNode(entry.DisplayName)
-                        )
-                    );
-
-                    Console.WriteLine($"For resource type '{entry.DisplayName}' will migrate triple '{graph.BaseUri}' dcterms:title '{entry.DisplayName}'. ");
+                    AssertToGraphLiteralNode(graph, resourceTypeGraphName, dcterms + "title", entry.DisplayName);
+                    Console.WriteLine($"For resource type '{entry.DisplayName}' will migrate triple '{graph.BaseUri} {dcterms}title {entry.DisplayName}'. ");
                 }
                 else
                 {
-                    Console.WriteLine($"For resource type '{entry.DisplayName}' will NOT migrate triple '{graph.BaseUri}' dcterms:title '{entry.DisplayName}'. ");
+                    Console.WriteLine($"For resource type '{entry.DisplayName}' will NOT migrate triple '{graph.BaseUri} {dcterms}title {entry.DisplayName}'. ");
                 }
                 if (!getTriplesDcatDataService.Any() || !getTriplesDctermsTitle.Any())
                 {

src/SQL2Linked/Implementations/RoleStructuralData.cs

@@ -7,9 +7,10 @@ namespace SQL2Linked.Implementations
     public class RoleStructuralData : StructuralData<Role, RoleModel>
     {
         public readonly string RoleUrlPrefix = "https://purl.org/coscine/roles";
-        public readonly Uri RdfType = new("http://www.w3.org/1999/02/22-rdf-syntax-ns#type");
-        public readonly Uri orgRole = new("http://www.w3.org/ns/org#Role");
-        public readonly Uri dctermsTitle = new("http://purl.org/dc/terms/title");
+        public readonly Uri cosc = new("https://purl.org/coscine/");
+        public readonly Uri rdf = new("http://www.w3.org/1999/02/22-rdf-syntax-ns#");
+        public readonly Uri org = new("http://www.w3.org/ns/org#");
+        public readonly Uri dcterms = new("http://purl.org/dc/terms/");
 
         public override IEnumerable<IGraph> ConvertToLinkedData(IEnumerable<Role> entries)
         {
@@ -21,43 +22,29 @@ namespace SQL2Linked.Implementations
                 var graph = RdfStoreConnector.GetGraph(roleGraphName);
 
                 // check if a triple with a org:role already exists in the role graph
-                var getTriplesOrgRole = graph.GetTriplesWithObject(orgRole);
+                var getTriplesOrgRole = graph.GetTriplesWithObject(new Uri(org + "Role"));
 
                 if (!getTriplesOrgRole.Any())
                 {
-                    graph.Assert(
-                        new Triple(
-                            graph.CreateUriNode(new Uri(roleGraphName)),
-                            graph.CreateUriNode(RdfType),
-                            graph.CreateUriNode(orgRole)
-                        )
-                    );
-
-                    Console.WriteLine($"For role '{entry.DisplayName}' will migrate triple '{graph.BaseUri}' a org:Role. ");
+                    AssertToGraphUriNode(graph, roleGraphName, rdf + "type", org + "Role");
+                    Console.WriteLine($"For role '{entry.DisplayName}' will migrate triple '{graph.BaseUri} {rdf}type {org}Role'. ");
                 }
                 else
                 {
-                    Console.WriteLine($"For role '{entry.DisplayName}' will NOT migrate triple '{graph.BaseUri}' a org:Role. ");
+                    Console.WriteLine($"For role '{entry.DisplayName}' will NOT migrate triple '{graph.BaseUri} {rdf}type {org}Role'. ");
                 }
 
                 // check if a triple with dcterms:title '{entry.DisplayName}' already exists in the role graph
-                var getTriplesDctermsTitle = graph.GetTriplesWithPredicate(dctermsTitle);
+                var getTriplesDctermsTitle = graph.GetTriplesWithPredicate(new Uri(dcterms + "title"));
 
                 if (!getTriplesDctermsTitle.Any())
                 {
-                    graph.Assert(
-                        new Triple(
-                            graph.CreateUriNode(new Uri(roleGraphName)),
-                            graph.CreateUriNode(dctermsTitle),
-                            graph.CreateLiteralNode(entry.DisplayName)
-                        )
-                    );
-
-                    Console.WriteLine($"For role '{entry.DisplayName}' will migrate triple '{graph.BaseUri}' dcterms:title '{entry.DisplayName}'. ");
+                    AssertToGraphLiteralNode(graph, roleGraphName, dcterms + "title", entry.DisplayName);
+                    Console.WriteLine($"For role '{entry.DisplayName}' will migrate triple '{graph.BaseUri} {dcterms}title {entry.DisplayName}'. ");
                 }
                 else
                 {
-                    Console.WriteLine($"For role '{entry.DisplayName}' will NOT migrate triple '{graph.BaseUri}' dcterms:title '{entry.DisplayName}'. ");
+                    Console.WriteLine($"For role '{entry.DisplayName}' will NOT migrate triple '{graph.BaseUri} {dcterms}title {entry.DisplayName}'. ");
                 }
                 if (!getTriplesOrgRole.Any() || !getTriplesDctermsTitle.Any())
                 {

src/SQL2Linked/Implementations/UserStructuralData.cs

@@ -8,8 +8,8 @@ namespace SQL2Linked.Implementations
     public class UserStructuralData : StructuralData<User, UserModel>
     {
         public readonly string UserUrlPrefix = "https://purl.org/coscine/users";
-        public readonly Uri RdfType = new("http://www.w3.org/1999/02/22-rdf-syntax-ns#type");
-        public readonly Uri FoafPerson = new("http://xmlns.com/foaf/0.1/Person");
+        public readonly Uri rdf = new("http://www.w3.org/1999/02/22-rdf-syntax-ns#");
+        public readonly Uri foaf = new("http://xmlns.com/foaf/0.1/");
 
         public override IEnumerable<IGraph> ConvertToLinkedData(IEnumerable<User> entries)
         {
@@ -21,17 +21,16 @@ namespace SQL2Linked.Implementations
                 var graph = RdfStoreConnector.GetGraph(userGraphName);
 
                 // check if a triple with a foaf:Person already exists in the user graph
-                var getTriples = graph.GetTriplesWithObject(FoafPerson);
+                var getTriples = graph.GetTriplesWithObject(new Uri(foaf + "Person"));
+                // check if the current display name is already applied in the user graph
+                var getTriplesName = graph.GetTriplesWithPredicate(new Uri(foaf + "name"));
 
-                if (!getTriples.Any())
+                if (!getTriples.Any() || !getTriplesName.Any((triple) => triple.Object.ToString() == entry.DisplayName))
                 {
-                    graph.Assert(
-                        new Triple(
-                            graph.CreateUriNode(new Uri(userGraphName)),
-                            graph.CreateUriNode(RdfType),
-                            graph.CreateUriNode(FoafPerson)
-                        )
-                    );
+                    AssertToGraphUriNode(graph, userGraphName, rdf + "type", foaf + "Person");
+
+                    graph.Retract(getTriplesName);
+                    AssertToGraphLiteralNode(graph, userGraphName, foaf + "name", entry.DisplayName);
 
                     graphs.Add(graph);
 

src/SQL2Linked/StructuralData.cs

@@ -2,6 +2,7 @@
 using Coscine.Database.Models;
 using Coscine.Metadata;
 using VDS.RDF;
+using VDS.RDF.Query;
 
 namespace SQL2Linked
 {
@@ -10,12 +11,16 @@ namespace SQL2Linked
         public T Model { get; init; }
         public ConsulConfiguration Configuration { get; init; }
         public RdfStoreConnector RdfStoreConnector { get; init; }
+        public static string Prefix { get; set; }
+        public readonly SparqlRemoteEndpoint QueryEndpoint;
 
         public StructuralData()
         {
             Configuration = new ConsulConfiguration();
             RdfStoreConnector = new RdfStoreConnector(Configuration.GetStringAndWait("coscine/local/virtuoso/additional/url"));
             Model = new T();
+            Prefix = Configuration.GetStringAndWait("coscine/global/epic/prefix");
+            QueryEndpoint = new SparqlRemoteEndpoint(new Uri(Configuration.GetStringAndWait("coscine/local/virtuoso/additional/url")));
         }
 
         public abstract IEnumerable<IGraph> ConvertToLinkedData(IEnumerable<S> entries);
@@ -51,5 +56,36 @@ namespace SQL2Linked
                 Console.WriteLine();
             }
         }
+        public void AssertToGraphUriNode(IGraph graph, string graphSubject, string graphPredicate, string graphObject)
+        {
+            graph.Assert(
+                new Triple(
+                    graph.CreateUriNode(new Uri(graphSubject)),
+                    graph.CreateUriNode(new Uri(graphPredicate)),
+                    graph.CreateUriNode(new Uri(graphObject))
+                )
+            );
+        }
+        public void AssertToGraphLiteralNode(IGraph graph, string graphSubject, string graphPredicate, string graphObject, Uri? objectType = null)
+        {
+            graph.Assert(
+                new Triple(
+                    graph.CreateUriNode(new Uri(graphSubject)),
+                    graph.CreateUriNode(new Uri(graphPredicate)),
+                    graph.CreateLiteralNode(graphObject, objectType)
+                )
+            );
+        }
+
+        public void AssertToGraphBlankAndUriNode(IGraph graph, IBlankNode graphSubject, string graphPredicate, string graphObject)
+        {
+            graph.Assert(
+                new Triple(
+                    graphSubject,
+                    graph.CreateUriNode(new Uri(graphPredicate)),
+                    graph.CreateUriNode(new Uri(graphObject))
+                )
+            );
+        }
     }
 }