时间戳

首页 > 解决方案 > 如何在 cassandra docker 映像启动或 Spring Boot 应用程序启动时创建键空间

spring-boot - 如何在 cassandra docker 映像启动或 Spring Boot 应用程序启动时创建键空间

问题描述

我需要在 docker 容器中将 Spring Boot 应用程序与 Cassandra DB 连接，并且我需要在 Spring 应用程序启动时甚至在 Cassandra 容器启动时创建密钥空间。我怎样才能做到这一点？

标签： spring-bootdockercassandra

解决方案

在您的 spring-boot java 配置中，您可以拥有一个执行此操作的 bean。

@Configuration
@PropertySource("classpath:cassandra.properties")
public class DaoConfig {
     @Bean
     public CassandraSessionManager getCassandraSessionManager() {
         return new CassandraSessionManager();
     }
}

如果你使用 datastax 的 cassandra java-driver，你可以像下面这样创建你的密钥空间。

String query = "CREATE KEYSPACE mykeyspace WITH replication = 
{'class':'SimpleStrategy','replication_factor':1};";              
Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1").build();
Session session = cluster.connect();
session.execute(query);

更常见的用例是连接到现有的键空间，你可以这样做https://github.com/joychakravarty/JNotes/blob/jnotes_withSpring/src/main/java/com/jc/jnotes/dao/remote/cassandra/ CassandraSessionManager.java

推荐阅读