Class DatabricksResultSet
java.lang.Object
com.databricks.jdbc.api.impl.DatabricksResultSet
- All Implemented Interfaces:
IDatabricksResultSet,IDatabricksResultSetInternal,AutoCloseable,ResultSet,Wrapper
public class DatabricksResultSet
extends Object
implements IDatabricksResultSet, IDatabricksResultSetInternal
-
Field Summary
FieldsFields 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
ConstructorsConstructorDescriptionDatabricksResultSet(StatementStatus statementStatus, StatementId statementId, StatementType statementType, IDatabricksStatementInternal parentStatement, IExecutionResult executionResult, DatabricksResultSetMetaData resultSetMetaData, boolean complexDatatypeSupport) DatabricksResultSet(StatementStatus statementStatus, StatementId statementId, TFetchResultsResp resultsResp, StatementType statementType, IDatabricksStatementInternal parentStatement, IDatabricksSession session) DatabricksResultSet(StatementStatus statementStatus, StatementId statementId, ResultData resultData, ResultManifest resultManifest, StatementType statementType, IDatabricksSession session, IDatabricksStatementInternal parentStatement) DatabricksResultSet(StatementStatus statementStatus, StatementId statementId, List<ColumnMetadata> columnMetadataList, List<List<Object>> rows, StatementType statementType) DatabricksResultSet(StatementStatus statementStatus, StatementId statementId, List<String> columnNames, List<String> columnTypeText, int[] columnTypes, int[] columnTypePrecisions, int[] isNullables, Object[][] rows, StatementType statementType) DatabricksResultSet(StatementStatus statementStatus, StatementId statementId, List<String> columnNames, List<String> columnTypeText, List<Integer> columnTypes, List<Integer> columnTypePrecisions, List<Nullable> columnNullables, List<List<Object>> rows, StatementType statementType) -
Method Summary
Modifier and TypeMethodDescriptionbooleanabsolute(int row) voidvoidvoidvoidvoidclose()voidintfindColumn(String columnLabel) booleanfirst()getArray(int columnIndex) getAsciiStream(int columnIndex) getAsciiStream(String columnLabel) getBigDecimal(int columnIndex) getBigDecimal(int columnIndex, int scale) getBigDecimal(String columnLabel) getBigDecimal(String columnLabel, int scale) getBinaryStream(int columnIndex) getBinaryStream(String columnLabel) getBlob(int columnIndex) booleangetBoolean(int columnIndex) booleangetBoolean(String columnLabel) bytegetByte(int columnIndex) bytebyte[]getBytes(int columnIndex) byte[]getCharacterStream(int columnIndex) getCharacterStream(String columnLabel) getClob(int columnIndex) intgetDate(int columnIndex) doublegetDouble(int columnIndex) doubleRetrieves the current status of the statement associated with this result set.intintfloatgetFloat(int columnIndex) floatintintgetInt(int columnIndex) intlonggetLong(int columnIndex) longgetMap(int columnIndex) Retrieves the SQL `Map` from the specified column index in the result set.Retrieves the SQL `Map` from the specified column using its label.getNCharacterStream(int columnIndex) getNCharacterStream(String columnLabel) getNClob(int columnIndex) getNString(int columnIndex) getNString(String columnLabel) getObject(int columnIndex) <T> T<T> TgetRef(int columnIndex) intgetRow()getRowId(int columnIndex) shortgetShort(int columnIndex) shortgetSQLXML(int columnIndex) Retrieves the unique identifier of the statement associated with this result set.Retrieves the current status of the statement associated with this result set.getString(int columnIndex) getStruct(int columnIndex) Retrieves the SQL `Struct` from the specified column index in the result set.Retrieves the SQL `Struct` from the specified column using its label.getTime(int columnIndex) getTimestamp(int columnIndex) getTimestamp(int columnIndex, Calendar cal) getTimestamp(String columnLabel) getTimestamp(String columnLabel, Calendar cal) intgetType()getUnicodeStream(int columnIndex) getUnicodeStream(String columnLabel) longRetrieves the number of rows affected by the SQL statement.getURL(int columnIndex) org.apache.http.entity.InputStreamEntitybooleanChecks whether the executed SQL statement has produced an update count.voidbooleanbooleanbooleanisClosed()booleanisFirst()booleanisLast()booleanisWrapperFor(Class<?> iface) booleanlast()voidvoidbooleannext()booleanprevious()voidbooleanrelative(int rows) booleanbooleanbooleanvoidsetFetchDirection(int direction) voidsetFetchSize(int rows) voidtoString()void<T> TvoidupdateArray(int columnIndex, Array x) voidupdateArray(String columnLabel, Array x) voidupdateAsciiStream(int columnIndex, InputStream x) voidupdateAsciiStream(int columnIndex, InputStream x, int length) voidupdateAsciiStream(int columnIndex, InputStream x, long length) voidupdateAsciiStream(String columnLabel, InputStream x) voidupdateAsciiStream(String columnLabel, InputStream x, int length) voidupdateAsciiStream(String columnLabel, InputStream x, long length) voidupdateBigDecimal(int columnIndex, BigDecimal x) voidupdateBigDecimal(String columnLabel, BigDecimal x) voidupdateBinaryStream(int columnIndex, InputStream x) voidupdateBinaryStream(int columnIndex, InputStream x, int length) voidupdateBinaryStream(int columnIndex, InputStream x, long length) voidupdateBinaryStream(String columnLabel, InputStream x) voidupdateBinaryStream(String columnLabel, InputStream x, int length) voidupdateBinaryStream(String columnLabel, InputStream x, long length) voidupdateBlob(int columnIndex, InputStream inputStream) voidupdateBlob(int columnIndex, InputStream inputStream, long length) voidupdateBlob(int columnIndex, Blob x) voidupdateBlob(String columnLabel, InputStream inputStream) voidupdateBlob(String columnLabel, InputStream inputStream, long length) voidupdateBlob(String columnLabel, Blob x) voidupdateBoolean(int columnIndex, boolean x) voidupdateBoolean(String columnLabel, boolean x) voidupdateByte(int columnIndex, byte x) voidupdateByte(String columnLabel, byte x) voidupdateBytes(int columnIndex, byte[] x) voidupdateBytes(String columnLabel, byte[] x) voidupdateCharacterStream(int columnIndex, Reader x) voidupdateCharacterStream(int columnIndex, Reader x, int length) voidupdateCharacterStream(int columnIndex, Reader x, long length) voidupdateCharacterStream(String columnLabel, Reader reader) voidupdateCharacterStream(String columnLabel, Reader reader, int length) voidupdateCharacterStream(String columnLabel, Reader reader, long length) voidupdateClob(int columnIndex, Reader reader) voidupdateClob(int columnIndex, Reader reader, long length) voidupdateClob(int columnIndex, Clob x) voidupdateClob(String columnLabel, Reader reader) voidupdateClob(String columnLabel, Reader reader, long length) voidupdateClob(String columnLabel, Clob x) voidupdateDate(int columnIndex, Date x) voidupdateDate(String columnLabel, Date x) voidupdateDouble(int columnIndex, double x) voidupdateDouble(String columnLabel, double x) voidupdateFloat(int columnIndex, float x) voidupdateFloat(String columnLabel, float x) voidupdateInt(int columnIndex, int x) voidvoidupdateLong(int columnIndex, long x) voidupdateLong(String columnLabel, long x) voidupdateNCharacterStream(int columnIndex, Reader x) voidupdateNCharacterStream(int columnIndex, Reader x, long length) voidupdateNCharacterStream(String columnLabel, Reader reader) voidupdateNCharacterStream(String columnLabel, Reader reader, long length) voidupdateNClob(int columnIndex, Reader reader) voidupdateNClob(int columnIndex, Reader reader, long length) voidupdateNClob(int columnIndex, NClob nClob) voidupdateNClob(String columnLabel, Reader reader) voidupdateNClob(String columnLabel, Reader reader, long length) voidupdateNClob(String columnLabel, NClob nClob) voidupdateNString(int columnIndex, String nString) voidupdateNString(String columnLabel, String nString) voidupdateNull(int columnIndex) voidupdateNull(String columnLabel) voidupdateObject(int columnIndex, Object x) voidupdateObject(int columnIndex, Object x, int scaleOrLength) voidupdateObject(int columnIndex, Object x, SQLType targetSqlType) voidupdateObject(int columnIndex, Object x, SQLType targetSqlType, int scaleOrLength) voidupdateObject(String columnLabel, Object x) voidupdateObject(String columnLabel, Object x, int scaleOrLength) voidupdateObject(String columnLabel, Object x, SQLType targetSqlType) voidupdateObject(String columnLabel, Object x, SQLType targetSqlType, int scaleOrLength) voidvoidvoidvoidupdateRowId(int columnIndex, RowId x) voidupdateRowId(String columnLabel, RowId x) voidupdateShort(int columnIndex, short x) voidupdateShort(String columnLabel, short x) voidupdateSQLXML(int columnIndex, SQLXML xmlObject) voidupdateSQLXML(String columnLabel, SQLXML xmlObject) voidupdateString(int columnIndex, String x) voidupdateString(String columnLabel, String x) voidupdateTime(int columnIndex, Time x) voidupdateTime(String columnLabel, Time x) voidupdateTimestamp(int columnIndex, Timestamp x) voidupdateTimestamp(String columnLabel, Timestamp x) booleanwasNull()
-
Field Details
-
AFFECTED_ROWS_COUNT
- See Also:
-
-
Constructor Details
-
DatabricksResultSet
public DatabricksResultSet(StatementStatus statementStatus, StatementId statementId, ResultData resultData, ResultManifest resultManifest, StatementType statementType, IDatabricksSession session, IDatabricksStatementInternal parentStatement) throws DatabricksSQLException - Throws:
DatabricksSQLException
-
DatabricksResultSet
public DatabricksResultSet(StatementStatus statementStatus, StatementId statementId, StatementType statementType, IDatabricksStatementInternal parentStatement, IExecutionResult executionResult, DatabricksResultSetMetaData resultSetMetaData, boolean complexDatatypeSupport) -
DatabricksResultSet
public DatabricksResultSet(StatementStatus statementStatus, StatementId statementId, TFetchResultsResp resultsResp, StatementType statementType, IDatabricksStatementInternal parentStatement, IDatabricksSession session) throws SQLException - Throws:
SQLException
-
DatabricksResultSet
public DatabricksResultSet(StatementStatus statementStatus, StatementId statementId, List<String> columnNames, List<String> columnTypeText, int[] columnTypes, int[] columnTypePrecisions, int[] isNullables, Object[][] rows, StatementType statementType) -
DatabricksResultSet
-
DatabricksResultSet
public DatabricksResultSet(StatementStatus statementStatus, StatementId statementId, List<ColumnMetadata> columnMetadataList, List<List<Object>> rows, StatementType statementType)
-
-
Method Details
-
next
- Specified by:
nextin interfaceResultSet- Throws:
SQLException
-
close
- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceResultSet- Throws:
DatabricksSQLException
-
wasNull
- Specified by:
wasNullin interfaceResultSet- Throws:
SQLException
-
getString
- Specified by:
getStringin interfaceResultSet- Throws:
SQLException
-
getBoolean
- Specified by:
getBooleanin interfaceResultSet- Throws:
SQLException
-
getByte
- Specified by:
getBytein interfaceResultSet- Throws:
SQLException
-
getShort
- Specified by:
getShortin interfaceResultSet- Throws:
SQLException
-
getInt
- Specified by:
getIntin interfaceResultSet- Throws:
SQLException
-
getLong
- Specified by:
getLongin interfaceResultSet- Throws:
SQLException
-
getFloat
- Specified by:
getFloatin interfaceResultSet- Throws:
SQLException
-
getDouble
- Specified by:
getDoublein interfaceResultSet- Throws:
SQLException
-
getBigDecimal
- Specified by:
getBigDecimalin interfaceResultSet- Throws:
SQLException
-
getBytes
- Specified by:
getBytesin interfaceResultSet- Throws:
SQLException
-
getDate
- Specified by:
getDatein interfaceResultSet- Throws:
SQLException
-
getTime
- Specified by:
getTimein interfaceResultSet- Throws:
SQLException
-
getTimestamp
- Specified by:
getTimestampin interfaceResultSet- Throws:
SQLException
-
getAsciiStream
- Specified by:
getAsciiStreamin interfaceResultSet- Throws:
SQLException
-
getUnicodeStream
- Specified by:
getUnicodeStreamin interfaceResultSet- Throws:
SQLException
-
getBinaryStream
- Specified by:
getBinaryStreamin interfaceResultSet- Throws:
SQLException
-
getString
- Specified by:
getStringin interfaceResultSet- Throws:
SQLException
-
getBoolean
- Specified by:
getBooleanin interfaceResultSet- Throws:
SQLException
-
getByte
- Specified by:
getBytein interfaceResultSet- Throws:
SQLException
-
getShort
- Specified by:
getShortin interfaceResultSet- Throws:
SQLException
-
getInt
- Specified by:
getIntin interfaceResultSet- Throws:
SQLException
-
getLong
- Specified by:
getLongin interfaceResultSet- Throws:
SQLException
-
getFloat
- Specified by:
getFloatin interfaceResultSet- Throws:
SQLException
-
getDouble
- Specified by:
getDoublein interfaceResultSet- Throws:
SQLException
-
getBigDecimal
- Specified by:
getBigDecimalin interfaceResultSet- Throws:
SQLException
-
getBytes
- Specified by:
getBytesin interfaceResultSet- Throws:
SQLException
-
getDate
- Specified by:
getDatein interfaceResultSet- Throws:
SQLException
-
getTime
- Specified by:
getTimein interfaceResultSet- Throws:
SQLException
-
getTimestamp
- Specified by:
getTimestampin interfaceResultSet- Throws:
SQLException
-
getAsciiStream
- Specified by:
getAsciiStreamin interfaceResultSet- Throws:
SQLException
-
getUnicodeStream
- Specified by:
getUnicodeStreamin interfaceResultSet- Throws:
SQLException
-
getBinaryStream
- Specified by:
getBinaryStreamin interfaceResultSet- Throws:
SQLException
-
getWarnings
- Specified by:
getWarningsin interfaceResultSet- Throws:
SQLException
-
clearWarnings
- Specified by:
clearWarningsin interfaceResultSet- Throws:
SQLException
-
getCursorName
- Specified by:
getCursorNamein interfaceResultSet- Throws:
SQLException
-
getMetaData
- Specified by:
getMetaDatain interfaceResultSet- Throws:
SQLException
-
getObject
- Specified by:
getObjectin interfaceResultSet- Throws:
SQLException
-
getObject
- Specified by:
getObjectin interfaceResultSet- Throws:
SQLException
-
findColumn
- Specified by:
findColumnin interfaceResultSet- Throws:
SQLException
-
getCharacterStream
- Specified by:
getCharacterStreamin interfaceResultSet- Throws:
SQLException
-
getCharacterStream
- Specified by:
getCharacterStreamin interfaceResultSet- Throws:
SQLException
-
getBigDecimal
- Specified by:
getBigDecimalin interfaceResultSet- Throws:
SQLException
-
getBigDecimal
- Specified by:
getBigDecimalin interfaceResultSet- Throws:
SQLException
-
isBeforeFirst
- Specified by:
isBeforeFirstin interfaceResultSet- Throws:
SQLException
-
isAfterLast
Limitation: For lazy-loaded result sets (
LazyThriftResult), particularly those usingTSparkRowSetType.COLUMN_BASED_SET, this method cannot reliably determine the cursor position. The total row count remains unknown until all rows are fetched, preventing accurate detection of whether the cursor is after the last row. This is specific to Databricks JDBC dialect.- Specified by:
isAfterLastin interfaceResultSet- Throws:
SQLException
-
isFirst
- Specified by:
isFirstin interfaceResultSet- Throws:
SQLException
-
isLast
This method uses different strategies based on the result set type:
- For
LazyThriftResultinstances: Checks if there are no more rows available (usinghasNext()), since the total row count is unknown until all rows are fetched. - For other result types: Compares the current row position against the known total row count.
- Specified by:
isLastin interfaceResultSet- Returns:
trueif the cursor is on the last row,falseotherwise- Throws:
SQLException- if the result set is closed or an error occurs
- For
-
beforeFirst
- Specified by:
beforeFirstin interfaceResultSet- Throws:
SQLException
-
afterLast
- Specified by:
afterLastin interfaceResultSet- Throws:
SQLException
-
first
- Specified by:
firstin interfaceResultSet- Throws:
SQLException
-
last
- Specified by:
lastin interfaceResultSet- Throws:
SQLException
-
getRow
- Specified by:
getRowin interfaceResultSet- Throws:
SQLException
-
absolute
- Specified by:
absolutein interfaceResultSet- Throws:
SQLException
-
relative
- Specified by:
relativein interfaceResultSet- Throws:
SQLException
-
previous
- Specified by:
previousin interfaceResultSet- Throws:
SQLException
-
setFetchDirection
- Specified by:
setFetchDirectionin interfaceResultSet- Throws:
SQLException
-
getFetchDirection
- Specified by:
getFetchDirectionin interfaceResultSet- Throws:
SQLException
-
setFetchSize
- Specified by:
setFetchSizein interfaceResultSet- Throws:
SQLException
-
getFetchSize
- Specified by:
getFetchSizein interfaceResultSet- Throws:
SQLException
-
getType
- Specified by:
getTypein interfaceResultSet- Throws:
SQLException
-
getConcurrency
- Specified by:
getConcurrencyin interfaceResultSet- Throws:
SQLException
-
rowUpdated
- Specified by:
rowUpdatedin interfaceResultSet- Throws:
SQLException
-
rowInserted
- Specified by:
rowInsertedin interfaceResultSet- Throws:
SQLException
-
rowDeleted
- Specified by:
rowDeletedin interfaceResultSet- Throws:
SQLException
-
updateNull
- Specified by:
updateNullin interfaceResultSet- Throws:
SQLException
-
updateBoolean
- Specified by:
updateBooleanin interfaceResultSet- Throws:
SQLException
-
updateByte
- Specified by:
updateBytein interfaceResultSet- Throws:
SQLException
-
updateShort
- Specified by:
updateShortin interfaceResultSet- Throws:
SQLException
-
updateInt
- Specified by:
updateIntin interfaceResultSet- Throws:
SQLException
-
updateLong
- Specified by:
updateLongin interfaceResultSet- Throws:
SQLException
-
updateFloat
- Specified by:
updateFloatin interfaceResultSet- Throws:
SQLException
-
updateDouble
- Specified by:
updateDoublein interfaceResultSet- Throws:
SQLException
-
updateBigDecimal
- Specified by:
updateBigDecimalin interfaceResultSet- Throws:
SQLException
-
updateString
- Specified by:
updateStringin interfaceResultSet- Throws:
SQLException
-
updateBytes
- Specified by:
updateBytesin interfaceResultSet- Throws:
SQLException
-
updateDate
- Specified by:
updateDatein interfaceResultSet- Throws:
SQLException
-
updateTime
- Specified by:
updateTimein interfaceResultSet- Throws:
SQLException
-
updateTimestamp
- Specified by:
updateTimestampin interfaceResultSet- Throws:
SQLException
-
updateAsciiStream
- Specified by:
updateAsciiStreamin interfaceResultSet- Throws:
SQLException
-
updateBinaryStream
- Specified by:
updateBinaryStreamin interfaceResultSet- Throws:
SQLException
-
updateCharacterStream
- Specified by:
updateCharacterStreamin interfaceResultSet- Throws:
SQLException
-
updateObject
- Specified by:
updateObjectin interfaceResultSet- Throws:
SQLException
-
updateObject
- Specified by:
updateObjectin interfaceResultSet- Throws:
SQLException
-
updateObject
public void updateObject(int columnIndex, Object x, SQLType targetSqlType, int scaleOrLength) throws SQLException - Specified by:
updateObjectin interfaceResultSet- Throws:
SQLException
-
updateObject
public void updateObject(String columnLabel, Object x, SQLType targetSqlType, int scaleOrLength) throws SQLException - Specified by:
updateObjectin interfaceResultSet- Throws:
SQLException
-
updateObject
- Specified by:
updateObjectin interfaceResultSet- Throws:
SQLException
-
updateObject
- Specified by:
updateObjectin interfaceResultSet- Throws:
SQLException
-
updateNull
- Specified by:
updateNullin interfaceResultSet- Throws:
SQLException
-
updateBoolean
- Specified by:
updateBooleanin interfaceResultSet- Throws:
SQLException
-
updateByte
- Specified by:
updateBytein interfaceResultSet- Throws:
SQLException
-
updateShort
- Specified by:
updateShortin interfaceResultSet- Throws:
SQLException
-
updateInt
- Specified by:
updateIntin interfaceResultSet- Throws:
SQLException
-
updateLong
- Specified by:
updateLongin interfaceResultSet- Throws:
SQLException
-
updateFloat
- Specified by:
updateFloatin interfaceResultSet- Throws:
SQLException
-
updateDouble
- Specified by:
updateDoublein interfaceResultSet- Throws:
SQLException
-
updateBigDecimal
- Specified by:
updateBigDecimalin interfaceResultSet- Throws:
SQLException
-
updateString
- Specified by:
updateStringin interfaceResultSet- Throws:
SQLException
-
updateBytes
- Specified by:
updateBytesin interfaceResultSet- Throws:
SQLException
-
updateDate
- Specified by:
updateDatein interfaceResultSet- Throws:
SQLException
-
updateTime
- Specified by:
updateTimein interfaceResultSet- Throws:
SQLException
-
updateTimestamp
- Specified by:
updateTimestampin interfaceResultSet- Throws:
SQLException
-
updateAsciiStream
- Specified by:
updateAsciiStreamin interfaceResultSet- Throws:
SQLException
-
updateBinaryStream
- Specified by:
updateBinaryStreamin interfaceResultSet- Throws:
SQLException
-
updateCharacterStream
public void updateCharacterStream(String columnLabel, Reader reader, int length) throws SQLException - Specified by:
updateCharacterStreamin interfaceResultSet- Throws:
SQLException
-
updateObject
- Specified by:
updateObjectin interfaceResultSet- Throws:
SQLException
-
updateObject
- Specified by:
updateObjectin interfaceResultSet- Throws:
SQLException
-
insertRow
- Specified by:
insertRowin interfaceResultSet- Throws:
SQLException
-
updateRow
- Specified by:
updateRowin interfaceResultSet- Throws:
SQLException
-
deleteRow
- Specified by:
deleteRowin interfaceResultSet- Throws:
SQLException
-
refreshRow
- Specified by:
refreshRowin interfaceResultSet- Throws:
SQLException
-
cancelRowUpdates
- Specified by:
cancelRowUpdatesin interfaceResultSet- Throws:
SQLException
-
moveToInsertRow
- Specified by:
moveToInsertRowin interfaceResultSet- Throws:
SQLException
-
moveToCurrentRow
- Specified by:
moveToCurrentRowin interfaceResultSet- Throws:
SQLException
-
getStatement
- Specified by:
getStatementin interfaceResultSet- Throws:
SQLException
-
getObject
- Specified by:
getObjectin interfaceResultSet- Throws:
SQLException
-
getRef
- Specified by:
getRefin interfaceResultSet- Throws:
SQLException
-
getBlob
- Specified by:
getBlobin interfaceResultSet- Throws:
SQLException
-
getClob
- Specified by:
getClobin interfaceResultSet- Throws:
SQLException
-
getArray
- Specified by:
getArrayin interfaceResultSet- Throws:
SQLException
-
getStruct
Retrieves the SQL `Struct` from the specified column index in the result set.- Specified by:
getStructin interfaceIDatabricksResultSet- Parameters:
columnIndex- the index of the column in the result set (1-based)- Returns:
- a `Struct` object if the column contains a struct; `null` if the value is SQL `NULL`
- Throws:
SQLException- if the column is not of `STRUCT` type or if any SQL error occurs
-
getMap
Retrieves the SQL `Map` from the specified column index in the result set.- Specified by:
getMapin interfaceIDatabricksResultSet- Parameters:
columnIndex- the index of the column in the result set (1-based)- Returns:
- a `Mapinvalid input: '<'String, Object>` if the column contains a map; `null` if the value is SQL `NULL`
- Throws:
SQLException- if the column is not of `MAP` type or if any SQL error occurs
-
getObject
- Specified by:
getObjectin interfaceResultSet- Throws:
SQLException
-
getRef
- Specified by:
getRefin interfaceResultSet- Throws:
SQLException
-
getBlob
- Specified by:
getBlobin interfaceResultSet- Throws:
SQLException
-
getClob
- Specified by:
getClobin interfaceResultSet- Throws:
SQLException
-
getArray
- Specified by:
getArrayin interfaceResultSet- Throws:
SQLException
-
getStruct
Description copied from interface:IDatabricksResultSetRetrieves the SQL `Struct` from the specified column using its label.- Specified by:
getStructin interfaceIDatabricksResultSet- Parameters:
columnLabel- the label for the column specified in the SQL query- Returns:
- a `Struct` object if the column contains a struct; `null` if the value is SQL `NULL`
- Throws:
SQLException- if the column is not of `STRUCT` type or if any SQL error occurs
-
getMap
Description copied from interface:IDatabricksResultSetRetrieves the SQL `Map` from the specified column using its label.- Specified by:
getMapin interfaceIDatabricksResultSet- Parameters:
columnLabel- the label for the column specified in the SQL query- Returns:
- a `Mapinvalid input: '<'String, Object>` if the column contains a map; `null` if the value is SQL `NULL`
- Throws:
SQLException- if the column is not of `MAP` type or if any SQL error occurs
-
getDate
- Specified by:
getDatein interfaceResultSet- Throws:
SQLException
-
getDate
- Specified by:
getDatein interfaceResultSet- Throws:
SQLException
-
getTime
- Specified by:
getTimein interfaceResultSet- Throws:
SQLException
-
getTime
- Specified by:
getTimein interfaceResultSet- Throws:
SQLException
-
getTimestamp
- Specified by:
getTimestampin interfaceResultSet- Throws:
SQLException
-
getTimestamp
- Specified by:
getTimestampin interfaceResultSet- Throws:
SQLException
-
getURL
- Specified by:
getURLin interfaceResultSet- Throws:
SQLException
-
getURL
- Specified by:
getURLin interfaceResultSet- Throws:
SQLException
-
updateRef
- Specified by:
updateRefin interfaceResultSet- Throws:
SQLException
-
updateRef
- Specified by:
updateRefin interfaceResultSet- Throws:
SQLException
-
updateBlob
- Specified by:
updateBlobin interfaceResultSet- Throws:
SQLException
-
updateBlob
- Specified by:
updateBlobin interfaceResultSet- Throws:
SQLException
-
updateClob
- Specified by:
updateClobin interfaceResultSet- Throws:
SQLException
-
updateClob
- Specified by:
updateClobin interfaceResultSet- Throws:
SQLException
-
updateArray
- Specified by:
updateArrayin interfaceResultSet- Throws:
SQLException
-
updateArray
- Specified by:
updateArrayin interfaceResultSet- Throws:
SQLException
-
getRowId
- Specified by:
getRowIdin interfaceResultSet- Throws:
SQLException
-
getRowId
- Specified by:
getRowIdin interfaceResultSet- Throws:
SQLException
-
updateRowId
- Specified by:
updateRowIdin interfaceResultSet- Throws:
SQLException
-
updateRowId
- Specified by:
updateRowIdin interfaceResultSet- Throws:
SQLException
-
getHoldability
- Specified by:
getHoldabilityin interfaceResultSet- Throws:
SQLException
-
isClosed
- Specified by:
isClosedin interfaceResultSet- Throws:
SQLException
-
updateNString
- Specified by:
updateNStringin interfaceResultSet- Throws:
SQLException
-
updateNString
- Specified by:
updateNStringin interfaceResultSet- Throws:
SQLException
-
updateNClob
- Specified by:
updateNClobin interfaceResultSet- Throws:
SQLException
-
updateNClob
- Specified by:
updateNClobin interfaceResultSet- Throws:
SQLException
-
getNClob
- Specified by:
getNClobin interfaceResultSet- Throws:
SQLException
-
getNClob
- Specified by:
getNClobin interfaceResultSet- Throws:
SQLException
-
getSQLXML
- Specified by:
getSQLXMLin interfaceResultSet- Throws:
SQLException
-
getSQLXML
- Specified by:
getSQLXMLin interfaceResultSet- Throws:
SQLException
-
updateSQLXML
- Specified by:
updateSQLXMLin interfaceResultSet- Throws:
SQLException
-
updateSQLXML
- Specified by:
updateSQLXMLin interfaceResultSet- Throws:
SQLException
-
getNString
- Specified by:
getNStringin interfaceResultSet- Throws:
SQLException
-
getNString
- Specified by:
getNStringin interfaceResultSet- Throws:
SQLException
-
getNCharacterStream
- Specified by:
getNCharacterStreamin interfaceResultSet- Throws:
SQLException
-
getNCharacterStream
- Specified by:
getNCharacterStreamin interfaceResultSet- Throws:
SQLException
-
updateNCharacterStream
- Specified by:
updateNCharacterStreamin interfaceResultSet- Throws:
SQLException
-
updateNCharacterStream
public void updateNCharacterStream(String columnLabel, Reader reader, long length) throws SQLException - Specified by:
updateNCharacterStreamin interfaceResultSet- Throws:
SQLException
-
updateAsciiStream
- Specified by:
updateAsciiStreamin interfaceResultSet- Throws:
SQLException
-
updateBinaryStream
- Specified by:
updateBinaryStreamin interfaceResultSet- Throws:
SQLException
-
updateCharacterStream
- Specified by:
updateCharacterStreamin interfaceResultSet- Throws:
SQLException
-
updateAsciiStream
- Specified by:
updateAsciiStreamin interfaceResultSet- Throws:
SQLException
-
updateBinaryStream
- Specified by:
updateBinaryStreamin interfaceResultSet- Throws:
SQLException
-
updateCharacterStream
public void updateCharacterStream(String columnLabel, Reader reader, long length) throws SQLException - Specified by:
updateCharacterStreamin interfaceResultSet- Throws:
SQLException
-
updateBlob
- Specified by:
updateBlobin interfaceResultSet- Throws:
SQLException
-
updateBlob
public void updateBlob(String columnLabel, InputStream inputStream, long length) throws SQLException - Specified by:
updateBlobin interfaceResultSet- Throws:
SQLException
-
updateClob
- Specified by:
updateClobin interfaceResultSet- Throws:
SQLException
-
updateClob
- Specified by:
updateClobin interfaceResultSet- Throws:
SQLException
-
updateNClob
- Specified by:
updateNClobin interfaceResultSet- Throws:
SQLException
-
updateNClob
- Specified by:
updateNClobin interfaceResultSet- Throws:
SQLException
-
updateNCharacterStream
- Specified by:
updateNCharacterStreamin interfaceResultSet- Throws:
SQLException
-
updateNCharacterStream
- Specified by:
updateNCharacterStreamin interfaceResultSet- Throws:
SQLException
-
updateAsciiStream
- Specified by:
updateAsciiStreamin interfaceResultSet- Throws:
SQLException
-
updateBinaryStream
- Specified by:
updateBinaryStreamin interfaceResultSet- Throws:
SQLException
-
updateCharacterStream
- Specified by:
updateCharacterStreamin interfaceResultSet- Throws:
SQLException
-
updateAsciiStream
- Specified by:
updateAsciiStreamin interfaceResultSet- Throws:
SQLException
-
updateBinaryStream
- Specified by:
updateBinaryStreamin interfaceResultSet- Throws:
SQLException
-
updateCharacterStream
- Specified by:
updateCharacterStreamin interfaceResultSet- Throws:
SQLException
-
updateBlob
- Specified by:
updateBlobin interfaceResultSet- Throws:
SQLException
-
updateBlob
- Specified by:
updateBlobin interfaceResultSet- Throws:
SQLException
-
updateClob
- Specified by:
updateClobin interfaceResultSet- Throws:
SQLException
-
updateClob
- Specified by:
updateClobin interfaceResultSet- Throws:
SQLException
-
updateNClob
- Specified by:
updateNClobin interfaceResultSet- Throws:
SQLException
-
updateNClob
- Specified by:
updateNClobin interfaceResultSet- Throws:
SQLException
-
getObject
- Specified by:
getObjectin interfaceResultSet- Throws:
SQLException
-
getObject
- Specified by:
getObjectin interfaceResultSet- Throws:
SQLException
-
unwrap
- Specified by:
unwrapin interfaceWrapper- Throws:
SQLException
-
isWrapperFor
- Specified by:
isWrapperForin interfaceWrapper- Throws:
SQLException
-
getStatementId
Description copied from interface:IDatabricksResultSetRetrieves the unique identifier of the statement associated with this result set.- Specified by:
getStatementIdin interfaceIDatabricksResultSet- Returns:
- A string representing the statement ID
-
getStatementStatus
Description copied from interface:IDatabricksResultSetRetrieves the current status of the statement associated with this result set. This can be used to monitor the execution progress and state of the statement.- Specified by:
getStatementStatusin interfaceIDatabricksResultSet- Returns:
- The current
StatementStatusof the statement
-
getExecutionStatus
Description copied from interface:IDatabricksResultSetRetrieves the current status of the statement associated with this result set. This can be used to monitor the execution progress and state of the statement.- Specified by:
getExecutionStatusin interfaceIDatabricksResultSet- Returns:
- The current
StatementStatusof the statement
-
getUpdateCount
Description copied from interface:IDatabricksResultSetRetrieves the number of rows affected by the SQL statement. For SELECT statements or statements that don't modify data, this will return 0.- Specified by:
getUpdateCountin interfaceIDatabricksResultSet- Returns:
- The number of rows affected by INSERT, UPDATE, or DELETE statements
- Throws:
SQLException- if a database access error occurs or this method is called on a closed result set
-
hasUpdateCount
Description copied from interface:IDatabricksResultSetChecks whether the executed SQL statement has produced an update count. This is typically true for DML (Data Manipulation Language) statements like INSERT, UPDATE, or DELETE.- Specified by:
hasUpdateCountin interfaceIDatabricksResultSet- Returns:
- true if the statement has produced an update count, false otherwise
- Throws:
SQLException- if a database access error occurs or this method is called on a closed result set
-
getVolumeOperationInputStream
- Specified by:
getVolumeOperationInputStreamin interfaceIDatabricksResultSetInternal- Throws:
SQLException
-
setSilenceNonTerminalExceptions
public void setSilenceNonTerminalExceptions()- Specified by:
setSilenceNonTerminalExceptionsin interfaceIDatabricksResultSetInternal
-
unsetSilenceNonTerminalExceptions
public void unsetSilenceNonTerminalExceptions()- Specified by:
unsetSilenceNonTerminalExceptionsin interfaceIDatabricksResultSetInternal
-
toString
-