io.r2dbc.proxy.test

Class MockConnectionInfo

java.lang.Object

io.r2dbc.proxy.test.MockConnectionInfo

All Implemented Interfaces:

ConnectionInfo

public final class MockConnectionInfo
extends Object
implements ConnectionInfo

Mock implementation of ConnectionInfo for testing.

Author:

Tadaya Tsuyukubo

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MockConnectionInfo.Builder

Method Summary

Modifier and Type	Method and Description
static MockConnectionInfo.Builder	builder() Provides a builder for MockConnectionInfo.
static MockConnectionInfo	empty() Provide an empty MockConnectionInfo.
int	getCommitCount() Returns how many times Connection.commitTransaction() method is called.
String	getConnectionId() Get ID for the connection.
io.r2dbc.spi.Connection	getOriginalConnection() Retrieve original Connection.
int	getRollbackCount() Returns how many times Connection.rollbackTransaction() method is called.
int	getTransactionCount() Returns how many times Connection.beginTransaction() method is called.
ValueStore	getValueStore() Retrieve ValueStore which is associated to the scope of logical connection.
void	incrementCommitCount() Increment commit count.
void	incrementRollbackCount() Increment rollback count.
void	incrementTransactionCount() Increment transaction count.
boolean	isClosed() Returns whether connection is closed or not.
void	setClosed(boolean closed) Set boolean to indicate whether the connection is closed 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 MockConnectionInfo.Builder builder()

Provides a builder for MockConnectionInfo.

Returns:

builder

empty

public static MockConnectionInfo empty()

Provide an empty MockConnectionInfo.

Returns:

a MockConnectionInfo.

getOriginalConnection

public io.r2dbc.spi.Connection getOriginalConnection()

Description copied from interface: ConnectionInfo

Retrieve original Connection.

Specified by:

getOriginalConnection in interface ConnectionInfo

Returns:

connection

getConnectionId

public String getConnectionId()

Description copied from interface: ConnectionInfo

Get ID for the connection.

Specified by:

getConnectionId in interface ConnectionInfo

Returns:

connection ID

See Also:

ConnectionIdManager

incrementTransactionCount

public void incrementTransactionCount()

Description copied from interface: ConnectionInfo

Increment transaction count.

Specified by:

incrementTransactionCount in interface ConnectionInfo

incrementCommitCount

public void incrementCommitCount()

Description copied from interface: ConnectionInfo

Increment commit count.

Specified by:

incrementCommitCount in interface ConnectionInfo

incrementRollbackCount

public void incrementRollbackCount()

Description copied from interface: ConnectionInfo

Increment rollback count.

Specified by:

incrementRollbackCount in interface ConnectionInfo

getTransactionCount

public int getTransactionCount()

Description copied from interface: ConnectionInfo

Returns how many times Connection.beginTransaction() method is called.

Specified by:

getTransactionCount in interface ConnectionInfo

Returns:

num of beginTransaction() method being called

getCommitCount

public int getCommitCount()

Description copied from interface: ConnectionInfo

Returns how many times Connection.commitTransaction() method is called.

Specified by:

getCommitCount in interface ConnectionInfo

Returns:

num of commitTransaction method being called

getRollbackCount

public int getRollbackCount()

Description copied from interface: ConnectionInfo

Returns how many times Connection.rollbackTransaction() method is called.

Specified by:

getRollbackCount in interface ConnectionInfo

Returns:

num of rollback methods being called

isClosed

public boolean isClosed()

Description copied from interface: ConnectionInfo

Returns whether connection is closed or not.

Specified by:

isClosed in interface ConnectionInfo

Returns:

true if connection is closed

setClosed

public void setClosed(boolean closed)

Description copied from interface: ConnectionInfo

Set boolean to indicate whether the connection is closed or not.

Specified by:

setClosed in interface ConnectionInfo

Parameters:

closed - set true if Connection is closed

getValueStore

public ValueStore getValueStore()

Description copied from interface: ConnectionInfo

Retrieve ValueStore which is associated to the scope of logical connection.

Values can be stored or retrieved from this store while connection is available.

Specified by:

getValueStore in interface ConnectionInfo

Returns:

value store