Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

org.apache.derby.client.net
Class NetCursor  view NetCursor download NetCursor.java

java.lang.Object
  extended byorg.apache.derby.client.am.Cursor
      extended byorg.apache.derby.client.net.NetCursor
Direct Known Subclasses:
NetSqldta

public class NetCursor
extends org.apache.derby.client.am.Cursor


Field Summary
(package private)  boolean blocking_
           
(package private)  java.util.ArrayList extdtaData_
           
(package private)  java.util.HashMap extdtaPositions_
           
(package private)  boolean[] isGraphic_
           
(package private)  int maximumRowSize_
           
(package private)  NetAgent netAgent_
           
(package private)  NetResultSet netResultSet_
           
(package private)  int numMddOverrides_
           
(package private)  Typdef qrydscTypdef_
           
(package private)  boolean rtnextrow_
           
(package private)  int targetSqlamForTypdef_
           
(package private)  int[] typeToUseForComputingDataLength_
           
 
Fields inherited from class org.apache.derby.client.am.Cursor
agent_, allRowsReceivedFromServer_, BYTES, ccsid_, charsetName_, columnDataComputedLength_, columnDataIsNullCache_, columnDataLengthCache_, columnDataPosition_, columnDataPositionCache_, columns_, currentRowPosition_, dataBuffer_, dataBufferStream_, DBCS_CLOB, fdocaLength_, hasLobs_, isNull_, isUpdateDeleteHole_, isUpdateDeleteHoleCache_, jdbcTypes_, lastValidBytePosition_, MBCS_CLOB, NULL_TERMINATED_BYTES, NULL_TERMINATED_STRING, nullable_, position_, ROW_IS_NOT_NULL, ROW_IS_NULL, SBCS_CLOB, STRING, VARIABLE_BYTES, VARIABLE_SHORT_BYTES, VARIABLE_SHORT_STRING, VARIABLE_STRING
 
Constructor Summary
(package private) NetCursor(NetAgent netAgent)
           
(package private) NetCursor(NetAgent netAgent, int qryprctyp)
           
 
Method Summary
private  void adjustColumnOffsetsForColumnsPreviouslyCalculated(int index)
           
private  int[] allocateColumnDataComputedLengthArray(int row)
           
private  boolean[] allocateColumnDataIsNullArray(int row)
           
private  int[] allocateColumnDataPositionArray(int row)
           
(package private)  void allocateColumnOffsetAndLengthArrays()
           
protected  void allocateDataBuffer()
           
protected  void allocateDataBuffer(int length)
           
protected  boolean calculateColumnOffsetsForRow_(int rowIndex)
           
(package private)  void calculateLobColumnPositionsForRow()
           
private  void checkAndThrowReceivedEndqryrm()
           
private  void checkAndThrowReceivedEndqryrm(int lastValidBytePositionBeforeFetch)
           
protected  void clearLobData_()
           
private  int completeSplitRow()
           
private  int completeSplitRow(int index)
           
(package private)  int ensureSpaceForDataBuffer(int ddmLength)
           
protected  byte[] findExtdtaData(int column)
           
 org.apache.derby.client.am.Blob getBlobColumn_(int column, org.apache.derby.client.am.Agent agent)
           
 byte[] getClobBytes_(int column, int[] dataOffset)
           
 org.apache.derby.client.am.Clob getClobColumn_(int column, org.apache.derby.client.am.Agent agent)
           
protected  int getDecimalLength(int index)
           
protected  void getMoreData_()
           
(package private)  void initializeColumnInfoArrays(Typdef typdef, int columnCount, int targetSqlamForTypdef)
           
protected  boolean isDataBufferNull()
           
(package private)  boolean isNonTrivialDataLob(int index)
           
 void nullDataForGC()
           
private  NetSqlca parseSQLCAGRP(Typdef typdef)
           
(package private)  NetSqlca parseSQLCARD(Typdef typdef)
           
private  void parseSQLCAXGRP(Typdef typdef, NetSqlca netSqlca)
           
private  void parseSQLDIAGGRP()
           
private  java.lang.String parseVCS(Typdef typdefInEffect)
           
private  byte[] readFdocaBytes(int length)
           
private  int readFdocaInt()
           
private  int readFdocaOneByte()
           
private  int readFdocaOneByte(int index)
           
private  java.lang.String readFdocaString(int length, java.lang.String encoding)
           
private  int readFdocaTwoByteLength()
           
private  int readFdocaTwoByteLength(int index)
           
private  void resetCurrentRowPosition()
           
(package private)  void setBlocking(int queryProtocolType)
           
private  void shiftPartialRowToBeginning()
           
private  int skipFdocaBytes(int length)
           
private  int skipFdocaBytes(int length, int index)
           
 
Methods inherited from class org.apache.derby.client.am.Cursor
allocateCharBuffer, currentRowPositionIsEqualToNextRowPosition, dataBufferHasUnprocessedData, getArray, getAsciiStream, getBinaryStream, getBlob, getCharacterStream, getClob, getDataBuffer, getDataBufferLength, getLastValidBytePosition, getObject, getRef, getUnicodeStream, incrementRowsReadEvent, makeNextRowPositionCurrent, markCurrentRowPosition, markNextRowPosition, next, resetDataBuffer, setAllRowsReceivedFromServer, setBuffer, setIsUpdataDeleteHole, setNumberOfColumns
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

netResultSet_

NetResultSet netResultSet_

netAgent_

NetAgent netAgent_

qrydscTypdef_

Typdef qrydscTypdef_

targetSqlamForTypdef_

int targetSqlamForTypdef_

numMddOverrides_

int numMddOverrides_

maximumRowSize_

int maximumRowSize_

blocking_

boolean blocking_

typeToUseForComputingDataLength_

int[] typeToUseForComputingDataLength_

isGraphic_

boolean[] isGraphic_

extdtaPositions_

java.util.HashMap extdtaPositions_

extdtaData_

java.util.ArrayList extdtaData_

rtnextrow_

boolean rtnextrow_
Constructor Detail

NetCursor

NetCursor(NetAgent netAgent)

NetCursor

NetCursor(NetAgent netAgent,
          int qryprctyp)
Method Detail

calculateColumnOffsetsForRow_

protected boolean calculateColumnOffsetsForRow_(int rowIndex)
                                         throws org.apache.derby.client.am.SqlException,
                                                org.apache.derby.client.am.DisconnectException

isDataBufferNull

protected boolean isDataBufferNull()

allocateDataBuffer

protected void allocateDataBuffer()

allocateDataBuffer

protected void allocateDataBuffer(int length)

readFdocaInt

private int readFdocaInt()
                  throws org.apache.derby.client.am.DisconnectException,
                         org.apache.derby.client.am.SqlException

readFdocaOneByte

private int readFdocaOneByte()
                      throws org.apache.derby.client.am.DisconnectException,
                             org.apache.derby.client.am.SqlException

readFdocaOneByte

private int readFdocaOneByte(int index)
                      throws org.apache.derby.client.am.DisconnectException,
                             org.apache.derby.client.am.SqlException

readFdocaBytes

private byte[] readFdocaBytes(int length)
                       throws org.apache.derby.client.am.DisconnectException,
                              org.apache.derby.client.am.SqlException

readFdocaTwoByteLength

private int readFdocaTwoByteLength()
                            throws org.apache.derby.client.am.DisconnectException,
                                   org.apache.derby.client.am.SqlException

readFdocaTwoByteLength

private int readFdocaTwoByteLength(int index)
                            throws org.apache.derby.client.am.DisconnectException,
                                   org.apache.derby.client.am.SqlException

skipFdocaBytes

private int skipFdocaBytes(int length)
                    throws org.apache.derby.client.am.DisconnectException,
                           org.apache.derby.client.am.SqlException

skipFdocaBytes

private int skipFdocaBytes(int length,
                           int index)
                    throws org.apache.derby.client.am.DisconnectException,
                           org.apache.derby.client.am.SqlException

shiftPartialRowToBeginning

private void shiftPartialRowToBeginning()

adjustColumnOffsetsForColumnsPreviouslyCalculated

private void adjustColumnOffsetsForColumnsPreviouslyCalculated(int index)

resetCurrentRowPosition

private void resetCurrentRowPosition()

calculateLobColumnPositionsForRow

void calculateLobColumnPositionsForRow()

isNonTrivialDataLob

boolean isNonTrivialDataLob(int index)

clearLobData_

protected void clearLobData_()

parseSQLCARD

NetSqlca parseSQLCARD(Typdef typdef)
                throws org.apache.derby.client.am.DisconnectException,
                       org.apache.derby.client.am.SqlException

parseSQLCAGRP

private NetSqlca parseSQLCAGRP(Typdef typdef)
                        throws org.apache.derby.client.am.DisconnectException,
                               org.apache.derby.client.am.SqlException

parseSQLCAXGRP

private void parseSQLCAXGRP(Typdef typdef,
                            NetSqlca netSqlca)
                     throws org.apache.derby.client.am.DisconnectException,
                            org.apache.derby.client.am.SqlException

parseSQLDIAGGRP

private void parseSQLDIAGGRP()
                      throws org.apache.derby.client.am.DisconnectException,
                             org.apache.derby.client.am.SqlException

parseVCS

private java.lang.String parseVCS(Typdef typdefInEffect)
                           throws org.apache.derby.client.am.DisconnectException,
                                  org.apache.derby.client.am.SqlException

readFdocaString

private java.lang.String readFdocaString(int length,
                                         java.lang.String encoding)
                                  throws org.apache.derby.client.am.DisconnectException,
                                         org.apache.derby.client.am.SqlException

allocateColumnOffsetAndLengthArrays

void allocateColumnOffsetAndLengthArrays()

setBlocking

void setBlocking(int queryProtocolType)

findExtdtaData

protected byte[] findExtdtaData(int column)

getBlobColumn_

public org.apache.derby.client.am.Blob getBlobColumn_(int column,
                                                      org.apache.derby.client.am.Agent agent)
                                               throws org.apache.derby.client.am.SqlException

getClobColumn_

public org.apache.derby.client.am.Clob getClobColumn_(int column,
                                                      org.apache.derby.client.am.Agent agent)
                                               throws org.apache.derby.client.am.SqlException

getClobBytes_

public byte[] getClobBytes_(int column,
                            int[] dataOffset)
                     throws org.apache.derby.client.am.SqlException

initializeColumnInfoArrays

void initializeColumnInfoArrays(Typdef typdef,
                                int columnCount,
                                int targetSqlamForTypdef)
                          throws org.apache.derby.client.am.DisconnectException

ensureSpaceForDataBuffer

int ensureSpaceForDataBuffer(int ddmLength)

getMoreData_

protected void getMoreData_()
                     throws org.apache.derby.client.am.SqlException

nullDataForGC

public void nullDataForGC()

checkAndThrowReceivedEndqryrm

private void checkAndThrowReceivedEndqryrm()
                                    throws org.apache.derby.client.am.SqlException

checkAndThrowReceivedEndqryrm

private void checkAndThrowReceivedEndqryrm(int lastValidBytePositionBeforeFetch)
                                    throws org.apache.derby.client.am.SqlException

completeSplitRow

private int completeSplitRow()
                      throws org.apache.derby.client.am.DisconnectException,
                             org.apache.derby.client.am.SqlException

completeSplitRow

private int completeSplitRow(int index)
                      throws org.apache.derby.client.am.DisconnectException,
                             org.apache.derby.client.am.SqlException

allocateColumnDataPositionArray

private int[] allocateColumnDataPositionArray(int row)

allocateColumnDataComputedLengthArray

private int[] allocateColumnDataComputedLengthArray(int row)

allocateColumnDataIsNullArray

private boolean[] allocateColumnDataIsNullArray(int row)

getDecimalLength

protected int getDecimalLength(int index)