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.request.AsyncMultiRead;
33 import org.simantics.db.request.AsyncRead;
34 import org.simantics.db.request.ExternalRead;
35 import org.simantics.db.request.MultiRead;
36 import org.simantics.db.request.Read;
38 public interface ReadGraphSupport {
42 void forPossibleObject(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncProcedure<Resource> procedure);
44 void forEachPredicate(ReadGraphImpl graph, Resource subject, AsyncMultiProcedure<Resource> procedure);
45 void forEachPredicate(ReadGraphImpl graph, Resource subject, MultiProcedure<Resource> procedure);
46 IntSet getPredicates(ReadGraphImpl graph, Resource subject) throws Throwable;
48 void forEachStatement(ReadGraphImpl graph, Resource subject, Resource predicate, MultiProcedure<Statement> procedure);
49 void forEachStatement(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncMultiProcedure<Statement> procedure);
50 void forEachStatement(ReadGraphImpl graph, Resource subject, Resource predicate, StatementProcedure procedure);
51 void forStatementSet(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncSetListener<Statement> procedure);
52 void forAssertedStatementSet(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncSetListener<Statement> procedure);
53 void forEachAssertedStatement(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncMultiProcedure<Statement> procedure);
54 void forEachObject(ReadGraphImpl graph, Resource subject, Resource predicate, MultiProcedure<Resource> procedure);
55 void forEachObject(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncMultiProcedure<Resource> procedure);
56 void forEachDirectPredicate(ReadGraphImpl graph, Resource subject, AsyncMultiProcedure<Resource> procedure);
57 void forEachDirectStatement(ReadGraphImpl graph, Resource subject, Procedure<DirectStatements> procedure);
58 void forEachDirectStatement(ReadGraphImpl graph, Resource subject, AsyncProcedure<DirectStatements> procedure, boolean ignoreVirtual);
59 void forObjectSet(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncSetListener<Resource> procedure);
60 void forPredicateSet(ReadGraphImpl graph, Resource subject, AsyncSetListener<Resource> procedure);
61 void forPrincipalTypeSet(ReadGraphImpl graph, Resource subject, AsyncSetListener<Resource> procedure);
62 void forEachAssertedObject(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncMultiProcedure<Resource> procedure);
63 void forAssertedObjectSet(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncSetListener<Resource> procedure);
64 void forEachPrincipalType(ReadGraphImpl graph, Resource subject, AsyncMultiProcedure<Resource> procedure);
65 void forEachPrincipalType(ReadGraphImpl graph, Resource subject, MultiProcedure<Resource> procedure);
67 void forRelationInfo(ReadGraphImpl graph, Resource subject, AsyncProcedure<RelationInfo> procedure);
68 void forTypes(ReadGraphImpl graph, Resource subject, AsyncProcedure<Set<Resource>> procedure);
69 IntSet getTypes(ReadGraphImpl graph, Resource subject) throws Throwable;
70 void forSupertypes(ReadGraphImpl graph, Resource subject, AsyncProcedure<Set<Resource>> procedure);
71 void forDirectSuperrelations(ReadGraphImpl graph, Resource subject, AsyncMultiProcedure<Resource> procedure);
72 void forPossibleSuperrelation(ReadGraphImpl graph, Resource subject, AsyncProcedure<Resource> procedure);
73 void forSuperrelations(ReadGraphImpl graph, Resource subject, AsyncProcedure<Set<Resource>> procedure);
74 byte[] getValue(ReadGraphImpl graph, Resource subject) throws DatabaseException;
75 void forValue(ReadGraphImpl graph, Resource subject, AsyncProcedure<byte[]> procedure);
76 void forPossibleValue(ReadGraphImpl graph, Resource subject, AsyncProcedure<byte[]> procedure);
77 void forInverse(ReadGraphImpl graph, Resource relation, AsyncProcedure<Resource> procedure);
78 void forResource(ReadGraphImpl graph, String id, AsyncProcedure<Resource> procedure);
79 void forBuiltin(ReadGraphImpl graph, String id, AsyncProcedure<Resource> procedure);
81 void forHasStatement(ReadGraphImpl graph, Resource subject, AsyncProcedure<Boolean> procedure);
82 void forHasStatement(ReadGraphImpl graph, Resource subject, Resource predicate, AsyncProcedure<Boolean> procedure);
83 void forHasStatement(ReadGraphImpl graph, Resource subject, Resource predicate, Resource object, AsyncProcedure<Boolean> procedure);
85 void forHasValue(ReadGraphImpl graph, Resource subject, AsyncProcedure<Boolean> procedure);
86 void forOrderedSet(ReadGraphImpl graph, Resource subject, AsyncMultiProcedure<Resource> procedure);
88 //<T> T query(ReadGraphImpl graph, Read<T> request, CacheEntry parent, AsyncProcedure<T> procedure, ListenerBase listener) throws DatabaseException;
89 <T> void query(ReadGraphImpl graph, MultiRead<T> request, CacheEntry parent, AsyncMultiProcedure<T> procedure, ListenerBase listener);
90 // <T> void query(ReadGraphImpl graph, AsyncRead<T> request, CacheEntry parent, AsyncProcedure<T> procedure, ListenerBase listener) throws DatabaseException;
91 <T> void query(ReadGraphImpl graph, AsyncMultiRead<T> request, CacheEntry parent, AsyncMultiProcedure<T> procedure, ListenerBase listener);
92 //<T> void query(ReadGraphImpl graph, ExternalRead<T> request, CacheEntry parent, Procedure<T> procedure, ListenerBase listener);
94 // <T> T tryQuery(final ReadGraphImpl graph, final Read<T> request) throws DatabaseException;
95 // <T> void tryQuery(final ReadGraphImpl graph, final AsyncRead<T> request, final AsyncProcedure<T> procedure);
97 VirtualGraph getProvider(Resource subject, Resource predicate, Resource object);
98 VirtualGraph getProvider(Resource subject, Resource predicate);
99 VirtualGraph getValueProvider(Resource subject);