Я использую Cassandra в качестве источника данных в моем загрузочном приложении Spring и хочу инициализировать базу данных перед запуском приложения.
До сих пор я определил класс «CassandraConfiguration», расширяющий класс «AbstractCassandraConfiguration», как в примерах, которые вы можете видеть ниже, и у меня есть репозиторий, расширяющий «CassandraRepository». Когда я сам создаю пространство ключей и таблицу, приложение работает нормально.
Однако я хочу автоматически создавать пространство ключей и таблицы при запуске приложения. Для этого я предоставил файл schema.cql в папке ресурсов, но мне не удалось заставить этот скрипт работать.
Кто-нибудь знает, что я могу сделать для автоматического создания пространств ключей и таблиц?
Спасибо.
Изменить: я использую версии Cassandra 2.0.9, spring-boot 1.3.2.RELEASE и datastax cassandra driver 2.1.6.
CassandraConfiguration.java
@Configuration
@PropertySource(value = { "classpath:cassandra.properties" })
@EnableCassandraRepositories(basePackages = { "bla.bla.bla.repository" })
public class CassandraConfiguration extends AbstractCassandraConfiguration {
@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;
}
@Bean
public CassandraMappingContext cassandraMapping() throws ClassNotFoundException {
return new BasicCassandraMappingContext();
}
@Bean
public CassandraConverter converter() throws ClassNotFoundException {
return new MappingCassandraConverter(cassandraMapping());
}
@Override
protected String getKeyspaceName() {
return environment.getProperty( "cassandra.keyspace" );
}
@Bean
public CassandraSessionFactoryBean session() throws Exception {
CassandraSessionFactoryBean session = new CassandraSessionFactoryBean();
session.setCluster(cluster().getObject());
session.setKeyspaceName(environment.getProperty("cassandra.keyspace"));
session.setConverter(converter());
session.setSchemaAction(SchemaAction.NONE);
return session;
}
@Override
public SchemaAction getSchemaAction() {
return SchemaAction.RECREATE_DROP_UNUSED;
}
}