-/*******************************************************************************\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
+/*******************************************************************************
+ * Copyright (c) 2007, 2013 Association for Decentralized Information Management
+ * in Industry THTH ry.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ * VTT Technical Research Centre of Finland - initial API and implementation
+ *******************************************************************************/
+package org.simantics.objmap.graph.rules.domain;
+
+import java.util.Arrays;
+import java.util.Collection;
+import java.util.HashMap;
+import java.util.Map;
+
+import org.apache.log4j.Logger;
+import org.simantics.db.ReadGraph;
+import org.simantics.db.Resource;
+import org.simantics.db.Statement;
+import org.simantics.db.WriteGraph;
+import org.simantics.db.exception.DatabaseException;
+import org.simantics.layer0.Layer0;
+import org.simantics.objmap.exceptions.MappingException;
+import org.simantics.objmap.graph.annotations.factories.CompoundRelatedGetSetValueRuleFactory;
+
+/**
+ *
+ * @author Marko Luukkainen
+ */
+public class CompoundValueAccessor implements IDomainAccessor<Resource,Object> {
+
+ static Logger LOGGER = Logger.getLogger("org.simantics.objmap");
+
+ Resource objRelation;
+ Resource objType;
+ Resource valRelation;
+
+ public CompoundValueAccessor(Resource objRelation, Resource objType, Resource valRelation) {
+ this.objRelation = objRelation;
+ this.objType = objType;
+ this.valRelation = valRelation;
+ }
+
+ @Override
+ public Object get(ReadGraph g, Resource element) throws MappingException {
+ try {
+ Layer0 l0 = Layer0.getInstance(g);
+ LOGGER.info(" CompoundValueAccessor.get");
+ Collection<Statement> coll = g.getStatements(element, objRelation);
+ Map<String,Object> map = new HashMap<String, Object>();
+ for (Statement c : coll) {
+ String name = g.getRelatedValue(c.getObject(), l0.HasName);
+ if (!map.containsKey(name) || !c.isAsserted(element))
+ map.put(name, g.getRelatedValue(c.getObject(), valRelation));
+ }
+ return map;
+ } catch (DatabaseException e) {
+ throw new MappingException(e);
+ }
+ }
+
+ @Override
+ public boolean set(WriteGraph g, Resource element, Object v)
+ throws MappingException {
+ try {
+ Layer0 l0 = Layer0.getInstance(g);
+ LOGGER.info(" CompoundValueAccessor.set");
+ @SuppressWarnings("unchecked")
+ Map<String,Object> values = (Map<String, Object>)v;
+
+ Collection<Statement> coll = g.getStatements(element, objRelation);
+ Map<String,Statement> stmMap = new HashMap<String, Statement>();
+ Map<String,Object> valueMap = new HashMap<String, Object>();
+ for (Statement c : coll) {
+ String name = g.getRelatedValue(c.getObject(), l0.HasName);
+ if (!stmMap.containsKey(name) || !c.isAsserted(element)) {
+ stmMap.put(name, c);
+ valueMap.put(name, g.getRelatedValue(c.getObject(), valRelation));
+ }
+ }
+ boolean changed = false;
+ for (String key : values.keySet()) {
+ Object value = values.get(key);
+ if (value.equals(valueMap.get(key)))
+ continue;
+ changed = true;
+ Statement stm = stmMap.get(key);
+ if (stm == null || stm.isAsserted(element)) {
+ Resource obj = g.newResource();
+ g.claim(obj, l0.InstanceOf, objType);
+ g.claimLiteral(obj, l0.HasName, key);
+ g.claim(element, objRelation, obj);
+ stm = getStatement(g, element, objRelation, obj);
+ }
+
+ Statement valueStatement = g.getPossibleStatement(stm.getObject(), valRelation);
+ Resource valueType = CompoundRelatedGetSetValueRuleFactory.dataTypeOfClass(g, value.getClass());
+ if(valueStatement == null) {
+
+ Resource valueResource = g.newResource();
+ g.claim(valueResource, Layer0.getInstance(g).InstanceOf, null, valueType);
+ g.claim(stm.getObject(), valRelation, valueResource);
+ g.claimValue(valueResource, value);
+ } else {
+
+
+ if (!valueStatement.isAsserted(stm.getObject()))
+ g.claimValue(valueStatement.getObject(), value);
+ else {
+ Resource valueResource = g.newResource();
+ g.claim(valueResource, Layer0.getInstance(g).InstanceOf, null,
+ valueType);
+ g.claim(stm.getObject(), valRelation, valueResource);
+ g.claimValue(valueResource, value);
+ }
+ }
+ }
+ return changed;
+
+ } catch (DatabaseException e) {
+ throw new MappingException(e);
+ }
+
+ }
+
+ private Statement getStatement(ReadGraph g, Resource s, Resource p, Resource o) throws DatabaseException{
+ for (Statement stm : g.getStatements(s, p)) {
+ if (stm.getObject().equals(o))
+ return stm;
+ }
+ return null;
+ }
+
+ private boolean equals(Object o1, Object o2) {
+ if (o1 instanceof boolean[])
+ Arrays.equals((boolean[])o1,(boolean[])o2);
+ if (o1 instanceof int[])
+ Arrays.equals((int[])o1,(int[])o2);
+ if (o1 instanceof float[])
+ Arrays.equals((float[])o1,(float[])o2);
+ if (o1 instanceof double[])
+ Arrays.equals((double[])o1,(double[])o2);
+ if (o1 instanceof byte[])
+ Arrays.equals((byte[])o1,(byte[])o2);
+ return o1.equals(o2);
+
+ }
+
+}
Code Review / simantics / platform.git / blobdiff