--- /dev/null
+/*******************************************************************************\r
+ * Copyright (c) 2007, 2013 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.objmap.graph.rules.domain;\r
+\r
+import java.util.Arrays;\r
+import java.util.Collection;\r
+import java.util.HashMap;\r
+import java.util.Map;\r
+\r
+import org.apache.log4j.Logger;\r
+import org.simantics.db.ReadGraph;\r
+import org.simantics.db.Resource;\r
+import org.simantics.db.Statement;\r
+import org.simantics.db.WriteGraph;\r
+import org.simantics.db.exception.DatabaseException;\r
+import org.simantics.layer0.Layer0;\r
+import org.simantics.objmap.exceptions.MappingException;\r
+import org.simantics.objmap.graph.annotations.factories.CompoundRelatedGetSetValueRuleFactory;\r
+\r
+/**\r
+ * \r
+ * @author Marko Luukkainen\r
+ */\r
+public class CompoundValueAccessor implements IDomainAccessor<Resource,Object> {\r
+\r
+ static Logger LOGGER = Logger.getLogger("org.simantics.objmap");\r
+ \r
+ Resource objRelation;\r
+ Resource objType;\r
+ Resource valRelation;\r
+\r
+ public CompoundValueAccessor(Resource objRelation, Resource objType, Resource valRelation) {\r
+ this.objRelation = objRelation;\r
+ this.objType = objType;\r
+ this.valRelation = valRelation;\r
+ }\r
+\r
+ @Override\r
+ public Object get(ReadGraph g, Resource element) throws MappingException {\r
+ try {\r
+ Layer0 l0 = Layer0.getInstance(g);\r
+ LOGGER.info(" CompoundValueAccessor.get");\r
+ Collection<Statement> coll = g.getStatements(element, objRelation);\r
+ Map<String,Object> map = new HashMap<String, Object>();\r
+ for (Statement c : coll) {\r
+ String name = g.getRelatedValue(c.getObject(), l0.HasName);\r
+ if (!map.containsKey(name) || !c.isAsserted(element))\r
+ map.put(name, g.getRelatedValue(c.getObject(), valRelation));\r
+ }\r
+ return map;\r
+ } catch (DatabaseException e) {\r
+ throw new MappingException(e);\r
+ }\r
+ }\r
+ \r
+ @Override\r
+ public boolean set(WriteGraph g, Resource element, Object v)\r
+ throws MappingException {\r
+ try {\r
+ Layer0 l0 = Layer0.getInstance(g);\r
+ LOGGER.info(" CompoundValueAccessor.set");\r
+ @SuppressWarnings("unchecked")\r
+ Map<String,Object> values = (Map<String, Object>)v;\r
+ \r
+ Collection<Statement> coll = g.getStatements(element, objRelation);\r
+ Map<String,Statement> stmMap = new HashMap<String, Statement>();\r
+ Map<String,Object> valueMap = new HashMap<String, Object>();\r
+ for (Statement c : coll) {\r
+ String name = g.getRelatedValue(c.getObject(), l0.HasName);\r
+ if (!stmMap.containsKey(name) || !c.isAsserted(element)) {\r
+ stmMap.put(name, c);\r
+ valueMap.put(name, g.getRelatedValue(c.getObject(), valRelation));\r
+ }\r
+ }\r
+ boolean changed = false;\r
+ for (String key : values.keySet()) {\r
+ Object value = values.get(key);\r
+ if (value.equals(valueMap.get(key)))\r
+ continue;\r
+ changed = true;\r
+ Statement stm = stmMap.get(key);\r
+ if (stm == null || stm.isAsserted(element)) {\r
+ Resource obj = g.newResource();\r
+ g.claim(obj, l0.InstanceOf, objType);\r
+ g.claimLiteral(obj, l0.HasName, key);\r
+ g.claim(element, objRelation, obj);\r
+ stm = getStatement(g, element, objRelation, obj);\r
+ }\r
+ \r
+ Statement valueStatement = g.getPossibleStatement(stm.getObject(), valRelation);\r
+ Resource valueType = CompoundRelatedGetSetValueRuleFactory.dataTypeOfClass(g, value.getClass());\r
+ if(valueStatement == null) {\r
+ \r
+ Resource valueResource = g.newResource();\r
+ g.claim(valueResource, Layer0.getInstance(g).InstanceOf, null, valueType);\r
+ g.claim(stm.getObject(), valRelation, valueResource);\r
+ g.claimValue(valueResource, value); \r
+ } else {\r
+ \r
+ \r
+ if (!valueStatement.isAsserted(stm.getObject()))\r
+ g.claimValue(valueStatement.getObject(), value);\r
+ else {\r
+ Resource valueResource = g.newResource();\r
+ g.claim(valueResource, Layer0.getInstance(g).InstanceOf, null,\r
+ valueType);\r
+ g.claim(stm.getObject(), valRelation, valueResource);\r
+ g.claimValue(valueResource, value);\r
+ }\r
+ }\r
+ }\r
+ return changed;\r
+ \r
+ } catch (DatabaseException e) {\r
+ throw new MappingException(e);\r
+ }\r
+ \r
+ }\r
+ \r
+ private Statement getStatement(ReadGraph g, Resource s, Resource p, Resource o) throws DatabaseException{\r
+ for (Statement stm : g.getStatements(s, p)) {\r
+ if (stm.getObject().equals(o))\r
+ return stm;\r
+ }\r
+ return null;\r
+ }\r
+ \r
+ private boolean equals(Object o1, Object o2) {\r
+ if (o1 instanceof boolean[])\r
+ Arrays.equals((boolean[])o1,(boolean[])o2);\r
+ if (o1 instanceof int[])\r
+ Arrays.equals((int[])o1,(int[])o2);\r
+ if (o1 instanceof float[])\r
+ Arrays.equals((float[])o1,(float[])o2);\r
+ if (o1 instanceof double[])\r
+ Arrays.equals((double[])o1,(double[])o2);\r
+ if (o1 instanceof byte[])\r
+ Arrays.equals((byte[])o1,(byte[])o2);\r
+ return o1.equals(o2);\r
+ \r
+ }\r
+\r
+}\r
Code Review / simantics / platform.git / blobdiff