Package com.firebolt.jdbc.client.query

Class StatementClientImpl

java.lang.Object

com.firebolt.jdbc.client.FireboltClient

com.firebolt.jdbc.client.query.StatementClientImpl

All Implemented Interfaces:

StatementClient, CacheListener, EventListener

public class StatementClientImpl
extends FireboltClient
implements StatementClient

Field Summary

Fields inherited from class com.firebolt.jdbc.client.FireboltClient

connection

Constructor Summary

Constructors

Constructor	Description
StatementClientImpl(okhttp3.OkHttpClient httpClient, FireboltConnection connection, String customDrivers, String customClients)

Method Summary

Modifier and Type	Method	Description
void	abortStatement(@NonNull String statementLabel, @NonNull FireboltProperties properties)	Call endpoint to abort a running SQL statement
InputStream	executeSqlStatement(@NonNull StatementInfoWrapper statementInfoWrapper, @NonNull FireboltProperties connectionProperties, boolean systemEngine, int queryTimeout)	Sends SQL statement to Firebolt Retries to send the statement if the first execution is unauthorized
boolean	isStatementRunning(String statementId)
protected void	validateResponse(String host, int statusCode, String errorMessageFromServer)
protected void	validateResponse(String host, okhttp3.Response response, Boolean isCompress)

Methods inherited from class com.firebolt.jdbc.client.FireboltClient

cleanup, createPostRequest, createPostRequest, execute, execute, getResource, getResource, getResponseAsString, isCallSuccessful, jsonToObject

Methods inherited from class java.lang.Object

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

Constructor Details

StatementClientImpl

public StatementClientImpl(okhttp3.OkHttpClient httpClient,
 FireboltConnection connection,
 String customDrivers,
 String customClients)

Method Details

executeSqlStatement

public InputStream executeSqlStatement(@NonNull
 @NonNull StatementInfoWrapper statementInfoWrapper,
 @NonNull
 @NonNull FireboltProperties connectionProperties,
 boolean systemEngine,
 int queryTimeout)
                                throws SQLException

Sends SQL statement to Firebolt Retries to send the statement if the first execution is unauthorized

Specified by:

executeSqlStatement in interface StatementClient

Parameters:

statementInfoWrapper - the statement wrapper

connectionProperties - the connection properties

systemEngine - indicates if system engine is used

queryTimeout - query timeout

Returns:

the server response

Throws:

SQLException

abortStatement

public void abortStatement(@NonNull
 @NonNull String statementLabel,
 @NonNull
 @NonNull FireboltProperties properties)
                    throws SQLException

Description copied from interface: StatementClient

Call endpoint to abort a running SQL statement

Specified by:

abortStatement in interface StatementClient

Throws:

SQLException

isStatementRunning

public boolean isStatementRunning(String statementId)

Specified by:

isStatementRunning in interface StatementClient

validateResponse

protected void validateResponse(String host,
 okhttp3.Response response,
 Boolean isCompress)
                         throws SQLException

Overrides:

validateResponse in class FireboltClient

Throws:

SQLException

validateResponse

protected void validateResponse(String host,
 int statusCode,
 String errorMessageFromServer)
                         throws SQLException

Overrides:

validateResponse in class FireboltClient

Throws:

SQLException