| Package | Description |
|---|---|
| com.pivotal.gemfirexd.internal.client.am | |
| com.pivotal.gemfirexd.internal.client.net |
| Modifier and Type | Method and Description |
|---|---|
void |
Agent.accumulateChainBreakingReadExceptionAndThrow(DisconnectException e) |
void |
Agent.accumulateDisconnectException(DisconnectException e) |
| Modifier and Type | Method and Description |
|---|---|
void |
Agent.accumulateChainBreakingReadExceptionAndThrow(DisconnectException e) |
protected abstract boolean |
Cursor.calculateColumnOffsetsForRow_(int row,
boolean allowServerFetch)
Calculate the column offsets for a row.
|
void |
StatementCallbackInterface.completeOpenQuery(Sqlca sqlca,
ResultSet resultSet) |
void |
ResultSet.flowFetch() |
void |
ResultSet.flowPositioningFetch(int scrollOrientation,
int rowToFetch) |
abstract void |
Agent.flush_() |
long |
Sqlca.getRowCount() |
protected void |
ResultSet.moveToAfterLast() |
protected void |
ResultSet.moveToBeforeFirst() |
void |
ResultSet.readDeleteRow() |
void |
ResultSet.readInsertRow() |
void |
ResultSet.readUpdateRow() |
void |
ResultSet.setRowCountEvent(long rowCount) |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
NetCursor.calculateColumnOffsetsForRow_(int rowIndex,
boolean allowServerFetch)
Calculate the column offsets for a row.
|
protected boolean |
NetConnectionReply.checkAndGetReceivedFlag(boolean receivedFlag) |
protected void |
NetAgent.checkOpen() |
protected void |
NetConnectionReply.checkRequiredObjects(boolean receivedFlag) |
protected void |
NetConnectionReply.checkRequiredObjects(boolean receivedFlag,
boolean receivedFlag2) |
protected void |
NetConnectionReply.checkRequiredObjects(boolean receivedFlag,
boolean receivedFlag2,
boolean receivedFlag3) |
protected void |
NetConnectionReply.checkRequiredObjects(boolean receivedFlag,
boolean receivedFlag2,
boolean receivedFlag3,
boolean receivedFlag4) |
protected void |
NetConnectionReply.checkRequiredObjects(boolean receivedFlag,
boolean receivedFlag2,
boolean receivedFlag3,
boolean receivedFlag4,
boolean receivedFlag5,
boolean receivedFlag6) |
protected void |
NetConnectionReply.checkRequiredObjects(boolean receivedFlag,
boolean receivedFlag2,
boolean receivedFlag3,
boolean receivedFlag4,
boolean receivedFlag5,
boolean receivedFlag6,
boolean receivedFlag7) |
protected void |
NetStatementReply.copyEXTDTA(NetCursor netCursor) |
protected void |
NetConnectionReply.doObjnsprmSemantics(int codePoint) |
protected void |
NetConnectionReply.doPrccnvrmSemantics(int conversationProtocolErrorCode) |
protected void |
NetConnectionReply.doPrmnsprmSemantics(int codePoint) |
protected void |
Reply.endOfSameIdChainData() |
protected int |
Reply.ensureALayerDataInBuffer(int desiredDataSize) |
protected void |
Reply.ensureBLayerDataInBuffer(int desiredDataSize) |
protected int |
Reply.fill(int minimumBytesNeeded) |
void |
NetAgent.flush_() |
protected void |
Request.flushExistingDSS() |
protected int |
Request.flushScalarStreamSegment() |
protected int |
Request.flushScalarStreamSegment(int leftToRead,
int bytesToRead) |
long |
NetSqlca.getRowCount(Typdef typdef) |
protected void |
Reply.matchCodePoint(int expectedCodePoint) |
protected void |
Request.padScalarStreamForError(int leftToRead,
int bytesToRead) |
protected int |
NetConnectionReply.parseCCSIDDBC() |
protected int |
NetConnectionReply.parseCCSIDMBC() |
protected int |
NetConnectionReply.parseCCSIDSBC() |
protected void |
NetConnectionReply.parseCMDCHKRM() |
protected void |
NetConnectionReply.parseCMDNSPRM() |
protected int |
NetConnectionReply.parseCODPNT() |
protected int |
NetConnectionReply.parseCODPNTDR() |
protected void |
NetConnectionReply.parseCommitError(ConnectionCallbackInterface connection) |
protected byte[] |
NetConnectionReply.parseCRRTKN(boolean skip) |
protected void |
NetStatementReply.parseENDQRYRM(ResultSetCallbackInterface resultSetI) |
protected void |
NetStatementReply.parseEndQuery(ResultSetCallbackInterface resultSetI) |
protected String |
NetConnectionReply.parseEXTNAM() |
protected int |
NetStatementReply.parseFastQRYATTSCR() |
protected int |
NetStatementReply.parseFastQRYATTSET() |
protected int |
NetStatementReply.parseFastQRYATTSNS() |
protected int |
NetStatementReply.parseFastQRYATTUPD() |
protected int |
NetStatementReply.parseFastQRYPRCTYP() |
protected int |
NetStatementReply.parseFastSQLCSRHLD() |
protected int |
NetConnectionReply.parseFastSVRCOD(int minSvrcod,
int maxSvrcod) |
protected String |
NetConnectionReply.parseFastVCS() |
protected Hashtable |
NetXAConnectionReply.parseIndoubtList() |
protected Hashtable |
NetConnectionReply.parseIndoubtList() |
protected void |
NetConnectionReply.parseInitialPBSD(Connection connection)
Parse the initial PBSD - PiggyBackedSessionData code point.
|
protected void |
Reply.parseLengthAndMatchCodePoint(int expectedCodePoint) |
protected int |
NetConnectionReply.parseMGRLVLN() |
protected void |
NetStatementReply.parseOpenQuery(StatementCallbackInterface statementI) |
protected NetResultSet |
NetStatementReply.parseOPNQRYRM(StatementCallbackInterface statementI,
boolean isOPNQRYreply)
Open Query Complete Reply Message indicates to the requester
that an OPNQRY or EXCSQLSTT command completed normally and that
the query process has been initiated.
|
protected void |
NetConnectionReply.parsePBSD()
Parse a PBSD - PiggyBackedSessionData code point.
|
protected Object |
NetStatementReply.parsePKGNAMCSN(boolean skip) |
protected Object |
NetPackageReply.parsePKGNAMCT(boolean skip) |
protected ArrayList |
NetStatementReply.parsePKGSNLST() |
protected int |
NetConnectionReply.parsePRCCNVCD() |
protected void |
NetConnectionReply.parsePRCCNVRM() |
protected String |
NetConnectionReply.parsePRDID(boolean skip) |
protected int |
NetStatementReply.parseQRYATTSCR() |
protected int |
NetStatementReply.parseQRYATTSET() |
protected int |
NetStatementReply.parseQRYATTSNS() |
protected int |
NetStatementReply.parseQRYATTUPD() |
protected void |
NetStatementReply.parseQRYDSC(NetCursor cursor) |
protected void |
NetStatementReply.parseQRYDTA(NetResultSet netResultSet) |
protected int |
NetStatementReply.parseQRYPRCTYP() |
protected String |
NetConnectionReply.parseRDBNAM(boolean skip) |
protected void |
NetPackageReply.parseRDBUPDRM() |
protected NetResultSet |
NetStatementReply.parseResultSetCursor(StatementCallbackInterface statementI,
Section section) |
protected void |
NetStatementReply.parseResultSetProcedure(StatementCallbackInterface statementI) |
protected ArrayList |
NetStatementReply.parseRSLSETRM() |
protected int |
NetConnectionReply.parseSECCHKCD() |
protected int[] |
NetConnectionReply.parseSECMEC() |
protected byte[] |
NetConnectionReply.parseSECTKN(boolean skip) |
protected NetSqlca |
NetConnectionReply.parseSQLCARD(Sqlca[] rowsetSqlca) |
protected ColumnMetaData |
NetStatementReply.parseSQLCINRD() |
protected int |
NetStatementReply.parseSQLCSRHLD() |
protected NetSqlca |
NetStatementReply.parseSQLDARD(ColumnMetaData columnMetaData,
StatementCallbackInterface statement,
boolean skipBytes) |
protected NetSqlca |
NetStatementReply.parseSQLDTARD(NetSqldta netSqldta) |
protected int |
NetStatementReply.parseSQLRSLRD(ArrayList sectionAL) |
protected String |
NetConnectionReply.parseSRVCLSNM() |
protected String |
NetConnectionReply.parseSRVNAM() |
protected String |
NetConnectionReply.parseSRVRLSLV() |
protected int |
NetConnectionReply.parseSVRCOD(int minSvrcod,
int maxSvrcod) |
protected int |
NetXAConnectionReply.parseSYNCCTLreply(ConnectionCallbackInterface connection) |
protected int |
NetConnectionReply.parseSYNCCTLreply(ConnectionCallbackInterface connection) |
protected byte |
NetXAConnectionReply.parseSYNCTYPE() |
protected byte |
NetConnectionReply.parseSYNCTYPE() |
protected int |
NetConnectionReply.parseSYNERRCD() |
protected void |
NetConnectionReply.parseSYNTAXRM() |
protected int |
NetConnectionReply.parseTypdefsOrMgrlvlovrs() |
protected int |
NetConnectionReply.parseUOWDSP() |
protected String |
NetConnectionReply.parseUSRID(boolean skip) |
protected void |
NetConnectionReply.parseVALNSPRM() |
protected int |
NetXAConnectionReply.parseXARETVAL() |
protected int |
NetConnectionReply.parseXARETVAL() |
protected Xid |
NetXAConnectionReply.parseXID() |
protected Xid |
NetConnectionReply.parseXID() |
protected int |
NetXAConnectionReply.parseXIDCNT() |
protected int |
NetConnectionReply.parseXIDCNT() |
protected int |
Reply.peekCodePoint() |
protected int |
Reply.peekFastBytes(byte[] b,
int offset,
int length) |
protected int |
Reply.peekFastLength() |
protected int |
Reply.peekLength() |
protected int |
Reply.peekNumOfColumns() |
protected int |
Reply.peekTotalColumnCount(int tripletLength) |
protected int |
Request.prepScalarStream(boolean chained,
boolean chainedWithSameCorrelator,
boolean writeNullByte,
int leftToRead) |
void |
ConnectionReplyInterface.readCommitSubstitute(ConnectionCallbackInterface connection) |
void |
NetConnectionReply.readCommitSubstitute(ConnectionCallbackInterface connection) |
void |
ResultSetReplyInterface.readCursorClose(ResultSetCallbackInterface resultSet) |
void |
NetResultSetReply.readCursorClose(ResultSetCallbackInterface resultSet) |
void |
NetStatementReply.readDescribeInput(PreparedStatementCallbackInterface preparedStatement) |
void |
StatementReplyInterface.readDescribeInput(PreparedStatementCallbackInterface preparedStatement) |
void |
NetStatementReply.readDescribeOutput(PreparedStatementCallbackInterface preparedStatement) |
void |
StatementReplyInterface.readDescribeOutput(PreparedStatementCallbackInterface preparedStatement) |
protected void |
Reply.readDSSContinuationHeader() |
protected void |
Reply.readDssHeader() |
void |
NetStatementReply.readExecute(PreparedStatementCallbackInterface preparedStatement) |
void |
StatementReplyInterface.readExecute(PreparedStatementCallbackInterface preparedStatement) |
void |
NetStatementReply.readExecuteCall(StatementCallbackInterface statement) |
void |
StatementReplyInterface.readExecuteCall(StatementCallbackInterface statement) |
void |
NetStatementReply.readExecuteImmediate(StatementCallbackInterface statement) |
void |
StatementReplyInterface.readExecuteImmediate(StatementCallbackInterface statement) |
void |
ResultSetReplyInterface.readFetch(ResultSetCallbackInterface resultSet) |
void |
NetResultSetReply.readFetch(ResultSetCallbackInterface resultSet) |
protected int |
Reply.readLengthAndCodePoint() |
void |
ConnectionReplyInterface.readLocalCommit(ConnectionCallbackInterface connection) |
void |
NetConnectionReply.readLocalCommit(ConnectionCallbackInterface connection) |
void |
ConnectionReplyInterface.readLocalRollback(ConnectionCallbackInterface connection) |
void |
NetConnectionReply.readLocalRollback(ConnectionCallbackInterface connection) |
void |
NetXAConnectionReply.readLocalXACommit(ConnectionCallbackInterface connection) |
void |
ConnectionReplyInterface.readLocalXACommit(ConnectionCallbackInterface connection) |
void |
NetConnectionReply.readLocalXACommit(ConnectionCallbackInterface connection) |
void |
NetXAConnectionReply.readLocalXARollback(ConnectionCallbackInterface connection) |
void |
ConnectionReplyInterface.readLocalXARollback(ConnectionCallbackInterface connection) |
void |
NetConnectionReply.readLocalXARollback(ConnectionCallbackInterface connection) |
void |
NetXAConnectionReply.readLocalXAStart(ConnectionCallbackInterface connection) |
void |
ConnectionReplyInterface.readLocalXAStart(ConnectionCallbackInterface connection) |
void |
NetConnectionReply.readLocalXAStart(ConnectionCallbackInterface connection) |
void |
NetStatementReply.readOpenQuery(StatementCallbackInterface statement) |
void |
StatementReplyInterface.readOpenQuery(StatementCallbackInterface statement) |
void |
ResultSetReplyInterface.readPositioningFetch(ResultSetCallbackInterface resultSet) |
void |
NetResultSetReply.readPositioningFetch(ResultSetCallbackInterface resultSet) |
void |
NetStatementReply.readPrepare(StatementCallbackInterface statement) |
void |
StatementReplyInterface.readPrepare(StatementCallbackInterface statement) |
void |
NetStatementReply.readPrepareDescribeOutput(StatementCallbackInterface statement) |
void |
StatementReplyInterface.readPrepareDescribeOutput(StatementCallbackInterface statement) |
void |
ResultSetReplyInterface.readScrollableFetch(ResultSetCallbackInterface resultSet) |
void |
NetResultSetReply.readScrollableFetch(ResultSetCallbackInterface resultSet) |
void |
NetStatementReply.readSetSpecialRegister(StatementCallbackInterface statement) |
void |
StatementReplyInterface.readSetSpecialRegister(StatementCallbackInterface statement) |
void |
NetStatementReply.readStatementID(StatementCallbackInterface statement) |
void |
StatementReplyInterface.readStatementID(StatementCallbackInterface statement) |
protected void |
NetXAConnectionReply.readXaCommit(NetConnection conn) |
protected void |
NetConnectionReply.readXaCommit(NetConnection conn) |
protected int |
NetXAConnectionReply.readXaEndUnitOfWork(NetConnection conn) |
protected int |
NetConnectionReply.readXaEndUnitOfWork(NetConnection conn) |
protected void |
NetXAConnectionReply.readXaForget(NetConnection conn) |
protected void |
NetConnectionReply.readXaForget(NetConnection conn) |
protected int |
NetXAConnectionReply.readXaPrepare(NetConnection conn) |
protected int |
NetConnectionReply.readXaPrepare(NetConnection conn) |
protected void |
NetXAConnectionReply.readXaRecover(NetConnection conn) |
protected void |
NetConnectionReply.readXaRecover(NetConnection conn) |
protected int |
NetXAConnectionReply.readXaRollback(NetConnection conn) |
protected int |
NetConnectionReply.readXaRollback(NetConnection conn) |
protected void |
NetXAConnectionReply.readXaStartUnitOfWork(NetConnection conn) |
protected void |
NetConnectionReply.readXaStartUnitOfWork(NetConnection conn) |
protected void |
NetAgent.sendRequest() |
protected void |
Reply.startSameIdChainParse() |
void |
NetAgent.throwCommunicationsFailure(Throwable cause) |
| Constructor and Description |
|---|
Typdef(NetAgent netAgent,
int ccsidSbc,
String typdefnam,
int ccsidDbc,
int ccsidMbc) |
Copyright © 2010-2015 Pivotal Software, Inc. All rights reserved.