Method Summary |
|
public void | addActivation(Activation a) Add the activation to those known about by this connection. |
public void | addDeclaredGlobalTempTable(TableDescriptor td) |
public boolean | anyoneBlocked() |
public StringBuffer | appendErrorInfo() |
public void | appendOptimizerTraceOutput(String output) |
public void | autoincrementCreateCounter(String s, String t, String c, Long initialValue, long increment, int position) |
public void | autoincrementFlushCache(UUID tableUUID) Flush the cache of autoincrement values being kept by the lcc. |
public void | beginNestedTransaction(boolean readOnly) Start a Nested User Transaction (NUT) with the store. |
public boolean | checkIfAnyDeclaredGlobalTempTablesForThisConnection() |
public void | cleanupOnError(Throwable error) If worse than a transaction error, everything goes; we
rely on other contexts to kill the context manager
for this session.
If a transaction error, act like we saw a rollback.
If more severe or a java error, the outer cleanup
will shutdown the connection, so we don't have to clean up.
REMIND: connection should throw out all contexts and start
over when the connection is closed... |
public void | commitNestedTransaction() |
public String | convertIdentifierCase(String id) Convert an identifier to the proper case for this connection. |
public void | copyHashtableToAIHT(Hashtable from) Copies an existing hashtable of autoincrement mappings
into autoincrementHT, the cache of autoincrement values
kept in the languageconnectioncontext. |
final public boolean | dataDictionaryInWriteMode() |
public int | decrementBindCount() |
protected void | doCommit(boolean commitStore, boolean sync, int commitflag, boolean requestedByUser) This is where the work on internalCommit(), userCOmmit() and
internalCommitNoSync() actually takes place.
When a commit happens, the language connection context
will close all open activations/cursors and commit the
Store transaction.
REVISIT: we talked about having a LanguageTransactionContext,
but since store transaction management is currently in flux
and our context might want to delegate to that context,
for now all commit/rollback actions are handled directly by
the language connection context.
REVISIT: this may need additional alterations when
RELEASE SAVEPOINT/ROLLBACK TO SAVEPOINT show up.
Since the access manager's own context takes care of its own
resources on commit, and the transaction stays open, there is
nothing that this context has to do with the transaction controller.
Also, tell the data dictionary that the transaction is finished,
if necessary (that is, if the data dictionary was put into
DDL mode in this transaction.
Parameters: commitStore - true if we should commit the Store transaction Parameters: sync - true means do a synchronized commit,false means do an unsynchronized commit Parameters: commitflag - if this is an unsynchronized commit, the flags topass to commitNoSync in the store'sTransactionController. |
public boolean | dropDeclaredGlobalTempTable(String tableName) |
public void | emptyCache() Empty as much of the cache as possible. |
public AccessFactory | getAccessFactory() |
public int | getActivationCount() Return the number of activations known for this connection. |
public String | getAuthorizationId() |
public Authorizer | getAuthorizer() |
public boolean | getAutoincrementUpdate() |
public int | getBindCount() |
public int | getCacheSize() |
public int | getCurrentIsolationLevel() |
public String | getCurrentIsolationLevelStr() |
public String | getCurrentSchemaName() |
public DataDictionary | getDataDictionary() |
public DataValueFactory | getDataValueFactory() Get the data value factory to use with this language connection
context. |
public Database | getDatabase() |
public String | getDbname() |
public String | getDeclaredGlobalTemporaryTablesSchemaName() Get the declared global temporary tables schema name. |
public SchemaDescriptor | getDefaultSchema() |
public String | getDrdaID() |
public ExecutionContext | getExecutionContext() |
public int | getIdentifierCasing() Get casing for delimited identifiers. |
public Long | getIdentityValue() Get the identity column value most recently generated. |
public int | getInstanceNumber() |
public LanguageConnectionFactory | getLanguageConnectionFactory() Get the language connection factory to use with this language connection
context. |
public LanguageFactory | getLanguageFactory() Get the language factory to use with this language connection
context. |
public Activation | getLastActivation() |
public int | getLockEscalationThreshold() get the lock escalation threshold. |
public Object | getLockObject(int lockScope) Get the lock handle for the current transaction. |
public boolean | getLogQueryPlan() |
public boolean | getLogStatementText() |
public OptimizerFactory | getOptimizerFactory() |
public boolean | getOptimizerTrace() |
public boolean | getOptimizerTraceHtml() |
public String | getOptimizerTraceOutput() |
public int | getPrepareIsolationLevel() |
public boolean | getRunTimeStatisticsMode() |
public RunTimeStatistics | getRunTimeStatisticsObject() |
public StatementContext | getStatementContext() |
public int | getStatementDepth() Reports how many statement levels deep we are. |
public boolean | getStatisticsTiming() |
public String | getSysIBMSchemaName() Get the name of the SYSIBM schema. |
public String | getSystemDiagSchemaName() Get the name of the SYSCS_DIAG schema. |
public String | getSystemSchemaName() Get the name of the system schema. |
public String | getSystemUtilSchemaName() Get the name of the SYSCS_UTIL schema. |
public TableDescriptor | getTableDescriptorForDeclaredGlobalTempTable(String tableName) |
public TransactionController | getTransactionCompile() Get the transaction controller to use at compile time with this language
connection context. |
public TransactionController | getTransactionExecute() |
public TriggerExecutionContext | getTriggerExecutionContext() Get the topmost tec. |
public TableDescriptor | getTriggerTable() |
public String | getUniqueCursorName() Get a connection unique system generated name for a cursor. |
public int | getUniqueSavepointID() Get a connection unique system generated id for an unnamed savepoint. |
public String | getUniqueSavepointName() Get a connection unique system generated name for an unnamed savepoint. |
public int | incrementBindCount() |
protected SchemaDescriptor | initDefaultSchemaDescriptor() |
public void | initialize(boolean sqlConnection) |
public void | internalCommit(boolean commitStore) Do a commit as appropriate for an internally generated
commit (e.g. |
final public void | internalCommitNoSync(int commitflag) Commit the language transaction by doing a commitNoSync()
on the store's TransactionController.
Do *NOT* tell the data dictionary that the transaction is
finished. |
public void | internalRollback() Do a rollback as appropriate for an internally generated
rollback (e.g. |
public void | internalRollbackToSavepoint(String savepointName, boolean refreshStyle, Object kindOfSavepoint) Let the context deal with a rollback to savepoint
Parameters: savepointName - Name of the savepoint that needs to be rolled back Parameters: refreshStyle - boolean indicating whether or not the controller should closeopen conglomerates and scans. |
public boolean | isIsolationLevelSetUsingSQLorJDBC() |
public boolean | isLastHandler(int severity) |
public boolean | isReadOnly() |
public boolean | isTransactionPristine() Reports whether there is any outstanding work in the transaction. |
public void | languageSetSavePoint(String savepointName, Object kindOfSavepoint) Sets a savepoint. |
public Long | lastAutoincrementValue(String schemaName, String tableName, String columnName) Implements ConnectionInfo.lastAutoincrementValue.
lastAutoincrementValue searches for the last autoincrement value inserted
into a column specified by the user. |
public CursorActivation | lookupCursorActivation(String cursorName) See if a given cursor is available for use.
if so return its activation. |
public PreparedStatement | lookupStatement(GenericStatement statement) See if a given statement has already been compiled for this user, and
if so use its prepared statement. |
public void | markTempTableAsModifiedInUnitOfWork(String tableName) |
public long | nextAutoincrementValue(String schemaName, String tableName, String columnName) returns the next value to be inserted into an autoincrement col.
This is used internally by the system to generate autoincrement values
which are going to be inserted into a autoincrement column. |
public void | notifyUnusedActivation() |
public void | popCompilerContext(CompilerContext cc) Pop a CompilerContext off the context stack. |
public void | popExecutionStmtValidator(ExecutionStmtValidator validator) Remove the validator. |
public void | popStatementContext(StatementContext statementContext, Throwable error) Pop a StatementContext of the context stack. |
public void | popTriggerExecutionContext(TriggerExecutionContext tec) Remove the tec. |
public void | popTriggerTable(TableDescriptor td) Remove the trigger table descriptor. |
public PreparedStatement | prepareInternalStatement(SchemaDescriptor compilationSchema, String sqlText, boolean isForReadOnly, boolean forMetaData) |
public PreparedStatement | prepareInternalStatement(String sqlText) |
final public CompilerContext | pushCompilerContext() Push a CompilerContext on the context stack with
the current default schema as the default schema
which we compile against. |
public CompilerContext | pushCompilerContext(SchemaDescriptor sd) Push a CompilerContext on the context stack with
the passed in default schema as the default schema
we compile against. |
public void | pushExecutionStmtValidator(ExecutionStmtValidator validator) Push a new execution statement validator. |
public StatementContext | pushStatementContext(boolean isAtomic, boolean isForReadOnly, String stmtText, ParameterValueSet pvs, boolean rollbackParentContext, long timeoutMillis) Push a StatementContext on the context stack.
Parameters: isAtomic - whether this statement is atomic or not Parameters: isForReadOnly - whether this statement is for a read only resultset Parameters: stmtText - the text of the statement. |
public void | pushTriggerExecutionContext(TriggerExecutionContext tec) Push a new trigger execution context. |
public void | pushTriggerTable(TableDescriptor td) Set the trigger table descriptor. |
public void | releaseSavePoint(String savepointName, Object kindOfSavepoint) |
public void | removeActivation(Activation a) Remove the activation to those known about by this connection. |
public void | removeStatement(Statement statement) This method will remove a statement from the statement cache. |
public void | resetFromPool() Reset the connection before it is returned (indirectly) by
a PooledConnection object. |
public void | resetIsolationLevelFlagUsedForSQLandJDBC() |
protected void | resetStatementDepth() Resets the statementDepth. |
public void | setAutoincrementUpdate(boolean flag) |
final public void | setDataDictionaryWriteMode() |
public void | setDefaultSchema(SchemaDescriptor sd) Set the default schema -- used by SET SCHEMA. |
public void | setDrdaID(String drdaID) |
public void | setIdentityValue(long val) Set the field of most recently generated identity column value. |
public void | setIsolationLevel(int isolationLevel) |
public void | setLogStatementText(boolean logStatementText) |
public boolean | setOptimizerTrace(boolean onOrOff) |
public boolean | setOptimizerTraceHtml(boolean onOrOff) |
public void | setOptimizerTraceOutput(String startingText) |
public void | setPrepareIsolationLevel(int level) |
public void | setReadOnly(boolean on) |
public void | setRunTimeStatisticsMode(boolean onOrOff) |
public void | setRunTimeStatisticsObject(RunTimeStatistics runTimeStatisticsObject) |
public void | setStatisticsTiming(boolean onOrOff) |
public void | setTransaction(TransactionController tran) Sets the transaction controller to use with this language connection
context. |
public void | userCommit() Do a commmit as is appropriate for a user requested
commit (e.g. |
public void | userRollback() Do a rollback as is appropriate for a user requested
rollback (e.g. |
public boolean | usesSqlAuthorization() |
public void | validateStmtExecution(ConstantAction constantAction) Validate a statement. |
public boolean | verifyAllHeldResultSetsAreClosed() Verify that there are no activations with open held result sets. |
public boolean | verifyNoOpenResultSets(PreparedStatement pStmt, Provider provider, int action) Verify that there are no activations with open result sets
on the specified prepared statement. |
final public void | xaCommit(boolean onePhase) Same as userCommit except commit a distributed transaction. |
public void | xaRollback() Same as userRollback() except rolls back a distrubuted transaction. |