io.r2dbc.proxy.test

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 and Description
static class	MockQueryExecutionInfo.Builder

Method Summary

Modifier and Type	Method and Description
static MockQueryExecutionInfo.Builder	builder() Provides a builder for MockQueryExecutionInfo.
static MockQueryExecutionInfo	empty() Provide an empty MockMethodExecutionInfo.
int	getBatchSize() Get the size of the batch query.
int	getBindingsSize() Get the number of the binding.
ConnectionInfo	getConnectionInfo() Get the associated ConnectionInfo.
Object	getCurrentMappedResult() Mapped query result available for each-query-result-callback(ProxyExecutionListener.eachQueryResult(QueryExecutionInfo)).
int	getCurrentResultCount() Represent Nth Result.
Duration	getExecuteDuration() Get the time that took queries to execute.
Method	getMethod() Get the invoked query execution Method.
Object[]	getMethodArgs() Get the arguments of the invocation.
ProxyEventType	getProxyEventType() Get the proxy event type for query execution.
List<QueryInfo>	getQueries() Get the list of QueryInfo.
long	getThreadId() Get the currently executed thread ID.
String	getThreadName() Get the currently executed thread name.
Throwable	getThrowable() Get the thrown exception.
ExecutionType	getType() Get the type of query execution.
ValueStore	getValueStore() Retrieve ValueStore which is associated to the scope of before/after method execution.
boolean	isSuccess() Indicate whether the query execution was successful or not.

Methods inherited from class java.lang.Object

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

Method Detail

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

Get the invoked query execution Method.

Specified by:

getMethod in interface QueryExecutionInfo

Returns:

invoked method

getMethodArgs

public Object[] getMethodArgs()

Description copied from interface: QueryExecutionInfo

Get the arguments of the invocation. This can be null when method is invoked with no argument.

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

Get the thrown exception. For ProxyExecutionListener.beforeQuery(QueryExecutionInfo) callback or query execution did't throw any error, this returns null.

Specified by:

getThrowable in interface QueryExecutionInfo

Returns:

thrown exception

getConnectionInfo

public ConnectionInfo getConnectionInfo()

Description copied from interface: QueryExecutionInfo

Get the associated ConnectionInfo.

Specified by:

getConnectionInfo in interface QueryExecutionInfo

Returns:

connection info

isSuccess

public boolean isSuccess()

Description copied from interface: QueryExecutionInfo

Indicate whether the query execution was successful or not. Contains valid value only after the query execution. 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

Get the size of the batch query. i.e. Number of the calls of Batch.add(String).

Specified by:

getBatchSize in interface QueryExecutionInfo

Returns:

batch size

getQueries

public List<QueryInfo> getQueries()

Description copied from interface: QueryExecutionInfo

Get the list of QueryInfo.

Specified by:

getQueries in interface QueryExecutionInfo

Returns:

list of queries. This will NOT return null.

getType

public ExecutionType getType()

Description copied from interface: QueryExecutionInfo

Get 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

Get the number of the binding. i.e. Number of the calls of Statement.add().

Specified by:

getBindingsSize in interface QueryExecutionInfo

Returns:

size of the binding

getExecuteDuration

public Duration getExecuteDuration()

Description copied from interface: QueryExecutionInfo

Get the time that took queries to execute.

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

Get the currently executed thread name.

Specified by:

getThreadName in interface QueryExecutionInfo

Returns:

thread name

getThreadId

public long getThreadId()

Description copied from interface: QueryExecutionInfo

Get the currently executed thread ID.

Specified by:

getThreadId in interface QueryExecutionInfo

Returns:

thread ID

getProxyEventType

public ProxyEventType getProxyEventType()

Description copied from interface: QueryExecutionInfo

Get the proxy event type for 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

Represent Nth Result. On each query result callback(ProxyExecutionListener.eachQueryResult(QueryExecutionInfo)), this value indicates Nth Result starting from 1. (1st query result, 2nd query result, 3rd, 4th,...). This returns 0 for before query execution(ProxyExecutionListener.beforeQuery(QueryExecutionInfo)). For after query execution(ProxyExecutionListener.afterQuery(QueryExecutionInfo)), this returns total number of Result 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

Mapped query result available for each-query-result-callback(ProxyExecutionListener.eachQueryResult(QueryExecutionInfo)). For before and after query execution(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

Retrieve ValueStore which is associated to the scope of before/after method execution. Mainly used for passing values between ProxyExecutionListener.beforeQuery(QueryExecutionInfo) and ProxyExecutionListener.afterQuery(QueryExecutionInfo).

Specified by:

getValueStore in interface QueryExecutionInfo

Returns:

value store