package org.simantics.document.server.request; import java.util.ArrayList; import java.util.Collections; import java.util.Comparator; import java.util.HashSet; import java.util.List; import java.util.Set; import org.simantics.db.ReadGraph; import org.simantics.db.common.procedure.adapter.TransientCacheAsyncListener; import org.simantics.db.exception.DatabaseException; import org.simantics.db.layer0.request.VariableRead; import org.simantics.db.layer0.variable.Variable; import org.simantics.document.server.JSONObject; public class DocumentRequest extends VariableRead> { public static boolean PROFILE = false; public DocumentRequest(Variable var) { super(var); } @Override public List perform(ReadGraph graph) throws DatabaseException { long s = System.nanoTime(); Set nodes = graph.syncRequest(new NodesRequest(variable), TransientCacheAsyncListener.>instance()); HashSet rs = new HashSet(); // result if(nodes.isEmpty()) { return Collections.emptyList(); } /*TreeMap nodeMap = new TreeMap(); for (Variable node : nodes) { nodeMap.put(node.getURI(graph), node); } System.out.println("*************************************************************************"); for (Variable node : nodeMap.values()) { System.out.println(" " + node.getURI(graph)); }*/ for(Variable node : nodes) { rs.add(graph.syncRequest(new NodeRequest(node), TransientCacheAsyncListener.instance())); } ArrayList result = new ArrayList(rs); Collections.sort(result, new Comparator() { @Override public int compare(JSONObject o1, JSONObject o2) { return o1.id.compareTo(o2.id); } }); if(PROFILE) { long dura = System.nanoTime()-s; System.err.println("DocumentRequest " + System.identityHashCode(this) + " " + variable.getURI(graph) + " in " + 1e-6*dura + "ms."); } return result; } }