--- /dev/null
+/*******************************************************************************\r
+ * Copyright (c) 2007, 2010 Association for Decentralized Information Management\r
+ * in Industry THTH ry.\r
+ * All rights reserved. This program and the accompanying materials\r
+ * are made available under the terms of the Eclipse Public License v1.0\r
+ * which accompanies this distribution, and is available at\r
+ * http://www.eclipse.org/legal/epl-v10.html\r
+ *\r
+ * Contributors:\r
+ * VTT Technical Research Centre of Finland - initial API and implementation\r
+ *******************************************************************************/\r
+package org.simantics.db.layer0.util;\r
+\r
+import java.util.Collection;\r
+\r
+import org.simantics.databoard.Accessors;\r
+import org.simantics.databoard.accessor.Accessor;\r
+import org.simantics.databoard.accessor.error.AccessorConstructionException;\r
+import org.simantics.databoard.accessor.error.AccessorException;\r
+import org.simantics.databoard.accessor.event.Event;\r
+import org.simantics.databoard.accessor.interestset.InterestSet;\r
+import org.simantics.databoard.binding.Binding;\r
+import org.simantics.db.ReadGraph;\r
+import org.simantics.db.RequestProcessor;\r
+import org.simantics.db.Resource;\r
+import org.simantics.db.WriteGraph;\r
+import org.simantics.db.common.request.WriteRequest;\r
+import org.simantics.db.exception.DatabaseException;\r
+import org.simantics.db.procedure.Listener;\r
+import org.simantics.db.request.Read;\r
+\r
+public class GraphAccessorUtils {\r
+\r
+ static private class ValueReadRequest implements Read<Object> {\r
+ Resource resource;\r
+ Binding binding;\r
+ \r
+ public ValueReadRequest(Resource resource, Binding binding) {\r
+ this.resource = resource;\r
+ this.binding = binding;\r
+ }\r
+\r
+ @Override\r
+ public Object perform(ReadGraph graph) throws DatabaseException {\r
+ return graph.getValue(resource, binding);\r
+ }\r
+ }\r
+ \r
+\r
+ static private class ValueReadRequest2 implements Read<Object> {\r
+ Resource resource;\r
+ Resource relation;\r
+ Object defaultValue;\r
+ Binding binding;\r
+ \r
+ public ValueReadRequest2(Resource resource, Resource relation, Object defaultValue, Binding binding) {\r
+ this.resource = resource;\r
+ this.relation = relation;\r
+ this.defaultValue = defaultValue;\r
+ this.binding = binding;\r
+ }\r
+\r
+ @Override\r
+ public Object perform(ReadGraph graph) throws DatabaseException {\r
+ Object value = graph.getPossibleRelatedValue(resource, relation, binding);\r
+ if(value != null)\r
+ return value;\r
+ else\r
+ return defaultValue;\r
+ }\r
+ }\r
+ \r
+ static private class ValueReadListener implements Listener<Object> {\r
+\r
+ Binding binding;\r
+ Accessor accessor; \r
+ \r
+ public ValueReadListener(Binding binding) {\r
+ this.binding = binding;\r
+ }\r
+\r
+ @Override\r
+ public void exception(Throwable t) {\r
+ }\r
+\r
+ @Override\r
+ public void execute(Object result) {\r
+ if(accessor == null)\r
+ try {\r
+ accessor = Accessors.getAccessor(binding, result); \r
+ } catch (AccessorConstructionException e) {\r
+ e.printStackTrace();\r
+ }\r
+ else\r
+ try {\r
+ if(!binding.equals(accessor.getValue(binding), result))\r
+ accessor.setValue(binding, result);\r
+ } catch (AccessorException e) {\r
+ e.printStackTrace();\r
+ } \r
+ }\r
+\r
+ @Override\r
+ public boolean isDisposed() {\r
+ // TODO Auto-generated method stub\r
+ return false;\r
+ }\r
+ \r
+ }\r
+ \r
+ static private class AccessorListener implements Accessor.Listener {\r
+\r
+ Accessor accessor;\r
+ RequestProcessor rp;\r
+ Resource resource;\r
+ Binding binding;\r
+ \r
+ public AccessorListener(Accessor accessor, RequestProcessor rp,\r
+ Resource resource, Binding binding) {\r
+ this.accessor = accessor;\r
+ this.rp = rp;\r
+ this.resource = resource;\r
+ this.binding = binding;\r
+ }\r
+\r
+ @Override\r
+ public void onEvents(Collection<Event> event) {\r
+ rp.asyncRequest(new WriteRequest() { \r
+ @Override\r
+ public void perform(WriteGraph graph) throws DatabaseException {\r
+ try {\r
+ Object a = accessor.getValue(binding);\r
+ Object b = graph.getValue(resource, binding);\r
+ if(!binding.equals(a, b))\r
+ graph.claimValue(resource, a, binding);\r
+ } catch (AccessorException e) {\r
+ throw new DatabaseException(e);\r
+ }\r
+ }\r
+ });\r
+ }\r
+ \r
+ }\r
+ \r
+ static private class AccessorListener2 implements Accessor.Listener {\r
+\r
+ Accessor accessor;\r
+ RequestProcessor rp;\r
+ Resource resource;\r
+ Resource relation;\r
+ Binding binding;\r
+ \r
+ public AccessorListener2(Accessor accessor, RequestProcessor rp,\r
+ Resource resource, Resource relation, Binding binding) {\r
+ this.accessor = accessor;\r
+ this.rp = rp;\r
+ this.resource = resource;\r
+ this.relation = relation;\r
+ this.binding = binding;\r
+ }\r
+\r
+ @Override\r
+ public void onEvents(Collection<Event> event) {\r
+ rp.asyncRequest(new WriteRequest() { \r
+ @Override\r
+ public void perform(WriteGraph graph) throws DatabaseException {\r
+ try {\r
+ Object a = accessor.getValue(binding);\r
+ \r
+ Resource valueResource = graph.getPossibleObject(resource, relation);\r
+ if(valueResource == null) {\r
+ valueResource = graph.newResource(); \r
+ graph.claim(resource, relation, valueResource);\r
+ graph.claimValue(valueResource, a, binding);\r
+ }\r
+ else {\r
+ Object b = graph.getValue(valueResource, binding);\r
+ if(!binding.equals(a, b))\r
+ graph.claimLiteral(resource, relation, a, binding);\r
+ }\r
+ } catch (AccessorException e) {\r
+ throw new DatabaseException(e);\r
+ }\r
+ }\r
+ });\r
+ }\r
+ \r
+ }\r
+ \r
+ public static Accessor create(RequestProcessor rp, Resource resource, Binding binding) throws DatabaseException {\r
+ ValueReadRequest request = new ValueReadRequest(resource, binding);\r
+ ValueReadListener listener = new ValueReadListener(binding);\r
+ rp.syncRequest(request, listener);\r
+ try {\r
+ listener.accessor.addListener(\r
+ new AccessorListener(listener.accessor, rp, resource, binding), \r
+ InterestSet.newInterestSet(listener.accessor.type(), true, false, true),\r
+ null, null);\r
+ } catch (AccessorException e) {\r
+ e.printStackTrace();\r
+ }\r
+ return listener.accessor; \r
+ }\r
+ \r
+ public static Accessor create(RequestProcessor rp, Resource resource, Resource relation, Object defaultValue, Binding binding) throws DatabaseException {\r
+ ValueReadRequest2 request = new ValueReadRequest2(resource, relation, defaultValue, binding);\r
+ ValueReadListener listener = new ValueReadListener(binding);\r
+ rp.syncRequest(request, listener);\r
+ try {\r
+ listener.accessor.addListener(\r
+ new AccessorListener2(listener.accessor, rp, resource, relation, binding), \r
+ InterestSet.newInterestSet(listener.accessor.type(), true, false, true),\r
+ null, null);\r
+ } catch (AccessorException e) {\r
+ e.printStackTrace();\r
+ }\r
+ return listener.accessor; \r
+ }\r
+ \r
+}\r
Code Review / simantics / platform.git / blobdiff