1 /*******************************************************************************
2 * Copyright (c) 2007, 2018 Association for Decentralized Information Management
4 * All rights reserved. This program and the accompanying materials
5 * are made available under the terms of the Eclipse Public License v1.0
6 * which accompanies this distribution, and is available at
7 * http://www.eclipse.org/legal/epl-v10.html
10 * VTT Technical Research Centre of Finland - initial API and implementation
11 *******************************************************************************/
12 package org.simantics.db.impl.graph;
16 import org.simantics.db.RelationInfo;
17 import org.simantics.db.Resource;
18 import org.simantics.db.Session;
19 import org.simantics.db.Statement;
20 import org.simantics.db.VirtualGraph;
21 import org.simantics.db.exception.DatabaseException;
22 import org.simantics.db.impl.query.CacheEntry;
23 import org.simantics.db.impl.query.IntSet;
24 import org.simantics.db.procedure.AsyncMultiProcedure;
25 import org.simantics.db.procedure.AsyncProcedure;
26 import org.simantics.db.procedure.AsyncSetListener;
27 import org.simantics.db.procedure.ListenerBase;
28 import org.simantics.db.procedure.MultiProcedure;
29 import org.simantics.db.procedure.StatementProcedure;
30 import org.simantics.db.procedure.SyncMultiProcedure;
31 import org.simantics.db.request.AsyncMultiRead;
32 import org.simantics.db.request.MultiRead;
34 public interface ReadGraphSupport {
38 void forPossibleObject(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncProcedure<Resource> procedure);
40 void forEachPredicate(ReadGraphImpl graph, Resource subject, AsyncMultiProcedure<Resource> procedure);
41 void forEachPredicate(ReadGraphImpl graph, Resource subject, MultiProcedure<Resource> procedure);
42 IntSet getPredicates(ReadGraphImpl graph, Resource subject) throws Throwable;
44 void forEachStatement(ReadGraphImpl graph, Resource subject, Resource predicate, MultiProcedure<Statement> procedure);
45 void forEachStatement(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncMultiProcedure<Statement> procedure);
46 void forEachStatement(ReadGraphImpl graph, Resource subject, Resource predicate, StatementProcedure procedure);
47 void forStatementSet(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncSetListener<Statement> procedure);
48 void forAssertedStatementSet(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncSetListener<Statement> procedure);
49 void forEachAssertedStatement(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncMultiProcedure<Statement> procedure);
50 void forEachObject(ReadGraphImpl graph, Resource subject, Resource predicate, MultiProcedure<Resource> procedure);
51 void forEachObject(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncMultiProcedure<Resource> procedure);
52 void forEachDirectPredicate(ReadGraphImpl graph, Resource subject, AsyncProcedure<Set<Resource>> procedure);
53 void forObjectSet(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncSetListener<Resource> procedure);
54 void forPredicateSet(ReadGraphImpl graph, Resource subject, AsyncSetListener<Resource> procedure);
55 void forPrincipalTypeSet(ReadGraphImpl graph, Resource subject, AsyncSetListener<Resource> procedure);
56 void forEachAssertedObject(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncMultiProcedure<Resource> procedure);
57 void forAssertedObjectSet(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncSetListener<Resource> procedure);
58 void forEachPrincipalType(ReadGraphImpl graph, Resource subject, AsyncMultiProcedure<Resource> procedure);
59 void forEachPrincipalType(ReadGraphImpl graph, Resource subject, MultiProcedure<Resource> procedure);
61 RelationInfo getRelationInfo(ReadGraphImpl graph, Resource subject) throws DatabaseException;
63 void forTypes(ReadGraphImpl graph, Resource subject, AsyncProcedure<Set<Resource>> procedure);
64 IntSet getTypes(ReadGraphImpl graph, Resource subject) throws Throwable;
65 void forSupertypes(ReadGraphImpl graph, Resource subject, AsyncProcedure<Set<Resource>> procedure);
66 void forDirectSuperrelations(ReadGraphImpl graph, Resource subject, AsyncMultiProcedure<Resource> procedure);
67 void forPossibleSuperrelation(ReadGraphImpl graph, Resource subject, AsyncProcedure<Resource> procedure);
68 void forSuperrelations(ReadGraphImpl graph, Resource subject, AsyncProcedure<Set<Resource>> procedure);
69 byte[] getValue(ReadGraphImpl graph, Resource subject) throws DatabaseException;
70 void forValue(ReadGraphImpl graph, Resource subject, AsyncProcedure<byte[]> procedure);
71 void forPossibleValue(ReadGraphImpl graph, Resource subject, AsyncProcedure<byte[]> procedure);
72 void forInverse(ReadGraphImpl graph, Resource relation, AsyncProcedure<Resource> procedure);
73 void forResource(ReadGraphImpl graph, String id, AsyncProcedure<Resource> procedure);
74 void forBuiltin(ReadGraphImpl graph, String id, AsyncProcedure<Resource> procedure);
76 void forHasStatement(ReadGraphImpl graph, Resource subject, AsyncProcedure<Boolean> procedure);
77 void forHasStatement(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncProcedure<Boolean> procedure);
78 void forHasStatement(ReadGraphImpl graph, Resource subject, Resource predicate, Resource object, AsyncProcedure<Boolean> procedure);
80 void forHasValue(ReadGraphImpl graph, Resource subject, AsyncProcedure<Boolean> procedure);
81 void forOrderedSet(ReadGraphImpl graph, Resource subject, AsyncMultiProcedure<Resource> procedure);
83 <T> void query(ReadGraphImpl graph, MultiRead<T> request, CacheEntry parent, SyncMultiProcedure<T> procedure, ListenerBase listener);
84 <T> void query(ReadGraphImpl graph, AsyncMultiRead<T> request, CacheEntry parent, AsyncMultiProcedure<T> procedure, ListenerBase listener);
86 VirtualGraph getProvider(Resource subject, Resource predicate, Resource object);
87 VirtualGraph getProvider(Resource subject, Resource predicate);
88 VirtualGraph getValueProvider(Resource subject);