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