Class AbstractSessionConfiguration

java.lang.Object

org.springframework.data.cassandra.config.AbstractSessionConfiguration

All Implemented Interfaces:

Aware, BeanFactoryAware

Direct Known Subclasses:

AbstractCassandraConfiguration

@Configuration
public abstract class AbstractSessionConfiguration
extends Object
implements BeanFactoryAware

Spring Configuration class used to configure a Cassandra client application CqlSession connected to a Cassandra cluster. Enables a Cassandra Keyspace to be specified along with the ability to execute arbitrary CQL on startup as well as shutdown.

Author:

Matthew T. Adams, John Blum, Mark Paluch

See Also:

• BeanFactoryAware
• Configuration

Constructor Summary

Constructors

Constructor	Description
AbstractSessionConfiguration()

Method Summary

Modifier and Type	Method	Description
CqlSessionFactoryBean	cassandraSession()	Creates a CqlSessionFactoryBean that provides a Cassandra CqlSession.
CqlTemplate	cqlTemplate()	Creates a CqlTemplate configured with getRequiredSessionFactory().
protected BeanFactory	getBeanFactory()	Returns the configured reference to the BeanFactory.
protected @Nullable CompressionType	getCompressionType()	Returns the CompressionType.
protected String	getContactPoints()	Returns the Cassandra contact points.
protected @Nullable DriverConfigLoaderBuilderConfigurer	getDriverConfigLoaderBuilderConfigurer()	Returns the DriverConfigLoaderBuilderConfigurer.
protected @Nullable Resource	getDriverConfigurationResource()	Returns the Resource pointing to a driver configuration file.
protected List<CreateKeyspaceSpecification>	getKeyspaceCreations()	Returns the list of keyspace creations to be run right after initialization.
protected List<DropKeyspaceSpecification>	getKeyspaceDrops()	Returns the list of keyspace drops to be run before shutdown.
protected abstract String	getKeyspaceName()	Return the name of the keyspace to connect to.
protected @Nullable String	getLocalDataCenter()	Returns the local data center name used for LoadBalancingPolicy, defaulting to datacenter1.
protected int	getPort()	Returns the Cassandra port.
protected com.datastax.oss.driver.api.core.CqlSession	getRequiredSession()	Returns the initialized CqlSession instance.
protected SessionFactory	getRequiredSessionFactory()	Returns the initialized CqlSession instance.
protected @Nullable SessionBuilderConfigurer	getSessionBuilderConfigurer()	Returns the SessionBuilderConfigurer.
protected @Nullable String	getSessionName()	Returns the session name.
protected <T> T	requireBeanOfType(Class<T> beanType)	Gets a required bean of the provided type from the BeanFactory.
void	setBeanFactory(BeanFactory beanFactory)	Configures a reference to the BeanFactory.

Methods inherited from class Object

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

Constructor Details

AbstractSessionConfiguration

public AbstractSessionConfiguration()

Method Details

setBeanFactory

public void setBeanFactory(BeanFactory beanFactory)
                    throws BeansException

Configures a reference to the BeanFactory.

Specified by:

setBeanFactory in interface BeanFactoryAware

Parameters:

beanFactory - reference to the BeanFactory.

Throws:

BeansException - if the BeanFactory could not be initialized.

See Also:

• BeanFactory

getBeanFactory

protected BeanFactory getBeanFactory()

Returns the configured reference to the BeanFactory.

Returns:

the configured reference to the BeanFactory.

Throws:

IllegalStateException - if the BeanFactory reference was not configured.

See Also:

• BeanFactory

requireBeanOfType

protected <T> T requireBeanOfType(Class<T> beanType)

Gets a required bean of the provided type from the BeanFactory.

Type Parameters:

T - parameterized class type of the bean.

Parameters:

beanType - type of the bean.

Returns:

a required bean of the given type from the BeanFactory.

See Also:

• BeanFactory.getBean(Class)
• getBeanFactory()

getKeyspaceName

protected abstract String getKeyspaceName()

Return the name of the keyspace to connect to.

Returns:

must not be null.

getLocalDataCenter

protected @Nullable String getLocalDataCenter()

Returns the local data center name used for LoadBalancingPolicy, defaulting to datacenter1. Typically required when connecting a Cassandra cluster. Not required when using an Astra connection bundle.

Returns:

the local data center name. Can be null when using an Astra connection bundle.

getSessionName

protected @Nullable String getSessionName()

Returns the session name.

Returns:

the session name; may be null.

Since:

3.0

getCompressionType

protected @Nullable CompressionType getCompressionType()

Returns the CompressionType.

Returns:

the CompressionType, may be null.

getContactPoints

protected String getContactPoints()

Returns the Cassandra contact points. Defaults to localhost

Returns:

the Cassandra contact points

See Also:

• CqlSessionFactoryBean.DEFAULT_CONTACT_POINTS

getPort

protected int getPort()

Returns the Cassandra port. Defaults to 9042.

Returns:

the Cassandra port

See Also:

• CqlSessionFactoryBean.DEFAULT_PORT

getKeyspaceCreations

protected List<CreateKeyspaceSpecification> getKeyspaceCreations()

Returns the list of keyspace creations to be run right after initialization.

Returns:

the list of keyspace creations, may be empty but never null.

getKeyspaceDrops

protected List<DropKeyspaceSpecification> getKeyspaceDrops()

Returns the list of keyspace drops to be run before shutdown.

Returns:

the list of keyspace drops, may be empty but never null.

getRequiredSession

protected com.datastax.oss.driver.api.core.CqlSession getRequiredSession()

Returns the initialized CqlSession instance.

Returns:

the CqlSession.

Throws:

IllegalStateException - if the session factory is not initialized.

getRequiredSessionFactory

protected SessionFactory getRequiredSessionFactory()

Returns the initialized CqlSession instance.

Returns:

the CqlSession.

Throws:

IllegalStateException - if the session factory is not initialized.

getSessionBuilderConfigurer

protected @Nullable SessionBuilderConfigurer getSessionBuilderConfigurer()

Returns the SessionBuilderConfigurer.

Returns:

the SessionBuilderConfigurer; may be null.

Since:

1.5

getDriverConfigLoaderBuilderConfigurer

protected @Nullable DriverConfigLoaderBuilderConfigurer getDriverConfigLoaderBuilderConfigurer()

Returns the DriverConfigLoaderBuilderConfigurer. The configuration gets applied after applying System Properties config overrides and before the driver config file.

Returns:

the DriverConfigLoaderBuilderConfigurer; may be null.

Since:

3.1.2

getDriverConfigurationResource

protected @Nullable Resource getDriverConfigurationResource()

Returns the Resource pointing to a driver configuration file. The configuration file is applied after applying System Properties and the configuration built by this configuration class.

Returns:

the Resource; may be null if none provided.

Since:

3.1.2

See Also:

• Driver Configuration

cassandraSession

@Bean
public CqlSessionFactoryBean cassandraSession()

Creates a CqlSessionFactoryBean that provides a Cassandra CqlSession.

Returns:

the CqlSessionFactoryBean.

See Also:

• getKeyspaceName()

cqlTemplate

@Bean
public CqlTemplate cqlTemplate()

Creates a CqlTemplate configured with getRequiredSessionFactory().

Returns:

the CqlTemplate.

See Also:

• getRequiredSession()