-package org.simantics.db.layer0.util;\r
-\r
-import java.io.IOException;\r
-import java.util.TreeMap;\r
-\r
-import org.simantics.databoard.Bindings;\r
-import org.simantics.databoard.binding.Binding;\r
-import org.simantics.databoard.binding.mutable.Variant;\r
-import org.simantics.databoard.container.DataContainer;\r
-import org.simantics.databoard.serialization.Serializer;\r
-import org.simantics.databoard.type.Datatype;\r
-import org.simantics.databoard.util.binary.ByteBufferReadable;\r
-import org.simantics.db.ReadGraph;\r
-import org.simantics.graph.db.TransferableGraphSource;\r
-import org.simantics.graph.representation.Identity;\r
-import org.simantics.graph.representation.TransferableGraph1;\r
-import org.simantics.graph.representation.Value;\r
-\r
-public class TGTransferableGraphSource implements TransferableGraphSource {\r
-\r
- final private TransferableGraph1 tg;\r
- \r
- public TGTransferableGraphSource(TransferableGraph1 tg) {\r
- this.tg = tg;\r
- }\r
-\r
- @Override\r
- public DataContainer getHeader() throws Exception {\r
- return null;\r
- }\r
- \r
- @Override\r
- public int getResourceCount() {\r
- return tg.resourceCount;\r
- }\r
- \r
- @Override\r
- public int getIdentityCount() {\r
- return tg.identities.length;\r
- }\r
- \r
- @Override\r
- public int getStatementCount() {\r
- return tg.statements.length;\r
- }\r
- \r
- @Override\r
- public int getValueCount() {\r
- return tg.values.length;\r
- }\r
-\r
- @Override\r
- public void forStatements(ReadGraph graph, TransferableGraphSourceProcedure<int[]> procedure) throws Exception {\r
- int[] value = new int[4];\r
- for(int i=0;i<tg.statements.length;i+=4) {\r
- value[0] = tg.statements[i];\r
- value[1] = tg.statements[i+1];\r
- value[2] = tg.statements[i+2];\r
- value[3] = tg.statements[i+3];\r
- procedure.execute(value);\r
- }\r
- }\r
-\r
- @Override\r
- public void forIdentities(ReadGraph graph, TransferableGraphSourceProcedure<Identity> procedure) throws Exception {\r
- for(int i=0;i<tg.identities.length;i++) {\r
- procedure.execute(tg.identities[i]);\r
- }\r
- }\r
-\r
- @Override\r
- public void forValues(ReadGraph graph, TransferableGraphSourceProcedure<Value> procedure) throws Exception {\r
- for(int i=0;i<tg.values.length;i++) {\r
- procedure.execute(tg.values[i]);\r
- }\r
- }\r
-\r
- @Override\r
- public void forValues2(ReadGraph graph, TransferableGraphSourceValueProcedure procedure) throws Exception {\r
- for(int i=0;i<tg.values.length;i++) {\r
- Value value = tg.values[i];\r
- Binding binding = value.value.getBinding();\r
- Datatype dt = binding.type();\r
- Serializer s = Bindings.getSerializer(binding);\r
- procedure.execute(value.resource, dt, new ByteBufferReadable(s.serialize(value.value.getValue(binding))));\r
- }\r
- }\r
- \r
- @Override\r
- public TreeMap<String, Variant> getExtensions() {\r
- return tg.extensions;\r
- }\r
- \r
- @Override\r
- public void reset() {\r
- }\r
-\r
- @Override\r
- public void close() {\r
- }\r
-\r
-}\r
+package org.simantics.db.layer0.util;
+
+import java.io.IOException;
+import java.util.TreeMap;
+
+import org.simantics.databoard.Bindings;
+import org.simantics.databoard.binding.Binding;
+import org.simantics.databoard.binding.mutable.Variant;
+import org.simantics.databoard.container.DataContainer;
+import org.simantics.databoard.serialization.Serializer;
+import org.simantics.databoard.type.Datatype;
+import org.simantics.databoard.util.binary.ByteBufferReadable;
+import org.simantics.db.ReadGraph;
+import org.simantics.graph.db.TransferableGraphSource;
+import org.simantics.graph.representation.Identity;
+import org.simantics.graph.representation.TransferableGraph1;
+import org.simantics.graph.representation.Value;
+
+public class TGTransferableGraphSource implements TransferableGraphSource {
+
+ final private TransferableGraph1 tg;
+
+ public TGTransferableGraphSource(TransferableGraph1 tg) {
+ this.tg = tg;
+ }
+
+ @Override
+ public DataContainer getHeader() throws Exception {
+ return null;
+ }
+
+ @Override
+ public int getResourceCount() {
+ return tg.resourceCount;
+ }
+
+ @Override
+ public int getIdentityCount() {
+ return tg.identities.length;
+ }
+
+ @Override
+ public int getStatementCount() {
+ return tg.statements.length;
+ }
+
+ @Override
+ public int getValueCount() {
+ return tg.values.length;
+ }
+
+ @Override
+ public void forStatements(ReadGraph graph, TransferableGraphSourceProcedure<int[]> procedure) throws Exception {
+ int[] value = new int[4];
+ for(int i=0;i<tg.statements.length;i+=4) {
+ value[0] = tg.statements[i];
+ value[1] = tg.statements[i+1];
+ value[2] = tg.statements[i+2];
+ value[3] = tg.statements[i+3];
+ procedure.execute(value);
+ }
+ }
+
+ @Override
+ public void forIdentities(ReadGraph graph, TransferableGraphSourceProcedure<Identity> procedure) throws Exception {
+ for(int i=0;i<tg.identities.length;i++) {
+ procedure.execute(tg.identities[i]);
+ }
+ }
+
+ @Override
+ public void forValues(ReadGraph graph, TransferableGraphSourceProcedure<Value> procedure) throws Exception {
+ for(int i=0;i<tg.values.length;i++) {
+ procedure.execute(tg.values[i]);
+ }
+ }
+
+ @Override
+ public void forValues2(ReadGraph graph, TransferableGraphSourceValueProcedure procedure) throws Exception {
+ for(int i=0;i<tg.values.length;i++) {
+ Value value = tg.values[i];
+ Binding binding = value.value.getBinding();
+ Datatype dt = binding.type();
+ Serializer s = Bindings.getSerializer(binding);
+ procedure.execute(value.resource, dt, new ByteBufferReadable(s.serialize(value.value.getValue(binding))));
+ }
+ }
+
+ @Override
+ public TreeMap<String, Variant> getExtensions() {
+ return tg.extensions;
+ }
+
+ @Override
+ public void reset() {
+ }
+
+ @Override
+ public void close() {
+ }
+
+}
Code Review / simantics / platform.git / blobdiff