DB-client fixes
[simantics/platform.git] / bundles / org.simantics.db.procore / src / fi / vtt / simantics / procore / internal / GraphSessionVirtual.java
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
8  *\r
9  * Contributors:\r
10  *     VTT Technical Research Centre of Finland - initial API and implementation\r
11  *******************************************************************************/\r
12 package fi.vtt.simantics.procore.internal;\r
13 \r
14 import gnu.trove.map.hash.THashMap;\r
15 \r
16 import java.io.File;\r
17 import java.io.FileInputStream;\r
18 import java.io.IOException;\r
19 import java.io.InputStream;\r
20 import java.util.Properties;\r
21 import java.util.Set;\r
22 import java.util.concurrent.atomic.AtomicLong;\r
23 \r
24 import org.simantics.db.ClusterCreator;\r
25 import org.simantics.db.Database;\r
26 import org.simantics.db.SessionReference;\r
27 import org.simantics.db.Database.Session;\r
28 import org.simantics.db.exception.DatabaseException;\r
29 import org.simantics.db.impl.support.VirtualGraphServerSupport;\r
30 import org.simantics.db.procore.protocol.Constants;\r
31 import org.simantics.db.server.ProCoreException;\r
32 import org.simantics.db.service.ClusterUID;\r
33 \r
34 class GraphSessionVirtual extends GraphSession { // Äsh! This extends relation was/is a pure design choice.\r
35     private static String FileName = "virtualGraph.builtins.dat";\r
36     private static long BuiltinClusterId = -1; // Virtual graph doesn't have clusters.\r
37     static class VirtualSession implements Session {\r
38         @Override\r
39         public Database getDatabase() {\r
40             return null;\r
41         }\r
42         @Override\r
43         public void close() throws ProCoreException {\r
44         }\r
45         @Override\r
46         public void open() throws ProCoreException {\r
47         }\r
48         @Override\r
49         public boolean isClosed() throws ProCoreException {\r
50             return false;\r
51         }\r
52         @Override\r
53         public String execute(String command) throws ProCoreException {\r
54             return null;\r
55         }\r
56         @Override\r
57         public void acceptCommit(long transactionId, long changeSetId, byte[] metadata) throws ProCoreException {\r
58         }\r
59         @Override\r
60         public long cancelCommit(long transactionId, long changeSetId, byte[] metadata, OnChangeSetUpdate on) throws ProCoreException {\r
61             return 0;\r
62         }\r
63         @Override\r
64         public Transaction askReadTransaction() throws ProCoreException {\r
65             return null;\r
66         }\r
67         @Override\r
68         public Transaction askWriteTransaction(long transactionId) throws ProCoreException {\r
69             return null;\r
70         }\r
71         @Override\r
72         public long endTransaction(long transactionId) throws ProCoreException {\r
73             return 0;\r
74         }\r
75         @Override\r
76         public byte[] getChangeSetMetadata(long changeSetId) throws ProCoreException {\r
77             return null;\r
78         }\r
79         @Override\r
80         public ChangeSetData getChangeSetData(long minChangeSetId, long maxChangeSetId, OnChangeSetUpdate on) throws ProCoreException {\r
81             return null;\r
82         }\r
83         @Override\r
84         public ChangeSetIds getChangeSetIds() throws ProCoreException {\r
85             return null;\r
86         }\r
87         @Override\r
88         public Cluster getCluster(byte[] clusterId) throws ProCoreException {\r
89             return null;\r
90         }\r
91         @Override\r
92         public ClusterChanges getClusterChanges(long changeSetId, byte[] clusterId) throws ProCoreException {\r
93             return null;\r
94         }\r
95         @Override\r
96         public ClusterIds getClusterIds() throws ProCoreException {\r
97             return null;\r
98         }\r
99         @Override\r
100         public Information getInformation() throws ProCoreException {\r
101             return null;\r
102         }\r
103         @Override\r
104         public Refresh getRefresh(long changeSetId) throws ProCoreException {\r
105             return null;\r
106         }\r
107         @Override\r
108         public ResourceSegment getResourceSegment(byte[] clusterUID, int resourceIndex, long offset, short size) throws ProCoreException {\r
109             return null;\r
110         }\r
111         @Override\r
112         public long reserveIds(int count) throws ProCoreException {\r
113             return 0;\r
114         }\r
115         @Override\r
116         public void updateCluster(byte[] operations) throws ProCoreException {\r
117         }\r
118         @Override\r
119         public boolean undo(long[] cChangeSetIds, OnChangeSetUpdate onChangeSetUpdate) throws ProCoreException {\r
120             return false;\r
121         }\r
122         @Override\r
123         public <T> T clone(ClusterUID clusterUID, ClusterCreator clusterCreator) throws DatabaseException {\r
124             throw new UnsupportedOperationException();\r
125         }\r
126         @Override\r
127         public boolean refreshEnabled() {\r
128             return false;\r
129         }\r
130         @Override\r
131         public boolean rolledback() {\r
132             // TODO Auto-generated method stub\r
133             return false;\r
134         }\r
135     }\r
136     private AtomicLong changeSetId = new AtomicLong(Constants.NullChangeSetId);\r
137     private AtomicLong transactionId = new AtomicLong(Constants.NullTransactionId);\r
138     public static ServerInformationImpl serverInfo = new ServerInformationImpl("serverId", "protocolId", "databaseId", 0);\r
139     private VirtualGraphServerSupport virtualGraphServerSupport;\r
140         public GraphSessionVirtual(SessionImplSocket sessionImpl, SessionReference sessionReference, VirtualGraphServerSupport vgss) {\r
141         super(sessionImpl, sessionReference, new VirtualSession()); // Super does not expect null session.\r
142         virtualGraphServerSupport = vgss;\r
143     }\r
144     protected THashMap<String, BuiltinData> initBuiltinMap()\r
145     throws DatabaseException {\r
146         try {\r
147             Properties props = new Properties();\r
148             File from = new File(FileName);\r
149             InputStream in = new FileInputStream(from);\r
150             props.load(in);\r
151             THashMap<String, BuiltinData>  builtins = new THashMap<String, BuiltinData>();\r
152             Set<String> keys = props.stringPropertyNames();\r
153             for (String key : keys) {\r
154                 long resourceId = Long.parseLong(key);\r
155                 long cluster = BuiltinClusterId;\r
156                 int resourceIndex = (int)resourceId;\r
157                 String uri = props.getProperty(key);\r
158                 BuiltinData bd = new BuiltinData(resourceIndex, cluster);\r
159                 builtins.put(uri, bd);\r
160             }\r
161             return builtins;\r
162         } catch(IOException e) {\r
163             if (DEBUG)\r
164                 e.printStackTrace();\r
165             throw new DatabaseException("Failed to read builtins.", e);\r
166         }\r
167     }\r
168     @Override\r
169     protected ServerInformationImpl getServerInformation() {\r
170         return serverInfo;\r
171     }\r
172     @Override\r
173     public void acceptCommit(long transactionId, long csid, byte[] metadata)\r
174     throws DatabaseException {\r
175         changeSetId.incrementAndGet();\r
176     }\r
177 \r
178     @Override\r
179     public void cancelCommit(long transactionId, long csid, byte[] metadata, SynchronizeContextI context)\r
180     throws DatabaseException {\r
181         changeSetId.incrementAndGet();\r
182     }\r
183 \r
184     @Override\r
185     public void endTransaction(long transactionId, boolean write)\r
186     throws DatabaseException {\r
187 \r
188     }\r
189 \r
190     @Override\r
191     public long askWriteTransaction(int thread, long transactionId)\r
192     throws DatabaseException {\r
193         if (Constants.NullTransactionId != transactionId)\r
194             return transactionId;\r
195         else\r
196             return this.transactionId.incrementAndGet();\r
197     }\r
198     @Override\r
199     public long askReadTransaction(int thread)\r
200     throws DatabaseException {\r
201         return transactionId.incrementAndGet();\r
202     }\r
203     @Override\r
204     public void stop() throws DatabaseException {\r
205         if (DEBUG)\r
206             System.out.println("GraphSessionVirtual: stop.");\r
207 \r
208     }\r
209     @Override\r
210     public long reserveIds(int count)\r
211     throws DatabaseException {\r
212 //        VirtualGraphServerSupport s = session.getService(VirtualGraphServerSupport.class);\r
213         long id = Constants.NullSubjectId;\r
214         for (int i=0; i<count; ++i)\r
215            id = virtualGraphServerSupport.createVirtual();\r
216         return id;\r
217     }\r
218 }