Package com.databricks.jdbc.api.internal

Interface IDatabricksStatementInternal

All Known Implementing Classes:

DatabricksCallableStatement, DatabricksPreparedStatement, DatabricksStatement

public interface IDatabricksStatementInternal

Extended callback handle for java.sql.Statement interface

Method Summary

Modifier and Type	Method	Description
void	allowInputStreamForVolumeOperation(boolean allowedInputStream)
void	close(boolean removeFromSession)
default void	closeServerOperation()	Proactively closes the server-side operation to release server resources while keeping the client-side Statement open for reuse.
org.apache.http.entity.InputStreamEntity	getInputStreamForUCVolume()
long	getLargeMaxRows()
int	getMaxRows()
Statement	getStatement()
StatementId	getStatementId()
void	handleResultSetClose(IDatabricksResultSet resultSet)
boolean	isAllowedInputStreamForVolumeOperation()
default void	markDirectResultsReceived()	Marks that the server returned direct (inline) results and closed the operation.
void	setInputStreamForUCVolume(org.apache.http.entity.InputStreamEntity inputStream)
void	setStatementId(StatementId statementId)

Method Detail

close

void close(boolean removeFromSession)
    throws DatabricksSQLException

Throws:

DatabricksSQLException

handleResultSetClose

void handleResultSetClose(IDatabricksResultSet resultSet)
                   throws DatabricksSQLException

Throws:

DatabricksSQLException

getMaxRows

int getMaxRows()
        throws DatabricksSQLException

Throws:

DatabricksSQLException

getLargeMaxRows

long getLargeMaxRows()
              throws DatabricksSQLException

Throws:

DatabricksSQLException

setStatementId

void setStatementId(StatementId statementId)

getStatementId

StatementId getStatementId()

getStatement

Statement getStatement()

allowInputStreamForVolumeOperation

void allowInputStreamForVolumeOperation(boolean allowedInputStream)
                                 throws DatabricksSQLException

Throws:

DatabricksSQLException

isAllowedInputStreamForVolumeOperation

boolean isAllowedInputStreamForVolumeOperation()
                                        throws DatabricksSQLException

Throws:

DatabricksSQLException

setInputStreamForUCVolume

void setInputStreamForUCVolume(org.apache.http.entity.InputStreamEntity inputStream)
                        throws DatabricksSQLException

Throws:

DatabricksSQLException

getInputStreamForUCVolume

org.apache.http.entity.InputStreamEntity getInputStreamForUCVolume()
                                                            throws DatabricksSQLException

Throws:

DatabricksSQLException

markDirectResultsReceived

default void markDirectResultsReceived()

Marks that the server returned direct (inline) results and closed the operation. The JDBC Statement remains open for re-execution. Default no-op for implementations that don't support direct results.

closeServerOperation

default void closeServerOperation()

Proactively closes the server-side operation to release server resources while keeping the client-side Statement open for reuse. Default no-op for implementations that don't support proactive close.