cassandra - Datastax Java 驱动程序 4.x : How to get cluster name?

Question

将 cassandra 的 java 驱动程序从 3.7 升级到 4.0(或更高版本)后 - 我无法解析集群名称。

我需要我的应用程序使用 Java 驱动程序连接到的 cassandra 集群的名称。早些时候它作为“Cluster.getMetadata().getClusterName()”可用。但是在升级到 datastax-driver-core-4.0 或更高版本之后-我无法从 CqlSession.getMetadata().. 解析集群名称。

这非常重要，因为我已经根据不同的集群分离了操作。

Answer 1

我相信 java api 不再提供集群名称。相反，只需从 system.local 查询它:

SimpleStatement statement =SimpleStatement.newInstance("SELECT cluster_name FROM system.local");
ResultSet resultSet = session.execute(statement);
Row row = resultSet.one();
System.out.println(row.getString("cluster_name"));