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

Quick Search    Search Deep

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

java.lang.Object
  extended byorg.apache.derby.client.net.Request
Direct Known Subclasses:
NetConnectionRequest

public class Request
extends java.lang.Object


Field Summary
protected  byte[] bytes_
           
protected  CcsidManager ccsidManager_
           
private  int correlationID_
           
private  int dssLengthLocation_
           
private  int[] markStack_
           
private static int MAX_MARKS_NESTING
           
protected  NetAgent netAgent_
           
protected  int offset_
           
protected  boolean passwordIncluded_
           
protected  int passwordLength_
           
protected  int passwordStart_
           
private  boolean simpleDssFinalize
           
private  int top_
           
 
Constructor Summary
(package private) Request(NetAgent netAgent, CcsidManager ccsidManager, int bufferSize)
           
(package private) Request(NetAgent netAgent, int minSize, CcsidManager ccsidManager)
           
 
Method Summary
private  void buildDss(boolean dssHasSameCorrelator, boolean chainedToNextStructure, boolean nextHasSameCorrelator, int dssType, int corrId, boolean simpleFinalizeBuildingNextDss)
           
private  byte[] buildLengthAndCodePointForEncryptedLob(int codePoint, int leftToRead, boolean writeNullByte, int extendedLengthByteCount)
           
private  void buildLengthAndCodePointForLob(int codePoint, int leftToRead, boolean writeNullByte, int extendedLengthByteCount)
           
(package private)  void buildTripletHeader(int tripletLength, int tripletType, int tripletId)
           
private  int calculateExtendedLengthByteCount(long ddmSize)
           
protected  void clearBuffer()
           
protected  void createCommand()
           
(package private)  void createCommandData()
           
(package private)  void createEncryptedCommandData()
           
protected  void createXACommand()
           
protected  boolean doesRequestContainData()
           
protected  void ensureLength(int length)
           
protected  void finalizeDssLength()
           
protected  void finalizePreviousChainedDss(boolean dssHasSameCorrelator)
           
protected  void flush(java.io.OutputStream socketOutputStream)
           
protected  int flushScalarStreamSegment(int leftToRead, int bytesToRead)
           
(package private)  void initialize()
           
private  void mark()
           
protected  void markForCachingPKGNAMCSN()
           
protected  void markLengthBytes(int codePoint)
           
(package private)  void maskOutPassword()
           
(package private)  void padBytes(byte padByte, int length)
           
protected  void padScalarStreamForError(int leftToRead, int bytesToRead)
           
private  int popMark()
           
protected  int popMarkForCachingPKGNAMCSN()
           
protected  int prepScalarStream(boolean chained, boolean chainedWithSameCorrelator, boolean writeNullByte, int leftToRead)
           
protected  void sendBytes(java.io.OutputStream socketOutputStream)
           
(package private)  void setCcsidMgr(CcsidManager ccsidManager)
           
 void setCorrelationID(int id)
           
 void setDssLengthLocation(int location)
           
protected  void updateLengthBytes()
           
(package private)  void write1Byte(int value)
           
(package private)  void write2Bytes(int value)
           
(package private)  void write4Bytes(long value)
           
(package private)  void writeBigDecimal(java.math.BigDecimal v, int declaredPrecision, int declaredScale)
           
(package private)  void writeBoolean(boolean v)
           
(package private)  void writeByte(byte v)
           
(package private)  void writeBytes(byte[] buf)
           
(package private)  void writeBytes(byte[] buf, int length)
           
(package private)  void writeCodePoint4Bytes(int codePoint, int value)
           
(package private)  void writeDate(java.sql.Date date)
           
(package private)  void writeDDMString(java.lang.String s)
           
protected  void writeDouble(double v)
           
(package private)  byte[] writeEXTDTALengthCodePointForEncryption(int length, int codePoint)
           
private  void writeExtendedLengthBytes(int extendedLengthByteCount, long length)
           
private  byte[] writeExtendedLengthBytesForEncryption(int extendedLengthByteCount, long length)
           
protected  void writeFloat(float v)
           
(package private)  void writeInt(int v)
           
protected  void writeIntFdocaData(int v)
           
(package private)  void writeLDBytes(byte[] bytes)
           
private  void writeLDBytesX(int ldSize, byte[] bytes)
           
(package private)  void writeLengthCodePoint(int length, int codePoint)
           
(package private)  void writeLidAndLengths(int[][] lidAndLengthOverrides, int count, int offset)
           
(package private)  void writeLidAndLengths(int[][] lidAndLengthOverrides, int count, int offset, boolean mddRequired, java.util.Hashtable map)
           
(package private)  void writeLong(long v)
           
protected  void writeLongFdocaData(long v)
           
protected  void writeScalar1Byte(int codePoint, int value)
           
(package private)  void writeScalar2Bytes(int codePoint, int value)
           
protected  void writeScalar4Bytes(int codePoint, long value)
           
(package private)  void writeScalar8Bytes(int codePoint, long value)
           
(package private)  void writeScalarBytes(int codePoint, byte[] buff)
           
(package private)  void writeScalarBytes(int codePoint, byte[] buf, int length)
           
(package private)  void writeScalarBytes(int codePoint, byte[] buff, int start, int length)
           
(package private)  void writeScalarHeader(int codePoint, int dataLength)
           
(package private)  void writeScalarPaddedBytes(byte[] buff, int paddedLength, byte padByte)
           
(package private)  void writeScalarPaddedBytes(int codePoint, byte[] buff, int paddedLength, byte padByte)
           
(package private)  void writeScalarPaddedString(int codePoint, java.lang.String string, int paddedLength)
           
(package private)  void writeScalarPaddedString(java.lang.String string, int paddedLength)
           
(package private)  void writeScalarStream(boolean chained, boolean chainedWithSameCorrelator, int codePoint, int length, java.io.InputStream in, boolean writeNullByte, int parameterIndex)
           
(package private)  void writeScalarStream(boolean chained, boolean chainedWithSameCorrelator, int codePoint, int length, java.io.Reader r, boolean writeNullByte, int parameterIndex)
           
(package private)  void writeScalarString(int codePoint, java.lang.String string)
           
(package private)  void writeShort(short v)
           
protected  void writeShortFdocaData(short v)
           
(package private)  void writeSingleorMixedCcsidLDString(java.lang.String s, java.lang.String encoding)
           
(package private)  void writeTime(java.sql.Time time)
           
(package private)  void writeTimestamp(java.sql.Timestamp timestamp)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

bytes_

protected byte[] bytes_

offset_

protected int offset_

MAX_MARKS_NESTING

private static final int MAX_MARKS_NESTING
See Also:
Constant Field Values

markStack_

private int[] markStack_

top_

private int top_

ccsidManager_

protected CcsidManager ccsidManager_

dssLengthLocation_

private int dssLengthLocation_

correlationID_

private int correlationID_

simpleDssFinalize

private boolean simpleDssFinalize

passwordIncluded_

protected boolean passwordIncluded_

passwordStart_

protected int passwordStart_

passwordLength_

protected int passwordLength_

netAgent_

protected NetAgent netAgent_
Constructor Detail

Request

Request(NetAgent netAgent,
        int minSize,
        CcsidManager ccsidManager)

Request

Request(NetAgent netAgent,
        CcsidManager ccsidManager,
        int bufferSize)
Method Detail

clearBuffer

protected final void clearBuffer()

initialize

final void initialize()

setCcsidMgr

final void setCcsidMgr(CcsidManager ccsidManager)

ensureLength

protected final void ensureLength(int length)

createCommand

protected final void createCommand()

createXACommand

protected void createXACommand()

createCommandData

final void createCommandData()

createEncryptedCommandData

final void createEncryptedCommandData()

buildDss

private final void buildDss(boolean dssHasSameCorrelator,
                            boolean chainedToNextStructure,
                            boolean nextHasSameCorrelator,
                            int dssType,
                            int corrId,
                            boolean simpleFinalizeBuildingNextDss)

writeScalarStream

final void writeScalarStream(boolean chained,
                             boolean chainedWithSameCorrelator,
                             int codePoint,
                             int length,
                             java.io.InputStream in,
                             boolean writeNullByte,
                             int parameterIndex)
                      throws org.apache.derby.client.am.DisconnectException,
                             org.apache.derby.client.am.SqlException

writeScalarStream

final void writeScalarStream(boolean chained,
                             boolean chainedWithSameCorrelator,
                             int codePoint,
                             int length,
                             java.io.Reader r,
                             boolean writeNullByte,
                             int parameterIndex)
                      throws org.apache.derby.client.am.DisconnectException

prepScalarStream

protected final int prepScalarStream(boolean chained,
                                     boolean chainedWithSameCorrelator,
                                     boolean writeNullByte,
                                     int leftToRead)
                              throws org.apache.derby.client.am.DisconnectException

flushScalarStreamSegment

protected final int flushScalarStreamSegment(int leftToRead,
                                             int bytesToRead)
                                      throws org.apache.derby.client.am.DisconnectException

padScalarStreamForError

protected final void padScalarStreamForError(int leftToRead,
                                             int bytesToRead)
                                      throws org.apache.derby.client.am.DisconnectException

writeExtendedLengthBytes

private final void writeExtendedLengthBytes(int extendedLengthByteCount,
                                            long length)

writeExtendedLengthBytesForEncryption

private final byte[] writeExtendedLengthBytesForEncryption(int extendedLengthByteCount,
                                                           long length)

finalizePreviousChainedDss

protected final void finalizePreviousChainedDss(boolean dssHasSameCorrelator)

doesRequestContainData

protected final boolean doesRequestContainData()

finalizeDssLength

protected final void finalizeDssLength()

markLengthBytes

protected final void markLengthBytes(int codePoint)

mark

private final void mark()

popMark

private final int popMark()

markForCachingPKGNAMCSN

protected final void markForCachingPKGNAMCSN()

popMarkForCachingPKGNAMCSN

protected final int popMarkForCachingPKGNAMCSN()

updateLengthBytes

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

calculateExtendedLengthByteCount

private final int calculateExtendedLengthByteCount(long ddmSize)

padBytes

final void padBytes(byte padByte,
                    int length)

write1Byte

final void write1Byte(int value)

buildTripletHeader

final void buildTripletHeader(int tripletLength,
                              int tripletType,
                              int tripletId)

writeLidAndLengths

final void writeLidAndLengths(int[][] lidAndLengthOverrides,
                              int count,
                              int offset)

writeLidAndLengths

final void writeLidAndLengths(int[][] lidAndLengthOverrides,
                              int count,
                              int offset,
                              boolean mddRequired,
                              java.util.Hashtable map)

write2Bytes

final void write2Bytes(int value)

write4Bytes

final void write4Bytes(long value)

writeBytes

final void writeBytes(byte[] buf,
                      int length)

writeBytes

final void writeBytes(byte[] buf)

writeCodePoint4Bytes

final void writeCodePoint4Bytes(int codePoint,
                                int value)

writeScalar1Byte

protected final void writeScalar1Byte(int codePoint,
                                      int value)

writeScalar2Bytes

final void writeScalar2Bytes(int codePoint,
                             int value)

writeScalar4Bytes

protected final void writeScalar4Bytes(int codePoint,
                                       long value)

writeScalar8Bytes

final void writeScalar8Bytes(int codePoint,
                             long value)

writeLengthCodePoint

final void writeLengthCodePoint(int length,
                                int codePoint)

writeEXTDTALengthCodePointForEncryption

final byte[] writeEXTDTALengthCodePointForEncryption(int length,
                                                     int codePoint)

writeScalarBytes

final void writeScalarBytes(int codePoint,
                            byte[] buf,
                            int length)

writeScalarHeader

final void writeScalarHeader(int codePoint,
                             int dataLength)

writeScalarString

final void writeScalarString(int codePoint,
                             java.lang.String string)
                      throws org.apache.derby.client.am.SqlException

writeScalarPaddedString

final void writeScalarPaddedString(int codePoint,
                                   java.lang.String string,
                                   int paddedLength)
                            throws org.apache.derby.client.am.SqlException

writeScalarPaddedString

final void writeScalarPaddedString(java.lang.String string,
                                   int paddedLength)
                            throws org.apache.derby.client.am.SqlException

writeScalarBytes

final void writeScalarBytes(int codePoint,
                            byte[] buff)

writeScalarBytes

final void writeScalarBytes(int codePoint,
                            byte[] buff,
                            int start,
                            int length)

writeScalarPaddedBytes

final void writeScalarPaddedBytes(int codePoint,
                                  byte[] buff,
                                  int paddedLength,
                                  byte padByte)

writeScalarPaddedBytes

final void writeScalarPaddedBytes(byte[] buff,
                                  int paddedLength,
                                  byte padByte)

flush

protected void flush(java.io.OutputStream socketOutputStream)
              throws java.io.IOException

sendBytes

protected void sendBytes(java.io.OutputStream socketOutputStream)
                  throws java.io.IOException

maskOutPassword

final void maskOutPassword()

writeByte

final void writeByte(byte v)

writeShort

final void writeShort(short v)

writeInt

void writeInt(int v)

writeLong

final void writeLong(long v)

writeShortFdocaData

protected void writeShortFdocaData(short v)

writeIntFdocaData

protected void writeIntFdocaData(int v)

writeLongFdocaData

protected void writeLongFdocaData(long v)

writeFloat

protected void writeFloat(float v)

writeDouble

protected void writeDouble(double v)

writeBigDecimal

final void writeBigDecimal(java.math.BigDecimal v,
                           int declaredPrecision,
                           int declaredScale)
                    throws org.apache.derby.client.am.SqlException

writeDate

final void writeDate(java.sql.Date date)
              throws org.apache.derby.client.am.SqlException

writeTime

final void writeTime(java.sql.Time time)
              throws org.apache.derby.client.am.SqlException

writeTimestamp

final void writeTimestamp(java.sql.Timestamp timestamp)
                   throws org.apache.derby.client.am.SqlException

writeBoolean

final void writeBoolean(boolean v)

writeSingleorMixedCcsidLDString

final void writeSingleorMixedCcsidLDString(java.lang.String s,
                                           java.lang.String encoding)
                                    throws org.apache.derby.client.am.SqlException

writeLDBytes

final void writeLDBytes(byte[] bytes)

writeLDBytesX

private final void writeLDBytesX(int ldSize,
                                 byte[] bytes)

writeDDMString

final void writeDDMString(java.lang.String s)
                   throws org.apache.derby.client.am.SqlException

buildLengthAndCodePointForEncryptedLob

private byte[] buildLengthAndCodePointForEncryptedLob(int codePoint,
                                                      int leftToRead,
                                                      boolean writeNullByte,
                                                      int extendedLengthByteCount)
                                               throws org.apache.derby.client.am.DisconnectException

buildLengthAndCodePointForLob

private void buildLengthAndCodePointForLob(int codePoint,
                                           int leftToRead,
                                           boolean writeNullByte,
                                           int extendedLengthByteCount)
                                    throws org.apache.derby.client.am.DisconnectException

setDssLengthLocation

public void setDssLengthLocation(int location)

setCorrelationID

public void setCorrelationID(int id)