public abstract class SingleHopPreparedStatement extends PreparedStatement
| Modifier and Type | Field and Description |
|---|---|
com.pivotal.gemfirexd.internal.shared.common.Converter |
crossConverter |
clientParamTypeAtFirstExecute, internalPreparedStatement, materialPreparedStatement_, outputRegistered_, parameterMetaData_, parameters_, pooledConnection_, singleHopInfoAlreadyFetched_, sql_, superFlowExecuteCalled_autoGeneratedKeys_, cachedCursor_, cachedSingletonRowData_, CLOSE_ALL_RESULTS, CLOSE_CURRENT_RESULT, cursorAttributesToSendOnPrepare_, doWriteTimeout, fetchDirection_, fetchSize_, generatedKeysColumnIndexes_, generatedKeysColumnNames_, generatedKeysResultSet_, indexOfCurrentResultSet_, isCommitSql__, isPoolable, isPreparedStatement_, isQuery__, isRollbackSql__, KEEP_CURRENT_RESULT, materialStatement_, numInvisibleRS_, preparedStatementForAutoGeneratedKeys_, resultSetConcurrency_, resultSetHoldability_, resultSetType_, section_, SET_SCHEMA_STATEMENT, singletonRowData_, specialRegisterArrayList, sqlMode_, statementUUID, TIMEOUT_STATEMENTCLOSE_ALL_RESULTS, CLOSE_CURRENT_RESULT, EXECUTE_FAILED, KEEP_CURRENT_RESULT, NO_GENERATED_KEYS, RETURN_GENERATED_KEYS, SUCCESS_NO_INFO| Constructor and Description |
|---|
SingleHopPreparedStatement(Agent agent,
Connection connection,
String sql,
int type,
int concurrency,
int holdability,
int autoGeneratedKeys,
String[] columnNames,
int[] columnIndexes,
ClientPooledConnection cpc) |
SingleHopPreparedStatement(Agent agent,
Connection connection,
String sql,
Section section,
ClientPooledConnection cpc) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
cleanSingleHopPrepStmnt() |
void |
createNewSetForTesting() |
boolean |
execute() |
ResultSet |
executeQuery() |
int |
executeUpdate() |
protected void |
flowExecute(int executeType,
int currExecSeq) |
ResultSet |
getResultSet() |
Set |
getRoutingObjectSet() |
NetResultSet |
getSuperResultSet() |
void |
initialize(Section sec) |
static String |
returnParameters(Object[] parameters) |
void |
setRoutingObjectSetToNull() |
protected ResultSet |
singleHopPrepStmntExecuteQuery() |
static void |
sleepForRetry(Connection connection_) |
boolean |
wasSingleHopCalledInExecution() |
addBatch, clearParameters, completeDescribeInput, completeDescribeOutput, completeLocalCommit, completeLocalRollback, execute, execute, execute, execute, executeBatch, executeBatchX, executeQuery, executeUpdate, executeUpdate, executeUpdate, executeUpdate, flowExecuteRead, flowExecuteWrite, getClientParamType, getJdbcStatementInterfaceName, getMetaData, getParameterMetaData, initResetPreparedStatement, listenToUnitOfWork, makeNewClientParamTypeFrom, markClosed, readDescribeInput, readDescribeOutput, readExecute, reset, resetPreparedStatement, resetPreparedStatement, resetPreparedStatement, setAndStoreClientParamType, setArray, setAsciiStream, setAsciiStream, setAsciiStream, setBigDecimal, setBinaryStream, setBinaryStream, setBinaryStream, setBinaryStreamX, setBlob, setBlob, setBlob, setBlobX, setBoolean, setByte, setBytes, setBytesX, setCharacterStream, setCharacterStream, setCharacterStream, setClob, setClob, setClob, setDate, setDate, setDouble, setFloat, setInt, setLong, setNull, setNull, setObject, setObject, setObject, setRef, setShort, setString, setTime, setTime, setTimestamp, setTimestamp, setUnicodeStream, setURL, writeDescribeInput, writeDescribeOutput, writeExecuteaccumulateWarning, addBatch, cancel, checkForDuplicateCursorName, checkForStoredProcResultSetCount, clearBatch, clearWarnings, close, closeX, completeExecute, completeExecuteCall, completeExecuteCall, completeExecuteCallOpenQuery, completeExecuteImmediate, completeExecuteSetStatement, completeOpenQuery, completePrepare, completePrepareDescribeOutput, completeSqlca, completeStatementIDRead, finalize, getConnection, getConnectionCallbackInterface, getFetchDirection, getFetchSize, getGeneratedKeys, getGuessedResultSetMetaData, getMaxFieldSize, getMaxRows, getMoreResults, getMoreResults, getQueryTimeout, getResultSetConcurrency, getResultSetHoldability, getResultSetType, getSection, getSqlWarnings, getUpdateCount, getWarnings, initResetPreparedStatement, isCallMode, isClosed, isClosedNoThrow, isPoolable, isQueryMode, isWrapperFor, jdbc3FeatureNotSupported, jdbc3FeatureNotSupported, markAutoCommitted, needStatementUUID, readExecuteCall, readExecuteImmediate, readExecuteImmediateForBatch, readOpenQuery, readPrepare, readPrepareDescribeOutput, readSetSpecialRegister, readStatementID, removeClientCursorNameFromCache, resetStatement, resetStatement, resultSetCommitting, resultSetCommitting, setCursorName, setEscapeProcessing, setFetchDirection, setFetchSize, setMaxFieldSize, setMaxRows, setOwner, setPoolable, setQueryTimeout, setupCursorNameCacheAndMappings, setUpdateCount, substituteClientCursorNameWithServerCursorName, upperCaseProcedureName, writeExecuteCall, writeExecuteImmediate, writeGetStmtUUID, writeOpenQuery, writePrepare, writePrepareDescribeOutput, writeSetSpecialRegisterclone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitsetNCharacterStream, setNCharacterStream, setNClob, setNClob, setNClob, setNString, setRowId, setSQLXMLaddBatch, cancel, clearBatch, clearWarnings, close, closeOnCompletion, getConnection, getFetchDirection, getFetchSize, getGeneratedKeys, getMaxFieldSize, getMaxRows, getMoreResults, getMoreResults, getQueryTimeout, getResultSetConcurrency, getResultSetHoldability, getResultSetType, getUpdateCount, getWarnings, isClosed, isCloseOnCompletion, isPoolable, setCursorName, setEscapeProcessing, setFetchDirection, setFetchSize, setMaxFieldSize, setMaxRows, setPoolable, setQueryTimeoutisWrapperFor, unwrapaccumulateWarning, completeExecute, completeExecuteCall, completeExecuteCall, completeExecuteCallOpenQuery, completeExecuteImmediate, completeExecuteSetStatement, completeOpenQuery, completePrepare, completePrepareDescribeOutput, completeSqlca, completeStatementIDRead, getConnectionCallbackInterface, getGuessedResultSetMetaData, getSectionpublic final com.pivotal.gemfirexd.internal.shared.common.Converter crossConverter
public SingleHopPreparedStatement(Agent agent, Connection connection, String sql, Section section, ClientPooledConnection cpc) throws SqlException
SqlExceptionpublic SingleHopPreparedStatement(Agent agent, Connection connection, String sql, int type, int concurrency, int holdability, int autoGeneratedKeys, String[] columnNames, int[] columnIndexes, ClientPooledConnection cpc) throws SqlException
SqlExceptionpublic void initialize(Section sec) throws SQLException
SQLExceptionpublic int executeUpdate()
throws SQLException
executeUpdate in interface PreparedStatementexecuteUpdate in class PreparedStatementSQLExceptionprotected ResultSet singleHopPrepStmntExecuteQuery() throws SQLException
singleHopPrepStmntExecuteQuery in class PreparedStatementSQLExceptionpublic ResultSet executeQuery() throws SQLException
executeQuery in interface PreparedStatementexecuteQuery in class PreparedStatementSQLExceptionpublic boolean execute()
throws SQLException
execute in interface PreparedStatementexecute in class PreparedStatementSQLExceptionprotected void flowExecute(int executeType,
int currExecSeq)
throws SqlException
flowExecute in class PreparedStatementSqlExceptionpublic static void sleepForRetry(Connection connection_) throws SqlException
SqlExceptionprotected void cleanSingleHopPrepStmnt()
throws SqlException
cleanSingleHopPrepStmnt in class StatementSqlExceptionpublic Set getRoutingObjectSet()
public void createNewSetForTesting()
public void setRoutingObjectSetToNull()
public boolean wasSingleHopCalledInExecution()
public ResultSet getResultSet() throws SQLException
getResultSet in interface StatementgetResultSet in class StatementSQLExceptionpublic NetResultSet getSuperResultSet() throws SQLException
getSuperResultSet in class PreparedStatementSQLExceptionCopyright © 2010-2015 Pivotal Software, Inc. All rights reserved.