从Cassandra ResultSet获取一个BigInteger属性

10

我正在尝试获取Cassandra列族中键值对的数量。以下是我使用的代码。

PreparedStatement statement = client.session
            .prepare("select count(*) from corpus.word_usage");
ResultSet results = client.session.execute(statement.bind());   
Row row = results.one();
System.out.println(row.getVarint(0));

但是当我运行这段代码时,我得到了以下异常。

Exception in thread "main" com.datastax.driver.core.exceptions.InvalidTypeException: Column count is of type bigint
   at com.datastax.driver.core.ColumnDefinitions.checkType(ColumnDefinitions.java:291)
   at com.datastax.driver.core.ArrayBackedRow.getVarint(ArrayBackedRow.java:185)
   at SimpleClient.main(SimpleClient.java:57)
根据DataStax文档(http://www.datastax.com/drivers/java/2.0/com/datastax/driver/core/Row.html),getVarint应该返回一个BigInteger。那么为什么我在这里会得到一个异常?我做错了什么?
3个回答

12

你可以选择将值作为long类型获取。

我没有测试过,但你可以尝试这样做:

PreparedStatement statement = client.session.prepare("select count(*) from corpus.word_usage");
ResultSet results = client.session.execute(statement.bind());   
Row row = results.one();
long expected = row.getLong("count");

链接已经失效了。您可能需要检查一下。 - kfkhalili
bigint Cassandra类型映射为long Java类型。文档链接:CQL到Java类型映射 @kfkhalili - Miguel M. Serrano

0

Cassandra中的bigint与Java中的long类型相对应。文档:CQL到Java类型映射

在您的情况下:

row.getLong(0)

0

以下代码有效。但我不确定为什么它有效。

row.getLong(0)

您IP地址为143.198.54.68,由于运营成本限制,当前对于免费用户的使用频率限制为每个IP每72小时10次对话,如需解除限制,请点击左下角设置图标按钮(手机用户先点击左上角菜单按钮)。 - sme
它能够工作是因为Cassandra bigint类型被映射为Java的long类型。包含Cassandra-Java映射类型的完整文档链接: https://dev59.com/JV4c5IYBdhLWcg3w59qQ#64895551 - Miguel M. Serrano

网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接