public class DrillResultSetImpl extends org.apache.calcite.avatica.AvaticaResultSet implements DrillResultSet
ResultSet
.accessorList, columnMetaDataList, cursor, firstFrame, localCalendar, resultSetMetaData, signature, state, statement
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
Modifier and Type | Method and Description |
---|---|
boolean |
absolute(int row) |
void |
afterLast() |
void |
beforeFirst() |
protected void |
cancel() |
void |
cancelRowUpdates() |
protected void |
checkOpen()
Throws AlreadyClosedSqlException or QueryCanceledSqlException if this
ResultSet is closed.
|
void |
close() |
void |
deleteRow() |
protected DrillResultSetImpl |
execute() |
boolean |
first() |
String |
getCursorName() |
Object |
getObject(int columnIndex) |
String |
getQueryId()
Gets the ID of the associated query (the query whose results this ResultSet
presents).
|
RowId |
getRowId(int columnIndex) |
RowId |
getRowId(String columnLabel) |
void |
insertRow() |
boolean |
isLast() |
boolean |
last() |
void |
moveToCurrentRow() |
void |
moveToInsertRow() |
boolean |
next() |
boolean |
previous() |
void |
refreshRow() |
boolean |
relative(int rows) |
void |
updateArray(int columnIndex,
Array x) |
void |
updateArray(String columnLabel,
Array x) |
void |
updateAsciiStream(int columnIndex,
InputStream x) |
void |
updateAsciiStream(int columnIndex,
InputStream x,
int length) |
void |
updateAsciiStream(int columnIndex,
InputStream x,
long length) |
void |
updateAsciiStream(String columnLabel,
InputStream x) |
void |
updateAsciiStream(String columnLabel,
InputStream x,
int length) |
void |
updateAsciiStream(String columnLabel,
InputStream x,
long length) |
void |
updateBigDecimal(int columnIndex,
BigDecimal x) |
void |
updateBigDecimal(String columnLabel,
BigDecimal x) |
void |
updateBinaryStream(int columnIndex,
InputStream x) |
void |
updateBinaryStream(int columnIndex,
InputStream x,
int length) |
void |
updateBinaryStream(int columnIndex,
InputStream x,
long length) |
void |
updateBinaryStream(String columnLabel,
InputStream x) |
void |
updateBinaryStream(String columnLabel,
InputStream x,
int length) |
void |
updateBinaryStream(String columnLabel,
InputStream x,
long length) |
void |
updateBlob(int columnIndex,
Blob x) |
void |
updateBlob(int columnIndex,
InputStream inputStream) |
void |
updateBlob(int columnIndex,
InputStream inputStream,
long length) |
void |
updateBlob(String columnLabel,
Blob x) |
void |
updateBlob(String columnLabel,
InputStream inputStream) |
void |
updateBlob(String columnLabel,
InputStream inputStream,
long length) |
void |
updateBoolean(int columnIndex,
boolean x) |
void |
updateBoolean(String columnLabel,
boolean x) |
void |
updateByte(int columnIndex,
byte x) |
void |
updateByte(String columnLabel,
byte x) |
void |
updateBytes(int columnIndex,
byte[] x) |
void |
updateBytes(String columnLabel,
byte[] x) |
void |
updateCharacterStream(int columnIndex,
Reader x) |
void |
updateCharacterStream(int columnIndex,
Reader x,
int length) |
void |
updateCharacterStream(int columnIndex,
Reader x,
long length) |
void |
updateCharacterStream(String columnLabel,
Reader reader) |
void |
updateCharacterStream(String columnLabel,
Reader reader,
int length) |
void |
updateCharacterStream(String columnLabel,
Reader reader,
long length) |
void |
updateClob(int columnIndex,
Clob x) |
void |
updateClob(int columnIndex,
Reader reader) |
void |
updateClob(int columnIndex,
Reader reader,
long length) |
void |
updateClob(String columnLabel,
Clob x) |
void |
updateClob(String columnLabel,
Reader reader) |
void |
updateClob(String columnLabel,
Reader reader,
long length) |
void |
updateDate(int columnIndex,
Date x) |
void |
updateDate(String columnLabel,
Date x) |
void |
updateDouble(int columnIndex,
double x) |
void |
updateDouble(String columnLabel,
double x) |
void |
updateFloat(int columnIndex,
float x) |
void |
updateFloat(String columnLabel,
float x) |
void |
updateInt(int columnIndex,
int x) |
void |
updateInt(String columnLabel,
int x) |
void |
updateLong(int columnIndex,
long x) |
void |
updateLong(String columnLabel,
long x) |
void |
updateNCharacterStream(int columnIndex,
Reader x) |
void |
updateNCharacterStream(int columnIndex,
Reader x,
long length) |
void |
updateNCharacterStream(String columnLabel,
Reader reader) |
void |
updateNCharacterStream(String columnLabel,
Reader reader,
long length) |
void |
updateNClob(int columnIndex,
NClob nClob) |
void |
updateNClob(int columnIndex,
Reader reader) |
void |
updateNClob(int columnIndex,
Reader reader,
long length) |
void |
updateNClob(String columnLabel,
NClob nClob) |
void |
updateNClob(String columnLabel,
Reader reader) |
void |
updateNClob(String columnLabel,
Reader reader,
long length) |
void |
updateNString(int columnIndex,
String nString) |
void |
updateNString(String columnLabel,
String nString) |
void |
updateNull(int columnIndex) |
void |
updateNull(String columnLabel) |
void |
updateObject(int columnIndex,
Object x) |
void |
updateObject(int columnIndex,
Object x,
int scaleOrLength) |
void |
updateObject(int columnIndex,
Object x,
SQLType targetSqlType) |
void |
updateObject(int columnIndex,
Object x,
SQLType targetSqlType,
int scaleOrLength) |
void |
updateObject(String columnLabel,
Object x) |
void |
updateObject(String columnLabel,
Object x,
int scaleOrLength) |
void |
updateObject(String columnLabel,
Object x,
SQLType targetSqlType) |
void |
updateObject(String columnLabel,
Object x,
SQLType targetSqlType,
int scaleOrLength) |
void |
updateRef(int columnIndex,
Ref x) |
void |
updateRef(String columnLabel,
Ref x) |
void |
updateRow() |
void |
updateRowId(int columnIndex,
RowId x) |
void |
updateRowId(String columnLabel,
RowId x) |
void |
updateShort(int columnIndex,
short x) |
void |
updateShort(String columnLabel,
short x) |
void |
updateSQLXML(int columnIndex,
SQLXML xmlObject) |
void |
updateSQLXML(String columnLabel,
SQLXML xmlObject) |
void |
updateString(int columnIndex,
String x) |
void |
updateString(String columnLabel,
String x) |
void |
updateTime(int columnIndex,
Time x) |
void |
updateTime(String columnLabel,
Time x) |
void |
updateTimestamp(int columnIndex,
Timestamp x) |
void |
updateTimestamp(String columnLabel,
Timestamp x) |
clearWarnings, execute2, findColumn, getArray, getArray, getAsciiStream, getAsciiStream, getBigDecimal, getBigDecimal, getBigDecimal, getBigDecimal, getBinaryStream, getBinaryStream, getBlob, getBlob, getBoolean, getBoolean, getByte, getByte, getBytes, getBytes, getCharacterStream, getCharacterStream, getClob, getClob, getConcurrency, getDate, getDate, getDate, getDate, getDouble, getDouble, getFetchDirection, getFetchSize, getFloat, getFloat, getHoldability, getInt, getInt, getLocalCalendar, getLong, getLong, getMetaData, getNCharacterStream, getNCharacterStream, getNClob, getNClob, getNString, getNString, getObject, getObject, getObject, getObject, getObject, getRef, getRef, getRow, getShort, getShort, getSQLXML, getSQLXML, getStatement, getString, getString, getTime, getTime, getTime, getTime, getTimestamp, getTimestamp, getTimestamp, getTimestamp, getType, getUnicodeStream, getUnicodeStream, getURL, getURL, getWarnings, isAfterLast, isBeforeFirst, isClosed, isFirst, isWrapperFor, rowDeleted, rowInserted, rowUpdated, setFetchDirection, setFetchSize, unwrap, wasNull
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getBigDecimal, getBigDecimal, getByte, getByte, getDouble, getDouble, getFloat, getFloat, getInt, getInt, getLong, getLong, getObject, getShort, getShort, getString, getString, isWrapperFor, unwrap
clearWarnings, findColumn, getArray, getArray, getAsciiStream, getAsciiStream, getBigDecimal, getBigDecimal, getBinaryStream, getBinaryStream, getBlob, getBlob, getBoolean, getBoolean, getBytes, getBytes, getCharacterStream, getCharacterStream, getClob, getClob, getConcurrency, getDate, getDate, getDate, getDate, getFetchDirection, getFetchSize, getHoldability, getMetaData, getNCharacterStream, getNCharacterStream, getNClob, getNClob, getNString, getNString, getObject, getObject, getObject, getObject, getRef, getRef, getRow, getSQLXML, getSQLXML, getStatement, getTime, getTime, getTime, getTime, getTimestamp, getTimestamp, getTimestamp, getTimestamp, getType, getUnicodeStream, getUnicodeStream, getURL, getURL, getWarnings, isAfterLast, isBeforeFirst, isClosed, isFirst, rowDeleted, rowInserted, rowUpdated, setFetchDirection, setFetchSize, wasNull
protected void checkOpen() throws SQLException
checkOpen
in class org.apache.calcite.avatica.AvaticaResultSet
ExecutionCanceledSqlException
- if ResultSet is closed because of
cancellation and no QueryCanceledSqlException has been thrown yet
for this ResultSetAlreadyClosedSqlException
- if ResultSet is closedSQLException
- if error in calling AvaticaResultSet.isClosed()
protected void cancel()
cancel
in class org.apache.calcite.avatica.AvaticaResultSet
public boolean next() throws SQLException
next
in interface ResultSet
next
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void close()
close
in interface AutoCloseable
close
in interface ResultSet
close
in class org.apache.calcite.avatica.AvaticaResultSet
public String getCursorName() throws SQLException
getCursorName
in interface ResultSet
getCursorName
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public Object getObject(int columnIndex) throws SQLException
DrillResultSet
Drill: Conversions: Supports conversion from all types.
getObject
in interface ResultSet
getObject
in interface DrillResultSet
getObject
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public boolean isLast() throws SQLException
isLast
in interface ResultSet
isLast
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void beforeFirst() throws SQLException
beforeFirst
in interface ResultSet
beforeFirst
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void afterLast() throws SQLException
afterLast
in interface ResultSet
afterLast
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public boolean first() throws SQLException
first
in interface ResultSet
first
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public boolean last() throws SQLException
last
in interface ResultSet
last
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public boolean absolute(int row) throws SQLException
absolute
in interface ResultSet
absolute
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public boolean relative(int rows) throws SQLException
relative
in interface ResultSet
relative
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public boolean previous() throws SQLException
previous
in interface ResultSet
previous
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateNull(int columnIndex) throws SQLException
updateNull
in interface ResultSet
updateNull
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateBoolean(int columnIndex, boolean x) throws SQLException
updateBoolean
in interface ResultSet
updateBoolean
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateByte(int columnIndex, byte x) throws SQLException
updateByte
in interface ResultSet
updateByte
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateShort(int columnIndex, short x) throws SQLException
updateShort
in interface ResultSet
updateShort
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateInt(int columnIndex, int x) throws SQLException
updateInt
in interface ResultSet
updateInt
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateLong(int columnIndex, long x) throws SQLException
updateLong
in interface ResultSet
updateLong
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateFloat(int columnIndex, float x) throws SQLException
updateFloat
in interface ResultSet
updateFloat
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateDouble(int columnIndex, double x) throws SQLException
updateDouble
in interface ResultSet
updateDouble
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateBigDecimal(int columnIndex, BigDecimal x) throws SQLException
updateBigDecimal
in interface ResultSet
updateBigDecimal
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateString(int columnIndex, String x) throws SQLException
updateString
in interface ResultSet
updateString
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateBytes(int columnIndex, byte[] x) throws SQLException
updateBytes
in interface ResultSet
updateBytes
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateDate(int columnIndex, Date x) throws SQLException
updateDate
in interface ResultSet
updateDate
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateTime(int columnIndex, Time x) throws SQLException
updateTime
in interface ResultSet
updateTime
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateTimestamp(int columnIndex, Timestamp x) throws SQLException
updateTimestamp
in interface ResultSet
updateTimestamp
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateAsciiStream(int columnIndex, InputStream x, int length) throws SQLException
updateAsciiStream
in interface ResultSet
updateAsciiStream
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateBinaryStream(int columnIndex, InputStream x, int length) throws SQLException
updateBinaryStream
in interface ResultSet
updateBinaryStream
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateCharacterStream(int columnIndex, Reader x, int length) throws SQLException
updateCharacterStream
in interface ResultSet
updateCharacterStream
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateObject(int columnIndex, Object x, int scaleOrLength) throws SQLException
updateObject
in interface ResultSet
updateObject
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateObject(int columnIndex, Object x) throws SQLException
updateObject
in interface ResultSet
updateObject
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateObject(int columnIndex, Object x, SQLType targetSqlType, int scaleOrLength) throws SQLException
updateObject
in interface ResultSet
SQLException
public void updateObject(String columnLabel, Object x, SQLType targetSqlType, int scaleOrLength) throws SQLException
updateObject
in interface ResultSet
SQLException
public void updateObject(int columnIndex, Object x, SQLType targetSqlType) throws SQLException
updateObject
in interface ResultSet
SQLException
public void updateObject(String columnLabel, Object x, SQLType targetSqlType) throws SQLException
updateObject
in interface ResultSet
SQLException
public void updateNull(String columnLabel) throws SQLException
updateNull
in interface ResultSet
updateNull
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateBoolean(String columnLabel, boolean x) throws SQLException
updateBoolean
in interface ResultSet
updateBoolean
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateByte(String columnLabel, byte x) throws SQLException
updateByte
in interface ResultSet
updateByte
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateShort(String columnLabel, short x) throws SQLException
updateShort
in interface ResultSet
updateShort
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateInt(String columnLabel, int x) throws SQLException
updateInt
in interface ResultSet
updateInt
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateLong(String columnLabel, long x) throws SQLException
updateLong
in interface ResultSet
updateLong
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateFloat(String columnLabel, float x) throws SQLException
updateFloat
in interface ResultSet
updateFloat
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateDouble(String columnLabel, double x) throws SQLException
updateDouble
in interface ResultSet
updateDouble
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateBigDecimal(String columnLabel, BigDecimal x) throws SQLException
updateBigDecimal
in interface ResultSet
updateBigDecimal
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateString(String columnLabel, String x) throws SQLException
updateString
in interface ResultSet
updateString
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateBytes(String columnLabel, byte[] x) throws SQLException
updateBytes
in interface ResultSet
updateBytes
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateDate(String columnLabel, Date x) throws SQLException
updateDate
in interface ResultSet
updateDate
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateTime(String columnLabel, Time x) throws SQLException
updateTime
in interface ResultSet
updateTime
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateTimestamp(String columnLabel, Timestamp x) throws SQLException
updateTimestamp
in interface ResultSet
updateTimestamp
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateAsciiStream(String columnLabel, InputStream x, int length) throws SQLException
updateAsciiStream
in interface ResultSet
updateAsciiStream
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateBinaryStream(String columnLabel, InputStream x, int length) throws SQLException
updateBinaryStream
in interface ResultSet
updateBinaryStream
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateCharacterStream(String columnLabel, Reader reader, int length) throws SQLException
updateCharacterStream
in interface ResultSet
updateCharacterStream
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateObject(String columnLabel, Object x, int scaleOrLength) throws SQLException
updateObject
in interface ResultSet
updateObject
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateObject(String columnLabel, Object x) throws SQLException
updateObject
in interface ResultSet
updateObject
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void insertRow() throws SQLException
insertRow
in interface ResultSet
insertRow
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateRow() throws SQLException
updateRow
in interface ResultSet
updateRow
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void deleteRow() throws SQLException
deleteRow
in interface ResultSet
deleteRow
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void refreshRow() throws SQLException
refreshRow
in interface ResultSet
refreshRow
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void cancelRowUpdates() throws SQLException
cancelRowUpdates
in interface ResultSet
cancelRowUpdates
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void moveToInsertRow() throws SQLException
moveToInsertRow
in interface ResultSet
moveToInsertRow
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void moveToCurrentRow() throws SQLException
moveToCurrentRow
in interface ResultSet
moveToCurrentRow
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateRef(int columnIndex, Ref x) throws SQLException
updateRef
in interface ResultSet
updateRef
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateRef(String columnLabel, Ref x) throws SQLException
updateRef
in interface ResultSet
updateRef
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateBlob(int columnIndex, Blob x) throws SQLException
updateBlob
in interface ResultSet
updateBlob
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateBlob(String columnLabel, Blob x) throws SQLException
updateBlob
in interface ResultSet
updateBlob
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateClob(int columnIndex, Clob x) throws SQLException
updateClob
in interface ResultSet
updateClob
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateClob(String columnLabel, Clob x) throws SQLException
updateClob
in interface ResultSet
updateClob
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateArray(int columnIndex, Array x) throws SQLException
updateArray
in interface ResultSet
updateArray
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateArray(String columnLabel, Array x) throws SQLException
updateArray
in interface ResultSet
updateArray
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public RowId getRowId(int columnIndex) throws SQLException
getRowId
in interface ResultSet
getRowId
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public RowId getRowId(String columnLabel) throws SQLException
getRowId
in interface ResultSet
getRowId
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateRowId(int columnIndex, RowId x) throws SQLException
updateRowId
in interface ResultSet
updateRowId
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateRowId(String columnLabel, RowId x) throws SQLException
updateRowId
in interface ResultSet
updateRowId
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateNString(int columnIndex, String nString) throws SQLException
updateNString
in interface ResultSet
updateNString
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateNString(String columnLabel, String nString) throws SQLException
updateNString
in interface ResultSet
updateNString
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateNClob(int columnIndex, NClob nClob) throws SQLException
updateNClob
in interface ResultSet
updateNClob
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateNClob(String columnLabel, NClob nClob) throws SQLException
updateNClob
in interface ResultSet
updateNClob
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateSQLXML(int columnIndex, SQLXML xmlObject) throws SQLException
updateSQLXML
in interface ResultSet
updateSQLXML
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateSQLXML(String columnLabel, SQLXML xmlObject) throws SQLException
updateSQLXML
in interface ResultSet
updateSQLXML
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateNCharacterStream(int columnIndex, Reader x, long length) throws SQLException
updateNCharacterStream
in interface ResultSet
updateNCharacterStream
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateNCharacterStream(String columnLabel, Reader reader, long length) throws SQLException
updateNCharacterStream
in interface ResultSet
updateNCharacterStream
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateAsciiStream(int columnIndex, InputStream x, long length) throws SQLException
updateAsciiStream
in interface ResultSet
updateAsciiStream
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateBinaryStream(int columnIndex, InputStream x, long length) throws SQLException
updateBinaryStream
in interface ResultSet
updateBinaryStream
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateCharacterStream(int columnIndex, Reader x, long length) throws SQLException
updateCharacterStream
in interface ResultSet
updateCharacterStream
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateAsciiStream(String columnLabel, InputStream x, long length) throws SQLException
updateAsciiStream
in interface ResultSet
updateAsciiStream
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateBinaryStream(String columnLabel, InputStream x, long length) throws SQLException
updateBinaryStream
in interface ResultSet
updateBinaryStream
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateCharacterStream(String columnLabel, Reader reader, long length) throws SQLException
updateCharacterStream
in interface ResultSet
updateCharacterStream
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateBlob(int columnIndex, InputStream inputStream, long length) throws SQLException
updateBlob
in interface ResultSet
updateBlob
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateBlob(String columnLabel, InputStream inputStream, long length) throws SQLException
updateBlob
in interface ResultSet
updateBlob
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateClob(int columnIndex, Reader reader, long length) throws SQLException
updateClob
in interface ResultSet
updateClob
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateClob(String columnLabel, Reader reader, long length) throws SQLException
updateClob
in interface ResultSet
updateClob
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateNClob(int columnIndex, Reader reader, long length) throws SQLException
updateNClob
in interface ResultSet
updateNClob
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateNClob(String columnLabel, Reader reader, long length) throws SQLException
updateNClob
in interface ResultSet
updateNClob
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateNCharacterStream(int columnIndex, Reader x) throws SQLException
updateNCharacterStream
in interface ResultSet
updateNCharacterStream
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateNCharacterStream(String columnLabel, Reader reader) throws SQLException
updateNCharacterStream
in interface ResultSet
updateNCharacterStream
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateAsciiStream(int columnIndex, InputStream x) throws SQLException
updateAsciiStream
in interface ResultSet
updateAsciiStream
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateBinaryStream(int columnIndex, InputStream x) throws SQLException
updateBinaryStream
in interface ResultSet
updateBinaryStream
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateCharacterStream(int columnIndex, Reader x) throws SQLException
updateCharacterStream
in interface ResultSet
updateCharacterStream
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateAsciiStream(String columnLabel, InputStream x) throws SQLException
updateAsciiStream
in interface ResultSet
updateAsciiStream
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateBinaryStream(String columnLabel, InputStream x) throws SQLException
updateBinaryStream
in interface ResultSet
updateBinaryStream
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateCharacterStream(String columnLabel, Reader reader) throws SQLException
updateCharacterStream
in interface ResultSet
updateCharacterStream
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateBlob(int columnIndex, InputStream inputStream) throws SQLException
updateBlob
in interface ResultSet
updateBlob
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateBlob(String columnLabel, InputStream inputStream) throws SQLException
updateBlob
in interface ResultSet
updateBlob
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateClob(int columnIndex, Reader reader) throws SQLException
updateClob
in interface ResultSet
updateClob
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateClob(String columnLabel, Reader reader) throws SQLException
updateClob
in interface ResultSet
updateClob
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateNClob(int columnIndex, Reader reader) throws SQLException
updateNClob
in interface ResultSet
updateNClob
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public void updateNClob(String columnLabel, Reader reader) throws SQLException
updateNClob
in interface ResultSet
updateNClob
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
public String getQueryId() throws SQLException
DrillResultSet
getQueryId
in interface DrillResultSet
SQLException
- if this method is called on a closed result setprotected DrillResultSetImpl execute() throws SQLException
execute
in class org.apache.calcite.avatica.AvaticaResultSet
SQLException
Copyright © 1970 The Apache Software Foundation. All rights reserved.