如何通过JanusGraph API识别配置的Keyspace及区分创建来源

一、运行时获取最终生效的Keyspace名称 #

JanusGraph会根据配置自动推导最终使用的keyspace，你可以通过以下Java代码直接获取：

import org.janusgraph.core.JanusGraph;
import org.janusgraph.core.JanusGraphFactory;
import org.janusgraph.graphdb.configuration.GraphDatabaseConfiguration;

// 假设已完成JanusGraph实例初始化
JanusGraph graph = JanusGraphFactory.open("your-config.properties");
// 提取存储配置节点
GraphDatabaseConfiguration storageConfig = graph.getConfiguration().getConfiguration(GraphDatabaseConfiguration.STORAGE_NAMESPACE);
// 获取最终生效的keyspace名称
String keyspace = storageConfig.get(GraphDatabaseConfiguration.CASSANDRA_KEYSPACE);

这段代码会自动适配配置逻辑：如果未显式设置storage.cassandra.keyspace，会返回graph.graphname对应的取值，和JanusGraph的自动推导规则完全一致。

二、区分JanusGraph创建与CQL手动创建的Keyspace #

JanusGraph创建keyspace时会自动生成专属系统表，以此作为核心判断依据：

• 检查目标keyspace中是否存在以janusgraph_为前缀的系统表，比如：
  • janusgraph_ids：用于ID分配的系统表
  • janusgraph_schema：存储图结构元数据的表
  • janusgraph_txlog：事务日志表
• 具体Java验证代码：

import com.datastax.oss.driver.api.core.CqlSession;
import com.datastax.oss.driver.api.core.metadata.schema.KeyspaceMetadata;
import com.datastax.oss.driver.api.core.metadata.schema.TableMetadata;

// 初始化Cassandra会话（建议复用现有连接减少资源消耗）
try (CqlSession session = CqlSession.builder()
        .withKeyspace("system")
        .build()) {
    KeyspaceMetadata keyspaceMeta = session.getMetadata().getKeyspace("your-target-keyspace").orElse(null);
    if (keyspaceMeta != null) {
        boolean isJanusGraphCreated = keyspaceMeta.getTables().stream()
                .map(TableMetadata::getName)
                .anyMatch(tableName -> tableName.startsWith("janusgraph_"));
        if (isJanusGraphCreated) {
            // 该keyspace由JanusGraph创建
        } else {
            // 该keyspace是通过CQL手动创建的
        }
    }
}

注：JanusGraph默认会给创建的keyspace设置SimpleStrategy复制策略，但该配置可能被手动修改，因此优先检查系统表的方式更可靠。

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