如何通过EmbeddedCassandraServerHelper配置用户名与密码？

我来帮你搞定Embedded Cassandra的用户名密码配置问题！其实EmbeddedCassandraServerHelper完全支持通过自定义YAML文件开启认证并配置用户，下面是具体的实现步骤：

1. 创建自定义Cassandra配置YAML文件 #

首先你需要写一个包含认证相关配置的YAML文件，核心是开启密码认证、权限管理和角色管理模块。示例结构如下（可以根据你的需求补充其他配置）：

# 嵌入式Cassandra自定义配置
authenticator: PasswordAuthenticator  # 开启密码认证
authorizer: CassandraAuthorizer       # 开启权限控制
role_manager: CassandraRoleManager    # 启用角色管理

# 可选：自定义数据存储目录（避免和本地Cassandra冲突）
data_file_directories:
  - ./embedded-cassandra/data
commitlog_directory: ./embedded-cassandra/commitlog
saved_caches_directory: ./embedded-cassandra/caches

2. 启动嵌入式Cassandra时指定该YAML文件 #

在调用startEmbeddedCassandra方法时，直接传入你创建的自定义YAML文件对象即可：

import org.cassandraunit.utils.EmbeddedCassandraServerHelper;
import java.io.File;

public class EmbeddedCassandraSetup {
    public static void main(String[] args) throws Exception {
        // 指向你的自定义YAML文件路径
        File customConfig = new File("src/test/resources/cassandra-embedded.yaml");
        // 启动嵌入式Cassandra，加载自定义配置
        EmbeddedCassandraServerHelper.startEmbeddedCassandra(customConfig);
    }
}

3. 初始化自定义用户名和密码 #

开启认证后，Cassandra默认会自带一个超级用户cassandra，密码也是cassandra。你可以用这个默认用户连接后，创建自己的自定义用户：

import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.Session;

public class CreateCustomUser {
    public static void main(String[] args) {
        // 用默认超级用户连接
        Cluster cluster = Cluster.builder()
                .addContactPoints("127.0.0.1")
                .withPort(EmbeddedCassandraServerHelper.getNativeTransportPort())
                .withCredentials("cassandra", "cassandra")
                .build();
        
        Session session = cluster.connect();
        
        // 创建自定义超级用户（示例：用户名admin，密码admin）
        session.execute("CREATE ROLE IF NOT EXISTS admin WITH PASSWORD = 'admin' AND LOGIN = true AND SUPERUSER = true;");
        
        // 也可以创建普通用户
        session.execute("CREATE ROLE IF NOT EXISTS app_user WITH PASSWORD = 'app_pass' AND LOGIN = true;");
        
        // 关闭资源
        session.close();
        cluster.close();
    }
}

注意事项 #

• 确保你的cassandra-unit依赖版本和Cassandra核心版本匹配，避免配置不兼容的问题；
• 如果是测试场景，记得在测试结束后清理嵌入式Cassandra的存储目录，避免残留数据影响下次测试；
• 如果你不需要默认的cassandra用户，也可以连接后执行DROP ROLE cassandra;删除它（但要确保你已经创建了其他超级用户）。

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