org.springframework.r2dbc.connection

Class DelegatingConnectionFactory

java.lang.Object

org.springframework.r2dbc.connection.DelegatingConnectionFactory

All Implemented Interfaces:

ConnectionFactory, Wrapped<ConnectionFactory>

Direct Known Subclasses:

SingleConnectionFactory, TransactionAwareConnectionFactoryProxy

public class DelegatingConnectionFactory
extends Object
implements ConnectionFactory, Wrapped<ConnectionFactory>

R2DBC ConnectionFactory implementation that delegates all calls to a given target ConnectionFactory.

This class is meant to be subclassed, with subclasses overriding only those methods (such as create()) that should not simply delegate to the target ConnectionFactory.

Since:

5.3

Author:

Mark Paluch

See Also:

create()

Constructor Summary

Constructors

Constructor and Description
DelegatingConnectionFactory(ConnectionFactory targetConnectionFactory) Create a new DelegatingConnectionFactory.

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Mono<? extends Connection>	create()
ConnectionFactoryMetadata	getMetadata()
ConnectionFactory	getTargetConnectionFactory() Return the target ConnectionFactory that this ConnectionFactory delegates to.
ConnectionFactory	unwrap()

Methods inherited from class java.lang.Object

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

Constructor Detail

DelegatingConnectionFactory

public DelegatingConnectionFactory(ConnectionFactory targetConnectionFactory)

Create a new DelegatingConnectionFactory.

Parameters:

targetConnectionFactory - the target ConnectionFactory

Method Detail

getTargetConnectionFactory

public ConnectionFactory getTargetConnectionFactory()

Return the target ConnectionFactory that this ConnectionFactory delegates to.

create

public reactor.core.publisher.Mono<? extends Connection> create()

Specified by:

create in interface ConnectionFactory

getMetadata

public ConnectionFactoryMetadata getMetadata()

Specified by:

getMetadata in interface ConnectionFactory

unwrap

public ConnectionFactory unwrap()

Specified by:

unwrap in interface Wrapped<ConnectionFactory>