com.amazon.redshift.jdbc

Class RedshiftStatementImpl.StatementResultHandler

java.lang.Object

com.amazon.redshift.core.ResultHandlerBase

com.amazon.redshift.jdbc.RedshiftStatementImpl.StatementResultHandler

All Implemented Interfaces:

ResultHandler

Enclosing class:

RedshiftStatementImpl

public class RedshiftStatementImpl.StatementResultHandler
extends ResultHandlerBase

ResultHandler implementations for updates, queries, and either-or.

Constructor Summary

Constructors

Constructor and Description
StatementResultHandler(Statement stmt)

Method Summary

Modifier and Type	Method and Description
void	handleCommandStatus(String status, long updateCount, long insertOID) Called when a query that did not return a resultset completes.
void	handleResultRows(Query fromQuery, Field[] fields, List<Tuple> tuples, ResultCursor cursor, RedshiftRowsBlockingQueue<Tuple> queueTuples, int[] rowCount, Thread ringBufferThread) Called when result rows are received from a query.
void	handleWarning(SQLWarning warning) Called when a warning is emitted.
void	setStatementStateIdleFromInQuery() Set statement state on completion of the Ring buffer thread.
void	setStatementStateInQueryFromIdle() Set statement state on start from IDLE to IN_QUERY, in case Ring Buffer thread reset the new query state as IDLE.
boolean	setStatementStateInQuerySuspendedFromInQuery() Set statement state from IN_QUERY to IN_QUERY_SUSPENDED, to indicate that driver received a portal suspended state
boolean	wantsScrollableResultSet() Check the statement type

Methods inherited from class com.amazon.redshift.core.ResultHandlerBase

getException, getWarning, handleCompletion, handleError, secureProgress

Methods inherited from class java.lang.Object

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

Constructor Detail

StatementResultHandler

public StatementResultHandler(Statement stmt)

Method Detail

setStatementStateIdleFromInQuery

public void setStatementStateIdleFromInQuery()

Description copied from interface: ResultHandler

Set statement state on completion of the Ring buffer thread.

Specified by:

setStatementStateIdleFromInQuery in interface ResultHandler

Overrides:

setStatementStateIdleFromInQuery in class ResultHandlerBase

setStatementStateInQueryFromIdle

public void setStatementStateInQueryFromIdle()

Description copied from interface: ResultHandler

Set statement state on start from IDLE to IN_QUERY, in case Ring Buffer thread reset the new query state as IDLE.

Specified by:

setStatementStateInQueryFromIdle in interface ResultHandler

Overrides:

setStatementStateInQueryFromIdle in class ResultHandlerBase

setStatementStateInQuerySuspendedFromInQuery

public boolean setStatementStateInQuerySuspendedFromInQuery()

Description copied from interface: ResultHandler

Set statement state from IN_QUERY to IN_QUERY_SUSPENDED, to indicate that driver received a portal suspended state

Specified by:

setStatementStateInQuerySuspendedFromInQuery in interface ResultHandler

Overrides:

setStatementStateInQuerySuspendedFromInQuery in class ResultHandlerBase

wantsScrollableResultSet

public boolean wantsScrollableResultSet()

Description copied from interface: ResultHandler

Check the statement type

Specified by:

wantsScrollableResultSet in interface ResultHandler

Overrides:

wantsScrollableResultSet in class ResultHandlerBase

Returns:

true if scrollable, false for forward only.

handleResultRows

public void handleResultRows(Query fromQuery,
                             Field[] fields,
                             List<Tuple> tuples,
                             ResultCursor cursor,
                             RedshiftRowsBlockingQueue<Tuple> queueTuples,
                             int[] rowCount,
                             Thread ringBufferThread)

Description copied from interface: ResultHandler

Called when result rows are received from a query.

Specified by:

handleResultRows in interface ResultHandler

Overrides:

handleResultRows in class ResultHandlerBase

Parameters:

fromQuery - the underlying query that generated these results; this may not be very specific (e.g. it may be a query that includes multiple statements).

fields - column metadata for the resultset; might be null if Query.QUERY_NO_METADATA was specified.

tuples - the actual data. If this is set then queueTuples will be null.

cursor - a cursor to use to fetch additional data; null if no further results are present.

queueTuples - the actual data in a blocking queue. If this is set then tuples will be null.

rowCount - number of rows fetched from the socket.

ringBufferThread - a thread to fetch rows in the limited rows buffer.

handleCommandStatus

public void handleCommandStatus(String status,
                                long updateCount,
                                long insertOID)

Description copied from interface: ResultHandler

Called when a query that did not return a resultset completes.

Specified by:

handleCommandStatus in interface ResultHandler

Overrides:

handleCommandStatus in class ResultHandlerBase

Parameters:

status - the command status string (e.g. "SELECT") returned by the backend

updateCount - the number of rows affected by an INSERT, UPDATE, DELETE, FETCH, or MOVE command; -1 if not available.

insertOID - for a single-row INSERT query, the OID of the newly inserted row; 0 if not available.

handleWarning

public void handleWarning(SQLWarning warning)

Description copied from interface: ResultHandler

Called when a warning is emitted.

Specified by:

handleWarning in interface ResultHandler

Overrides:

handleWarning in class ResultHandlerBase

Parameters:

warning - the warning that occurred.