1 package fi.vtt.simantics.procore.internal;
\r
3 import java.io.InputStream;
\r
5 import org.simantics.db.ReadGraph;
\r
6 import org.simantics.db.Resource;
\r
7 import org.simantics.db.VirtualGraph;
\r
8 import org.simantics.db.WriteOnlyGraph;
\r
9 import org.simantics.db.exception.DatabaseException;
\r
10 import org.simantics.db.impl.graph.WriteGraphImpl;
\r
11 import org.simantics.db.service.ByteReader;
\r
12 import org.simantics.db.service.TransferableGraphSupport;
\r
14 public class TransferableGraphSupportImpl implements TransferableGraphSupport {
\r
16 final private SessionImplSocket session;
\r
18 TransferableGraphSupportImpl(SessionImplSocket session) {
\r
19 this.session = session;
\r
23 public InputStream getValueStream(ReadGraph graph, Resource resource) {
\r
24 return session.getValueStream(null, resource);
\r
28 public byte[] getValue(ReadGraph graph, Resource resource) {
\r
29 return session.getValue(null, resource);
\r
33 public void setValue(WriteOnlyGraph graph, Resource resource, VirtualGraph provider, byte[] raw) throws DatabaseException {
\r
35 WriteGraphImpl impl = (WriteGraphImpl)graph;
\r
36 VirtualGraph vg = session.getProvider(provider);
\r
37 impl.writeSupport.claimValue(vg, resource, raw);
\r
42 public void setValue(WriteOnlyGraph graph, Resource resource, VirtualGraph provider, ByteReader reader, int amount)
\r
43 throws DatabaseException {
\r
45 WriteGraphImpl impl = (WriteGraphImpl)graph;
\r
46 VirtualGraph vg = session.getProvider(provider);
\r
47 impl.writeSupport.claimValue(vg, resource, reader, amount);
\r