--- /dev/null
+package org.simantics.db.common.utils;\r
+\r
+import java.util.ArrayList;\r
+import java.util.Collection;\r
+import java.util.Collections;\r
+import java.util.HashSet;\r
+import java.util.Iterator;\r
+import java.util.List;\r
+import java.util.Set;\r
+\r
+import org.simantics.databoard.Bindings;\r
+import org.simantics.db.ReadGraph;\r
+import org.simantics.db.Resource;\r
+import org.simantics.db.Statement;\r
+import org.simantics.db.WriteGraph;\r
+import org.simantics.db.common.request.IsParent;\r
+import org.simantics.db.common.request.ObjectsWithType;\r
+import org.simantics.db.common.request.PossibleObjectWithType;\r
+import org.simantics.db.common.request.PossibleOwner;\r
+import org.simantics.db.exception.DatabaseException;\r
+import org.simantics.db.service.ClusteringSupport;\r
+import org.simantics.layer0.Layer0;\r
+import org.simantics.utils.datastructures.collections.CollectionUtils;\r
+\r
+public class CommonDBUtils {\r
+\r
+ public static boolean isParent(ReadGraph graph, Resource possibleParent, Resource possibleChild) throws DatabaseException {\r
+ return graph.sync(new IsParent(possibleParent, possibleChild));\r
+ }\r
+ \r
+ public static Resource parent(ReadGraph graph, Resource child) throws DatabaseException {\r
+ return graph.getSingleObject(child, Layer0.getInstance(graph).PartOf);\r
+ }\r
+ \r
+ public static String possibleRelatedString(ReadGraph graph, Resource subject, Resource relation) throws DatabaseException {\r
+ return graph.getRelatedValue(subject, relation, Bindings.STRING);\r
+ }\r
+\r
+ public static Integer possibleRelatedInteger(ReadGraph graph, Resource subject, Resource relation) throws DatabaseException {\r
+ return graph.getRelatedValue(subject, relation, Bindings.INTEGER);\r
+ }\r
+\r
+ public static Resource getPossibleOwner(ReadGraph graph, Resource resource) throws DatabaseException {\r
+ return graph.syncRequest(new PossibleOwner(resource));\r
+ }\r
+ \r
+ public static Resource commonAncestor(ReadGraph graph, Resource r1, Resource r2) throws DatabaseException {\r
+ Layer0 L0 = Layer0.getInstance(graph);\r
+ if(r1.equals(r2)) return r1;\r
+ HashSet<Resource> visited = new HashSet<Resource>();\r
+ visited.add(r1);\r
+ visited.add(r2);\r
+ while(true) {\r
+ if(r1 != null) {\r
+ r1 = graph.getPossibleObject(r1, L0.IsOwnedBy);\r
+ if(r1 != null)\r
+ if(!visited.add(r1)) return r1;\r
+ }\r
+ else if(r2 == null) return null;\r
+ if(r2 != null) {\r
+ r2 = graph.getPossibleObject(r2, L0.IsOwnedBy);\r
+ if(r2 != null)\r
+ if(!visited.add(r2)) return r2;\r
+ }\r
+ }\r
+ }\r
+ \r
+ public static Resource getNearestOwner(ReadGraph graph, Collection<Resource> resources) throws DatabaseException {\r
+\r
+ Layer0 L0 = Layer0.getInstance(graph);\r
+ \r
+ \r
+ Set<Resource> direct = new HashSet<Resource>();\r
+ Set<Resource> owners = new HashSet<Resource>();\r
+ \r
+ for(Resource r : resources) {\r
+ \r
+ Collection<Resource> objects = graph.getObjects(r, L0.IsOwnedBy);\r
+ // FIXME: \r
+ // TODO: getObjects returns duplicate entries (https://www.simantics.org/redmine/issues/4885) and therefore direct is Set<Resource>. Fix getObjects to not return duplicate entries\r
+ if (objects.size() > 1) objects = new HashSet<Resource>(objects);\r
+ \r
+ if (objects.size() == 1)\r
+ direct.addAll(objects);\r
+ else if (objects.isEmpty()) {\r
+ for(Statement stm : graph.getStatements(r, L0.IsWeaklyRelatedTo)) {\r
+ Resource inverse = graph.getPossibleInverse(stm.getPredicate());\r
+ if(inverse != null) {\r
+ if(graph.isSubrelationOf(inverse, L0.IsRelatedTo)) {\r
+ // Filter away tags\r
+ if(!r.equals(stm.getObject()))\r
+ owners.add(stm.getObject());\r
+ }\r
+ }\r
+ }\r
+ } else {\r
+ System.err.println("Multiple owners for " + graph.getPossibleURI(r) + " id : " + r);\r
+ for (Resource r2 : objects)\r
+ System.err.println("owner : " + graph.getPossibleURI(r2) + " id " + r2);\r
+ return null;\r
+ }\r
+ }\r
+ \r
+ if(!direct.isEmpty()) {\r
+ Iterator<Resource> iter = direct.iterator();\r
+ Resource common = iter.next();\r
+ while (iter.hasNext()) {\r
+ Resource other = iter.next();\r
+ common = commonAncestor(graph, common, other);\r
+ if (common == null) break;\r
+ }\r
+ if(common != null)\r
+ owners.add(common);\r
+ }\r
+ \r
+ if(!Collections.disjoint(owners, resources)) {\r
+ System.err.println("Overlapping owners:");\r
+ for(Resource r : resources)\r
+ System.err.println("-resource " + NameUtils.getSafeName(graph, r, true));\r
+ for(Resource r : owners)\r
+ System.err.println("-owner " + NameUtils.getSafeName(graph, r, true));\r
+ return null;\r
+ }\r
+ \r
+ if(owners.size() == 1) return owners.iterator().next();\r
+ if(owners.size() == 0) return null;\r
+ \r
+ return getNearestOwner(graph, owners);\r
+ \r
+ }\r
+ \r
+ public static Resource getClusterSetForNewResource(ReadGraph graph, Resource ... resources) throws DatabaseException {\r
+\r
+ if(resources.length == 1) return getClusterSetForNewResource(graph, resources[0]);\r
+ \r
+ Resource owner = getNearestOwner(graph, CollectionUtils.toList(resources));\r
+ if(owner == null) return null;\r
+ return getClusterSetForNewResource(graph, owner, new HashSet<Resource>());\r
+ \r
+ }\r
+ \r
+ public static Resource getClusterSetForNewResource(ReadGraph graph, Collection<Resource> resources) throws DatabaseException {\r
+\r
+ if(resources.size() == 1) return getClusterSetForNewResource(graph, resources.iterator().next());\r
+\r
+ Resource owner = getNearestOwner(graph, resources);\r
+ return getClusterSetForNewResource(graph, owner, new HashSet<Resource>());\r
+ \r
+ }\r
+ \r
+ public static Resource getClusterSetForNewResource(ReadGraph graph, Resource resource, Set<Resource> visited) throws DatabaseException {\r
+ \r
+ ClusteringSupport cs = graph.getService(ClusteringSupport.class);\r
+ if(cs.isClusterSet(resource)) return resource;\r
+ \r
+ Resource owner = getPossibleOwner(graph, resource);\r
+ \r
+ if(owner == null || owner == resource) return null;\r
+ if(!visited.add(owner)) return null;\r
+\r
+ return getClusterSetForNewResource(graph, owner, visited);\r
+ \r
+ }\r
+\r
+ public static Resource getClusterSetForNewResource(ReadGraph graph, Resource r) throws DatabaseException {\r
+ return getClusterSetForNewResource(graph, r, new HashSet<Resource>());\r
+ }\r
+\r
+\r
+ public static void selectClusterSet(WriteGraph graph, Collection<Resource> resources) throws DatabaseException {\r
+ Resource clusterSet = getClusterSetForNewResource(graph, resources);\r
+ if(clusterSet == null) clusterSet = graph.getRootLibrary();\r
+ graph.setClusterSet4NewResource(clusterSet);\r
+ }\r
+\r
+ public static void selectClusterSet(WriteGraph graph, Resource ... resources) throws DatabaseException {\r
+ Resource clusterSet = getClusterSetForNewResource(graph, resources);\r
+ if(clusterSet == null) clusterSet = graph.getRootLibrary();\r
+ graph.setClusterSet4NewResource(clusterSet);\r
+ }\r
+ \r
+ public static void selectClusterSet(WriteGraph graph, Resource resource) throws DatabaseException {\r
+ Resource clusterSet = getClusterSetForNewResource(graph, resource);\r
+ if(clusterSet == null) clusterSet = graph.getRootLibrary();\r
+ graph.setClusterSet4NewResource(clusterSet);\r
+ }\r
+ \r
+ public static List<Resource> objectsWithType(ReadGraph graph, Resource subject, Resource relation, Resource type) throws DatabaseException {\r
+ return new ArrayList<Resource>(graph.syncRequest(new ObjectsWithType(subject, relation, type)));\r
+ }\r
+\r
+ public static Resource possibleObjectWithType(ReadGraph graph, Resource subject, Resource relation, Resource type) throws DatabaseException {\r
+ return graph.syncRequest(new PossibleObjectWithType(subject, relation, type));\r
+ }\r
+\r
+}\r
Code Review / simantics / platform.git / blobdiff