Class MockQueryExecutionInfo

java.lang.Object

io.r2dbc.proxy.test.MockQueryExecutionInfo

All Implemented Interfaces:

QueryExecutionInfo

public final class MockQueryExecutionInfo
extends Object
implements QueryExecutionInfo

Mock implementation of QueryExecutionInfo for testing.

Author:

Tadaya Tsuyukubo

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	MockQueryExecutionInfo.Builder

Method Summary

Modifier and Type	Method	Description
static MockQueryExecutionInfo.Builder	builder()	Provides a builder for MockQueryExecutionInfo.
static MockQueryExecutionInfo	empty()	Provide an empty MockMethodExecutionInfo.
int	getBatchSize()	Returns the size of the batch query.
int	getBindingsSize()	Returns the number of bindings.
ConnectionInfo	getConnectionInfo()	Returns the associated ConnectionInfo.
Object	getCurrentMappedResult()	The mapped query result available for each query-result callback (ProxyExecutionListener.eachQueryResult(QueryExecutionInfo)).
int	getCurrentResultCount()	Represents the Nth Result.
Duration	getExecuteDuration()	Returns the time spent executing the query.
Method	getMethod()	Returns the method used for the query execution.
Object[]	getMethodArgs()	Returns the arguments passed to the invocation.
ProxyEventType	getProxyEventType()	Returns the proxy event type for the query execution.
List<QueryInfo>	getQueries()	Returns the list of QueryInfo.
long	getThreadId()	Returns the ID of the thread executing the query.
String	getThreadName()	Returns the name of the thread executing the query.
Throwable	getThrowable()	Returns the exception thrown by the invocation.
ExecutionType	getType()	Returns the type of query execution.
ValueStore	getValueStore()	Returns the ValueStore associated with the scope of the before/after query execution.
boolean	isSuccess()	Returns whether the query execution was successful.

Methods inherited from class java.lang.Object

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

Method Details

builder

public static MockQueryExecutionInfo.Builder builder()

Provides a builder for MockQueryExecutionInfo.

Returns:

builder

empty

public static MockQueryExecutionInfo empty()

Provide an empty MockMethodExecutionInfo.

Returns:

a MockMethodExecutionInfo.

getMethod

public Method getMethod()

Description copied from interface: QueryExecutionInfo

Returns the method used for the query execution.

Specified by:

getMethod in interface QueryExecutionInfo

Returns:

invoked method

getMethodArgs

public Object[] getMethodArgs()

Description copied from interface: QueryExecutionInfo

Returns the arguments passed to the invocation. This value may be null when the method is invoked without any arguments.

Specified by:

getMethodArgs in interface QueryExecutionInfo

Returns:

argument lists or null if the invoked method did not take any arguments

getThrowable

public Throwable getThrowable()

Description copied from interface: QueryExecutionInfo

Returns the exception thrown by the invocation. For the ProxyExecutionListener.beforeQuery(QueryExecutionInfo) callback, or when the query execution did not throw any error, this returns null.

Specified by:

getThrowable in interface QueryExecutionInfo

Returns:

thrown exception

getConnectionInfo

public ConnectionInfo getConnectionInfo()

Description copied from interface: QueryExecutionInfo

Returns the associated ConnectionInfo.

Specified by:

getConnectionInfo in interface QueryExecutionInfo

Returns:

connection info

isSuccess

public boolean isSuccess()

Description copied from interface: QueryExecutionInfo

Returns whether the query execution was successful. This value is populated only after the query execution completes. A query execution is considered successful when the Publisher returned from Statement.execute() either received completion or at least one element is emitted regardless of it has received cancellation.

Specified by:

isSuccess in interface QueryExecutionInfo

Returns:

true when query has successfully executed

getBatchSize

public int getBatchSize()

Description copied from interface: QueryExecutionInfo

Returns the size of the batch query. In other words, this is the number of calls to Batch.add(String).

Specified by:

getBatchSize in interface QueryExecutionInfo

Returns:

batch size

getQueries

public List<QueryInfo> getQueries()

Description copied from interface: QueryExecutionInfo

Returns the list of QueryInfo.

Specified by:

getQueries in interface QueryExecutionInfo

Returns:

the list of queries; never null

getType

public ExecutionType getType()

Description copied from interface: QueryExecutionInfo

Returns the type of query execution.

Specified by:

getType in interface QueryExecutionInfo

Returns:

type of query execution

getBindingsSize

public int getBindingsSize()

Description copied from interface: QueryExecutionInfo

Returns the number of bindings. In other words, this is the number of calls to Statement.add().

Specified by:

getBindingsSize in interface QueryExecutionInfo

Returns:

size of the binding

getExecuteDuration

public Duration getExecuteDuration()

Description copied from interface: QueryExecutionInfo

Returns the time spent executing the query.

Duration is only populated in appropriate phase. (e.g.: ProxyExecutionListener.afterQuery(QueryExecutionInfo))

Specified by:

getExecuteDuration in interface QueryExecutionInfo

Returns:

query execution duration

getThreadName

public String getThreadName()

Description copied from interface: QueryExecutionInfo

Returns the name of the thread executing the query.

Specified by:

getThreadName in interface QueryExecutionInfo

Returns:

thread name

getThreadId

public long getThreadId()

Description copied from interface: QueryExecutionInfo

Returns the ID of the thread executing the query.

Specified by:

getThreadId in interface QueryExecutionInfo

Returns:

thread ID

getProxyEventType

public ProxyEventType getProxyEventType()

Description copied from interface: QueryExecutionInfo

Returns the proxy event type for the query execution.

Specified by:

getProxyEventType in interface QueryExecutionInfo

Returns:

proxy event type; one of ProxyEventType.BEFORE_QUERY, ProxyEventType.AFTER_QUERY, or ProxyEventType.EACH_QUERY_RESULT

getCurrentResultCount

public int getCurrentResultCount()

Description copied from interface: QueryExecutionInfo

Represents the Nth Result. For each query-result callback (ProxyExecutionListener.eachQueryResult(QueryExecutionInfo)), this value indicates the Nth Result, starting from 1 (first, second, third, and so on). This returns 0 before query execution (ProxyExecutionListener.beforeQuery(QueryExecutionInfo)). For after-query execution (ProxyExecutionListener.afterQuery(QueryExecutionInfo)), it returns the total number of Result objects returned by this query execution.

Specified by:

getCurrentResultCount in interface QueryExecutionInfo

Returns:

Nth number of query result

getCurrentMappedResult

public Object getCurrentMappedResult()

Description copied from interface: QueryExecutionInfo

The mapped query result available for each query-result callback (ProxyExecutionListener.eachQueryResult(QueryExecutionInfo)). For the before- and after-query execution callbacks (ProxyExecutionListener.beforeQuery(QueryExecutionInfo) and ProxyExecutionListener.afterQuery(QueryExecutionInfo)), this returns null.

Specified by:

getCurrentMappedResult in interface QueryExecutionInfo

Returns:

currently mapped result

getValueStore

public ValueStore getValueStore()

Description copied from interface: QueryExecutionInfo

Returns the ValueStore associated with the scope of the before/after query execution. Mainly used for passing values between ProxyExecutionListener.beforeQuery(QueryExecutionInfo) and ProxyExecutionListener.afterQuery(QueryExecutionInfo).

Specified by:

getValueStore in interface QueryExecutionInfo

Returns:

value store