bundles/org.simantics.objmap2/src/org/simantics/objmap/graph/rules/domain/CompoundValueAccessor.java

   1 /*******************************************************************************\r
   2  * Copyright (c) 2007, 2013 Association for Decentralized Information Management\r
   3  * in Industry THTH ry.\r
   4  * All rights reserved. This program and the accompanying materials\r
   5  * are made available under the terms of the Eclipse Public License v1.0\r
   6  * which accompanies this distribution, and is available at\r
   7  * http://www.eclipse.org/legal/epl-v10.html\r
   8  *\r
   9  * Contributors:\r
  10  *     VTT Technical Research Centre of Finland - initial API and implementation\r
  11  *******************************************************************************/\r
  12 package org.simantics.objmap.graph.rules.domain;\r
  13 \r
  14 import java.util.Arrays;\r
  15 import java.util.Collection;\r
  16 import java.util.HashMap;\r
  17 import java.util.Map;\r
  18 \r
  19 import org.apache.log4j.Logger;\r
  20 import org.simantics.db.ReadGraph;\r
  21 import org.simantics.db.Resource;\r
  22 import org.simantics.db.Statement;\r
  23 import org.simantics.db.WriteGraph;\r
  24 import org.simantics.db.exception.DatabaseException;\r
  25 import org.simantics.layer0.Layer0;\r
  26 import org.simantics.objmap.exceptions.MappingException;\r
  27 import org.simantics.objmap.graph.annotations.factories.CompoundRelatedGetSetValueRuleFactory;\r
  28 \r
  29 /**\r
  30  * \r
  31  * @author Marko Luukkainen\r
  32  */\r
  33 public class CompoundValueAccessor implements IDomainAccessor<Resource,Object> {\r
  34 \r
  35     static Logger LOGGER = Logger.getLogger("org.simantics.objmap");\r
  36     \r
  37         Resource objRelation;\r
  38         Resource objType;\r
  39         Resource valRelation;\r
  40 \r
  41         public CompoundValueAccessor(Resource objRelation, Resource objType, Resource valRelation) {\r
  42                 this.objRelation = objRelation;\r
  43                 this.objType = objType;\r
  44                 this.valRelation = valRelation;\r
  45         }\r
  46 \r
  47         @Override\r
  48         public Object get(ReadGraph g, Resource element) throws MappingException {\r
  49                 try {\r
  50                         Layer0 l0 = Layer0.getInstance(g);\r
  51                     LOGGER.info("        CompoundValueAccessor.get");\r
  52                     Collection<Statement> coll = g.getStatements(element, objRelation);\r
  53                     Map<String,Object> map = new HashMap<String, Object>();\r
  54                     for (Statement c : coll) {\r
  55                         String name = g.getRelatedValue(c.getObject(), l0.HasName);\r
  56                         if (!map.containsKey(name) || !c.isAsserted(element))\r
  57                                 map.put(name, g.getRelatedValue(c.getObject(), valRelation));\r
  58                     }\r
  59                         return map;\r
  60                 } catch (DatabaseException e) {\r
  61                         throw new MappingException(e);\r
  62                 }\r
  63         }\r
  64         \r
  65         @Override\r
  66         public boolean set(WriteGraph g, Resource element, Object v)\r
  67                         throws MappingException {\r
  68                 try {\r
  69                         Layer0 l0 = Layer0.getInstance(g);\r
  70                     LOGGER.info("        CompoundValueAccessor.set");\r
  71                     @SuppressWarnings("unchecked")\r
  72                     Map<String,Object> values = (Map<String, Object>)v;\r
  73                     \r
  74                     Collection<Statement> coll = g.getStatements(element, objRelation);\r
  75                     Map<String,Statement> stmMap = new HashMap<String, Statement>();\r
  76                     Map<String,Object> valueMap = new HashMap<String, Object>();\r
  77                     for (Statement c : coll) {\r
  78                         String name = g.getRelatedValue(c.getObject(), l0.HasName);\r
  79                         if (!stmMap.containsKey(name) || !c.isAsserted(element)) {\r
  80                                 stmMap.put(name, c);\r
  81                                 valueMap.put(name, g.getRelatedValue(c.getObject(), valRelation));\r
  82                         }\r
  83                     }\r
  84                     boolean changed = false;\r
  85                     for (String key : values.keySet()) {\r
  86                         Object value = values.get(key);\r
  87                         if (value.equals(valueMap.get(key)))\r
  88                                 continue;\r
  89                         changed = true;\r
  90                         Statement stm = stmMap.get(key);\r
  91                         if (stm == null || stm.isAsserted(element)) {\r
  92                                 Resource obj = g.newResource();\r
  93                                 g.claim(obj, l0.InstanceOf, objType);\r
  94                                 g.claimLiteral(obj, l0.HasName, key);\r
  95                                 g.claim(element, objRelation, obj);\r
  96                                 stm = getStatement(g, element, objRelation, obj);\r
  97                         }\r
  98                         \r
  99                         Statement valueStatement = g.getPossibleStatement(stm.getObject(), valRelation);\r
 100                         Resource valueType = CompoundRelatedGetSetValueRuleFactory.dataTypeOfClass(g, value.getClass());\r
 101                                 if(valueStatement == null) {\r
 102                                         \r
 103                                         Resource valueResource = g.newResource();\r
 104                                         g.claim(valueResource, Layer0.getInstance(g).InstanceOf, null,  valueType);\r
 105                                         g.claim(stm.getObject(), valRelation, valueResource);\r
 106                                         g.claimValue(valueResource, value);                             \r
 107                                 } else {\r
 108                                                                         \r
 109                                         \r
 110                                         if (!valueStatement.isAsserted(stm.getObject()))\r
 111                                                 g.claimValue(valueStatement.getObject(), value);\r
 112                                         else {\r
 113                                                 Resource valueResource = g.newResource();\r
 114                                                 g.claim(valueResource, Layer0.getInstance(g).InstanceOf, null,\r
 115                                                                 valueType);\r
 116                                                 g.claim(stm.getObject(), valRelation, valueResource);\r
 117                                                 g.claimValue(valueResource, value);\r
 118                                         }\r
 119                                 }\r
 120                     }\r
 121                     return changed;\r
 122                     \r
 123                 } catch (DatabaseException e) {\r
 124                         throw new MappingException(e);\r
 125                 }\r
 126                 \r
 127         }\r
 128         \r
 129         private Statement getStatement(ReadGraph g, Resource s, Resource p, Resource o) throws DatabaseException{\r
 130                 for (Statement stm : g.getStatements(s, p)) {\r
 131                         if (stm.getObject().equals(o))\r
 132                                 return stm;\r
 133                 }\r
 134                 return null;\r
 135         }\r
 136         \r
 137         private boolean equals(Object o1, Object o2) {\r
 138                 if (o1 instanceof boolean[])\r
 139                         Arrays.equals((boolean[])o1,(boolean[])o2);\r
 140                 if (o1 instanceof int[])\r
 141                         Arrays.equals((int[])o1,(int[])o2);\r
 142                 if (o1 instanceof float[])\r
 143                         Arrays.equals((float[])o1,(float[])o2);\r
 144                 if (o1 instanceof double[])\r
 145                         Arrays.equals((double[])o1,(double[])o2);\r
 146                 if (o1 instanceof byte[])\r
 147                         Arrays.equals((byte[])o1,(byte[])o2);\r
 148                 return o1.equals(o2);\r
 149                 \r
 150         }\r
 151 \r
 152 }\r