Package com.nuodb.jdbc

Class EncodedDataStream

java.lang.Object

com.nuodb.impl.util.DataStream

com.nuodb.jdbc.EncodedDataStream

All Implemented Interfaces:

TimeValues, Iterable<com.nuodb.impl.util.DataStream.Segment>

Direct Known Subclasses:

RemEncodedStream

public class EncodedDataStream
extends com.nuodb.impl.util.DataStream
implements TimeValues

Nested Class Summary

Nested classes/interfaces inherited from class com.nuodb.impl.util.DataStream

com.nuodb.impl.util.DataStream.IterateSegments, com.nuodb.impl.util.DataStream.Segment

Field Summary

Fields inherited from class com.nuodb.impl.util.DataStream

DEFAULT_STRING_SIZE, totalLength

Fields inherited from interface com.nuodb.jdbc.TimeValues

MILLISECONDS_PER_DAY, MILLISECONDS_PER_HOUR, MILLISECONDS_PER_MINUTE, MILLISECONDS_SCALE, NANOSECONDS_SCALE, SECONDS_PER_DAY, SECONDS_PER_HOUR, SECONDS_PER_MINUTE, SECONDS_SCALE

Constructor Summary

Constructors

Constructor	Description
EncodedDataStream()
EncodedDataStream(int protocolVersion)

Method Summary

Modifier and Type	Method	Description
void	decode()
int	decode(byte[] source, int sourceOffset)
void	encodeArray(Array value)
void	encodeBigDecimal(BigDecimal bd)
void	encodeBoolean(boolean value)
void	encodeByte(byte value)
void	encodeBytes(byte[] value)
void	encodeDate(Date date)
void	encodeDouble(double dbl)
void	encodeInt(int value)
void	encodeLong(long value)
void	encodeLong(long value, int scale)
void	encodeNull()
void	encodeObject(Object obj)
void	encodeOldBigDecimal(BigDecimal bd)
void	encodeOutParameter(int index, com.nuodb.jdbc.RemCallableStatement.OutParameter param)
void	encodeScaledDate(Date date)
void	encodeScaledTime(Time time)
void	encodeScaledTimestamp(Timestamp val)
void	encodeString(String string)
void	encodeTime(Time time)
void	encodeTimestamp(Timestamp val)
boolean	getBoolean()
byte[]	getBytes()
void	getMessage(com.nuodb.impl.net.CryptoInputStream stream)
void	getMessage(com.nuodb.impl.net.CryptoInputStream stream, Long maxLength)
int	getProtocolVersion()
String	getString()
UUID	getUUId()
boolean	isEndOfMessage()
int	setBase64(char[] data, int dataOffset, int length)
void	setData(byte[] data, int offset, int length)
void	setProtocolVersion(int protocolVersion)
void	startMessage(int messageType)
void	write(byte[] b)

Methods inherited from class com.nuodb.impl.util.DataStream

getBuffer, getString, iterator, putBase64, readString, reset, send, write, write, write

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

EncodedDataStream

public EncodedDataStream()

EncodedDataStream

public EncodedDataStream(int protocolVersion)

Method Detail

setProtocolVersion

public void setProtocolVersion(int protocolVersion)

getProtocolVersion

public int getProtocolVersion()

startMessage

public void startMessage(int messageType)

write

public void write(byte[] b)

encodeOutParameter

public void encodeOutParameter(int index,
                               com.nuodb.jdbc.RemCallableStatement.OutParameter param)

encodeInt

public void encodeInt(int value)

encodeBoolean

public void encodeBoolean(boolean value)

encodeLong

public void encodeLong(long value)

encodeLong

public void encodeLong(long value,
                       int scale)

encodeString

public void encodeString(String string)
                  throws SQLException

Throws:

SQLException

encodeBytes

public void encodeBytes(byte[] value)
                 throws SQLException

Throws:

SQLException

encodeObject

public void encodeObject(Object obj)
                  throws SQLException

Throws:

SQLException

encodeArray

public void encodeArray(Array value)
                 throws SQLException

Throws:

SQLException

encodeByte

public void encodeByte(byte value)

encodeTimestamp

public void encodeTimestamp(Timestamp val)
                     throws SQLException

Throws:

SQLException

encodeScaledTimestamp

public void encodeScaledTimestamp(Timestamp val)
                           throws SQLException

Throws:

SQLException

decode

public void decode()
            throws SQLException

Throws:

SQLException

decode

public int decode(byte[] source,
                  int sourceOffset)
           throws SQLException

Throws:

SQLException

getString

public String getString()
                 throws SQLException

Throws:

SQLException

getUUId

public UUID getUUId()
             throws SQLException

Throws:

SQLException

getBoolean

public boolean getBoolean()
                   throws SQLException

Throws:

SQLException

getBytes

public byte[] getBytes()
                throws SQLException

Throws:

SQLException

encodeNull

public void encodeNull()

isEndOfMessage

public boolean isEndOfMessage()

encodeDate

public void encodeDate(Date date)

encodeScaledDate

public void encodeScaledDate(Date date)

encodeDouble

public void encodeDouble(double dbl)

encodeBigDecimal

public void encodeBigDecimal(BigDecimal bd)

encodeOldBigDecimal

public void encodeOldBigDecimal(BigDecimal bd)

encodeTime

public void encodeTime(Time time)
                throws SQLException

Throws:

SQLException

encodeScaledTime

public void encodeScaledTime(Time time)

getMessage

public void getMessage(com.nuodb.impl.net.CryptoInputStream stream)
                throws IOException

Overrides:

getMessage in class com.nuodb.impl.util.DataStream

Throws:

IOException

getMessage

public void getMessage(com.nuodb.impl.net.CryptoInputStream stream,
                       Long maxLength)
                throws IOException

Overrides:

getMessage in class com.nuodb.impl.util.DataStream

Throws:

IOException

setData

public void setData(byte[] data,
                    int offset,
                    int length)

Overrides:

setData in class com.nuodb.impl.util.DataStream

setBase64

public int setBase64(char[] data,
                     int dataOffset,
                     int length)

Overrides:

setBase64 in class com.nuodb.impl.util.DataStream