1 /*******************************************************************************
\r
2 * Copyright (c) 2007, 2010 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
10 * VTT Technical Research Centre of Finland - initial API and implementation
\r
11 *******************************************************************************/
\r
12 package org.simantics.db.procore.cluster;
\r
14 import gnu.trove.map.hash.TObjectIntHashMap;
\r
16 import org.simantics.db.exception.DatabaseException;
\r
17 import org.simantics.db.impl.ClusterTraitsBase;
\r
18 import org.simantics.db.service.ClusterUID;
\r
19 import org.simantics.db.service.ResourceUID;
\r
21 public class ClusterMap {
\r
22 private ForeignTable foreignTable;
\r
23 //private FlatTable flatTable;
\r
24 private TObjectIntHashMap<ClusterUID> hashMap;
\r
25 public ClusterMap(ForeignTable foreignTable, FlatTable flatTable) {
\r
26 this.foreignTable = foreignTable;
\r
27 //this.flatTable = flatTable;
\r
30 public void compact() {
\r
36 * 13 bytes for each element. Approx capacity = 3 * size
\r
38 public int getUsedSpace() {
\r
41 return 3 * 13 * hashMap.size();
\r
43 public int getForeignResourceIndex(int reference)
\r
44 throws DatabaseException {
\r
45 if (ClusterTraits.isFlat(reference))
\r
46 throw new DatabaseException("Flat reference is not supported yet.");
\r
48 return ClusterTraits.getResourceIndexFromForeignReference(reference);
\r
51 public final ResourceUID getResourceUID(int reference) throws DatabaseException {
\r
52 if (ClusterTraits.isFlat(reference))
\r
53 throw new DatabaseException("Flat reference is not supported yet. reference=" + reference);
\r
55 int foreignIndex = ClusterTraits.getForeignIndexFromReference(reference);
\r
56 return foreignTable.getResourceUID(foreignIndex);
\r
59 public int getForeignReferenceOrCreateByResourceKey(int resourceKey, ClusterUID clusterUID)
\r
60 throws DatabaseException {
\r
61 int resourceIndex = ClusterTraits.getResourceIndexFromResourceKey(resourceKey);
\r
62 return getForeignReferenceOrCreateByResourceIndex(resourceIndex, clusterUID);
\r
64 public int getForeignReferenceOrCreateByResourceIndex(int resourceIndex, ClusterUID clusterUID)
\r
65 throws DatabaseException {
\r
66 if (ClusterTraitsBase.isIllegalResourceIndex(resourceIndex))
\r
67 throw new DatabaseException("Illegal resource index=" + resourceIndex + ".");
\r
68 if (null == hashMap)
\r
69 hashMap = foreignTable.getHashMap();
\r
70 int foreignIndex = hashMap.get(clusterUID);
\r
71 if (0 == foreignIndex) {
\r
72 foreignIndex = foreignTable.createForeign(clusterUID.toRID(resourceIndex));
\r
73 hashMap.put(clusterUID, foreignIndex);
\r
75 return ClusterTraits.createForeignReference(foreignIndex, resourceIndex);
\r
77 public int getForeignReferenceOrZero(int resourceIndex, ClusterUID clusterUID)
\r
78 throws DatabaseException {
\r
79 // This is guaranteed by implementation
\r
80 // if(clusterId == 1) return (resourceIndex<<16) + 0x80000001;
\r
81 //return ClusterTraits.createForeignReference(1, resourceIndex);
\r
82 // new Exception("getForeignReferenceOrZero " + clusterId).printStackTrace();
\r
83 if (null == hashMap)
\r
84 hashMap = foreignTable.getHashMap();
\r
85 if (ClusterUID.Null.equals(clusterUID))
\r
86 throw new DatabaseException("Illegal cluster uid " + clusterUID);
\r
87 if (0 == resourceIndex)
\r
88 throw new DatabaseException("Illegal resource index " + resourceIndex);
\r
89 int foreignIndex = hashMap.get(clusterUID);
\r
90 if (0 == foreignIndex)
\r
92 //System.err.println("foreignIndex for " + clusterId + " = " + foreignIndex);
\r
93 return ClusterTraits.createForeignReference(foreignIndex, resourceIndex);
\r