java.lang.Object
org.apache.derby.client.net.Request
- Direct Known Subclasses:
- NetConnectionRequest
- public class Request
- extends java.lang.Object
|
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 |
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_
Request
Request(NetAgent netAgent,
int minSize,
CcsidManager ccsidManager)
Request
Request(NetAgent netAgent,
CcsidManager ccsidManager,
int bufferSize)
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)