1 /*******************************************************************************
2 * Copyright (c) 2007, 2010 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.DirectStatements;
17 import org.simantics.db.RelationInfo;
18 import org.simantics.db.Resource;
19 import org.simantics.db.Session;
20 import org.simantics.db.Statement;
21 import org.simantics.db.VirtualGraph;
22 import org.simantics.db.exception.DatabaseException;
23 import org.simantics.db.impl.query.CacheEntry;
24 import org.simantics.db.impl.query.IntSet;
25 import org.simantics.db.procedure.AsyncMultiProcedure;
26 import org.simantics.db.procedure.AsyncProcedure;
27 import org.simantics.db.procedure.AsyncSetListener;
28 import org.simantics.db.procedure.ListenerBase;
29 import org.simantics.db.procedure.MultiProcedure;
30 import org.simantics.db.procedure.Procedure;
31 import org.simantics.db.procedure.StatementProcedure;
32 import org.simantics.db.procedure.SyncMultiProcedure;
33 import org.simantics.db.procedure.SyncProcedure;
34 import org.simantics.db.request.AsyncMultiRead;
35 import org.simantics.db.request.MultiRead;
37 public interface ReadGraphSupport {
41 void forPossibleObject(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncProcedure<Resource> procedure);
43 void forEachPredicate(ReadGraphImpl graph, Resource subject, AsyncMultiProcedure<Resource> procedure);
44 void forEachPredicate(ReadGraphImpl graph, Resource subject, MultiProcedure<Resource> procedure);
45 IntSet getPredicates(ReadGraphImpl graph, Resource subject) throws Throwable;
47 void forEachStatement(ReadGraphImpl graph, Resource subject, Resource predicate, MultiProcedure<Statement> procedure);
48 void forEachStatement(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncMultiProcedure<Statement> procedure);
49 void forEachStatement(ReadGraphImpl graph, Resource subject, Resource predicate, StatementProcedure procedure);
50 void forStatementSet(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncSetListener<Statement> procedure);
51 void forAssertedStatementSet(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncSetListener<Statement> procedure);
52 void forEachAssertedStatement(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncMultiProcedure<Statement> procedure);
53 void forEachObject(ReadGraphImpl graph, Resource subject, Resource predicate, MultiProcedure<Resource> procedure);
54 void forEachObject(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncMultiProcedure<Resource> procedure);
55 void forEachDirectPredicate(ReadGraphImpl graph, Resource subject, AsyncProcedure<Set<Resource>> procedure);
56 void forObjectSet(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncSetListener<Resource> procedure);
57 void forPredicateSet(ReadGraphImpl graph, Resource subject, AsyncSetListener<Resource> procedure);
58 void forPrincipalTypeSet(ReadGraphImpl graph, Resource subject, AsyncSetListener<Resource> procedure);
59 void forEachAssertedObject(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncMultiProcedure<Resource> procedure);
60 void forAssertedObjectSet(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncSetListener<Resource> procedure);
61 void forEachPrincipalType(ReadGraphImpl graph, Resource subject, AsyncMultiProcedure<Resource> procedure);
62 void forEachPrincipalType(ReadGraphImpl graph, Resource subject, MultiProcedure<Resource> procedure);
64 RelationInfo getRelationInfo(ReadGraphImpl graph, Resource subject) throws DatabaseException;
66 void forTypes(ReadGraphImpl graph, Resource subject, AsyncProcedure<Set<Resource>> procedure);
67 IntSet getTypes(ReadGraphImpl graph, Resource subject) throws Throwable;
68 void forSupertypes(ReadGraphImpl graph, Resource subject, AsyncProcedure<Set<Resource>> procedure);
69 void forDirectSuperrelations(ReadGraphImpl graph, Resource subject, AsyncMultiProcedure<Resource> procedure);
70 void forPossibleSuperrelation(ReadGraphImpl graph, Resource subject, AsyncProcedure<Resource> procedure);
71 void forSuperrelations(ReadGraphImpl graph, Resource subject, AsyncProcedure<Set<Resource>> procedure);
72 byte[] getValue(ReadGraphImpl graph, Resource subject) throws DatabaseException;
73 void forValue(ReadGraphImpl graph, Resource subject, AsyncProcedure<byte[]> procedure);
74 void forPossibleValue(ReadGraphImpl graph, Resource subject, AsyncProcedure<byte[]> procedure);
75 void forInverse(ReadGraphImpl graph, Resource relation, AsyncProcedure<Resource> procedure);
76 void forResource(ReadGraphImpl graph, String id, AsyncProcedure<Resource> procedure);
77 void forBuiltin(ReadGraphImpl graph, String id, AsyncProcedure<Resource> procedure);
79 void forHasStatement(ReadGraphImpl graph, Resource subject, AsyncProcedure<Boolean> procedure);
80 void forHasStatement(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncProcedure<Boolean> procedure);
81 void forHasStatement(ReadGraphImpl graph, Resource subject, Resource predicate, Resource object, AsyncProcedure<Boolean> procedure);
83 void forHasValue(ReadGraphImpl graph, Resource subject, AsyncProcedure<Boolean> procedure);
84 void forOrderedSet(ReadGraphImpl graph, Resource subject, AsyncMultiProcedure<Resource> procedure);
86 //<T> T query(ReadGraphImpl graph, Read<T> request, CacheEntry parent, AsyncProcedure<T> procedure, ListenerBase listener) throws DatabaseException;
87 <T> void query(ReadGraphImpl graph, MultiRead<T> request, CacheEntry parent, SyncMultiProcedure<T> procedure, ListenerBase listener);
88 // <T> void query(ReadGraphImpl graph, AsyncRead<T> request, CacheEntry parent, AsyncProcedure<T> procedure, ListenerBase listener) throws DatabaseException;
89 <T> void query(ReadGraphImpl graph, AsyncMultiRead<T> request, CacheEntry parent, AsyncMultiProcedure<T> procedure, ListenerBase listener);
90 //<T> void query(ReadGraphImpl graph, ExternalRead<T> request, CacheEntry parent, Procedure<T> procedure, ListenerBase listener);
92 // <T> T tryQuery(final ReadGraphImpl graph, final Read<T> request) throws DatabaseException;
93 // <T> void tryQuery(final ReadGraphImpl graph, final AsyncRead<T> request, final AsyncProcedure<T> procedure);
95 VirtualGraph getProvider(Resource subject, Resource predicate, Resource object);
96 VirtualGraph getProvider(Resource subject, Resource predicate);
97 VirtualGraph getValueProvider(Resource subject);