Package com.databricks.jdbc.core
Interface IDatabricksStatement
-
- All Known Implementing Classes:
DatabricksPreparedStatement,DatabricksStatement
public interface IDatabricksStatementInterface for Databricks specific statement.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidallowInputStreamForVolumeOperation(boolean allowedInputStream)voidclose(boolean removeFromSession)InputStreamgetInputStreamForUCVolume()intgetMaxRows()StringgetSessionId()Returns the underlying session-Id for the statement.StatementgetStatement()StringgetStatementId()voidhandleResultSetClose(IDatabricksResultSet resultSet)booleanisAllowedInputStreamForVolumeOperation()voidsetInputStreamForUCVolume(InputStream inputStream)voidsetStatementId(String statementId)
-
-
-
Method Detail
-
getSessionId
String getSessionId()
Returns the underlying session-Id for the statement.
-
close
void close(boolean removeFromSession) throws SQLException- Throws:
SQLException
-
handleResultSetClose
void handleResultSetClose(IDatabricksResultSet resultSet) throws SQLException
- Throws:
SQLException
-
getMaxRows
int getMaxRows() throws SQLException- Throws:
SQLException
-
setStatementId
void setStatementId(String statementId)
-
getStatementId
String getStatementId()
-
getStatement
Statement getStatement()
-
allowInputStreamForVolumeOperation
void allowInputStreamForVolumeOperation(boolean allowedInputStream) throws DatabricksSQLException- Throws:
DatabricksSQLException
-
isAllowedInputStreamForVolumeOperation
boolean isAllowedInputStreamForVolumeOperation() throws DatabricksSQLException- Throws:
DatabricksSQLException
-
setInputStreamForUCVolume
void setInputStreamForUCVolume(InputStream inputStream) throws DatabricksSQLException
- Throws:
DatabricksSQLException
-
getInputStreamForUCVolume
InputStream getInputStreamForUCVolume() throws DatabricksSQLException
- Throws:
DatabricksSQLException
-
-