1 package com.daffodilwoods.daffodildb.server.datadictionarysystem; 2 3 11 import com.daffodilwoods.daffodildb.server.serversystem.*; 12 import com.daffodilwoods.daffodildb.server.sql99.*; 13 import com.daffodilwoods.daffodildb.server.sql99.common.*; 14 import com.daffodilwoods.daffodildb.server.sql99.ddl.descriptors.*; 15 import com.daffodilwoods.daffodildb.server.sql99.ddl.utility.*; 16 import com.daffodilwoods.daffodildb.server.sql99.dql.execution.*; 17 import com.daffodilwoods.daffodildb.server.sql99.dql.iterator.*; 18 import com.daffodilwoods.daffodildb.server.sql99.expression.booleanvalueexpression.*; 19 import com.daffodilwoods.daffodildb.server.sql99.utils.parser.*; 20 import com.daffodilwoods.daffodildb.utils.*; 21 import com.daffodilwoods.database.general.*; 22 import com.daffodilwoods.database.resource.*; 23 24 public class PreparedStatementGetter { 25 _ServerSession serverSession; 26 private _Executer indexInfoExecuter; 27 private _Executer indexColumnsExecuter; 28 private _Executer fullTextIndexColumnsExecuter; 29 private _Executer tableDescriptorExecuterForCheckConstraints; 30 private _Executer tableDescriptorExecuterForCheckConstraintsNonDef; 31 private _Executer tablesForeignConstriaintExecuter; 32 private _Executer primaryKeysExecuter; 33 private _Executer relatedTableAndColumnExecuter; 34 private _Executer columnExecuter; 35 private _Executer dataTypeExecuter; 36 private _Executer tableTypesAndCodesExecuter; 37 private _Executer checkIsIndexTableExecuter; 38 private _Executer domainConstraintsExecuter; 39 private _Executer deferredCheckingExecuter; 40 private _Executer defalutClauseExecuter; 41 private _Executer tableDescriptorExecuterForPrimaryAndUniqueConstraint; 42 private _Executer tableDescriptorExecuterForPrimaryAndUniqueConstraintNonDef; 43 private _Executer tablePrivilegesForTableExecuter; 44 private _Executer columnPrivilegesForColumnExecuter; 45 private _Executer referencedConstraintsJoinExecuter; 46 private _Executer referencedConstraintsJoinExecuterNonDef; 47 private _Executer referencingConstraintsJoinExecuter; 48 private _Executer referencingConstraintsJoinExecuterNonDef; 49 private _Executer trigersExecuterWithEventCondition; 50 private _Executer trigersExecuterWithTriggerNameCondition; 51 private _Executer triggeredUpdatedExecuterForAllColumns; 52 private _Executer triggerExecuterForUpdateType; 53 private _Executer viewsExecuterWithNameCondition; 54 private _Executer checkConstraintExecuter; 55 private _Executer tableConstraintExecuter; 56 private _Executer keyColumnUsageExecuter; 57 private _Executer triggerUpdateColumnsExecuter; 58 private _Executer checkTableUsedExecuter; 59 private _Executer checkColumnUsedExecuter; 60 private _Executer routinePrivilegesExecuter; 61 private _Executer hasAnyTriggerOnViewExecuter; 62 private _Executer isDateSpanTableExecuter; 63 private _Executer viewsForTableExecuter; 64 private _Executer materializedViewsFromViewsExecuter; 65 private _Executer mataerailzedQueryDefinitionExecuter; 66 private _Executer isValidRoleExecuter; 67 68 private _Executer tablesTableExecuter; 69 private _Executer columnsTableExecuter; 70 private _Executer dataTypeDescriptorTableExecuter; 71 private _Executer referentialConstraintsTableExecuter; 72 private _Executer keyColumnUsageTableExecuter; 73 private _Executer columnPrivilegesTableExecuter; 74 private _Executer tablePrivlegesTableExecuter; 75 private _Executer schemataTableExecuter; 76 private _Executer domainTableExecuter; 77 private _Executer domianConstrainttaTableExecuter; 78 private _Executer tableConstraintExecuterForPrimaryKey; 79 private _Executer RoleAuthorizationsExecterforGranteeOnly; 80 private _Executer allRoleAuthorizationsExecterforGranteeOnly; 81 private _Executer allRoleAuthorizationsExecuterforGranteeAndPublic; 82 private _Executer fulltextindexExecuter; 83 private _Executer userValidity; 84 private _Executer roleValidity; 85 private _Executer domainValidity; 86 private _Executer columnsExecuter; 87 private _Executer tableDependent_A; 88 private _Executer tableDependent_B; 89 private _Executer columnDependent_A; 90 private _Executer columnDependent_B; 91 private _Executer routineDependent_A; 92 private _Executer usageDependent_A; 93 private _Executer dependent_C; 94 private _Executer domainCheckConstaint; 95 private _Executer usageDependent_C_Column; 96 private _Executer usageDependent_C_Usage; 97 98 private _Executer primaryConstraintExecuter; 99 private _Executer checkColumnConstraintExecuter; 100 private _Executer checkDomainConstraintExecuter; 101 private _Executer checkTableConstraintExecuter; 102 private _Executer executerTriggerOnTableForUser; 103 private _Executer executerAbandonedViewForColumn; 104 private _Executer executerAbandonedViewForTable; 105 private _Executer indexExecuter; 106 private _Executer deleteConstraintExecuter; 107 private _Executer referentialConstraintExecuter; 108 private _Executer constraintExecuter; 109 private _Executer viewTableUsageExecuter; 110 private _Executer triggerTableUsageExecuter; 111 private _Executer routineTableUsageExecuter; 112 private _Executer tableReferencedCheckConstraintExecuter; 113 private _Executer conditionIndexInfoExecuter; 114 private _Executer dependentReferentialConstraintExecuter; 115 private _Executer sequenceExecuter; 116 private _Executer fullTextInfoExecuter; 117 private _Executer fullTextColumnInfoExecuter; 118 private _Executer referencedConstraintExecuter; 119 private _Executer keyColumnExecuter; 120 121 private booleanvalueexpression tablesTableCondition; 122 private booleanvalueexpression columnsTableCondition; 123 private booleanvalueexpression dataTypeDescriptorTableCondition; 124 private booleanvalueexpression tableConstraintsTableCondition; 125 private booleanvalueexpression checkConstraintsTableCondition; 126 private booleanvalueexpression referentialConstraintsTableCondition; 127 private booleanvalueexpression keyColumnUsageTableCondition; 128 private booleanvalueexpression columnPrivilegesTableCondition; 129 private booleanvalueexpression tablePrivlegesTableCondition; 130 private booleanvalueexpression checkTableUsageTableCondition; 131 private booleanvalueexpression checkColumnUsageTableCondition; 132 private booleanvalueexpression indexInfoTableCondition; 133 private booleanvalueexpression fullTextIndexInfoTableCondition; 134 135 private _Iterator columnsIter; 136 private TableDetails columnsTableDetail; 137 private _Iterator columnPrivilegesIter; 138 private TableDetails columnsPrivilegeTableDetail; 139 private _Iterator tablePrivilegesIter; 140 private TableDetails tablePrivilegeTableDetail; 141 private _Iterator dataTypeIter; 142 private TableDetails dataTypeTableDetail; 143 144 public PreparedStatementGetter(_ServerSession serverSession0) { 145 serverSession = serverSession0; 146 } 147 148 public _Executer getIndexInfoExecuter() throws DException { 149 if (indexInfoExecuter == null) { 150 String indexInfoQuery = "Select * from " + SystemTables.INDEXINFO 151 + " where table_catalog = ? and table_schema = ? and table_name = ? "; 152 indexInfoExecuter = (_Executer) serverSession.executeQueryParameterised(indexInfoQuery, 0); 153 } 154 return indexInfoExecuter; 155 } 156 157 public _Executer getFullTextIndexExecuter() throws DException { 158 if (fulltextindexExecuter == null) { 159 String indexInfoQuery = "Select * from " + SystemTables.FULLTEXTINFO 160 + " where table_catalog = ? and table_schema = ? and table_name = ? "; 161 fulltextindexExecuter = (_Executer) serverSession.executeQueryParameterised(indexInfoQuery, 0); 162 } 163 return fulltextindexExecuter; 164 } 165 166 public _Executer getIndexColumnsExecuter() throws DException { 167 if (indexColumnsExecuter == null) { 168 String indexColumnsQuery = "Select * from " 169 + SystemTables.INDEXCOLUMNS + " where table_catalog = ? and table_schema = ? and table_name = ? and indexname = ? order by ordinal_position"; 170 indexColumnsExecuter = (_Executer) serverSession.executeQueryParameterised(indexColumnsQuery, 0); 171 } 172 return indexColumnsExecuter; 173 } 174 175 public _Executer getFullTextIndexColumnsExecuter() throws DException { 176 if (fullTextIndexColumnsExecuter == null) { 177 String indexColumnsQuery = "Select * from " 178 + SystemTables.FULLTEXTCOLUMNINFO + " where table_catalog = ? and table_schema = ? and table_name = ? and indexname = ? order by ordinal_position"; 179 fullTextIndexColumnsExecuter = (_Executer) serverSession.executeQueryParameterised(indexColumnsQuery, 0); 180 } 181 return fullTextIndexColumnsExecuter; 182 } 183 184 public _Executer getTableDescriptorExecuterForCheckConstraints() throws DException { 185 if (tableDescriptorExecuterForCheckConstraints == null) { 186 String tableDescriptorQueryForCheckConstraints = "select * from " + SystemTables.table_constraints_TableName + " where table_catalog = ? and table_schema = ? and table_name = ? and constraint_type = '" + SqlKeywords.CHECK + "' and is_deferrable = 'YES' and initially_deferred = 'YES'"; 187 tableDescriptorExecuterForCheckConstraints = (_Executer) serverSession.executeQueryParameterised(tableDescriptorQueryForCheckConstraints, 0); 188 } 189 return tableDescriptorExecuterForCheckConstraints; 190 } 191 192 public _Executer getTableDescriptorExecuterForCheckConstraintsNonDef() throws DException { 193 if (tableDescriptorExecuterForCheckConstraintsNonDef == null) { 194 String tableDescriptorQueryForCheckConstraints = "select * from " + SystemTables.table_constraints_TableName + " where table_catalog = ? and table_schema = ? and table_name = ? and constraint_type = '" + SqlKeywords.CHECK + "' and (is_deferrable = 'NO' or (is_deferrable = 'YES' and initially_deferred = 'NO')) "; 195 tableDescriptorExecuterForCheckConstraintsNonDef = (_Executer) serverSession.executeQueryParameterised(tableDescriptorQueryForCheckConstraints, 0); 196 } 197 return tableDescriptorExecuterForCheckConstraintsNonDef; 198 } 199 200 public _Executer getTablesForeignConstriaintExecuter() throws DException { 201 if (tablesForeignConstriaintExecuter == null) { 202 String tablesForeignConstriaintQuery = " Select " 203 + SystemTables.key_column_usage_TableName + ".constraint_catalog, " 204 + SystemTables.key_column_usage_TableName + ".constraint_schema , " 205 + SystemTables.key_column_usage_TableName + ".constraint_name, " 206 + SystemTables.key_column_usage_TableName + ".ordinal_position " 207 + " from " + SystemTables.key_column_usage_TableName 208 + "," + SystemTables.table_constraints_TableName 209 + " where " 210 + SystemTables.key_column_usage_TableName + ".table_catalog = ? and " 211 + SystemTables.key_column_usage_TableName + ".table_schema = ? and " 212 + SystemTables.key_column_usage_TableName + ".table_name = ? and " 213 + SystemTables.key_column_usage_TableName + ".column_name = ?" 214 + " and (" 215 + SystemTables.table_constraints_TableName + ".constraint_catalog = " + SystemTables.key_column_usage_TableName + ".constraint_catalog and " 216 + SystemTables.table_constraints_TableName + ".constraint_schema = " + SystemTables.key_column_usage_TableName + ".constraint_schema and " 217 + SystemTables.table_constraints_TableName + ".constraint_name = " + SystemTables.key_column_usage_TableName + ".constraint_name " 218 + " ) " 219 + " and " + SystemTables.table_constraints_TableName + ".constraint_type = '" + SqlKeywords.FOREIGN + " " + SqlKeywords.KEY 220 + "\'"; 221 tablesForeignConstriaintExecuter = (_Executer) serverSession.executeQueryParameterised(tablesForeignConstriaintQuery, 0); 222 } 223 return tablesForeignConstriaintExecuter; 224 } 225 226 public _Executer getPrimaryKeysExecuter() throws DException { 227 if (primaryKeysExecuter == null) { 228 String primaryKeysQuery = " Select " 229 + SystemTables.key_column_usage_TableName + ".column_name" 230 + " from " + SystemTables.key_column_usage_TableName + ", " 231 + SystemTables.table_constraints_TableName 232 + " where " 233 + SystemTables.key_column_usage_TableName + ".constraint_catalog = " 234 + SystemTables.table_constraints_TableName + ".constraint_catalog And " 235 + SystemTables.key_column_usage_TableName + ".constraint_schema = " 236 + SystemTables.table_constraints_TableName + ".constraint_schema And " 237 + SystemTables.key_column_usage_TableName + ".constraint_name = " 238 + SystemTables.table_constraints_TableName + ".constraint_name And " 239 + SystemTables.table_constraints_TableName + ".table_catalog = ? and " 240 + SystemTables.table_constraints_TableName + ".table_schema = ? and " 241 + SystemTables.table_constraints_TableName + ".table_name = ? and " 242 + SystemTables.table_constraints_TableName + ".constraint_type = '" + SqlKeywords.PRIMARY + " " + SqlKeywords.KEY 243 + "'"; 244 primaryKeysExecuter = (_Executer) serverSession.executeQueryParameterised(primaryKeysQuery, 0); 245 } 246 return primaryKeysExecuter; 247 } 248 249 public _Executer getrelatedTableAndColumnExecuter() throws DException { 250 if (relatedTableAndColumnExecuter == null) { 251 String relatedTableAndColumnQuery = " Select " 252 + SystemTables.key_column_usage_TableName + ".table_catalog," 253 + SystemTables.key_column_usage_TableName + ".table_schema ," 254 + SystemTables.key_column_usage_TableName + ".table_name ," 255 + SystemTables.key_column_usage_TableName + ".column_name" 256 + " from " + SystemTables.key_column_usage_TableName 257 + "," + SystemTables.referential_constraints_TableName 258 + " where " 259 + SystemTables.key_column_usage_TableName + ".constraint_catalog = " 260 + SystemTables.referential_constraints_TableName + ".unique_constraint_catalog and " 261 + SystemTables.key_column_usage_TableName + ".constraint_schema = " 262 + SystemTables.referential_constraints_TableName + ".unique_constraint_schema and " 263 + SystemTables.key_column_usage_TableName + ".constraint_name =" 264 + SystemTables.referential_constraints_TableName + ".unique_constraint_name and " 265 + SystemTables.referential_constraints_TableName + ".constraint_catalog = ? and " 266 + SystemTables.referential_constraints_TableName + ".constraint_schema = ? and " 267 + SystemTables.referential_constraints_TableName + ".constraint_name = ? "; 268 relatedTableAndColumnExecuter = (_Executer) serverSession.executeQueryParameterised(relatedTableAndColumnQuery, 0); 269 } 270 return relatedTableAndColumnExecuter; 271 } 272 273 public _Executer getcolumnExecuter() throws DException { 274 if (columnExecuter == null) { 275 String columnQuery = "Select * from " + SystemTables.columns_TableName + " where table_catalog = ? and table_schema = ? and table_name = ? order by ordinal_position"; 276 columnExecuter = (_Executer) serverSession.executeQueryParameterised(columnQuery, 0); 277 } 278 return columnExecuter; 279 } 280 281 public _Executer getDataTypeExecuter() throws DException { 282 if (dataTypeExecuter == null) { 283 String dataTypeQuery = "Select * from " + SystemTables.dataTypeDescriptor_TableName + " where object_catalog = ? and object_schema = ? and object_name = ? and object_type = 'TABLE'"; 284 dataTypeExecuter = (_Executer) serverSession.executeQueryParameterised(dataTypeQuery, 0); 285 } 286 return dataTypeExecuter; 287 } 288 289 public _Executer getDataTypeDescriptorTableExecuter() throws DException { 290 if (dataTypeDescriptorTableExecuter == null) { 291 StringBuffer clause = new StringBuffer (); 292 clause.append("select * from "); 293 clause.append(SystemTables.dataTypeDescriptor_TableName); 294 clause.append(" where "); 295 clause.append("object_catalog = ? and object_schema = ? and object_name = ? and object_type = ? and dtd_identifier = ? "); 296 dataTypeDescriptorTableExecuter = (_Executer) serverSession.executeQueryParameterised(clause.toString(), 0); 297 } 298 return dataTypeDescriptorTableExecuter; 299 } 300 301 public _Executer getTableTypesAndCodesExecuter() throws DException { 302 if (tableTypesAndCodesExecuter == null) { 303 String tableTypesQuery = "select table_type,country_code,language_code from " + SystemTables.tables_TableName + " where table_catalog = ? and table_schema = ? and table_name = ?"; 304 tableTypesAndCodesExecuter = (_Executer) serverSession.executeQueryParameterised(tableTypesQuery, 0); 305 } 306 return tableTypesAndCodesExecuter; 307 } 308 309 public _Executer getCheckIsIndexTableExecuter() throws DException { 310 if (checkIsIndexTableExecuter == null) { 311 String checkIsIndexTableQuery = "select table_catalog,table_schema,table_name,indexname from " + SystemTables.INDEXINFO 312 + " where indextablename = ? "; 313 checkIsIndexTableExecuter = (_Executer) serverSession.executeQueryParameterised(checkIsIndexTableQuery, 0); 314 } 315 return checkIsIndexTableExecuter; 316 } 317 318 public _Executer getDomainConstraintsExecuter() throws DException { 319 if (domainConstraintsExecuter == null) { 320 String domainConstraintsQuery = "select * from " + SystemTables.domain_constraints_TableName + " where domain_catalog = ? and domain_schema = ? and domain_name = ? "; 321 domainConstraintsExecuter = (_Executer) serverSession.executeQueryParameterised(domainConstraintsQuery, 0); 322 } 323 return domainConstraintsExecuter; 324 } 325 326 public _Executer getdeferredCheckingExecuter() throws DException { 327 if (deferredCheckingExecuter == null) { 328 String deferredChecking = "select * from " + SystemTables.table_constraints_TableName + " where table_catalog = ? and table_schema = ? and table_name = ? and is_deferrable ='yes'"; 329 deferredCheckingExecuter = (_Executer) serverSession.executeQueryParameterised(deferredChecking, 0); 330 } 331 return deferredCheckingExecuter; 332 } 333 334 public _Executer getDefalutClauseExecuter() throws DException { 335 if (defalutClauseExecuter == null) { 336 String defalutClauseQuery = "select column_default,is_autoIncrement from " + SystemTables.columns_TableName 337 + " where table_catalog = ? and table_schema = ? and table_name = ? and column_name != '" + SystemFields.systemFields[SystemFields.rowId] + "' order by ordinal_position "; 338 defalutClauseExecuter = (_Executer) serverSession.executeQueryParameterised(defalutClauseQuery, 0); 339 } 340 return defalutClauseExecuter; 341 } 342 343 public _Executer getTableDescriptorExecuterForPrimaryAndUniqueConstraint() throws DException { 344 if (tableDescriptorExecuterForPrimaryAndUniqueConstraint == null) { 345 String tableDescriptorQueryForPrimaryAndUniqueConstraint = "select * from " + SystemTables.table_constraints_TableName + " where table_catalog = ? and table_schema = ? and table_name = ? and constraint_type in ('" + SqlKeywords.PRIMARY + " " + SqlKeywords.KEY + "','" + SqlKeywords.UNIQUE + "') and is_deferrable = 'YES' and initially_deferred = 'YES'"; 346 tableDescriptorExecuterForPrimaryAndUniqueConstraint = (_Executer) serverSession.executeQueryParameterised(tableDescriptorQueryForPrimaryAndUniqueConstraint, 0); 347 } 348 return tableDescriptorExecuterForPrimaryAndUniqueConstraint; 349 } 350 351 public _Executer getTableDescriptorExecuterForPrimaryAndUniqueConstraintNonDef() throws DException { 352 if (tableDescriptorExecuterForPrimaryAndUniqueConstraintNonDef == null) { 353 String tableDescriptorQueryForPrimaryAndUniqueConstraint = "select * from " + SystemTables.table_constraints_TableName + " where table_catalog = ? and table_schema = ? and table_name = ? and constraint_type in ('" + SqlKeywords.PRIMARY + " " + SqlKeywords.KEY + "','" + SqlKeywords.UNIQUE + "') and (is_deferrable = 'NO' or (is_deferrable = 'YES' and initially_deferred = 'NO'))"; 354 tableDescriptorExecuterForPrimaryAndUniqueConstraintNonDef = (_Executer) serverSession.executeQueryParameterised(tableDescriptorQueryForPrimaryAndUniqueConstraint, 0); 355 } 356 return tableDescriptorExecuterForPrimaryAndUniqueConstraintNonDef; 357 } 358 359 public _Executer getTablePrivilegesForTableExecuter() throws DException { 360 if (tablePrivilegesForTableExecuter == null) { 361 String tablePrivilegesForTableQuery = "select privilege_type,is_grantable from " + SystemTables.table_privileges_TableName 362 + " where table_catalog = ? and table_schema = ? and table_name = ? and grantee in ( ? )"; tablePrivilegesForTableExecuter = (_Executer) serverSession.executeQueryParameterised(tablePrivilegesForTableQuery, 0); 364 } 365 return tablePrivilegesForTableExecuter; 366 } 367 368 public _Executer getColumnPrivilegesForColumnExecuter() throws DException { 369 if (columnPrivilegesForColumnExecuter == null) { 370 String columnPrivilegesForColumnQuery = "select privilege_type,is_grantable from " + SystemTables.column_privileges_TableName 371 + " where table_catalog = ? and table_schema = ? and table_name = ? and column_name = ? and grantee in ( ? )"; columnPrivilegesForColumnExecuter = (_Executer) serverSession.executeQueryParameterised(columnPrivilegesForColumnQuery, 0); 373 } 374 return columnPrivilegesForColumnExecuter; 375 } 376 377 public _Executer getReferencedConstraintsJoinExecuter() throws DException { 378 if (referencedConstraintsJoinExecuter == null) { 379 String referencedConstraintsJoinQuery = " Select * from " + SystemTables.referential_constraints_TableName 380 + " , " + SystemTables.table_constraints_TableName + " as FCTable " 381 + " , " + SystemTables.table_constraints_TableName + " as PCTable" 382 + " where (" 383 + SystemTables.referential_constraints_TableName + ".constraint_catalog = FCtable.constraint_catalog and " 384 + SystemTables.referential_constraints_TableName + ".constraint_schema = FCTable.constraint_schema and " 385 + SystemTables.referential_constraints_TableName + ".constraint_name = FCTable.constraint_name and " 386 + "FCTable.constraint_type = '" + SqlKeywords.FOREIGN + " " + SqlKeywords.KEY + "' )" 387 + " and " 388 + SystemTables.referential_constraints_TableName + ".unique_constraint_catalog = PCTable.constraint_catalog and " 389 + SystemTables.referential_constraints_TableName + ".unique_constraint_schema = PCTable.constraint_schema and " 390 + SystemTables.referential_constraints_TableName + ".unique_constraint_name = " 391 + "PCTable.constraint_name and PCTable.table_catalog = ? and PCTable.table_schema = ? and " 392 + "PCTable.table_name = ? and (PCTable.constraint_type = '" + SqlKeywords.PRIMARY + " " + SqlKeywords.KEY 393 + "' or PCTable.constraint_type = '" + SqlKeywords.UNIQUE 394 + "' ) and FCTable.is_deferrable = 'YES' and FCTable.initially_deferred = 'YES'"; 395 referencedConstraintsJoinExecuter = (_Executer) serverSession.executeQueryParameterised(referencedConstraintsJoinQuery, 0); 396 } 397 return referencedConstraintsJoinExecuter; 398 } 399 400 public _Executer getReferencedConstraintsJoinExecuterNonDef() throws DException { 401 if (referencedConstraintsJoinExecuterNonDef == null) { 402 String referencedConstraintsJoinQuery = " Select * from " + SystemTables.referential_constraints_TableName 403 + " , " + SystemTables.table_constraints_TableName + " as FCTable " 404 + " , " + SystemTables.table_constraints_TableName + " as PCTable" 405 + " where (" 406 + SystemTables.referential_constraints_TableName + ".constraint_catalog = FCtable.constraint_catalog and " 407 + SystemTables.referential_constraints_TableName + ".constraint_schema = FCTable.constraint_schema and " 408 + SystemTables.referential_constraints_TableName + ".constraint_name = FCTable.constraint_name and " 409 + "FCTable.constraint_type = '" + SqlKeywords.FOREIGN + " " + SqlKeywords.KEY + "' )" 410 + " and " 411 + SystemTables.referential_constraints_TableName + ".unique_constraint_catalog = PCTable.constraint_catalog and " 412 + SystemTables.referential_constraints_TableName + ".unique_constraint_schema = PCTable.constraint_schema and " 413 + SystemTables.referential_constraints_TableName + ".unique_constraint_name = " 414 + "PCTable.constraint_name and PCTable.table_catalog = ? and PCTable.table_schema = ? and " 415 + "PCTable.table_name = ? and (PCTable.constraint_type = '" + SqlKeywords.PRIMARY + " " + SqlKeywords.KEY 416 + "' or PCTable.constraint_type = '" + SqlKeywords.UNIQUE 417 + "' ) and (FCTable.is_deferrable = 'NO' or (FCTable.is_deferrable = 'YES' and FCTable.initially_deferred = 'NO')) "; 418 referencedConstraintsJoinExecuterNonDef = (_Executer) serverSession.executeQueryParameterised(referencedConstraintsJoinQuery, 0); 419 } 420 return referencedConstraintsJoinExecuterNonDef; 421 } 422 423 public _Executer getReferencingConstraintsJoinExecuter() throws DException { 424 if (referencingConstraintsJoinExecuter == null) { 425 String referencingConstraintsJoinQuery = " Select * from " + SystemTables.referential_constraints_TableName 426 + " as RC , " + SystemTables.table_constraints_TableName 427 + " as TC where (" 428 + "RC.constraint_catalog = TC.constraint_catalog and " 429 + "RC.constraint_schema = TC.constraint_schema and " 430 + "RC.constraint_name = TC.constraint_name) " 431 + " and " 432 + "TC.table_catalog = ? and TC.table_schema = ? and TC.table_name = ? and " 433 + "TC.constraint_type = '" + SqlKeywords.FOREIGN + " " + SqlKeywords.KEY + "' and " 434 + "TC.is_deferrable = 'YES' and TC.initially_deferred = 'YES'"; 435 referencingConstraintsJoinExecuter = (_Executer) serverSession.executeQueryParameterised(referencingConstraintsJoinQuery, 0); 436 } 437 return referencingConstraintsJoinExecuter; 438 } 439 440 public _Executer getReferencingConstraintsJoinExecuterNonDef() throws DException { 441 if (referencingConstraintsJoinExecuterNonDef == null) { 442 String referencingConstraintsJoinQuery = " Select * from " + SystemTables.referential_constraints_TableName 443 + " as RC , " + SystemTables.table_constraints_TableName 444 + " as TC where (" 445 + "RC.constraint_catalog = TC.constraint_catalog and " 446 + "RC.constraint_schema = TC.constraint_schema and " 447 + "RC.constraint_name = TC.constraint_name ) " 448 + " and " 449 + "TC.table_catalog = ? and TC.table_schema = ? and TC.table_name = ? and " 450 + "TC.constraint_type = '" + SqlKeywords.FOREIGN + " " + SqlKeywords.KEY + "' and " 451 + "(TC.is_deferrable = 'NO' or (TC.is_deferrable = 'YES' and TC.initially_deferred = 'NO'))"; 452 referencingConstraintsJoinExecuterNonDef = (_Executer) serverSession.executeQueryParameterised(referencingConstraintsJoinQuery, 0); 453 } 454 return referencingConstraintsJoinExecuterNonDef; 455 } 456 457 public _Executer getRoleAuthorizationsExecuterforGranteeOnly() throws DException { 458 if (RoleAuthorizationsExecterforGranteeOnly == null) 459 RoleAuthorizationsExecterforGranteeOnly = (_Executer) serverSession.executeQueryParameterised(QueryMaker.getRoleAuthorizationsforGranteeOnly(), 0); 460 return RoleAuthorizationsExecterforGranteeOnly; 461 } 462 463 public _Executer getTrigersExecuterWithEventCondition() throws DException { 464 if (trigersExecuterWithEventCondition == null) { 465 String trigersQueryWithEventCondition = "select * from " + SystemTables.triggers_TableName + " where event_object_catalog = ? and event_object_schema = ? and event_object_table = ? and event_manipulation = ? and action_orientation = ? and condition_timing = ? "; 466 trigersExecuterWithEventCondition = (_Executer) serverSession.executeQueryParameterised(trigersQueryWithEventCondition, 0); 467 } 468 return trigersExecuterWithEventCondition; 469 } 470 471 public _Executer getTrigersExecuterWithTriggerNameCondition() throws DException { 472 if (trigersExecuterWithTriggerNameCondition == null) { 473 String trigersQueryWithTriggerNameCondition = "select * from " + SystemTables.triggers_TableName + " where trigger_catalog = ? and trigger_schema = ? and trigger_name = ? and event_manipulation = ? and action_orientation = ? and condition_timing = ? "; 474 trigersExecuterWithTriggerNameCondition = (_Executer) serverSession.executeQueryParameterised(trigersQueryWithTriggerNameCondition, 0); 475 } 476 return trigersExecuterWithTriggerNameCondition; 477 } 478 479 public _Executer getTriggeredUpdatedExecuterForAllColumns() throws DException { 480 if (triggeredUpdatedExecuterForAllColumns == null) { 481 String triggeredUpdatedQueryForAllColumns = "select * from " + SystemTables.triggered_update_columns_TableName + " where event_object_catalog = ? and event_object_schema = ? and event_object_table = ? "; 482 triggeredUpdatedExecuterForAllColumns = (_Executer) serverSession.executeQueryParameterised(triggeredUpdatedQueryForAllColumns, 0); 483 } 484 return triggeredUpdatedExecuterForAllColumns; 485 } 486 487 public _Executer getTriggerExecuterForUpdateType() throws DException { 488 489 if (triggerExecuterForUpdateType == null) { 490 String query2 = "select trigger_catalog,trigger_schema,trigger_name from " + SystemTables.triggered_update_columns_TableName + " where event_object_catalog = ? and event_object_schema = ? and event_object_table = ?"; 491 String triggerQueryForUpdateType = "select * from " + SystemTables.triggers_TableName + " where (event_object_catalog = ? and event_object_schema = ? and event_object_table = ? and event_manipulation = '" + SqlKeywords.UPDATE + "' and action_orientation = ? and condition_timing = ? ) " 492 + " and (trigger_catalog,trigger_schema,trigger_name) NOT IN (" + query2 + ")"; 493 triggerExecuterForUpdateType = (_Executer) serverSession.executeQueryParameterised(triggerQueryForUpdateType, 0); 494 } 495 return triggerExecuterForUpdateType; 496 } 497 498 public _Executer getViewsExecuterWithNameCondition() throws DException { 499 if (viewsExecuterWithNameCondition == null) { 500 String viewsQueryWithNameCondition = "select view_definition, check_option, is_updatable, is_insertable_into from " + SystemTables.views_TableName 501 + " where table_catalog = ? and table_schema = ? and table_name = ? "; 502 viewsExecuterWithNameCondition = (_Executer) serverSession.executeQueryParameterised(viewsQueryWithNameCondition, 0); 503 } 504 return viewsExecuterWithNameCondition; 505 } 506 507 public _Executer getCheckConstraintExecuter() throws DException { 508 if (checkConstraintExecuter == null) { 509 String checkConstraintQuery = "select check_clause from " 510 + SystemTables.check_constraints_TableName 511 + " where constraint_catalog = ? and constraint_schema = ? " 512 + " and constraint_name = ? "; 513 checkConstraintExecuter = (_Executer) serverSession.executeQueryParameterised(checkConstraintQuery, 0); 514 } 515 return checkConstraintExecuter; 516 } 517 518 public _Executer getTableConstraintExecuter() throws DException { 519 if (tableConstraintExecuter == null) { 520 String tableConstraintQuery = "select * from " 521 + SystemTables.table_constraints_TableName 522 + " where constraint_catalog = ? and constraint_schema = ? " 523 + " and constraint_name = ? "; 524 tableConstraintExecuter = (_Executer) serverSession.executeQueryParameterised(tableConstraintQuery, 0); 525 } 526 return tableConstraintExecuter; 527 } 528 529 public _Executer getKeyColumnUsageExecuter() throws DException { 530 if (keyColumnUsageExecuter == null) { 531 String keyColumnUsageQuery = "select * from " 532 + SystemTables.key_column_usage_TableName 533 + " where constraint_catalog = ? and constraint_schema = ? " 534 + " and constraint_name = ? order by ordinal_position "; 535 keyColumnUsageExecuter = (_Executer) serverSession.executeQueryParameterised(keyColumnUsageQuery, 0); 536 } 537 return keyColumnUsageExecuter; 538 } 539 540 public _Executer getTriggerUpdateColumnsExecuter() throws DException { 541 if (triggerUpdateColumnsExecuter == null) { 542 String triggerUpdateColumnsQuery = "select event_object_column from " + SystemTables.triggered_update_columns_TableName 543 + " where trigger_catalog = ? and trigger_schema = ? and trigger_name = ?"; 544 triggerUpdateColumnsExecuter = (_Executer) serverSession.executeQueryParameterised(triggerUpdateColumnsQuery, 0); 545 } 546 return triggerUpdateColumnsExecuter; 547 } 548 549 public _Executer getCheckTableUsedExecuter() throws DException { 550 if (checkTableUsedExecuter == null) { 551 String checkTableUsedQuery = " Select table_catalog,table_schema,table_name from " + SystemTables.check_table_usage_TableName + " where constraint_catalog = ? and constraint_schema = ? and constraint_name = ? "; 552 checkTableUsedExecuter = (_Executer) serverSession.executeQueryParameterised(checkTableUsedQuery, 0); 553 } 554 return checkTableUsedExecuter; 555 } 556 557 public _Executer getCheckColumnUsedExecuter() throws DException { 558 if (checkColumnUsedExecuter == null) { 559 String checkColumnUsedQuery = " Select table_catalog,table_schema,table_name,column_name from " + SystemTables.check_column_usage_TableName + " where constraint_catalog = ? and constraint_schema = ? and constraint_name = ? "; 560 checkColumnUsedExecuter = (_Executer) serverSession.executeQueryParameterised(checkColumnUsedQuery, 0); 561 } 562 return checkColumnUsedExecuter; 563 } 564 565 public _Executer getRoutinePrivilegesExecuter() throws DException { 566 if (routinePrivilegesExecuter == null) { 567 String routinePrivilegesQuery = "select is_grantable from " 568 + SystemTables.routine_privileges_TableName + " where specific_catalog = ? " 569 + " and specific_schema = ? " 570 + " and specific_name = ? and privilege_type ='" + SqlKeywords.EXECUTE + "'" 571 + " and grantee in ( ? )"; 572 routinePrivilegesExecuter = (_Executer) serverSession.executeQueryParameterised(routinePrivilegesQuery, 0); 573 } 574 return routinePrivilegesExecuter; 575 } 576 577 public _Executer getHasAnyTriggerOnViewExecuter() throws DException { 578 if (hasAnyTriggerOnViewExecuter == null) { 579 String hasAnyTriggerOnViewQuery = "select * from " + SystemTables.triggers_TableName + " where event_object_catalog = ? and event_object_schema = ? and event_object_table = ? "; 580 hasAnyTriggerOnViewExecuter = (_Executer) serverSession.executeQueryParameterised(hasAnyTriggerOnViewQuery, 0); 581 } 582 return hasAnyTriggerOnViewExecuter; 583 } 584 585 public _Executer getIsDateSpanTableExecuter() throws DException { 586 if (isDateSpanTableExecuter == null) { 587 String dateSpanQuery = " select * from " + SystemTables.columns_TableName + " where table_catalog = ? and table_schema = ? and table_name = ? and ( column_name = '" + SqlSchemaConstants.dateSpanFrom + "' or column_name = '" + SqlSchemaConstants.dateSpanTo + "')"; 588 isDateSpanTableExecuter = (_Executer) serverSession.executeQueryParameterised(dateSpanQuery, 0); 589 } 590 return isDateSpanTableExecuter; 591 } 592 593 public _Executer getViewsForTableExecuter() throws DException { 594 if (viewsForTableExecuter == null) { 595 String viewsForTableQuery = "select view_catalog,view_schema,view_name from " + SystemTables.view_table_usage_TableName + " where table_catalog = ? and table_schema = ? and table_name = ?"; 596 viewsForTableExecuter = (_Executer) serverSession.executeQueryParameterised(viewsForTableQuery, 0); 597 } 598 return viewsForTableExecuter; 599 } 600 601 public _Executer getMaterializedViewsFromViewsExecuter() throws DException { 602 if (materializedViewsFromViewsExecuter == null) { 603 String materializedViewsFromViews = "select table_catalog,table_schema,materialized_table_name from " + SystemTables.views_TableName + " where (table_catalog,table_schema,table_name) IN (?) and materialized_table_name is not null "; 604 materializedViewsFromViewsExecuter = (_Executer) serverSession.executeQueryParameterised(materializedViewsFromViews, 0); 605 } 606 return materializedViewsFromViewsExecuter; 607 } 608 609 public _Executer getMataerailzedQueryDefinitionExecuter() throws DException { 610 if (mataerailzedQueryDefinitionExecuter == null) { 611 String mataerailzedQueryDefinitionQuery = "select view_definition from " + SystemTables.views_TableName + " where table_catalog = ? and table_schema =? and materialized_table_name = ?"; 612 mataerailzedQueryDefinitionExecuter = (_Executer) serverSession.executeQueryParameterised(mataerailzedQueryDefinitionQuery, 0); 613 } 614 return mataerailzedQueryDefinitionExecuter; 615 } 616 617 public _Executer getColumnsTableExecuter() throws DException { 618 if (columnsTableExecuter == null) { 619 StringBuffer clause = new StringBuffer (); 620 clause.append(" select * from ").append(SystemTables.columns_TableName).append(" where "); 621 clause.append("table_catalog = ? and table_schema = ? and table_name =? and column_name = ? "); 622 columnsTableExecuter = (_Executer) serverSession.executeQueryParameterised(clause.toString(), 0); 623 } 624 return columnsTableExecuter; 625 } 626 627 public _Executer getTablesTableExecuter() throws DException { 628 if (tablesTableExecuter == null) { 629 String queryforLoadTable = "select * from " + SystemTables.tables_TableName 630 + " where table_catalog = ? and table_schema = ? and table_name = ?"; 631 tablesTableExecuter = (_Executer) serverSession.executeQueryParameterised(queryforLoadTable, 0); 632 } 633 return tablesTableExecuter; 634 } 635 636 public _Executer getReferentialConstraintsTableExecuter() throws DException { 637 if (referentialConstraintsTableExecuter == null) { 638 String referentialConstraintQuery = "select * from " + SystemTables.referential_constraints_TableName 639 + " where constraint_catalog = ? and constraint_schema = ? " 640 + " and constraint_name = ? "; 641 referentialConstraintsTableExecuter = (_Executer) serverSession.executeQueryParameterised(referentialConstraintQuery, 0); 642 } 643 return referentialConstraintsTableExecuter; 644 } 645 646 public _Executer getColumnPrivilegesTableExecuter() throws DException { 647 if (columnPrivilegesTableExecuter == null) { 648 StringBuffer clause = new StringBuffer (); 649 clause.append("select * from "); 650 clause.append(SystemTables.column_privileges_TableName); 651 clause.append(" where grantor =? and grantee = ? and table_catalog = ? and table_schema = ? and table_name = ? "); 652 clause.append(" and column_name = ? "); 653 clause.append(" and privilege_type = ?"); 654 columnPrivilegesTableExecuter = (_Executer) serverSession.executeQueryParameterised(clause.toString(), 0); 655 } 656 return columnPrivilegesTableExecuter; 657 } 658 659 public _Executer getTablePrivlegesTableExecuter() throws DException { 660 if (tablePrivlegesTableExecuter == null) { 661 StringBuffer clause = new StringBuffer (); 662 clause.append(" select * from "); 663 clause.append(SystemTables.table_privileges_TableName); 664 clause.append(" where grantor = ? and grantee = ? "); 665 clause.append(" and table_catalog = ? and table_schema = ?"); 666 clause.append(" and table_name = ? and privilege_type = ? "); 667 tablePrivlegesTableExecuter = (_Executer) serverSession.executeQueryParameterised(clause.toString(), 0); 668 } 669 return tablePrivlegesTableExecuter; 670 } 671 672 public _Executer getSchemataTableExecuter() throws DException { 673 if (schemataTableExecuter == null) { 674 String schemaQuery = "select * from " + SystemTables.schema_TableName + " where catalog_name = ? and schema_name = ? "; 675 schemataTableExecuter = (_Executer) serverSession.executeQueryParameterised(schemaQuery, 0); 676 } 677 return schemataTableExecuter; 678 } 679 680 public _Executer getDomianTableExecuter() throws DException { 681 if (domainTableExecuter == null) { 682 StringBuffer st = new StringBuffer (); 683 st.append("select * from "); 684 st.append(SystemTables.domains_TableName); 685 st.append(" where "); 686 st.append("domain_catalog = ? and domain_schema = ? and domain_name = ? "); 687 domainTableExecuter = (_Executer) serverSession.executeQueryParameterised(st.toString(), 0); 688 } 689 return domainTableExecuter; 690 } 691 692 public _Executer getDomainConstraintsTableExecuter() throws DException { 693 if (domianConstrainttaTableExecuter == null) { 694 StringBuffer clause = new StringBuffer (); 695 clause.append("select * from "); 696 clause.append(SystemTables.domain_constraints_TableName); 697 clause.append(" where "); 698 clause.append("constraint_catalog = ? and constraint_schema = ? and constraint_name = ?"); 699 domianConstrainttaTableExecuter = (_Executer) serverSession.executeQueryParameterised(clause.toString(), 0); 700 } 701 return domianConstrainttaTableExecuter; 702 } 703 704 public booleanvalueexpression getTablesTableCondition() throws DException { 705 if (tablesTableCondition == null) { 706 String bve = "TABLE_CATALOG=? and TABLE_SCHEMA=? and TABLE_NAME=?"; 707 tablesTableCondition = ConditionParser.parseCondition(bve, serverSession, SystemTables.tables_TableName); 708 } 709 return tablesTableCondition; 710 } 711 712 public booleanvalueexpression getColumnsTableCondition() throws DException { 713 if (columnsTableCondition == null) { 714 String bve = "TABLE_CATALOG=? and TABLE_SCHEMA=? and TABLE_NAME=? and COLUMN_NAME=?"; 715 columnsTableCondition = ConditionParser.parseCondition(bve, serverSession, SystemTables.columns_TableName); 716 } 717 return columnsTableCondition; 718 } 719 720 public booleanvalueexpression getDataTypeDescriptorTableCondition() throws DException { 721 if (dataTypeDescriptorTableCondition == null) { 722 String bve = "OBJECT_CATALOG=? and OBJECT_SCHEMA=? and OBJECT_NAME=? and OBJECT_TYPE=? and DTD_IDENTIFIER=?"; 723 dataTypeDescriptorTableCondition = ConditionParser.parseCondition(bve, serverSession, SystemTables.dataTypeDescriptor_TableName); 724 } 725 return dataTypeDescriptorTableCondition; 726 } 727 728 public booleanvalueexpression getTableConstraintsTableCondition() throws DException { 729 if (tableConstraintsTableCondition == null) { 730 String bve = "CONSTRAINT_CATALOG=? and CONSTRAINT_SCHEMA=? and CONSTRAINT_NAME=?"; 731 tableConstraintsTableCondition = ConditionParser.parseCondition(bve, serverSession, SystemTables.table_constraints_TableName); 732 } 733 return tableConstraintsTableCondition; 734 } 735 736 public booleanvalueexpression getCheckConstraintsTableCondition() throws DException { 737 if (checkConstraintsTableCondition == null) { 738 String bve = "CONSTRAINT_CATALOG=? and CONSTRAINT_SCHEMA=? and CONSTRAINT_NAME=?"; 739 checkConstraintsTableCondition = ConditionParser.parseCondition(bve, serverSession, SystemTables.check_constraints_TableName); 740 } 741 return checkConstraintsTableCondition; 742 } 743 744 public booleanvalueexpression getCheckTableUsageTableCondition() throws DException { 745 if (checkTableUsageTableCondition == null) { 746 String bve = "CONSTRAINT_CATALOG=? and CONSTRAINT_SCHEMA=? and CONSTRAINT_NAME=?"; 747 checkTableUsageTableCondition = ConditionParser.parseCondition(bve, serverSession, SystemTables.check_table_usage_TableName); 748 } 749 return checkTableUsageTableCondition; 750 } 751 752 public booleanvalueexpression getCheckColumnUsageTableCondition() throws DException { 753 if (checkColumnUsageTableCondition == null) { 754 String bve = "CONSTRAINT_CATALOG=? and CONSTRAINT_SCHEMA=? and CONSTRAINT_NAME=?"; 755 checkColumnUsageTableCondition = ConditionParser.parseCondition(bve, serverSession, SystemTables.check_column_usage_TableName); 756 } 757 return checkColumnUsageTableCondition; 758 } 759 760 public booleanvalueexpression getReferentialConstraintsTableCondition() throws DException { 761 if (referentialConstraintsTableCondition == null) { 762 String bve = "CONSTRAINT_CATALOG=? and CONSTRAINT_SCHEMA=? and CONSTRAINT_NAME=?"; 763 referentialConstraintsTableCondition = ConditionParser.parseCondition(bve, serverSession, SystemTables.referential_constraints_TableName); 764 } 765 return referentialConstraintsTableCondition; 766 } 767 768 public booleanvalueexpression getKeyColumnUsageTableCondition() throws DException { 769 if (keyColumnUsageTableCondition == null) { 770 String bve = "CONSTRAINT_CATALOG=? and CONSTRAINT_SCHEMA=? and CONSTRAINT_NAME=? and COLUMN_NAME=?"; 771 keyColumnUsageTableCondition = ConditionParser.parseCondition(bve, serverSession, SystemTables.key_column_usage_TableName); 772 } 773 return keyColumnUsageTableCondition; 774 } 775 776 public booleanvalueexpression getColumnPrivilegesTableCondition() throws DException { 777 if (columnPrivilegesTableCondition == null) { 778 String bve = "GRANTOR=? and GRANTEE=? and TABLE_CATALOG=? and TABLE_SCHEMA=? and TABLE_NAME=? and PRIVILEGE_TYPE=? and COLUMN_NAME=?"; 779 columnPrivilegesTableCondition = ConditionParser.parseCondition(bve, serverSession, SystemTables.column_privileges_TableName); 780 } 781 return columnPrivilegesTableCondition; 782 } 783 784 public booleanvalueexpression getTablePrivlegesTableCondition() throws DException { 785 if (tablePrivlegesTableCondition == null) { 786 String bve = "GRANTOR=? and GRANTEE=? and TABLE_CATALOG=? and TABLE_SCHEMA=? and TABLE_NAME=? and PRIVILEGE_TYPE=?"; 787 tablePrivlegesTableCondition = ConditionParser.parseCondition(bve, serverSession, SystemTables.table_privileges_TableName); 788 } 789 return tablePrivlegesTableCondition; 790 } 791 792 public _Executer getExecuterTablePrivilegeDescriptorDependent_A() throws DException { 793 return (tableDependent_A == null) 794 ? (tableDependent_A = (_Executer) serverSession.executeQueryParameterised(QueryGetter.tablePrivilegeDescriptorDependent_A, 0)) 795 : tableDependent_A; 796 } 797 798 public _Executer getExecuterTablePrivilegeDescriptorDependent_B() throws DException { 799 return (tableDependent_B == null) 800 ? (tableDependent_B = (_Executer) serverSession.executeQueryParameterised(QueryGetter.tablePrivilegeDescriptorDependent_B, 0)) 801 : tableDependent_B; 802 } 803 804 public _Executer getExecuterColumnPrivilegeDescriptorDependent_A() throws DException { 805 return (columnDependent_A == null) 806 ? (columnDependent_A = (_Executer) serverSession.executeQueryParameterised(QueryGetter.columnPrivilegeDescriptorDependent_A, 0)) 807 : columnDependent_A; 808 } 809 810 public _Executer getExecuterColumnPrivilegeDescriptorDependent_B() throws DException { 811 return (columnDependent_B == null) 812 ? (columnDependent_B = (_Executer) serverSession.executeQueryParameterised(QueryGetter.columnPrivilegeDescriptorDependent_B, 0)) 813 : columnDependent_B; 814 } 815 816 public _Executer getExecuterRoutinePrivilegeDescriptorDependent_A() throws DException { 817 return (routineDependent_A == null) 818 ? (routineDependent_A = (_Executer) serverSession.executeQueryParameterised(QueryGetter.routinePrivilegeDescriptorDependent_A, 0)) 819 : routineDependent_A; 820 } 821 822 public _Executer getExecuterUsagePrivilegeDescriptorDependent_A() throws DException { 823 return (usageDependent_A == null) 824 ? (usageDependent_A = (_Executer) serverSession.executeQueryParameterised(QueryGetter.usagePrivilegeDescriptorDependent_A, 0)) 825 : usageDependent_A; 826 } 827 828 public _Executer getExecuterPrivilegeDescriptorDependents_C() throws DException { 829 return (dependent_C == null) 830 ? (dependent_C = (_Executer) serverSession.executeQueryParameterised(QueryGetter.privilegeDescriptorDependents_C, 0)) 831 : dependent_C; 832 } 833 834 public _Executer getExecuterDomainCheckConstraints() throws DException { 835 return (domainCheckConstaint == null) 836 ? (domainCheckConstaint = (_Executer) serverSession.executeQueryParameterised(QueryGetter.domainCheckConstraints, 0)) 837 : domainCheckConstaint; 838 } 839 840 public _Executer getExecuterUsagePrivilegeDescriptorAncestor_C_Column() throws DException { 841 return (usageDependent_C_Column == null) 842 ? (usageDependent_C_Column = (_Executer) serverSession.executeQueryParameterised(QueryGetter.usagePrivilegeDescriptorAncestor_C_Column, 0)) 843 : usageDependent_C_Column; 844 } 845 846 public _Executer getExecuterUsagePrivilegeDescriptorAncestor_C_Usage() throws DException { 847 return (usageDependent_C_Usage == null) 848 ? (usageDependent_C_Usage = (_Executer) serverSession.executeQueryParameterised(QueryGetter.usagePrivilegeDescriptorAncestor_C_Usage, 0)) 849 : usageDependent_C_Usage; 850 } 851 852 public _Executer getTableConstraintExecuterForPrimaryKey() throws DException { 853 if (tableConstraintExecuterForPrimaryKey == null) { 854 String tableConstraintQueryForPrimaryKey = "select * from " 855 + SystemTables.table_constraints_TableName 856 + " where table_catalog = ? and table_schema = ? " 857 + " and table_name = ? and constraint_type = '" + SqlKeywords.PRIMARY 858 + " " + SqlKeywords.KEY + "'"; 859 tableConstraintExecuterForPrimaryKey = (_Executer) serverSession.executeQueryParameterised(tableConstraintQueryForPrimaryKey, 0); 860 } 861 return tableConstraintExecuterForPrimaryKey; 862 } 863 864 public _Executer getAllRoleAuthorizationsExecuterforGranteeOnly() throws DException { 865 if (allRoleAuthorizationsExecterforGranteeOnly == null) 866 allRoleAuthorizationsExecterforGranteeOnly = (_Executer) serverSession.executeQueryParameterised(QueryMaker.getAllRoleAuthorizationsforGranteeOnly(), 0); 867 return allRoleAuthorizationsExecterforGranteeOnly; 868 } 869 870 public _Executer getAllRoleAuthorizationsExecuterforGranteeAndPublic() throws DException { 871 if (allRoleAuthorizationsExecuterforGranteeAndPublic == null) { 872 allRoleAuthorizationsExecuterforGranteeAndPublic = (_Executer) serverSession.executeQueryParameterised(QueryMaker.getAllRoleAuthorizationsforGranteeAndPublic(), 0); 873 } 874 return allRoleAuthorizationsExecuterforGranteeAndPublic; 875 } 876 877 public _Executer getIsValidRoleExecuter() throws DException { 878 if (isValidRoleExecuter == null) { 879 isValidRoleExecuter = (_Executer) serverSession.executeQueryParameterised(QueryMaker.getIsValidRole(), 0); 880 } 881 return isValidRoleExecuter; 882 } 883 884 public _Executer getExecuterForUserValidity() throws DException { 885 if (userValidity == null) { 886 String userQuery = "Select * From " + SystemTables.users_TableName + " Where USER_NAME = ? "; 887 userValidity = (_Executer) serverSession.executeQueryParameterised(userQuery, 0); 888 } 889 return userValidity; 890 } 891 892 public _Executer getExecuterForRoleValidity() throws DException { 893 if (roleValidity == null) { 894 String roleQuery = "Select * From " + SystemTables.roles_TableName + " Where ROLE_NAME = ? "; 895 roleValidity = (_Executer) serverSession.executeQueryParameterised(roleQuery, 0); 896 } 897 return roleValidity; 898 } 899 900 public _Executer getExecuterForDomainValidity() throws DException { 901 if (domainValidity == null) { 902 String usage_clause = "select * from " + 903 SystemTables.usage_privileges_TableName 904 + " where object_catalog=? and object_schema=? and object_name=? and object_type = ? and grantee IN (?) "; 905 domainValidity = (_Executer) serverSession.executeQueryParameterised(usage_clause, 0); 906 } 907 return domainValidity; 908 } 909 910 public _Executer getPrimaryConstraintExecuter() throws DException { 911 if (primaryConstraintExecuter == null) { 912 String primaryKeyConstraint = "select * from " + SystemTables.table_constraints_TableName 913 + " as one, " + SystemTables.key_column_usage_TableName + " as two " 914 + " where one.constraint_catalog = two.constraint_catalog " 915 + " and one.constraint_schema = two.constraint_schema " 916 + " and one.constraint_name = two.constraint_name " 917 + " and two.table_catalog = ? " 918 + " and two.table_schema = ? " 919 + " and two.table_name = ? " 920 + " and two.column_name = ?" 921 + " and one.constraint_type in ('PRIMARY KEY', 'UNIQUE')"; 922 primaryConstraintExecuter = (_Executer) serverSession.executeQueryParameterised(primaryKeyConstraint, 0); 923 } 924 return primaryConstraintExecuter; 925 } 926 927 public _Executer getCheckConstraintForDomainExecuter() throws DException { 928 if (checkDomainConstraintExecuter == null) { 929 String checkDomainConstraint = "select * from " + SystemTables.domain_constraints_TableName 930 + " as one, " + SystemTables.check_column_usage_TableName + " as two " 931 + " where one.constraint_catalog = two.constraint_catalog " 932 + " and one.constraint_schema = two.constraint_schema " 933 + " and one.constraint_name = two.constraint_name " 934 + " and two.table_catalog = ? " 935 + " and two.table_schema = ? " 936 + " and two.table_name = ? " 937 + " and two.column_name = ? "; 938 939 checkDomainConstraintExecuter = (_Executer) serverSession.executeQueryParameterised(checkDomainConstraint, 0); 940 } 941 return checkDomainConstraintExecuter; 942 } 943 944 public _Executer getCheckColumnConstraintExecuter() throws DException { 945 if (checkColumnConstraintExecuter == null) { 946 String checkColumnConstraint = "select * from " + SystemTables.table_constraints_TableName 947 + " as one, " + SystemTables.check_column_usage_TableName + " as two " 948 + " where one.constraint_type = 'CHECK' " 949 + " and one.constraint_catalog = two.constraint_catalog " 950 + " and one.constraint_schema = two.constraint_schema " 951 + " and one.constraint_name = two.constraint_name " 952 + " and two.table_catalog = ? " 953 + " and two.table_schema = ? " 954 + " and two.table_name = ? " 955 + " and two.column_name = ? "; 956 checkColumnConstraintExecuter = (_Executer) serverSession.executeQueryParameterised(checkColumnConstraint, 0); 957 } 958 return checkColumnConstraintExecuter; 959 } 960 961 public _Executer getCheckTableConstraintExecuter() throws DException { 962 if (checkTableConstraintExecuter == null) { 963 String checkTableConstraint = "select * from " + SystemTables.table_constraints_TableName 964 + " as one, " + SystemTables.check_table_usage_TableName + " as two " 965 + " where one.constraint_type = 'CHECK' " 966 + " and one.constraint_catalog = two.constraint_catalog " 967 + " and one.constraint_schema = two.constraint_schema " 968 + " and one.constraint_name = two.constraint_name " 969 + " and two.table_catalog = ? " 970 + " and two.table_schema = ? " 971 + " and two.table_name = ? "; 972 checkTableConstraintExecuter = (_Executer) serverSession.executeQueryParameterised(checkTableConstraint, 0); 973 } 974 return checkTableConstraintExecuter; 975 } 976 977 public _Executer getTriggerOnTableExecuter() throws DException { 978 if (executerTriggerOnTableForUser == null) { 979 String triggerOnTableForUser = "select * from " + SystemTables.triggers_TableName 980 + " as one, " + SystemTables.schema_TableName + " as two " 981 + " where one.EVENT_OBJECT_CATALOG = ? " 982 + " and one.EVENT_OBJECT_SCHEMA = ? " 983 + " and one.EVENT_OBJECT_TABLE = ? " 984 + " and one.TRIGGER_CATALOG = two.CATALOG_NAME " 985 + " and one.TRIGGER_SCHEMA = two.SCHEMA_NAME " 986 + " and two.SCHEMA_OWNER = ? "; 987 executerTriggerOnTableForUser = (_Executer) serverSession.executeQueryParameterised(triggerOnTableForUser, 0); 988 } 989 return executerTriggerOnTableForUser; 990 } 991 992 public _Executer getAbandonedViewForColumnExecuter() throws DException { 993 if (executerAbandonedViewForColumn == null) { 994 String queryAbandonedViewForColumn = " select one.* from " 995 + SystemTables.views_TableName 996 + " as one, " + SystemTables.view_colum_usage_TableName + " as two " 997 + " where two.TABLE_CATALOG = ? " 998 + " and two.TABLE_SCHEMA = ? " 999 + " and two.TABLE_NAME = ? " 1000 + " and two.COLUMN_NAME = ? " 1001 + " and one.TABLE_CATALOG = two.VIEW_CATALOG " 1002 + " and one.TABLE_SCHEMA = two.VIEW_SCHEMA " 1003 + " and one.TABLE_NAME = two.VIEW_NAME "; 1004 executerAbandonedViewForColumn = (_Executer) serverSession.executeQueryParameterised(queryAbandonedViewForColumn, 0); 1005 } 1006 return executerAbandonedViewForColumn; 1007 } 1008 1009 public _Executer getAbandonedViewForTableExecuter() throws DException { 1010 if (executerAbandonedViewForTable == null) { 1011 String queryAbandonedViewForTable = " select one.* from " 1012 + SystemTables.views_TableName 1013 + " as one, " + SystemTables.view_table_usage_TableName + " as two " 1014 + " where two.TABLE_CATALOG = ? " 1015 + " and two.TABLE_SCHEMA = ? " 1016 + " and two.TABLE_NAME = ? " 1017 + " and one.TABLE_CATALOG = two.VIEW_CATALOG " 1018 + " and one.TABLE_SCHEMA = two.VIEW_SCHEMA " 1019 + " and one.TABLE_NAME = two.VIEW_NAME "; 1020 executerAbandonedViewForTable = (_Executer) serverSession.executeQueryParameterised(queryAbandonedViewForTable, 0); 1021 } 1022 return executerAbandonedViewForTable; 1023 } 1024 1025 public _Executer getIndexExecuter() throws DException { 1026 if (indexExecuter == null) { 1027 String indexColumnsQuery = 1028 "select column_name, orderType from " 1029 + SystemTables.INDEXCOLUMNS + " where table_catalog = ? and table_schema = ? and table_name = ? and indexname = ?"; 1030 indexExecuter = (_Executer) serverSession.executeQueryParameterised(indexColumnsQuery, 0); 1031 } 1032 return indexExecuter; 1033 } 1034 1035 public _Executer getDeleteConstraintExecuter() throws DException { 1036 if (deleteConstraintExecuter == null) { 1037 1040 String queryForConstraints = "select * from " + 1041 SqlSchemaConstants.table_constraints_TableName 1042 + " where table_catalog = ? and table_schema = ? and table_name = ?"; 1043 deleteConstraintExecuter = (_Executer) serverSession.executeQueryParameterised(queryForConstraints, 0); 1044 } 1045 return deleteConstraintExecuter; 1046 } 1047 1048 public _Executer getReferentialConstraintExecuter() throws DException { 1049 if (referentialConstraintExecuter == null) { 1050 1055 1056 String referentialQuery = " Select * from " + SystemTables.referential_constraints_TableName + 1057 " as refCons, " + SystemTables.table_constraints_TableName + " as tabCons where " + 1058 " tabCons.table_catalog = ? and tabCons.table_schema = ? and tabCons.table_name = ? and ( tabCons.constraint_type = '" + 1059 SqlKeywords.PRIMARY + " " + SqlKeywords.KEY + "' or tabCons.constraint_type = '" + 1060 SqlKeywords.UNIQUE + "') and refCons.unique_constraint_catalog = tabCons.constraint_catalog and " + 1061 " refCons.unique_constraint_schema = tabCons.constraint_schema and refCons.unique_constraint_name = tabCons.constraint_name"; 1062 1063 referentialConstraintExecuter = (_Executer) serverSession.executeQueryParameterised(referentialQuery, 0); 1064 } 1065 return referentialConstraintExecuter; 1066 } 1067 1068 public _Executer getConstraintExecuter() throws DException { 1069 if (constraintExecuter == null) { 1070 1073 String tableConstraintQuery = " Select * from " + 1074 SystemTables.table_constraints_TableName + " where " 1075 + SystemTables.table_constraints_TableName + 1076 ".constraint_catalog = ? and " 1077 + SystemTables.table_constraints_TableName + 1078 ".constraint_schema = ? and " 1079 + SystemTables.table_constraints_TableName + ".constraint_name = ? "; 1080 constraintExecuter = (_Executer) serverSession.executeQueryParameterised(tableConstraintQuery, 0); 1081 } 1082 return constraintExecuter; 1083 } 1084 1085 public _Executer getViewTableUsageExecuter() throws DException { 1086 if (viewTableUsageExecuter == null) { 1087 1090 String queryForViewTableUsage = "select * from " + 1091 SqlSchemaConstants.view_table_usage_TableName 1092 + " where table_catalog = ? and table_schema = ? and table_name = ?"; 1093 viewTableUsageExecuter = (_Executer) serverSession.executeQueryParameterised(queryForViewTableUsage, 0); 1094 } 1095 return viewTableUsageExecuter; 1096 } 1097 1098 public _Executer getTriggerTableUsageExecuter() throws DException { 1099 if (triggerTableUsageExecuter == null) { 1100 1103 String queryForTriggerTableUsage = "select * from " + 1104 SqlSchemaConstants.trigger_table_usage_TableName 1105 + " where table_catalog = ? and table_schema = ? and table_name = ?"; 1106 triggerTableUsageExecuter = (_Executer) serverSession.executeQueryParameterised(queryForTriggerTableUsage, 0); 1107 } 1108 return triggerTableUsageExecuter; 1109 } 1110 1111 public _Executer getRoutineTableUsageExecuter() throws DException { 1112 if (routineTableUsageExecuter == null) { 1113 1116 String queryForRoutineTableUsage = "select * from " + 1117 SqlSchemaConstants.routine_table_usage_TableName 1118 + " where table_catalog = ? and table_schema = ? and table_name = ?"; 1119 routineTableUsageExecuter = (_Executer) serverSession.executeQueryParameterised(queryForRoutineTableUsage, 0); 1120 } 1121 return routineTableUsageExecuter; 1122 } 1123 1124 public _Executer getTableReferencedCheckConstraintExecuter() throws DException { 1125 if (tableReferencedCheckConstraintExecuter == null) { 1126 String checkConstraintQuery = " Select * from " + 1127 SystemTables.check_table_usage_TableName + " as one , " 1128 + SystemTables.table_constraints_TableName + " as two " 1129 + " where one.table_catalog = ? and one.table_schema = ? and one.table_name = ? " 1130 + " and Not(two.table_catalog = ? and two.table_schema = ? and two.table_name = ?) " 1131 + " and one.CONSTRAINT_CATALOG = two.CONSTRAINT_CATALOG and one.CONSTRAINT_SCHEMA = two.CONSTRAINT_SCHEMA " 1132 + " and one.CONSTRAINT_NAME = two.CONSTRAINT_NAME "; 1133 tableReferencedCheckConstraintExecuter = (_Executer) serverSession.executeQueryParameterised(checkConstraintQuery, 0); 1134 } 1135 return tableReferencedCheckConstraintExecuter; 1136 } 1137 1138 public _Executer getConditionIndexInfoExecuter() throws DException { 1139 if (conditionIndexInfoExecuter == null) { 1140 String selectQuery = "select indextablename, numberOfRecords, rootNodeAddress, rootClusterSize, rootRecordNumber, fixedVariable,is_system_generated from " 1141 + SystemTables.INDEXINFO + " where table_catalog = ? and table_schema = ? and table_name = ? and indexname = ?"; 1142 conditionIndexInfoExecuter = (_Executer) serverSession.executeQueryParameterised(selectQuery, 0); 1143 } 1144 return conditionIndexInfoExecuter; 1145 } 1146 1147 public _Executer getDependentReferentialConstraintExecuter() throws DException { 1148 if (dependentReferentialConstraintExecuter == null) { 1149 String dependentReferentialConstraintQuery = "select * from " + 1150 SqlSchemaConstants.referential_constraints_TableName 1151 + " where unique_constraint_catalog = ? and unique_constraint_schema = ? " 1152 + " and unique_constraint_name = ? "; 1153 dependentReferentialConstraintExecuter = (_Executer) serverSession.executeQueryParameterised(dependentReferentialConstraintQuery, 0); 1154 } 1155 return dependentReferentialConstraintExecuter; 1156 } 1157 1158 public _Executer getSequenceExecuter() throws DException { 1159 if (sequenceExecuter == null) { 1160 1163 String sequenceQuery = "select * from " + SystemTables.sequence_number_TableName 1164 + " where sequence_catalog = ? and sequence_schema = ? and sequence_name = ? "; 1165 sequenceExecuter = (_Executer) serverSession.executeQueryParameterised(sequenceQuery, 0); 1166 } 1167 return sequenceExecuter; 1168 } 1169 1170 public _Executer getFullTextInfoExecuter() throws DException { 1171 if (fullTextInfoExecuter == null) { 1172 String fullTextInfoQuery = "select FixedVariable,* from " 1173 + SystemTables.FULLTEXTINFO + " where table_catalog = ? and table_schema = ? and table_name = ? and indexname = ?"; 1174 fullTextInfoExecuter = (_Executer) serverSession.executeQueryParameterised(fullTextInfoQuery, 0); 1175 } 1176 return fullTextInfoExecuter; 1177 } 1178 1179 public _Executer getFullTextColumnInfoExecuter() throws DException { 1180 if (fullTextColumnInfoExecuter == null) { 1181 String fullTextColumnnInfoQuery = 1182 "select column_name,orderType from " 1183 + SystemTables.FULLTEXTCOLUMNINFO + " where table_catalog = ? and table_schema = ? and table_name = ? and indexname = ?"; 1184 fullTextColumnInfoExecuter = (_Executer) serverSession.executeQueryParameterised(fullTextColumnnInfoQuery, 0); 1185 } 1186 return fullTextColumnInfoExecuter; 1187 } 1188 1189 public _Executer getColumnsExecuter() throws DException { 1190 if (columnsExecuter == null) { 1191 String columnsQuery = "select * from " + SqlSchemaConstants.columns_TableName + " where table_catalog = ? and table_schema = ? and table_name = ?"; 1192 columnsExecuter = (_Executer) serverSession.executeQueryParameterised(columnsQuery, 0); 1193 } 1194 return columnsExecuter; 1195 } 1196 1197 public _Iterator getInternalIteratorForColumnDescriptor(_ServerSession currentSession, QualifiedIdentifier tableName, 1198 booleanvalueexpression condition, Object [] conditionParameters) throws DException { 1199 if (columnsIter == null) { 1200 columnsTableDetail = new TableDetails(); 1201 columnsTableDetail.setTableName(tableName.getTableName()); 1202 _ServerSession globalSession = currentSession.getGlobalSession(); 1203 ConditionSingleTableExecuter conSingTE = new ConditionSingleTableExecuter(null, 1204 columnsTableDetail, globalSession, condition, null); 1205 columnsIter = globalSession.getInternalIterator(tableName, conSingTE); 1206 } 1207 columnsIter.setConditionVariableValue(condition.getReferences(new TableDetails[] { 1208 columnsTableDetail}), FieldUtility.getFields(conditionParameters), 1); 1209 return columnsIter; 1210 } 1211 1212 public _Iterator getInternalIteratorForColumnPrivilegeDescriptor(_ServerSession currentSession, QualifiedIdentifier tableName, 1213 booleanvalueexpression condition, Object [] conditionParameters) throws DException { 1214 if (columnPrivilegesIter == null) { 1215 columnsPrivilegeTableDetail = new TableDetails(); 1216 columnsPrivilegeTableDetail.setTableName(tableName.getTableName()); 1217 _ServerSession globalSession = currentSession.getGlobalSession(); 1218 ConditionSingleTableExecuter conSingTE = new ConditionSingleTableExecuter(null, 1219 columnsPrivilegeTableDetail, globalSession, condition, null); 1220 columnPrivilegesIter = globalSession.getInternalIterator(tableName, conSingTE); 1221 } 1222 columnPrivilegesIter.setConditionVariableValue(condition.getReferences(new TableDetails[] { 1223 columnsPrivilegeTableDetail}), FieldUtility.getFields(conditionParameters), 1); 1224 return columnPrivilegesIter; 1225 } 1226 1227 public _Iterator getInternalIteratorForTablePrivilegeDescriptor(_ServerSession currentSession, QualifiedIdentifier tableName, 1228 booleanvalueexpression condition, Object [] conditionParameters) throws DException { 1229 if (tablePrivilegesIter == null) { 1230 tablePrivilegeTableDetail = new TableDetails(); 1231 tablePrivilegeTableDetail.setTableName(tableName.getTableName()); 1232 _ServerSession globalSession = currentSession.getGlobalSession(); 1233 ConditionSingleTableExecuter conSingTE = new ConditionSingleTableExecuter(null, 1234 tablePrivilegeTableDetail, globalSession, condition, null); 1235 tablePrivilegesIter = globalSession.getInternalIterator(tableName, conSingTE); 1236 } 1237 tablePrivilegesIter.setConditionVariableValue(condition.getReferences(new TableDetails[] { 1238 tablePrivilegeTableDetail}), FieldUtility.getFields(conditionParameters), 1); 1239 return tablePrivilegesIter; 1240 } 1241 1242 public _Iterator getInternalIteratorForDataTypeDescriptor(_ServerSession currentSession, QualifiedIdentifier tableName, 1243 booleanvalueexpression condition, Object [] conditionParameters) throws DException { 1244 if (dataTypeIter == null) { 1245 dataTypeTableDetail = new TableDetails(); 1246 dataTypeTableDetail.setTableName(tableName.getTableName()); 1247 _ServerSession globalSession = currentSession.getGlobalSession(); 1248 ConditionSingleTableExecuter conSingTE = new ConditionSingleTableExecuter(null, 1249 dataTypeTableDetail, globalSession, condition, null); 1250 dataTypeIter = globalSession.getInternalIterator(tableName, conSingTE); 1251 } 1252 dataTypeIter.setConditionVariableValue(condition.getReferences(new TableDetails[] { 1253 dataTypeTableDetail}), FieldUtility.getFields(conditionParameters), 1); 1254 return dataTypeIter; 1255 } 1256 1257 public booleanvalueexpression getIndexInfoTableCondition() throws DException { 1258 if (indexInfoTableCondition == null) { 1259 String bve = "TABLE_CATALOG=? and TABLE_SCHEMA=? and TABLE_NAME=? and INDEXNAME=?"; 1260 indexInfoTableCondition = ConditionParser.parseCondition(bve, serverSession, SqlSchemaConstants.INDEXINFO); 1261 } 1262 return indexInfoTableCondition; 1263 } 1264 1265 public booleanvalueexpression getFullTextIndexInfoTableCondition() throws DException { 1266 if (fullTextIndexInfoTableCondition == null) { 1267 String bve = "TABLE_CATALOG=? and TABLE_SCHEMA=? and TABLE_NAME=? and INDEXNAME=?"; 1268 fullTextIndexInfoTableCondition = ConditionParser.parseCondition(bve, serverSession, SqlSchemaConstants.FULLTEXTINFO); 1269 } 1270 return fullTextIndexInfoTableCondition; 1271 } 1272 1273 public _Executer getReferencedConstraintExecuter() throws DException { 1274 if (referencedConstraintExecuter == null) { 1275 String clause = "select * from " + 1276 SqlSchemaConstants.table_constraints_TableName 1277 + " where table_catalog = ? and table_schema = ? and table_name = ? " + 1278 " and (constraint_type = 'Primary Key' or constraint_type = 'Unique')"; 1279 referencedConstraintExecuter = (_Executer) serverSession.executeQueryParameterised(clause, 0); 1280 } 1281 return referencedConstraintExecuter; 1282 } 1283 1284 public _Executer getKeyColumnExecuter() throws DException { 1285 if (keyColumnExecuter == null) { 1286 String clause = "select * from " + 1287 SqlSchemaConstants.key_column_usage_TableName + " where constraint_catalog = ? and constraint_schema = ? and constraint_name = ? "; 1288 keyColumnExecuter = (_Executer) serverSession.executeQueryParameterised(clause, 0); 1289 } 1290 return keyColumnExecuter; 1291 } } 1293 | Popular Tags |