1 /*******************************************************************************
\r
2 * Copyright (c) 2007, 2010 Association for Decentralized Information Management
\r
3 * in Industry THTH ry.
\r
4 * All rights reserved. This program and the accompanying materials
\r
5 * are made available under the terms of the Eclipse Public License v1.0
\r
6 * which accompanies this distribution, and is available at
\r
7 * http://www.eclipse.org/legal/epl-v10.html
\r
10 * VTT Technical Research Centre of Finland - initial API and implementation
\r
11 *******************************************************************************/
\r
12 package org.simantics.modeling.ui.modelBrowser2.contributions;
\r
14 import java.util.Collection;
\r
15 import java.util.Map;
\r
16 import java.util.function.Consumer;
\r
18 import org.simantics.Simantics;
\r
19 import org.simantics.browsing.ui.BuiltinKeys;
\r
20 import org.simantics.browsing.ui.NodeContext;
\r
21 import org.simantics.browsing.ui.Tester;
\r
22 import org.simantics.browsing.ui.graph.contributor.viewpoint.ContextInputCallbackViewpointContributor;
\r
23 import org.simantics.browsing.ui.graph.tester.GraphTesters;
\r
24 import org.simantics.databoard.Bindings;
\r
25 import org.simantics.db.ReadGraph;
\r
26 import org.simantics.db.RequestProcessor;
\r
27 import org.simantics.db.Resource;
\r
28 import org.simantics.db.Session;
\r
29 import org.simantics.db.common.primitiverequest.Adapter;
\r
30 import org.simantics.db.common.request.Queries;
\r
31 import org.simantics.db.exception.DatabaseException;
\r
32 import org.simantics.db.layer0.adapter.GenericRelationIndex;
\r
33 import org.simantics.db.request.Read;
\r
34 import org.simantics.layer0.Layer0;
\r
35 import org.simantics.modeling.ui.modelBrowser2.model.RelationViewNode;
\r
36 import org.simantics.operation.Layer0X;
\r
38 public class RelationView extends ContextInputCallbackViewpointContributor {
\r
40 public RelationView() {
\r
41 super(RelationViewNode.class);
\r
45 public Tester getNodeContextTester() {
\r
46 return GraphTesters.type(Layer0X.URIs.RelationView);
\r
50 public String getViewpointId() {
\r
55 protected void finalize() throws Throwable {
\r
56 //System.out.println("**** FINALIZING RelationView " + this);
\r
61 public void getContribution(ReadGraph graph, final NodeContext context, final Consumer<Collection<?>> callback) throws DatabaseException {
\r
63 final Session session = graph.getSession();
\r
65 RelationViewNode model = (RelationViewNode)context.getConstant(BuiltinKeys.INPUT);
\r
66 final Resource view = model.resource;
\r
68 final String filter = context.getConstant(BuiltinKeys.FILTER);
\r
69 Layer0 l0 = Layer0.getInstance(graph);
\r
70 Layer0X L0X = Layer0X.getInstance(graph);
\r
72 final Resource input = graph.getPossibleObject(view, l0.PartOf);
\r
73 final Resource relation = graph.getPossibleObject(view, L0X.AppliesRelation);
\r
74 final String bindingPattern = graph.getPossibleRelatedValue(view, L0X.HasBindingPattern, Bindings.STRING);
\r
76 final GenericRelationIndex index = graph.syncRequest(new org.simantics.db.common.primitiverequest.Adapter<GenericRelationIndex>(relation, GenericRelationIndex.class));
\r
78 // TODO: use DB ExternalRead instead of this listener hack which proliferates the index with listeners.
\r
80 index.addListener(session, input, new Runnable() {
\r
83 Simantics.async(new Runnable() {
\r
87 callback.accept(compute(session, filter, bindingPattern, view, relation, input));
\r
88 } catch (DatabaseException e) {
\r
89 e.printStackTrace();
\r
96 callback.accept(compute(graph, filter, bindingPattern, view, relation, input));
\r
100 Collection<?> compute(RequestProcessor processor, String filter, String bindingPattern, final Resource view, Resource relation, Resource input) throws DatabaseException {
\r
101 if (filter == null)
\r
104 GenericRelationIndex index = processor.syncRequest(new Adapter<GenericRelationIndex>(relation, GenericRelationIndex.class));
\r
105 final Collection<Map<String, Object>> results = index.query(processor, filter, bindingPattern, new Object[] { input }, 1000);
\r
107 return processor.syncRequest(new Read<Collection<?>>() {
\r
109 public Collection<?> perform(ReadGraph graph) throws DatabaseException {
\r
110 RelationViewContributor contrib = graph.syncRequest(Queries.adapt(view, RelationViewContributor.class));
\r
111 return contrib.getContribution(graph, results);
\r