Class ProxyConnectionFactory.Builder

java.lang.Object

io.r2dbc.proxy.ProxyConnectionFactory.Builder

Enclosing class:

ProxyConnectionFactory

public static final class ProxyConnectionFactory.Builder
extends Object

Builder to create a proxy ConnectionFactory. The returned ConnectionFactory is a proxy. Registered listeners and configuration will be used throughout the operations of the proxy. This class is not threadsafe.

Author:

Tadaya Tsuyukubo

Method Summary

Modifier and Type	Method	Description
ConnectionFactory	build()	Builds a proxy ConnectionFactory.
ConnectionFactory	getConnectionFactory()	Return the ConnectionFactory passed at creation.
ProxyConfig	getProxyConfig()	Return the ProxyConfig.
ProxyConnectionFactory.Builder	listener(ProxyExecutionListener listener)	Registers a ProxyExecutionListener.
ProxyConnectionFactory.Builder	onAfterMethod(Consumer<MethodExecutionInfo> consumer)	Registers a callback consumer for after-method execution.
ProxyConnectionFactory.Builder	onAfterQuery(Consumer<QueryExecutionInfo> consumer)	Registers a callback consumer for after-query execution.
ProxyConnectionFactory.Builder	onBeforeMethod(Consumer<MethodExecutionInfo> consumer)	Registers a callback consumer for before-method execution
ProxyConnectionFactory.Builder	onBeforeQuery(Consumer<QueryExecutionInfo> consumer)	Registers a callback consumer for before-query execution.
ProxyConnectionFactory.Builder	onEachQueryResult(Consumer<QueryExecutionInfo> consumer)	Registers a callback consumer for processing each query result.
ProxyConnectionFactory.Builder	proxyConfig(ProxyConfig proxyConfig)	Sets the ProxyConfig to use.

Methods inherited from class java.lang.Object

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

Method Details

build

public ConnectionFactory build()

Builds a proxy ConnectionFactory.

Returns:

a proxy ConnectionFactory

proxyConfig

public ProxyConnectionFactory.Builder proxyConfig(ProxyConfig proxyConfig)

Sets the ProxyConfig to use.

Parameters:

proxyConfig - proxy config

Returns:

builder

Throws:

IllegalArgumentException - if proxyConfig is null

onBeforeMethod

public ProxyConnectionFactory.Builder onBeforeMethod(Consumer<MethodExecutionInfo> consumer)

Registers a callback consumer for before-method execution

Parameters:

consumer - a consumer for before method execution

Returns:

builder

Throws:

IllegalArgumentException - if consumer is null

onAfterMethod

public ProxyConnectionFactory.Builder onAfterMethod(Consumer<MethodExecutionInfo> consumer)

Registers a callback consumer for after-method execution.

Parameters:

consumer - a consumer for after method execution

Returns:

builder

Throws:

IllegalArgumentException - if consumer is null

onBeforeQuery

public ProxyConnectionFactory.Builder onBeforeQuery(Consumer<QueryExecutionInfo> consumer)

Registers a callback consumer for before-query execution.

Parameters:

consumer - a consumer for before query execution

Returns:

builder

Throws:

IllegalArgumentException - if consumer is null

onAfterQuery

public ProxyConnectionFactory.Builder onAfterQuery(Consumer<QueryExecutionInfo> consumer)

Registers a callback consumer for after-query execution.

Parameters:

consumer - a consumer for after query execution

Returns:

builder

Throws:

IllegalArgumentException - if consumer is null

onEachQueryResult

public ProxyConnectionFactory.Builder onEachQueryResult(Consumer<QueryExecutionInfo> consumer)

Registers a callback consumer for processing each query result.

Parameters:

consumer - a consumer for each query result

Returns:

builder

Throws:

IllegalArgumentException - if consumer is null

listener

public ProxyConnectionFactory.Builder listener(ProxyExecutionListener listener)

Registers a ProxyExecutionListener.

Parameters:

listener - a listener to register

Returns:

builder

Throws:

IllegalArgumentException - if listener is null

getConnectionFactory

public ConnectionFactory getConnectionFactory()

Return the ConnectionFactory passed at creation.

Returns:

the connection factory

Since:

1.1.5

getProxyConfig

public ProxyConfig getProxyConfig()

Return the ProxyConfig.

Returns:

the proxy config

Since:

1.1.5