43 lines
1.7 KiB
Java
43 lines
1.7 KiB
Java
package com.example.crud;
|
|
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.LoggerFactory;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.context.annotation.Bean;
|
|
import org.springframework.context.annotation.Configuration;
|
|
import org.springframework.context.annotation.PropertySource;
|
|
import org.springframework.core.env.Environment;
|
|
import org.springframework.data.cassandra.config.CassandraClusterFactoryBean;
|
|
import org.springframework.data.cassandra.config.java.AbstractCassandraConfiguration;
|
|
import org.springframework.data.cassandra.mapping.BasicCassandraMappingContext;
|
|
import org.springframework.data.cassandra.mapping.CassandraMappingContext;
|
|
import org.springframework.data.cassandra.repository.config.EnableCassandraRepositories;
|
|
|
|
@Configuration
|
|
@PropertySource(value = {"classpath:cassandra.properties"})
|
|
@EnableCassandraRepositories(basePackages = {"example"})
|
|
public class CassandraConfiguration extends AbstractCassandraConfiguration {
|
|
|
|
private static final Logger LOG = LoggerFactory.getLogger(CassandraConfiguration.class);
|
|
|
|
@Autowired
|
|
private Environment environment;
|
|
|
|
@Bean
|
|
public CassandraClusterFactoryBean cluster() {
|
|
CassandraClusterFactoryBean cluster = new CassandraClusterFactoryBean();
|
|
cluster.setContactPoints(environment.getProperty("cassandra.contactpoints"));
|
|
cluster.setPort(Integer.parseInt(environment.getProperty("cassandra.port")));
|
|
return cluster;
|
|
}
|
|
|
|
@Override
|
|
protected String getKeyspaceName() {
|
|
return environment.getProperty("cassandra.keyspace");
|
|
}
|
|
|
|
@Bean
|
|
public CassandraMappingContext cassandraMapping() throws ClassNotFoundException {
|
|
return new BasicCassandraMappingContext();
|
|
}
|
|
} |