java - Cassandra Java 查询示例

Question

我是 java 和 Cassandra 的新手，我正在尝试编写一个简单的 java 应用程序，我想查询键空间中的表并返回所有行。我从下面这些代码行中收到以下错误，这是我尝试连接到 Cassandra 数据库的方式。 Nodetool 状态 返回并正常，所以我不确定我缺少什么。

使用的代码:

Cluster cluster = Cluster.builder().addContactPoint("192.168.1.30").build();
Session session = cluster.connect(); 

Error:tried: /192.168.x.x:9042 (com.datastax.driver.core.exceptions.InvalidQueryException: unconfigured table schema_keyspaces))

Answer 1

您看到的错误表明您正在尝试使用不兼容的 Java 驱动程序版本连接到 Cassandra 3.0 集群。

目前唯一兼容的驱动程序版本是 3.0.0-alpha5。 3.0.0-beta1 应该很快就会发布。