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(ColumnDefinition columnInfo) |
abstract java.math.BigInteger |
getInternalBigInteger(ColumnDefinition columnInfo) |
abstract boolean |
getInternalBoolean(ColumnDefinition columnInfo) |
abstract byte |
getInternalByte(ColumnDefinition columnInfo) |
abstract java.sql.Date |
getInternalDate(ColumnDefinition columnInfo,
java.util.Calendar cal,
java.util.TimeZone timeZone) |
abstract double |
getInternalDouble(ColumnDefinition columnInfo) |
abstract float |
getInternalFloat(ColumnDefinition columnInfo) |
abstract int |
getInternalInt(ColumnDefinition columnInfo) |
abstract java.time.LocalDate |
getInternalLocalDate(ColumnDefinition columnInfo,
java.util.TimeZone timeZone) |
abstract java.time.LocalTime |
getInternalLocalTime(ColumnDefinition columnInfo,
java.util.TimeZone timeZone) |
abstract long |
getInternalLong(ColumnDefinition columnInfo) |
protected long |
getInternalMediumInt(ColumnDefinition columnInfo) |
abstract java.lang.Object |
getInternalObject(ColumnDefinition columnInfo,
java.util.TimeZone timeZone) |
abstract java.time.OffsetTime |
getInternalOffsetTime(ColumnDefinition columnInfo,
java.util.TimeZone timeZone) |
abstract short |
getInternalShort(ColumnDefinition columnInfo) |
protected int |
getInternalSmallInt(ColumnDefinition columnInfo) |
abstract java.lang.String |
getInternalString(ColumnDefinition columnInfo,
java.util.Calendar cal,
java.util.TimeZone timeZone) |
abstract java.sql.Time |
getInternalTime(ColumnDefinition columnInfo,
java.util.Calendar cal,
java.util.TimeZone timeZone) |
abstract java.sql.Timestamp |
getInternalTimestamp(ColumnDefinition columnInfo,
java.util.Calendar userCalendar,
java.util.TimeZone timeZone) |
abstract java.lang.String |
getInternalTimeString(ColumnDefinition columnInfo) |
protected int |
getInternalTinyInt(ColumnDefinition columnInfo) |
abstract java.time.ZonedDateTime |
getInternalZonedDateTime(ColumnDefinition 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,
ColumnDefinition columnInfo) |
protected void |
rangeCheck(java.lang.Object className,
long minValue,
long maxValue,
long value,
ColumnDefinition 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,
ColumnDefinition columnDefinition) |
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(ColumnDefinition columnInfo, java.util.Calendar cal, java.util.TimeZone timeZone) throws java.sql.SQLException
java.sql.SQLException
public abstract int getInternalInt(ColumnDefinition columnInfo) throws java.sql.SQLException
java.sql.SQLException
public abstract long getInternalLong(ColumnDefinition columnInfo) throws java.sql.SQLException
java.sql.SQLException
public abstract float getInternalFloat(ColumnDefinition columnInfo) throws java.sql.SQLException
java.sql.SQLException
public abstract double getInternalDouble(ColumnDefinition columnInfo) throws java.sql.SQLException
java.sql.SQLException
public abstract java.math.BigDecimal getInternalBigDecimal(ColumnDefinition columnInfo) throws java.sql.SQLException
java.sql.SQLException
public abstract java.sql.Date getInternalDate(ColumnDefinition columnInfo, java.util.Calendar cal, java.util.TimeZone timeZone) throws java.sql.SQLException
java.sql.SQLException
public abstract java.sql.Time getInternalTime(ColumnDefinition columnInfo, java.util.Calendar cal, java.util.TimeZone timeZone) throws java.sql.SQLException
java.sql.SQLException
public abstract java.sql.Timestamp getInternalTimestamp(ColumnDefinition columnInfo, java.util.Calendar userCalendar, java.util.TimeZone timeZone) throws java.sql.SQLException
java.sql.SQLException
public abstract java.lang.Object getInternalObject(ColumnDefinition columnInfo, java.util.TimeZone timeZone) throws java.sql.SQLException
java.sql.SQLException
public abstract boolean getInternalBoolean(ColumnDefinition columnInfo) throws java.sql.SQLException
java.sql.SQLException
public abstract byte getInternalByte(ColumnDefinition columnInfo) throws java.sql.SQLException
java.sql.SQLException
public abstract short getInternalShort(ColumnDefinition columnInfo) throws java.sql.SQLException
java.sql.SQLException
public abstract java.lang.String getInternalTimeString(ColumnDefinition columnInfo)
public abstract java.math.BigInteger getInternalBigInteger(ColumnDefinition columnInfo) throws java.sql.SQLException
java.sql.SQLException
public abstract java.time.ZonedDateTime getInternalZonedDateTime(ColumnDefinition columnInfo, java.lang.Class clazz, java.util.TimeZone timeZone) throws java.sql.SQLException
java.sql.SQLException
public abstract java.time.OffsetTime getInternalOffsetTime(ColumnDefinition columnInfo, java.util.TimeZone timeZone) throws java.sql.SQLException
java.sql.SQLException
public abstract java.time.LocalTime getInternalLocalTime(ColumnDefinition columnInfo, java.util.TimeZone timeZone) throws java.sql.SQLException
java.sql.SQLException
public abstract java.time.LocalDate getInternalLocalDate(ColumnDefinition 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, ColumnDefinition columnDefinition)
protected int getInternalTinyInt(ColumnDefinition columnInfo)
protected long parseBit()
protected int getInternalSmallInt(ColumnDefinition columnInfo)
protected long getInternalMediumInt(ColumnDefinition columnInfo)
protected void rangeCheck(java.lang.Object className, long minValue, long maxValue, java.math.BigDecimal value, ColumnDefinition columnInfo) throws java.sql.SQLException
java.sql.SQLException
protected void rangeCheck(java.lang.Object className, long minValue, long maxValue, long value, ColumnDefinition 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()