|
1 package com.daffodilwoods.daffodildb.server.sql99.dql.execution;
2
3 import java.sql.*;
4 import java.sql.Date  ;
5 import java.util.*;
6 import com.daffodilwoods.daffodildb.server.datadictionarysystem.*;
7 import com.daffodilwoods.daffodildb.server.datasystem.interfaces.*;
8 import com.daffodilwoods.daffodildb.server.serversystem.*;
9 import com.daffodilwoods.daffodildb.server.sessionsystem.*;
10 import com.daffodilwoods.daffodildb.server.sql99.dml.declarecursor.*;
11 import com.daffodilwoods.daffodildb.server.sql99.dql.iterator.*;
12 import com.daffodilwoods.daffodildb.server.sql99.dql.plan.table.*;
13 import com.daffodilwoods.daffodildb.server.sql99.dql.queryexpression.orderbyclause.*;
14 import com.daffodilwoods.daffodildb.server.sql99.expression.booleanvalueexpression.*;
15 import com.daffodilwoods.database.general.*;
16 import com.daffodilwoods.database.resource.*;
17 import com.daffodilwoods.database.sqlinitiator._Order;
18 import com.daffodilwoods.daffodildb.server.sql99.common.TableDetails;
19 import com.daffodilwoods.daffodildb.server.serversystem._StatementExecutionContext;
20 import com.daffodilwoods.daffodildb.server.datadictionarysystem._ColumnCharacteristics;
21 import com.daffodilwoods.daffodildb.server.sessionsystem._UserSession;
22 import com.daffodilwoods.daffodildb.server.datadictionarysystem._DataDictionary;
23 import java.sql.Date ;
24 import java.sql.Time ;
25 import com.daffodilwoods.daffodildb.server.sessionsystem.SessionTransactionMode;
26 import java.sql.Timestamp ;
27 import java.util.TimeZone ;
28 import java.util.Properties ;
29 import com.daffodilwoods.daffodildb.server.datasystem.interfaces._IndexTable;
30 import java.util.HashMap ;
31 import com.daffodilwoods.daffodildb.server.sql99.dml.declarecursor._Cursor;
32 import com.daffodilwoods.daffodildb.server.datadictionarysystem._SequenceManager;
33 import com.daffodilwoods.daffodildb.utils.byteconverter.CbCUsffWbmvfIboemfs;
34 import com.daffodilwoods.daffodildb.server.datasystem.mergesystem.MergeDatabase;
35 import com.daffodilwoods.daffodildb.server.serversystem.triggerInfo._Triggers;
36
37
53
54 public class ServerSessionWrapper implements _ServerSession {
55
56
59
60 private int iteratorType;
61
62
65
66 private _ServerSession serverSession;
67
68
71
72 private String currentSchema;
73
74
77
78 private String currentCatalog;
79
80 transient DateTimeFunctions dateTimeFunctions;
81
82 public ServerSessionWrapper(_ServerSession serverSession0) {
83 serverSession = serverSession0;
84 dateTimeFunctions = new DateTimeFunctions();
85 }
86
87 public ServerSessionWrapper(_ServerSession serverSession0, String catalog, String schema) {
88 serverSession = serverSession0;
89 currentCatalog = catalog;
90 currentSchema = schema;
91 dateTimeFunctions = new DateTimeFunctions();
92 }
93
94
101
102 public String getCurrentSchema() throws DException {
103 return currentSchema == null ? serverSession.getCurrentSchema() : currentSchema;
104 }
105
106
113
114 public String getCurrentCatalog() throws DException {
115 return currentCatalog == null ? serverSession.getCurrentCatalog() : currentCatalog;
116 }
117
118
122
123 public int getType() {
124 return iteratorType;
125 }
126
127
131
132 public Object execute(String query, int queryTimeOut) throws DException {
133 return serverSession.execute(query, queryTimeOut);
134 }
135
136 public Object executeUpdate(String querys, int queryTimeOut) throws DException {
137 return serverSession.executeParameterised(querys, queryTimeOut);
138 }
139
140 public Object executeQuery(String query, int queryTimeOut) throws DException {
141 return serverSession.executeQuery(query, queryTimeOut);
142 }
143
144 public Object executeParameterised(String query, int queryTimeOut) throws DException {
145 return serverSession.executeParameterised(query, queryTimeOut);
146 }
147
148 public Object executeUpdateParameterised(String querys, int queryTimeOut) throws DException {
149 return serverSession.executeUpdateParameterised(querys, queryTimeOut);
150 }
151
152 public Object executeQueryParameterised(String query, int queryTimeOut) throws DException {
153 return serverSession.executeQueryParameterised(query, queryTimeOut);
154 }
155
156 public _ServerTable getServerTable(QualifiedIdentifier tableName) throws DException {
157 return serverSession.getServerTable(tableName);
158 }
159
160 public _StatementExecutionContext getStatementExecutionContext() throws DException {
161 return serverSession.getStatementExecutionContext();
162 }
163
164 public _ColumnCharacteristics getColumnCharacteristics(QualifiedIdentifier tblName) throws DException {
165 return serverSession.getColumnCharacteristics(tblName);
166 }
167
168 public void rollback() throws DException {
169 serverSession.rollback();
170 }
171
172 public void commit() throws DException {
173 serverSession.commit();
174 }
175
176 public void close() throws DException {
177 serverSession.close();
178 }
179
180 public void setUserSession(_UserSession userSession) throws DException {
181 serverSession.setUserSession(userSession);
182 }
183
184 public _UserSession getUserSession() throws DException {
185 return serverSession.getUserSession();
186 }
187
188 public _ServerSession getGlobalSession() throws DException {
189 return serverSession.getGlobalSession();
190 }
191
192 public boolean makePersistent() throws DException {
193 return serverSession.makePersistent();
194 }
195
196 public boolean prepare() throws DException {
197 return serverSession.prepare();
198 }
199
200 public _ServerSession getSystemServerSession() throws DException {
201 return serverSession.getSystemServerSession();
202 }
203
204 public _DataDictionary getDataDictionary() throws DException {
205 return serverSession.getDataDictionary();
206 }
207
208 public String getDatabaseURL() throws DException {
209 return serverSession.getDatabaseURL();
210 }
211
212 public String getModuleSchema() throws DException {
213 return serverSession.getModuleSchema();
214 }
215
216 public String getModuleCatalog() throws DException {
217 return serverSession.getModuleCatalog();
218 }
219
220 public String getCurrentRole() throws DException {
221 return serverSession.getCurrentRole();
222 }
223
224 public String getCurrentUser() throws DException {
225 return serverSession.getCurrentUser();
226 }
227
228 public Date getDate() throws DException {
229 return dateTimeFunctions.getDate();
230 }
231
232 public Time getTime() throws DException {
233 return dateTimeFunctions.getTime();
234 }
235
236 public void deleteTable(QualifiedIdentifier tableName, boolean dropTable) throws DException {
237 serverSession.deleteTable(tableName, dropTable);
238 }
239
240 public boolean isEnabledAuthorizationIdentifier(String authorizationIdentifier, boolean checkBrowserUser) throws DException {
241 return serverSession.isEnabledAuthorizationIdentifier(authorizationIdentifier, checkBrowserUser);
242 }
243
244 public String getAuthorizationIdentifier() throws DException {
245 return serverSession.getAuthorizationIdentifier();
246 }
247
248 public void setTransactionMode(SessionTransactionMode sessionTransactionMode) throws DException {
249 serverSession.setTransactionMode(sessionTransactionMode);
250 }
251
252 public SessionTransactionMode getTransactionMode() throws DException {
253 return serverSession.getTransactionMode();
254 }
255
256 public void setCurrentCatalog(String currentCatalog) throws DException {
257 serverSession.setCurrentCatalog(currentCatalog);
258 }
259
260 public void setCurrentSchema(String currentSchema) throws DException {
261 serverSession.setCurrentSchema(currentSchema);
262 }
263
264 public Timestamp getTimeStamp() throws DException {
265 return dateTimeFunctions.getTimeStamp();
266 }
267
268 public String getDatabase() throws DException {
269 return serverSession.getDatabase();
270 }
271
272 public int getIsolationLevel() throws DException {
273 return serverSession.getIsolationLevel();
274 }
275
276 public Object getSessionConstant() throws DException {
277 return serverSession.getSessionConstant();
278 }
279
280 public TimeZone getTimeZone() throws DException {
281 return serverSession.getTimeZone();
282 }
283
284 public void createDatabase(String databaseName, Properties prop) throws DException {
285 serverSession.createDatabase(databaseName, prop);
286 }
287
288 public _IndexTable getIndexTable(QualifiedIdentifier tableName) throws DException {
289 return serverSession.getIndexTable(tableName);
290 }
291
292 public void createIndex(QualifiedIdentifier tableName, String indexName, boolean nonUnique) throws DException {
293 serverSession.createIndex(tableName, indexName, nonUnique);
294 }
295
296 public void createTable(QualifiedIdentifier tableName) throws DException {
297 serverSession.createTable(tableName);
298 }
299
300 public void createIndexForSystemTable(QualifiedIdentifier tableName, String indexName) throws DException {
301 serverSession.createIndexForSystemTable(tableName, indexName);
302 }
303
304 public void dropTable(QualifiedIdentifier tableName) throws DException {
305 serverSession.dropTable(tableName);
306 }
307
308 public void dropIndex(QualifiedIdentifier tableName, String indexName) throws DException {
309 serverSession.dropIndex(tableName, indexName);
310 }
311
312 public _Iterator getIndexedIterator(_Iterator iterator, _ExpressionOrderValues orderValues, CbCUsffWbmvfIboemfs tempHandler) throws DException {
313 return serverSession.getIndexedIterator(iterator, orderValues, tempHandler);
314 }
315
316 public HashMap getViewMap() throws DException {
317 return serverSession.getViewMap();
318 }
319
320 public _ViewObject getViewObject(QualifiedIdentifier viewName, boolean checkUserRight) throws DException {
321 return serverSession.getViewObject(viewName, checkUserRight);
322 }
323
324 public boolean getAutoCommit() {
325 return serverSession.getAutoCommit();
326 }
327
328 public Object [] getForeignConstraintCharacteritics(QualifiedIdentifier tableName, String columnName) throws DException {
329 return serverSession.getForeignConstraintCharacteritics(tableName, columnName);
330 }
331
332 public String [] getUniqueInformation(QualifiedIdentifier tableName) throws DException {
333 return serverSession.getUniqueInformation(tableName);
334 }
335
336 public boolean cursorAlreadyCreated(String name) {
337 return serverSession.cursorAlreadyCreated(name);
338 }
339
340 public void addCursor(String cname, _Cursor cur) {
341 serverSession.addCursor(cname, cur);
342 }
343
344 public _Cursor getCursor(String cname) {
345 return serverSession.getCursor(cname);
346 }
347
348 public _SequenceManager getSequenceManager() throws DException {
349 return serverSession.getSequenceManager();
350 }
351
352 public int getEstimatedRowCount(QualifiedIdentifier parm1) throws DException {
353 return serverSession.getEstimatedRowCount(parm1);
354 }
355
356 public Object getSessionId() throws DException {
357 return serverSession.getSessionId();
358 }
359
360 public Object [] createDeepRecordCopy(QualifiedIdentifier tableName, Object [] keys) throws DException {
361 return serverSession.createDeepRecordCopy(tableName, keys);
362 }
363
364 public void startSavePoint() throws DException {
365 serverSession.startSavePoint();
366 }
367
368 public void commitSavePoint() throws DException {
369 serverSession.commitSavePoint();
370 }
371
372 public void rollbackSavePoint() throws DException {
373 serverSession.rollbackSavePoint();
374 }
375
376 public void releaseSavePoint() throws DException {
377 }
378
379 public void alterTable(QualifiedIdentifier tableName, _ColumnCharacteristics cc) throws DException {
380 alterTable(tableName, cc);
381 }
382
383 public boolean isConstraintCheckingDeffered() {
384 return serverSession.isConstraintCheckingDeffered();
385 }
386
387 public void dropDatabase(String databaseName, String userName, String password) throws DException {
388 serverSession.dropDatabase(databaseName, userName, password);
389 }
390
391 public boolean isDataModified() throws DException {
392 return serverSession.isDataModified();
393 }
394
395 public void alterTable(QualifiedIdentifier tableName, _ColumnCharacteristics cc, Object defaultValue) throws DException {
396 serverSession.alterTable(tableName, cc, defaultValue);
397 }
398
399 public void ignoreParallelSavePoint() throws DException {
400 serverSession.ignoreParallelSavePoint();
401 }
402
403 public void allowParallelSavePoint() throws DException {
404 serverSession.allowParallelSavePoint();
405 }
406
407 public void checkImmediateConstraintsOnCommit() throws DException {
408 serverSession.checkImmediateConstraintsOnCommit();
409 }
410
411 public void hideSavePoint() throws DException {
412 serverSession.hideSavePoint();
413 }
414
415 public void unhideSavePoint() throws DException {
416 serverSession.unhideSavePoint();
417 }
418
419 public _Iterator getIterator(QualifiedIdentifier tableName, _SingleTableExecuter ste) throws DException {
420 return serverSession.getIterator(tableName, ste);
421 }
422
423 public _Iterator getForeignKeyIterator(QualifiedIdentifier tableName, _SingleTableExecuter ste, _TableAlias[] tableAliasArray) throws DException {
424 return serverSession.getForeignKeyIterator(tableName, ste, tableAliasArray);
425 }
426
427 public void rollbackSavePoint(String parm1) throws com.daffodilwoods.database.resource.DException {
428 serverSession.rollbackSavePoint(parm1);
429 }
430
431 public void releaseSavePoint(String parm1) throws com.daffodilwoods.database.resource.DException {
432 serverSession.releaseSavePoint(parm1);
433 }
434
435 public void setSavePoint(String parm1) throws com.daffodilwoods.database.resource.DException {
436 serverSession.setSavePoint(parm1);
437 }
438
439 public String setSavePoint() throws com.daffodilwoods.database.resource.DException {
440 return serverSession.setSavePoint();
441 }
442
443 public Object execute(String query, int queryTimeOut, int type) throws DException {
444
445 throw new java.lang.UnsupportedOperationException ("Method execute() not yet implemented.");
446 }
447
448 public Object executeQuery(String query, int queryTimeOut, int type) throws DException {
449
450 throw new java.lang.UnsupportedOperationException ("Method executeQueryt() not yet implemented.");
451 }
452
453 public void setType(int type) {
454 iteratorType = type;
455 }
456
457 public void setRole(String roleName) throws DException {
458
459 throw new java.lang.UnsupportedOperationException ("Method setRole() not yet implemented.");
460 }
461
462 public boolean isActiveAuthorization(String authorization) throws DException {
463
464 throw new java.lang.UnsupportedOperationException ("Method isActiveAuthorization not yet implemented.");
465 }
466
467 public void createFullTextIndex(QualifiedIdentifier tableName, String indexName, String [] columnName) throws DException {
468 throw new java.lang.UnsupportedOperationException ("Method createFullTextIndex() not yet implemented.");
469 }
470
471 public void dropFullTextIndex(QualifiedIdentifier tableName, String indexName) throws DException {
472 throw new java.lang.UnsupportedOperationException ("Method dropFullTextIndex() not yet implemented.");
473 }
474
475 public _Iterator getInternalIterator(QualifiedIdentifier tableName, _SingleTableExecuter singleTableExecuter) throws DException {
476 return serverSession.getInternalIterator(tableName, singleTableExecuter);
477 }
478
479 public double getDbVersion() throws DException {
480 return serverSession.getDbVersion();
481
482 }
483
484 public void refereshTable(QualifiedIdentifier tableName,
485 boolean dropTable) throws DException {
486 serverSession.refereshTable(tableName, dropTable);
487 }
488
489 public _Triggers[] getAfterInsertTrigger(QualifiedIdentifier tableName, _TriggerCharacteristics triggerCharacteristics, _StatementExecutionContext statementExecutionContext) throws DException {
490 return serverSession.getAfterInsertTrigger(tableName, triggerCharacteristics, statementExecutionContext);
491 }
492
493 public _Triggers[] getBeforeInsertTrigger(QualifiedIdentifier tableName, _TriggerCharacteristics triggerCharacteristics, _StatementExecutionContext statementExecutionContext) throws DException {
494 return serverSession.getBeforeInsertTrigger(tableName, triggerCharacteristics, statementExecutionContext);
495 }
496
497 public _Triggers[] getAfterUpdateTrigger(QualifiedIdentifier tableName, _TriggerCharacteristics triggerCharacteristics, _StatementExecutionContext statementExecutionContext, int[] cols) throws DException {
498 return serverSession.getAfterUpdateTrigger(tableName, triggerCharacteristics, statementExecutionContext, cols);
499 }
500
501 public _Triggers[] getBeforeUpdateTrigger(QualifiedIdentifier tableName, _TriggerCharacteristics triggerCharacteristics, _StatementExecutionContext statementExecutionContext, int[] cols) throws DException {
502 return serverSession.getBeforeUpdateTrigger(tableName, triggerCharacteristics, statementExecutionContext, cols);
503 }
504
505 public _Triggers[] getAfterDeleteTrigger(QualifiedIdentifier tableName, _TriggerCharacteristics triggerCharacteristics, _StatementExecutionContext statementExecutionContext) throws DException {
506 return serverSession.getAfterDeleteTrigger(tableName, triggerCharacteristics, statementExecutionContext);
507 }
508
509 public _Triggers[] getBeforeDeleteTrigger(QualifiedIdentifier tableName, _TriggerCharacteristics triggerCharacteristics, _StatementExecutionContext statementExecutionContext) throws DException {
510 return serverSession.getBeforeDeleteTrigger(tableName, triggerCharacteristics, statementExecutionContext);
511 }
512
513 public void refreshTriggerInfo(QualifiedIdentifier tableName) throws DException {
514 serverSession.refreshTriggerInfo(tableName);
515
516 }
517
518 public void refreshTriggers(QualifiedIdentifier tableName) throws DException {
519 serverSession.refreshTriggers(tableName);
520 }
521
522 public _Triggers[] getAfterInsertTriggerOfStatementLevel(QualifiedIdentifier tableName, _TriggerCharacteristics triggerCharacteristics, _StatementExecutionContext statementExecutionContext) throws DException {
523 return serverSession.getAfterInsertTriggerOfStatementLevel(tableName, triggerCharacteristics, statementExecutionContext);
524 }
525
526 public _Triggers[] getBeforeInsertTriggerOfStatementLevel(QualifiedIdentifier tableName, _TriggerCharacteristics triggerCharacteristics, _StatementExecutionContext statementExecutionContext) throws DException {
527 return serverSession.getBeforeInsertTriggerOfStatementLevel(tableName, triggerCharacteristics, statementExecutionContext);
528 }
529
530 public _Triggers[] getAfterUpdateTriggerOfStatementLevel(QualifiedIdentifier tableName, _TriggerCharacteristics triggerCharacteristics, _StatementExecutionContext statementExecutionContext, int[] cols) throws DException {
531 return serverSession.getAfterUpdateTriggerOfStatementLevel(tableName, triggerCharacteristics, statementExecutionContext, cols);
532 }
533
534 public _Triggers[] getBeforeUpdateTriggerOfStatementLevel(QualifiedIdentifier tableName, _TriggerCharacteristics triggerCharacteristics, _StatementExecutionContext statementExecutionContext, int[] cols) throws DException {
535 return serverSession.getBeforeUpdateTriggerOfStatementLevel(tableName, triggerCharacteristics, statementExecutionContext, cols);
536 }
537
538 public _Triggers[] getAfterDeleteTriggerOfStatementLevel(QualifiedIdentifier tableName, _TriggerCharacteristics triggerCharacteristics, _StatementExecutionContext statementExecutionContext) throws DException {
539 return serverSession.getAfterDeleteTriggerOfStatementLevel(tableName, triggerCharacteristics, statementExecutionContext);
540 }
541
542 public _Triggers[] getBeforeDeleteTriggerOfStatementLevel(QualifiedIdentifier tableName, _TriggerCharacteristics triggerCharacteristics, _StatementExecutionContext statementExecutionContext) throws DException {
543 return serverSession.getBeforeDeleteTriggerOfStatementLevel(tableName, triggerCharacteristics, statementExecutionContext);
544 }
545
546 public ArrayList getCreateIndexList() throws DException {
547 return serverSession.getCreateIndexList();
548 }
549
550 public void resetTime() throws DException {
551 dateTimeFunctions.resetTransactionDate();
552 }
553
554 public void refreshConstraint(QualifiedIdentifier tableName) throws DException {
555 serverSession.refreshConstraint(tableName);
556 }
557
558 public int getTypeForPrivilige() throws DException {
559 return -1;
560 }
561
562 }
563 |
Popular Tags |
Java API By Example, From Geeks To Geeks.