io.r2dbc.proxy.callback

Class QueriesExecutionContext

java.lang.Object

io.r2dbc.proxy.callback.QueriesExecutionContext

public class QueriesExecutionContext
extends Object

The context of queries execution.

Holds the count of Result produced by Statement#execute and count that has consumed Result#[map|getRowsUpdated].

Author:

Thomas Deblock, Tadaya Tsuyukubo

Constructor Summary

Constructors

Constructor and Description
QueriesExecutionContext(Clock clock)

Method Summary

Modifier and Type	Method and Description
Duration	getElapsedDuration() Retrieve the elapsed time from the stopwatch that has started by startStopwatch().
void	incrementConsumedCount() Increment the count of consumptions from Result#[map|getRowsUpdated].
void	incrementProducedCount() Increment the count of produced Result from Statement#execute.
boolean	isAllConsumed() Whether currently all produced Results are consumed.
boolean	isQueryFinished() Whether the executed queries have finished and results are consumed.
void	markAllProduced() When QueryInvocationSubscriber produced all Result objects.
void	startStopwatch() Start the stopwatch.

Methods inherited from class java.lang.Object

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

Constructor Detail

QueriesExecutionContext

public QueriesExecutionContext(Clock clock)

Method Detail

incrementProducedCount

public void incrementProducedCount()

Increment the count of produced Result from Statement#execute.

incrementConsumedCount

public void incrementConsumedCount()

Increment the count of consumptions from Result#[map|getRowsUpdated].

getElapsedDuration

public Duration getElapsedDuration()

Retrieve the elapsed time from the stopwatch that has started by startStopwatch().

Returns:

duration from start

startStopwatch

public void startStopwatch()

Start the stopwatch.

isQueryFinished

public boolean isQueryFinished()

Whether the executed queries have finished and results are consumed.

The query is considered finished when the publisher from Statement#execute() have produced Results and those are consumed via Result#getRowsUpdated or Result#map.

Returns:

true if all Result are produced and consumed.

isAllConsumed

public boolean isAllConsumed()

Whether currently all produced Results are consumed.

Returns:

true if all produced Results are consumed.

markAllProduced

public void markAllProduced()

When QueryInvocationSubscriber produced all Result objects.