public abstract class RowProtocol
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static int |
BIT_LAST_FIELD_NOT_NULL |
static int |
BIT_LAST_FIELD_NULL |
static int |
BIT_LAST_ZERO_DATE |
byte[] |
buf |
protected int |
index |
static java.util.regex.Pattern |
isIntegerRegex |
int |
lastValueNull |
int |
length |
protected int |
maxFieldSize |
protected static int |
NULL_LENGTH |
protected Options |
options |
int |
pos |
static java.time.format.DateTimeFormatter |
TEXT_LOCAL_DATE_TIME |
static java.time.format.DateTimeFormatter |
TEXT_OFFSET_DATE_TIME |
static java.time.format.DateTimeFormatter |
TEXT_ZONED_DATE_TIME |
static int |
TINYINT1_IS_BIT |
static int |
YEAR_IS_DATE_TYPE |
Constructor and Description |
---|
RowProtocol(int maxFieldSize,
Options options) |
Modifier and Type | Method and Description |
---|---|
protected int |
extractNanos(java.lang.String timestring) |
abstract java.math.BigDecimal |
getInternalBigDecimal(ColumnInformation columnInfo) |
abstract java.math.BigInteger |
getInternalBigInteger(ColumnInformation columnInfo) |
abstract boolean |
getInternalBoolean(ColumnInformation columnInfo) |
abstract byte |
getInternalByte(ColumnInformation columnInfo) |
abstract java.sql.Date |
getInternalDate(ColumnInformation columnInfo,
java.util.Calendar cal,
java.util.TimeZone timeZone) |
abstract double |
getInternalDouble(ColumnInformation columnInfo) |
abstract float |
getInternalFloat(ColumnInformation columnInfo) |
abstract int |
getInternalInt(ColumnInformation columnInfo) |
abstract java.time.LocalDate |
getInternalLocalDate(ColumnInformation columnInfo,
java.util.TimeZone timeZone) |
abstract java.time.LocalTime |
getInternalLocalTime(ColumnInformation columnInfo,
java.util.TimeZone timeZone) |
abstract long |
getInternalLong(ColumnInformation columnInfo) |
protected long |
getInternalMediumInt(ColumnInformation columnInfo) |
abstract java.lang.Object |
getInternalObject(ColumnInformation columnInfo,
java.util.TimeZone timeZone) |
abstract java.time.OffsetTime |
getInternalOffsetTime(ColumnInformation columnInfo,
java.util.TimeZone timeZone) |
abstract short |
getInternalShort(ColumnInformation columnInfo) |
protected int |
getInternalSmallInt(ColumnInformation columnInfo) |
abstract java.lang.String |
getInternalString(ColumnInformation columnInfo,
java.util.Calendar cal,
java.util.TimeZone timeZone) |
abstract java.sql.Time |
getInternalTime(ColumnInformation columnInfo,
java.util.Calendar cal,
java.util.TimeZone timeZone) |
abstract java.sql.Timestamp |
getInternalTimestamp(ColumnInformation columnInfo,
java.util.Calendar userCalendar,
java.util.TimeZone timeZone) |
abstract java.lang.String |
getInternalTimeString(ColumnInformation columnInfo) |
protected int |
getInternalTinyInt(ColumnInformation columnInfo) |
abstract java.time.ZonedDateTime |
getInternalZonedDateTime(ColumnInformation columnInfo,
java.lang.Class clazz,
java.util.TimeZone timeZone) |
int |
getLengthMaxFieldSize() |
int |
getMaxFieldSize() |
abstract boolean |
isBinaryEncoded() |
boolean |
lastValueWasNull() |
protected long |
parseBit() |
protected void |
rangeCheck(java.lang.Object className,
long minValue,
long maxValue,
java.math.BigDecimal value,
ColumnInformation columnInfo) |
protected void |
rangeCheck(java.lang.Object className,
long minValue,
long maxValue,
long value,
ColumnInformation columnInfo) |
void |
resetRow(byte[] buf) |
abstract void |
setPosition(int position) |
boolean |
wasNull()
Reports whether the last column read had a value of Null.
|
protected java.lang.String |
zeroFillingIfNeeded(java.lang.String value,
ColumnInformation columnInformation) |
public static final int BIT_LAST_FIELD_NOT_NULL
public static final int BIT_LAST_FIELD_NULL
public static final int BIT_LAST_ZERO_DATE
public static final int TINYINT1_IS_BIT
public static final int YEAR_IS_DATE_TYPE
public static final java.time.format.DateTimeFormatter TEXT_LOCAL_DATE_TIME
public static final java.time.format.DateTimeFormatter TEXT_OFFSET_DATE_TIME
public static final java.time.format.DateTimeFormatter TEXT_ZONED_DATE_TIME
public static final java.util.regex.Pattern isIntegerRegex
protected static final int NULL_LENGTH
protected final int maxFieldSize
protected final Options options
public int lastValueNull
public byte[] buf
public int pos
public int length
protected int index
public RowProtocol(int maxFieldSize, Options options)
public void resetRow(byte[] buf)
public abstract void setPosition(int position)
public int getLengthMaxFieldSize()
public int getMaxFieldSize()
public abstract java.lang.String getInternalString(ColumnInformation columnInfo, java.util.Calendar cal, java.util.TimeZone timeZone) throws java.sql.SQLException
java.sql.SQLException
public abstract int getInternalInt(ColumnInformation columnInfo) throws java.sql.SQLException
java.sql.SQLException
public abstract long getInternalLong(ColumnInformation columnInfo) throws java.sql.SQLException
java.sql.SQLException
public abstract float getInternalFloat(ColumnInformation columnInfo) throws java.sql.SQLException
java.sql.SQLException
public abstract double getInternalDouble(ColumnInformation columnInfo) throws java.sql.SQLException
java.sql.SQLException
public abstract java.math.BigDecimal getInternalBigDecimal(ColumnInformation columnInfo) throws java.sql.SQLException
java.sql.SQLException
public abstract java.sql.Date getInternalDate(ColumnInformation columnInfo, java.util.Calendar cal, java.util.TimeZone timeZone) throws java.sql.SQLException
java.sql.SQLException
public abstract java.sql.Time getInternalTime(ColumnInformation columnInfo, java.util.Calendar cal, java.util.TimeZone timeZone) throws java.sql.SQLException
java.sql.SQLException
public abstract java.sql.Timestamp getInternalTimestamp(ColumnInformation columnInfo, java.util.Calendar userCalendar, java.util.TimeZone timeZone) throws java.sql.SQLException
java.sql.SQLException
public abstract java.lang.Object getInternalObject(ColumnInformation columnInfo, java.util.TimeZone timeZone) throws java.sql.SQLException
java.sql.SQLException
public abstract boolean getInternalBoolean(ColumnInformation columnInfo) throws java.sql.SQLException
java.sql.SQLException
public abstract byte getInternalByte(ColumnInformation columnInfo) throws java.sql.SQLException
java.sql.SQLException
public abstract short getInternalShort(ColumnInformation columnInfo) throws java.sql.SQLException
java.sql.SQLException
public abstract java.lang.String getInternalTimeString(ColumnInformation columnInfo)
public abstract java.math.BigInteger getInternalBigInteger(ColumnInformation columnInfo) throws java.sql.SQLException
java.sql.SQLException
public abstract java.time.ZonedDateTime getInternalZonedDateTime(ColumnInformation columnInfo, java.lang.Class clazz, java.util.TimeZone timeZone) throws java.sql.SQLException
java.sql.SQLException
public abstract java.time.OffsetTime getInternalOffsetTime(ColumnInformation columnInfo, java.util.TimeZone timeZone) throws java.sql.SQLException
java.sql.SQLException
public abstract java.time.LocalTime getInternalLocalTime(ColumnInformation columnInfo, java.util.TimeZone timeZone) throws java.sql.SQLException
java.sql.SQLException
public abstract java.time.LocalDate getInternalLocalDate(ColumnInformation columnInfo, java.util.TimeZone timeZone) throws java.sql.SQLException
java.sql.SQLException
public abstract boolean isBinaryEncoded()
public boolean lastValueWasNull()
protected java.lang.String zeroFillingIfNeeded(java.lang.String value, ColumnInformation columnInformation)
protected int getInternalTinyInt(ColumnInformation columnInfo)
protected long parseBit()
protected int getInternalSmallInt(ColumnInformation columnInfo)
protected long getInternalMediumInt(ColumnInformation columnInfo)
protected void rangeCheck(java.lang.Object className, long minValue, long maxValue, java.math.BigDecimal value, ColumnInformation columnInfo) throws java.sql.SQLException
java.sql.SQLException
protected void rangeCheck(java.lang.Object className, long minValue, long maxValue, long value, ColumnInformation columnInfo) throws java.sql.SQLException
java.sql.SQLException
protected int extractNanos(java.lang.String timestring) throws java.sql.SQLException
java.sql.SQLException
public boolean wasNull()