public class BinaryRowProtocol extends RowProtocol
| Modifier and Type | Field and Description |
|---|---|
private ColumnDefinition[] |
columnDefinition |
private int |
columnInformationLength |
BIT_LAST_FIELD_NOT_NULL, BIT_LAST_FIELD_NULL, BIT_LAST_ZERO_DATE, buf, index, isIntegerRegex, lastValueNull, length, maxFieldSize, NULL_LENGTH, options, pos, TEXT_LOCAL_DATE_TIME, TEXT_OFFSET_DATE_TIME, TEXT_ZONED_DATE_TIME, TINYINT1_IS_BIT, YEAR_IS_DATE_TYPE| Constructor and Description |
|---|
BinaryRowProtocol(ColumnDefinition[] columnDefinition,
int columnInformationLength,
int maxFieldSize,
Options options)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
java.math.BigDecimal |
getInternalBigDecimal(ColumnDefinition columnInfo)
Get BigDecimal from raw binary format.
|
java.math.BigInteger |
getInternalBigInteger(ColumnDefinition columnInfo)
Get BigInteger from raw binary format.
|
boolean |
getInternalBoolean(ColumnDefinition columnInfo)
Get boolean from raw binary format.
|
byte |
getInternalByte(ColumnDefinition columnInfo)
Get byte from raw binary format.
|
java.sql.Date |
getInternalDate(ColumnDefinition columnInfo,
java.util.Calendar cal,
java.util.TimeZone timeZone)
Get date from raw binary format.
|
double |
getInternalDouble(ColumnDefinition columnInfo)
Get double from raw binary format.
|
float |
getInternalFloat(ColumnDefinition columnInfo)
Get float from raw binary format.
|
int |
getInternalInt(ColumnDefinition columnInfo)
Get int from raw binary format.
|
java.time.LocalDate |
getInternalLocalDate(ColumnDefinition columnInfo,
java.util.TimeZone timeZone)
Get LocalDate from raw binary format.
|
java.time.LocalTime |
getInternalLocalTime(ColumnDefinition columnInfo,
java.util.TimeZone timeZone)
Get LocalTime from raw binary format.
|
long |
getInternalLong(ColumnDefinition columnInfo)
Get long from raw binary format.
|
java.lang.Object |
getInternalObject(ColumnDefinition columnInfo,
java.util.TimeZone timeZone)
Get Object from raw binary format.
|
java.time.OffsetTime |
getInternalOffsetTime(ColumnDefinition columnInfo,
java.util.TimeZone timeZone)
Get OffsetTime from raw binary format.
|
short |
getInternalShort(ColumnDefinition columnInfo)
Get short from raw binary format.
|
java.lang.String |
getInternalString(ColumnDefinition columnInfo,
java.util.Calendar cal,
java.util.TimeZone timeZone)
Get string from raw binary format.
|
java.sql.Time |
getInternalTime(ColumnDefinition columnInfo,
java.util.Calendar cal,
java.util.TimeZone timeZone)
Get time from raw binary format.
|
java.sql.Timestamp |
getInternalTimestamp(ColumnDefinition columnInfo,
java.util.Calendar userCalendar,
java.util.TimeZone timeZone)
Get timestamp from raw binary format.
|
java.lang.String |
getInternalTimeString(ColumnDefinition columnInfo)
Get Time in string format from raw binary format.
|
java.time.ZonedDateTime |
getInternalZonedDateTime(ColumnDefinition columnInfo,
java.lang.Class clazz,
java.util.TimeZone timeZone)
Get ZonedDateTime from raw binary format.
|
boolean |
isBinaryEncoded()
Indicate if data is binary encoded.
|
void |
setPosition(int newIndex)
Set length and pos indicator to asked index.
|
extractNanos, getInternalMediumInt, getInternalSmallInt, getInternalTinyInt, getLengthMaxFieldSize, getMaxFieldSize, lastValueWasNull, parseBit, rangeCheck, rangeCheck, resetRow, wasNull, zeroFillingIfNeededprivate final ColumnDefinition[] columnDefinition
private final int columnInformationLength
public BinaryRowProtocol(ColumnDefinition[] columnDefinition, int columnInformationLength, int maxFieldSize, Options options)
columnDefinition - column information.columnInformationLength - number of columnsmaxFieldSize - max field sizeoptions - connection optionspublic void setPosition(int newIndex)
setPosition in class RowProtocolnewIndex - index (0 is first).public java.lang.String getInternalString(ColumnDefinition columnInfo, java.util.Calendar cal, java.util.TimeZone timeZone) throws java.sql.SQLException
getInternalString in class RowProtocolcolumnInfo - column informationcal - calendartimeZone - time zonejava.sql.SQLException - if conversion failedpublic int getInternalInt(ColumnDefinition columnInfo) throws java.sql.SQLException
getInternalInt in class RowProtocolcolumnInfo - column informationjava.sql.SQLException - if column is not numeric or is not in Integer bounds.public long getInternalLong(ColumnDefinition columnInfo) throws java.sql.SQLException
getInternalLong in class RowProtocolcolumnInfo - column informationjava.sql.SQLException - if column is not numeric or is not in Long bounds (for big unsigned
values)public float getInternalFloat(ColumnDefinition columnInfo) throws java.sql.SQLException
getInternalFloat in class RowProtocolcolumnInfo - column informationjava.sql.SQLException - if column is not numeric or is not in Float bounds.public double getInternalDouble(ColumnDefinition columnInfo) throws java.sql.SQLException
getInternalDouble in class RowProtocolcolumnInfo - column informationjava.sql.SQLException - if column is not numeric or is not in Double bounds (unsigned columns).public java.math.BigDecimal getInternalBigDecimal(ColumnDefinition columnInfo) throws java.sql.SQLException
getInternalBigDecimal in class RowProtocolcolumnInfo - column informationjava.sql.SQLException - if column is not numericpublic java.sql.Date getInternalDate(ColumnDefinition columnInfo, java.util.Calendar cal, java.util.TimeZone timeZone) throws java.sql.SQLException
getInternalDate in class RowProtocolcolumnInfo - column informationcal - calendartimeZone - time zonejava.sql.SQLException - if column is not compatible to Datepublic java.sql.Time getInternalTime(ColumnDefinition columnInfo, java.util.Calendar cal, java.util.TimeZone timeZone) throws java.sql.SQLException
getInternalTime in class RowProtocolcolumnInfo - column informationcal - calendartimeZone - time zonejava.sql.SQLException - if column cannot be converted to Timepublic java.sql.Timestamp getInternalTimestamp(ColumnDefinition columnInfo, java.util.Calendar userCalendar, java.util.TimeZone timeZone) throws java.sql.SQLException
getInternalTimestamp in class RowProtocolcolumnInfo - column informationuserCalendar - user calendartimeZone - time zonejava.sql.SQLException - if column type is not compatiblepublic java.lang.Object getInternalObject(ColumnDefinition columnInfo, java.util.TimeZone timeZone) throws java.sql.SQLException
getInternalObject in class RowProtocolcolumnInfo - column informationtimeZone - time zonejava.sql.SQLException - if column type is not compatiblepublic boolean getInternalBoolean(ColumnDefinition columnInfo) throws java.sql.SQLException
getInternalBoolean in class RowProtocolcolumnInfo - column informationjava.sql.SQLException - if column type doesn't permit conversionpublic byte getInternalByte(ColumnDefinition columnInfo) throws java.sql.SQLException
getInternalByte in class RowProtocolcolumnInfo - column informationjava.sql.SQLException - if column type doesn't permit conversionpublic short getInternalShort(ColumnDefinition columnInfo) throws java.sql.SQLException
getInternalShort in class RowProtocolcolumnInfo - column informationjava.sql.SQLException - if column type doesn't permit conversionpublic java.lang.String getInternalTimeString(ColumnDefinition columnInfo)
getInternalTimeString in class RowProtocolcolumnInfo - column informationpublic java.math.BigInteger getInternalBigInteger(ColumnDefinition columnInfo) throws java.sql.SQLException
getInternalBigInteger in class RowProtocolcolumnInfo - column informationjava.sql.SQLException - if column type doesn't permit conversion or value is not in BigInteger
rangepublic java.time.ZonedDateTime getInternalZonedDateTime(ColumnDefinition columnInfo, java.lang.Class clazz, java.util.TimeZone timeZone) throws java.sql.SQLException
getInternalZonedDateTime in class RowProtocolcolumnInfo - column informationclazz - asked classtimeZone - time zonejava.sql.SQLException - if column type doesn't permit conversionpublic java.time.OffsetTime getInternalOffsetTime(ColumnDefinition columnInfo, java.util.TimeZone timeZone) throws java.sql.SQLException
getInternalOffsetTime in class RowProtocolcolumnInfo - column informationtimeZone - time zonejava.sql.SQLException - if column type doesn't permit conversionpublic java.time.LocalTime getInternalLocalTime(ColumnDefinition columnInfo, java.util.TimeZone timeZone) throws java.sql.SQLException
getInternalLocalTime in class RowProtocolcolumnInfo - column informationtimeZone - time zonejava.sql.SQLException - if column type doesn't permit conversionpublic java.time.LocalDate getInternalLocalDate(ColumnDefinition columnInfo, java.util.TimeZone timeZone) throws java.sql.SQLException
getInternalLocalDate in class RowProtocolcolumnInfo - column informationtimeZone - time zonejava.sql.SQLException - if column type doesn't permit conversionpublic boolean isBinaryEncoded()
isBinaryEncoded in class RowProtocol