如何通过Docker Compose初始化ScyllaDB？最佳方案探讨

针对你的ScyllaDB初始化需求，这里有几个更优的实践方案，覆盖本地开发到生产环境的场景：

方案1：从Classpath加载CQL文件批量执行（Micronaut内实现） #

把初始化语句写到src/main/resources/schema.cql文件里，然后在CqlSession初始化时读取并执行，这样更易维护，也方便批量添加语句：

1. 创建schema.cql文件：

CREATE KEYSPACE IF NOT EXISTS ${KEYSPACE_NAME} WITH replication = {'class': 'SimpleStrategy', 'replication_factor' : 3};
CREATE COLUMNFAMILY IF NOT EXISTS ${KEYSPACE_NAME}.payment_data (id uuid PRIMARY KEY, account_id int, person_id int, payment_id text);

2. 修改CqlSession单例代码，读取文件并替换变量、拆分执行：

@Singleton
public CqlSession cqlSession(ScyllaConfig scyllaConfig) throws IOException {
    CqlSessionBuilder sessionBuilder = CqlSession.builder()
            .addContactPoints(scyllaConfig.contactPoints().stream()
                    .map(host -> new InetSocketAddress(host, scyllaConfig.port()))
                    .toList())
            .withLocalDatacenter(scyllaConfig.datacenter());

    CqlSession session = sessionBuilder.build();

    // 读取Classpath下的CQL文件
    String cqlContent = Files.readString(Paths.get(ClassLoader.getSystemResource("schema.cql").toURI()));
    // 替换配置中的keyspace变量
    String resolvedCql = cqlContent.replace("${KEYSPACE_NAME}", scyllaConfig.keyspaceName());
    // 按分号拆分语句（过滤空行和注释）
    Arrays.stream(resolvedCql.split(";"))
            .map(String::trim)
            .filter(s -> !s.isEmpty() && !s.startsWith("--"))
            .forEach(session::execute);

    return session;
}

注意：如果CQL语句包含字符串内的分号，简单拆分可能出错，可使用com.datastax.oss:java-driver-core自带的语句解析工具，或Apache Commons Text的StringTokenizer处理。

方案2：Docker Compose结合初始化脚本（容器化本地开发） #

如果是全容器化部署，推荐用初始化容器在Scylla启动后自动执行CQL脚本，无需在应用代码中处理：

1. 编写初始化脚本init-scylla.sh：

#!/bin/bash
# 等待Scylla启动就绪
until cqlsh scylla-node -e "DESCRIBE KEYSPACES"; do
  echo "Waiting for Scylla to start..."
  sleep 5
done

# 执行初始化CQL
cqlsh scylla-node -f /schema.cql

2. 编写schema.cql（直接写死keyspace，无需变量）：

CREATE KEYSPACE IF NOT EXISTS my_keyspace WITH replication = {'class': 'SimpleStrategy', 'replication_factor' : 3};
CREATE COLUMNFAMILY IF NOT EXISTS my_keyspace.payment_data (id uuid PRIMARY KEY, account_id int, person_id int, payment_id text);

3. 配置docker-compose.yml：

version: '3.8'
services:
  scylla-node:
    image: scylladb/scylla:latest
    ports:
      - "9042:9042"
    volumes:
      - scylla-data:/var/lib/scylla
  scylla-init:
    image: scylladb/scylla:latest
    depends_on:
      - scylla-node
    volumes:
      - ./init-scylla.sh:/init-scylla.sh
      - ./schema.cql:/schema.cql
    command: ["bash", "/init-scylla.sh"]
  micronaut-app:
    build: .
    ports:
      - "8080:8080"
    depends_on:
      - scylla-init
    environment:
      - SCYLLA_CONTACT_POINTS=scylla-node
      - SCYLLA_KEYSPACE_NAME=my_keyspace

volumes:
  scylla-data:

启动时scylla-init容器会等待Scylla就绪后执行脚本，应用启动时schema已存在。

方案3：用Flyway做Schema版本控制（生产级推荐） #

生产环境推荐用数据库版本控制工具管理schema，Flyway支持CQL，Micronaut有官方集成，可跟踪版本、避免重复执行、支持回滚：

1. 添加Flyway依赖（以Gradle为例）：

implementation "io.micronaut.flyway:micronaut-flyway"
implementation "org.flywaydb:flyway-cassandra"

2. 在application.yml中配置Flyway：

flyway:
  enabled: true
  locations: classpath:db/migration
  url: jdbc:cassandra://${SCYLLA_CONTACT_POINTS}:9042/${SCYLLA_KEYSPACE_NAME}
  user: cassandra
  password: cassandra
  baseline-on-migrate: true

3. 创建src/main/resources/db/migration/V1__init_schema.cql文件：

CREATE KEYSPACE IF NOT EXISTS my_keyspace WITH replication = {'class': 'SimpleStrategy', 'replication_factor' : 3};
CREATE COLUMNFAMILY IF NOT EXISTS my_keyspace.payment_data (id uuid PRIMARY KEY, account_id int, person_id int, payment_id text);

启动应用时Flyway会自动执行未应用的schema版本，后续变更只需添加V2__xxxx.cql文件即可，适合团队协作和生产环境。

方案对比与选择 #

• 本地快速开发：方案1或方案2，方案1无需额外容器配置，方案2适配全容器化环境
• 生产环境：方案3，版本化管理schema，可追溯、可回滚，符合DevOps最佳实践

内容的提问来源于stack exchange，提问作者testing123