Package org.springframework.data.r2dbc.config

Class AbstractR2dbcConfiguration

java.lang.Object

org.springframework.data.r2dbc.config.AbstractR2dbcConfiguration

All Implemented Interfaces:

Aware, ApplicationContextAware

@Configuration(proxyBeanMethods=false)
public abstract class AbstractR2dbcConfiguration
extends Object
implements ApplicationContextAware

Base class for Spring Data R2DBC configuration containing bean declarations that must be registered for Spring Data R2DBC to work.

Author:

Mark Paluch

See Also:

• ConnectionFactory
• DatabaseClient
• EnableR2dbcRepositories

Constructor Summary

Constructors

Constructor	Description
AbstractR2dbcConfiguration()

Method Summary

Modifier and Type	Method	Description
abstract io.r2dbc.spi.ConnectionFactory	connectionFactory()	Return a R2DBC ConnectionFactory.
DatabaseClient	databaseClient()	Register a DatabaseClient using connectionFactory() and ReactiveDataAccessStrategy.
protected List<Object>	getCustomConverters()	Customization hook to return custom converters.
R2dbcDialect	getDialect(io.r2dbc.spi.ConnectionFactory connectionFactory)	Return a R2dbcDialect for the given ConnectionFactory.
protected CustomConversions.StoreConversions	getStoreConversions()	Returns the R2dbcDialect-specific CustomConversions.StoreConversions.
MappingR2dbcConverter	r2dbcConverter(R2dbcMappingContext mappingContext, R2dbcCustomConversions r2dbcCustomConversions)	Creates a R2dbcConverter using the configured r2dbcMappingContext(Optional, R2dbcCustomConversions) R2dbcMappingContext}.
R2dbcCustomConversions	r2dbcCustomConversions()	Register custom Converters in a CustomConversions object if required.
R2dbcEntityTemplate	r2dbcEntityTemplate(DatabaseClient databaseClient, ReactiveDataAccessStrategy dataAccessStrategy)	Register R2dbcEntityTemplate using databaseClient() and connectionFactory().
R2dbcMappingContext	r2dbcMappingContext(Optional<NamingStrategy> namingStrategy, R2dbcCustomConversions r2dbcCustomConversions)	Register a R2dbcMappingContext and apply an optional NamingStrategy.
ReactiveDataAccessStrategy	reactiveDataAccessStrategy(R2dbcConverter converter)	Creates a ReactiveDataAccessStrategy using the configured R2dbcConverter.
void	setApplicationContext(ApplicationContext applicationContext)

Methods inherited from class java.lang.Object

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

Constructor Details

AbstractR2dbcConfiguration

public AbstractR2dbcConfiguration()

Method Details

setApplicationContext

public void setApplicationContext(ApplicationContext applicationContext)
                           throws BeansException

Specified by:

setApplicationContext in interface ApplicationContextAware

Throws:

BeansException

connectionFactory

public abstract io.r2dbc.spi.ConnectionFactory connectionFactory()

Return a R2DBC ConnectionFactory. Annotate with Bean in case you want to expose a ConnectionFactory instance to the ApplicationContext.

Returns:

the configured ConnectionFactory.

getDialect

public R2dbcDialect getDialect(io.r2dbc.spi.ConnectionFactory connectionFactory)

Return a R2dbcDialect for the given ConnectionFactory. This method attempts to resolve a R2dbcDialect from ConnectionFactoryMetadata. Override this method to specify a dialect instead of attempting to resolve one.

Parameters:

connectionFactory - the configured ConnectionFactory.

Returns:

the resolved R2dbcDialect.

Throws:

DialectResolver.NoDialectException - if the R2dbcDialect cannot be determined.

databaseClient

@Bean({"r2dbcDatabaseClient","databaseClient"})
public DatabaseClient databaseClient()

Register a DatabaseClient using connectionFactory() and ReactiveDataAccessStrategy.

Returns:

must not be null.

Throws:

IllegalArgumentException - if any of the required args is null.

r2dbcEntityTemplate

@Bean
public R2dbcEntityTemplate r2dbcEntityTemplate(DatabaseClient databaseClient,
 ReactiveDataAccessStrategy dataAccessStrategy)

Register R2dbcEntityTemplate using databaseClient() and connectionFactory().

Parameters:

databaseClient - must not be null.

dataAccessStrategy - must not be null.

Returns:

Since:

1.2

r2dbcMappingContext

@Bean
public R2dbcMappingContext r2dbcMappingContext(Optional<NamingStrategy> namingStrategy,
 R2dbcCustomConversions r2dbcCustomConversions)

Register a R2dbcMappingContext and apply an optional NamingStrategy.

Parameters:

namingStrategy - optional NamingStrategy. Use NamingStrategy.INSTANCE as fallback.

r2dbcCustomConversions - customized R2DBC conversions.

Returns:

must not be null.

Throws:

IllegalArgumentException - if any of the required args is null.

reactiveDataAccessStrategy

@Bean
public ReactiveDataAccessStrategy reactiveDataAccessStrategy(R2dbcConverter converter)

Creates a ReactiveDataAccessStrategy using the configured R2dbcConverter.

Parameters:

converter - the configured R2dbcConverter.

Returns:

must not be null.

Throws:

IllegalArgumentException - if any of the mappingContext is null.

See Also:

• r2dbcConverter(R2dbcMappingContext, R2dbcCustomConversions)
• getDialect(ConnectionFactory)

r2dbcConverter

@Bean
public MappingR2dbcConverter r2dbcConverter(R2dbcMappingContext mappingContext,
 R2dbcCustomConversions r2dbcCustomConversions)

Creates a R2dbcConverter using the configured r2dbcMappingContext(Optional, R2dbcCustomConversions) R2dbcMappingContext}.

Parameters:

mappingContext - the configured R2dbcMappingContext.

r2dbcCustomConversions - customized R2DBC conversions.

Returns:

must not be null.

Throws:

IllegalArgumentException - if any of the mappingContext is null.

Since:

1.2

See Also:

• r2dbcMappingContext(Optional, R2dbcCustomConversions)
• getDialect(ConnectionFactory)

r2dbcCustomConversions

@Bean
public R2dbcCustomConversions r2dbcCustomConversions()

Register custom Converters in a CustomConversions object if required. These CustomConversions will be registered with the BasicRelationalConverter and r2dbcMappingContext(Optional, R2dbcCustomConversions). Returns an empty R2dbcCustomConversions instance by default. Override getCustomConverters() to supply custom converters.

Returns:

must not be null.

See Also:

• getCustomConverters()

getCustomConverters

protected List<Object> getCustomConverters()

Customization hook to return custom converters.

Returns:

return custom converters.

getStoreConversions

protected CustomConversions.StoreConversions getStoreConversions()

Returns the R2dbcDialect-specific CustomConversions.StoreConversions.

Returns:

the R2dbcDialect-specific CustomConversions.StoreConversions.