Cassandra Java 查询示例

Cassandra Java query example

我是 java 和 Cassandra 的新手,我正在尝试编写一个简单的 java 应用程序,我想在键空间和 [=19] 中查询 table =] 所有行。我从下面这些代码行中得到以下错误是我尝试连接到 Cassandra 数据库的方式。 Nodetool status returns up and normal 所以我不确定我错过了什么。

使用的代码:

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))

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

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