ru.yandex.clickhouse.response

Class ClickHouseResultSet

java.lang.Object

ru.yandex.clickhouse.response.AbstractResultSet

ru.yandex.clickhouse.response.ClickHouseResultSet

All Implemented Interfaces:

AutoCloseable, ResultSet, Wrapper

Direct Known Subclasses:

ClickHouseScrollableResultSet

public class ClickHouseResultSet
extends AbstractResultSet

Field Summary

Fields

Modifier and Type	Field and Description
protected ByteFragment	nextLine
protected int	rowNumber
protected ByteFragment[]	values

Fields inherited from interface java.sql.ResultSet

CLOSE_CURSORS_AT_COMMIT, CONCUR_READ_ONLY, CONCUR_UPDATABLE, FETCH_FORWARD, FETCH_REVERSE, FETCH_UNKNOWN, HOLD_CURSORS_OVER_COMMIT, TYPE_FORWARD_ONLY, TYPE_SCROLL_INSENSITIVE, TYPE_SCROLL_SENSITIVE

Constructor Summary

Constructors

Constructor and Description
ClickHouseResultSet(InputStream is, int bufferSize, String db, String table, boolean usesWithTotals, ClickHouseStatement statement, TimeZone timeZone, ClickHouseProperties properties)

Method Summary

Modifier and Type	Method and Description
void	close()
int	findColumn(String column)
Array	getArray(int columnIndex)
Array	getArray(String column)
BigDecimal	getBigDecimal(int columnIndex)
BigDecimal	getBigDecimal(int columnIndex, int scale)
BigDecimal	getBigDecimal(String columnLabel)
BigDecimal	getBigDecimal(String columnLabel, int scale)
BigInteger	getBigInteger(int columnIndex)
BigInteger	getBigInteger(String columnLabel)
boolean	getBoolean(int colNum)
boolean	getBoolean(String column)
byte	getByte(int colNum)
byte	getByte(String column)
byte[]	getBytes(int colNum)
byte[]	getBytes(String column)
String[]	getColumnNames()
Date	getDate(int columnIndex)
Date	getDate(int columnIndex, Calendar calendar)
Date	getDate(String columnLabel)
String	getDb()
double	getDouble(int columnIndex)
double	getDouble(String columnLabel)
float	getFloat(int columnIndex)
float	getFloat(String columnLabel)
int	getInt(int colNum)
int	getInt(String column)
long	getLong(int colNum)
long	getLong(String column)
long[]	getLongArray(int colNum) Deprecated. prefer to use regular JDBC API
long[]	getLongArray(String column) Parse the value in current row at column with label column as an array of long
ResultSetMetaData	getMetaData()
Object	getObject(int columnIndex)
<T> T	getObject(int columnIndex, Class<T> type)
Object	getObject(String columnLabel)
<T> T	getObject(String columnLabel, Class<T> type)
int	getRow()
short	getShort(int colNum)
short	getShort(String column)
Statement	getStatement()
String	getString(int colNum)
String	getString(String column)
String	getTable()
Time	getTime(int columnIndex)
Time	getTime(int columnIndex, Calendar calendar)
Time	getTime(String columnLabel)
Timestamp	getTimestamp(int columnIndex)
Timestamp	getTimestamp(int columnIndex, Calendar cal)
Timestamp	getTimestamp(String column)
Timestamp	getTimestamp(String column, Calendar cal)
Long	getTimestampAsLong(int colNum) Deprecated. prefer to use regular JDBC API methods, e.g. getTimestamp(int) or getObject(int, Class) using Instant
Long	getTimestampAsLong(int colNum, TimeZone timeZone) Deprecated. prefer to use regular JDBC API method
void	getTotals()
int	getType()
ByteFragment[]	getValues() Deprecated. prefer to use regular JDBC API to retrieve the results
protected boolean	hasNext() Check if there is another row.
boolean	isAfterLast()
boolean	isBeforeFirst()
boolean	isClosed()
boolean	isFirst()
boolean	isLast()
boolean	next()
void	setFetchDirection(int direction)
void	setFetchSize(int rows)
void	setMaxRows(int maxRows)
String	toString()
boolean	wasNull()

Methods inherited from class ru.yandex.clickhouse.response.AbstractResultSet

absolute, afterLast, beforeFirst, cancelRowUpdates, clearWarnings, deleteRow, first, getAsciiStream, getAsciiStream, getBinaryStream, getBinaryStream, getBlob, getBlob, getCharacterStream, getCharacterStream, getClob, getClob, getConcurrency, getCursorName, getDate, getFetchDirection, getFetchSize, getHoldability, getNCharacterStream, getNCharacterStream, getNClob, getNClob, getNString, getNString, getObject, getObject, getRef, getRef, getRowId, getRowId, getSQLXML, getSQLXML, getTime, getUnicodeStream, getUnicodeStream, getURL, getURL, getWarnings, insertRow, isWrapperFor, last, moveToCurrentRow, moveToInsertRow, previous, refreshRow, relative, rowDeleted, rowInserted, rowUpdated, unwrap, updateArray, updateArray, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateBigDecimal, updateBigDecimal, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBlob, updateBlob, updateBlob, updateBlob, updateBlob, updateBlob, updateBoolean, updateBoolean, updateByte, updateByte, updateBytes, updateBytes, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateClob, updateClob, updateClob, updateClob, updateClob, updateClob, updateDate, updateDate, updateDouble, updateDouble, updateFloat, updateFloat, updateInt, updateInt, updateLong, updateLong, updateNCharacterStream, updateNCharacterStream, updateNCharacterStream, updateNCharacterStream, updateNClob, updateNClob, updateNClob, updateNClob, updateNClob, updateNClob, updateNString, updateNString, updateNull, updateNull, updateObject, updateObject, updateObject, updateObject, updateRef, updateRef, updateRow, updateRowId, updateRowId, updateShort, updateShort, updateSQLXML, updateSQLXML, updateString, updateString, updateTime, updateTime, updateTimestamp, updateTimestamp

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.sql.ResultSet

updateObject, updateObject, updateObject, updateObject

Field Detail

values

protected ByteFragment[] values

nextLine

protected ByteFragment nextLine

rowNumber

protected int rowNumber

Constructor Detail

ClickHouseResultSet

public ClickHouseResultSet(InputStream is,
                           int bufferSize,
                           String db,
                           String table,
                           boolean usesWithTotals,
                           ClickHouseStatement statement,
                           TimeZone timeZone,
                           ClickHouseProperties properties)
                    throws IOException

Throws:

IOException

Method Detail

hasNext

protected boolean hasNext()
                   throws SQLException

Check if there is another row.

Returns:

true if this result set has another row after the current cursor position, false else

Throws:

SQLException - if something goes wrong

isBeforeFirst

public boolean isBeforeFirst()
                      throws SQLException

Specified by:

isBeforeFirst in interface ResultSet

Overrides:

isBeforeFirst in class AbstractResultSet

Throws:

SQLException

isAfterLast

public boolean isAfterLast()
                    throws SQLException

Specified by:

isAfterLast in interface ResultSet

Overrides:

isAfterLast in class AbstractResultSet

Throws:

SQLException

isFirst

public boolean isFirst()
                throws SQLException

Specified by:

isFirst in interface ResultSet

Overrides:

isFirst in class AbstractResultSet

Throws:

SQLException

isLast

public boolean isLast()
               throws SQLException

Specified by:

isLast in interface ResultSet

Overrides:

isLast in class AbstractResultSet

Throws:

SQLException

next

public boolean next()
             throws SQLException

Specified by:

next in interface ResultSet

Overrides:

next in class AbstractResultSet

Throws:

SQLException

close

public void close()
           throws SQLException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ResultSet

Overrides:

close in class AbstractResultSet

Throws:

SQLException

isClosed

public boolean isClosed()
                 throws SQLException

Specified by:

isClosed in interface ResultSet

Overrides:

isClosed in class AbstractResultSet

Throws:

SQLException

getTotals

public void getTotals()
               throws SQLException

Throws:

SQLException

getMetaData

public ResultSetMetaData getMetaData()
                              throws SQLException

Specified by:

getMetaData in interface ResultSet

Overrides:

getMetaData in class AbstractResultSet

Throws:

SQLException

wasNull

public boolean wasNull()
                throws SQLException

Specified by:

wasNull in interface ResultSet

Overrides:

wasNull in class AbstractResultSet

Throws:

SQLException

getInt

public int getInt(String column)
           throws SQLException

Specified by:

getInt in interface ResultSet

Overrides:

getInt in class AbstractResultSet

Throws:

SQLException

getBoolean

public boolean getBoolean(String column)
                   throws SQLException

Specified by:

getBoolean in interface ResultSet

Overrides:

getBoolean in class AbstractResultSet

Throws:

SQLException

getLong

public long getLong(String column)
             throws SQLException

Specified by:

getLong in interface ResultSet

Overrides:

getLong in class AbstractResultSet

Throws:

SQLException

getString

public String getString(String column)
                 throws SQLException

Specified by:

getString in interface ResultSet

Overrides:

getString in class AbstractResultSet

Throws:

SQLException

getBytes

public byte[] getBytes(String column)
                throws SQLException

Specified by:

getBytes in interface ResultSet

Overrides:

getBytes in class AbstractResultSet

Throws:

SQLException

getTimestamp

public Timestamp getTimestamp(String column)
                       throws SQLException

Specified by:

getTimestamp in interface ResultSet

Overrides:

getTimestamp in class AbstractResultSet

Throws:

SQLException

getTimestamp

public Timestamp getTimestamp(int columnIndex)
                       throws SQLException

Specified by:

getTimestamp in interface ResultSet

Overrides:

getTimestamp in class AbstractResultSet

Throws:

SQLException

getTimestamp

public Timestamp getTimestamp(String column,
                              Calendar cal)
                       throws SQLException

Specified by:

getTimestamp in interface ResultSet

Overrides:

getTimestamp in class AbstractResultSet

Throws:

SQLException

getTimestamp

public Timestamp getTimestamp(int columnIndex,
                              Calendar cal)
                       throws SQLException

Specified by:

getTimestamp in interface ResultSet

Overrides:

getTimestamp in class AbstractResultSet

Throws:

SQLException

getShort

public short getShort(String column)
               throws SQLException

Specified by:

getShort in interface ResultSet

Overrides:

getShort in class AbstractResultSet

Throws:

SQLException

getByte

public byte getByte(String column)
             throws SQLException

Specified by:

getByte in interface ResultSet

Overrides:

getByte in class AbstractResultSet

Throws:

SQLException

getLongArray

public long[] getLongArray(String column)
                    throws SQLException

Description copied from class: AbstractResultSet

Parse the value in current row at column with label column as an array of long

Specified by:

getLongArray in class AbstractResultSet

Parameters:

column - the label, name, alias of the column

Returns:

an array of longs

Throws:

SQLException - if the value cannot be interpreted as long[]

getArray

public Array getArray(int columnIndex)
               throws SQLException

Specified by:

getArray in interface ResultSet

Overrides:

getArray in class AbstractResultSet

Throws:

SQLException

getArray

public Array getArray(String column)
               throws SQLException

Specified by:

getArray in interface ResultSet

Overrides:

getArray in class AbstractResultSet

Throws:

SQLException

getDouble

public double getDouble(String columnLabel)
                 throws SQLException

Specified by:

getDouble in interface ResultSet

Overrides:

getDouble in class AbstractResultSet

Throws:

SQLException

getFloat

public float getFloat(String columnLabel)
               throws SQLException

Specified by:

getFloat in interface ResultSet

Overrides:

getFloat in class AbstractResultSet

Throws:

SQLException

getDate

public Date getDate(String columnLabel)
             throws SQLException

Specified by:

getDate in interface ResultSet

Overrides:

getDate in class AbstractResultSet

Throws:

SQLException

getTime

public Time getTime(String columnLabel)
             throws SQLException

Specified by:

getTime in interface ResultSet

Overrides:

getTime in class AbstractResultSet

Throws:

SQLException

getObject

public Object getObject(String columnLabel)
                 throws SQLException

Specified by:

getObject in interface ResultSet

Overrides:

getObject in class AbstractResultSet

Throws:

SQLException

getString

public String getString(int colNum)
                 throws SQLException

Specified by:

getString in interface ResultSet

Overrides:

getString in class AbstractResultSet

Throws:

SQLException

getInt

public int getInt(int colNum)
           throws SQLException

Specified by:

getInt in interface ResultSet

Overrides:

getInt in class AbstractResultSet

Throws:

SQLException

getBoolean

public boolean getBoolean(int colNum)
                   throws SQLException

Specified by:

getBoolean in interface ResultSet

Overrides:

getBoolean in class AbstractResultSet

Throws:

SQLException

getLong

public long getLong(int colNum)
             throws SQLException

Specified by:

getLong in interface ResultSet

Overrides:

getLong in class AbstractResultSet

Throws:

SQLException

getBytes

public byte[] getBytes(int colNum)

Specified by:

getBytes in interface ResultSet

Overrides:

getBytes in class AbstractResultSet

getTimestampAsLong

@Deprecated
public Long getTimestampAsLong(int colNum)

Deprecated. prefer to use regular JDBC API methods, e.g. getTimestamp(int) or getObject(int, Class) using Instant

Tries to parse the value as a timestamp using the connection time zone if applicable and return its representation as milliseconds since epoch.

Parameters:

colNum - column number

Returns:

timestamp value as milliseconds since epoch

getTimestampAsLong

@Deprecated
public Long getTimestampAsLong(int colNum,
                                           TimeZone timeZone)

Deprecated. prefer to use regular JDBC API method

Tries to parse the value as a timestamp and return its representation as milliseconds since epoch

Parameters:

colNum - the column number

timeZone - time zone to use when parsing date / date time values

Returns:

value interpreted as timestamp as milliseconds since epoch

getShort

public short getShort(int colNum)
               throws SQLException

Specified by:

getShort in interface ResultSet

Overrides:

getShort in class AbstractResultSet

Throws:

SQLException

getByte

public byte getByte(int colNum)

Specified by:

getByte in interface ResultSet

Overrides:

getByte in class AbstractResultSet

getLongArray

@Deprecated
public long[] getLongArray(int colNum)
                                throws SQLException

Deprecated. prefer to use regular JDBC API

Parse the value in current row at column index colNum as an array of long

Parameters:

colNum - column number

Returns:

an array of longs

Throws:

SQLException - if the value cannot be interpreted as long[]

getFloat

public float getFloat(int columnIndex)
               throws SQLException

Specified by:

getFloat in interface ResultSet

Overrides:

getFloat in class AbstractResultSet

Throws:

SQLException

getDouble

public double getDouble(int columnIndex)
                 throws SQLException

Specified by:

getDouble in interface ResultSet

Overrides:

getDouble in class AbstractResultSet

Throws:

SQLException

getStatement

public Statement getStatement()

Specified by:

getStatement in interface ResultSet

Overrides:

getStatement in class AbstractResultSet

getDate

public Date getDate(int columnIndex)
             throws SQLException

Specified by:

getDate in interface ResultSet

Overrides:

getDate in class AbstractResultSet

Throws:

SQLException

getDate

public Date getDate(int columnIndex,
                    Calendar calendar)
             throws SQLException

Specified by:

getDate in interface ResultSet

Overrides:

getDate in class AbstractResultSet

Throws:

SQLException

getTime

public Time getTime(int columnIndex)
             throws SQLException

Specified by:

getTime in interface ResultSet

Overrides:

getTime in class AbstractResultSet

Throws:

SQLException

getTime

public Time getTime(int columnIndex,
                    Calendar calendar)
             throws SQLException

Specified by:

getTime in interface ResultSet

Overrides:

getTime in class AbstractResultSet

Throws:

SQLException

getObject

public Object getObject(int columnIndex)
                 throws SQLException

Specified by:

getObject in interface ResultSet

Overrides:

getObject in class AbstractResultSet

Throws:

SQLException

getType

public int getType()
            throws SQLException

Specified by:

getType in interface ResultSet

Overrides:

getType in class AbstractResultSet

Throws:

SQLException

getRow

public int getRow()
           throws SQLException

Throws:

SQLException

getDb

public String getDb()

getTable

public String getTable()

setMaxRows

public void setMaxRows(int maxRows)

findColumn

public int findColumn(String column)
               throws SQLException

Specified by:

findColumn in interface ResultSet

Overrides:

findColumn in class AbstractResultSet

Throws:

SQLException

getObject

public <T> T getObject(int columnIndex,
                       Class<T> type)
                throws SQLException

Throws:

SQLException

getObject

public <T> T getObject(String columnLabel,
                       Class<T> type)
                throws SQLException

Throws:

SQLException

getValues

@Deprecated
public ByteFragment[] getValues()

Deprecated. prefer to use regular JDBC API to retrieve the results

Retrieve the results in "raw" form.

Returns:

the results as an array of ByteFragments

getBigDecimal

public BigDecimal getBigDecimal(String columnLabel)
                         throws SQLException

Specified by:

getBigDecimal in interface ResultSet

Overrides:

getBigDecimal in class AbstractResultSet

Throws:

SQLException

getBigDecimal

public BigDecimal getBigDecimal(int columnIndex)
                         throws SQLException

Specified by:

getBigDecimal in interface ResultSet

Overrides:

getBigDecimal in class AbstractResultSet

Throws:

SQLException

getBigDecimal

public BigDecimal getBigDecimal(String columnLabel,
                                int scale)
                         throws SQLException

Specified by:

getBigDecimal in interface ResultSet

Overrides:

getBigDecimal in class AbstractResultSet

Throws:

SQLException

getBigDecimal

public BigDecimal getBigDecimal(int columnIndex,
                                int scale)
                         throws SQLException

Specified by:

getBigDecimal in interface ResultSet

Overrides:

getBigDecimal in class AbstractResultSet

Throws:

SQLException

getBigInteger

public BigInteger getBigInteger(String columnLabel)
                         throws SQLException

Throws:

SQLException

getBigInteger

public BigInteger getBigInteger(int columnIndex)
                         throws SQLException

Throws:

SQLException

getColumnNames

public String[] getColumnNames()

setFetchDirection

public void setFetchDirection(int direction)
                       throws SQLException

Specified by:

setFetchDirection in interface ResultSet

Overrides:

setFetchDirection in class AbstractResultSet

Throws:

SQLException

setFetchSize

public void setFetchSize(int rows)
                  throws SQLException

Specified by:

setFetchSize in interface ResultSet

Overrides:

setFetchSize in class AbstractResultSet

Throws:

SQLException

toString

public String toString()

Overrides:

toString in class Object