5

我正在尝试通过 Java 创建一个计数器列,但在运行它时出现错误。我正在使用 CQL 3.0.0 和 Cassandra 1.1.2

Statement st = con.createStatement();
String data = "CREATE COLUMNFAMILY user_count(priKey text PRIMARY KEY, countME counter)";
st.execute(data);

这是我得到的错误:

Exception in thread "main" java.sql.SQLSyntaxErrorException:        
org.apache.cassandra.config.ConfigurationException: Cannot add a counter column   
(countme) in a non counter column family

'CREATE COLUMNFAMILY user_count(priKey text PRIMARY KEY, countME counter)'
at org.apache.cassandra.cql.jdbc.CassandraStatement.doExecute(CassandraStatement.java:179)
at org.apache.cassandra.cql.jdbc.CassandraStatement.execute(CassandraStatement.java:203)
at cassandratest.EdgeCreator.aaListData(EdgeCreator.java:1323)
at cassandratest.Main.main(Main.java:214)

我已经尝试过Cassandra cql 比较器类型计数器的答案,但我知道 CQL 3.0.0 的 default_validation 不再可用。我搜索了文档,但一无所获。我正在寻找如何使用 Java 创建一个计数器列族并增加它。我在这里先向您的帮助表示感谢!

这也是我在这里的第一篇文章,所以如果有任何问题,请告诉我,以便我将来更正。

更新 在 cqlsh 中使用 CREATE 语句时,我得到一个 ConfigurationException。cqlsh 会话如下:

Connected to Test Cluster at localhost:9160.
[cqlsh 3.0.0 | Cassandra 1.1.0 | CQL spec 3.0.0 | Thrift protocol 19.30.0]
Use HELP for help.
cqlsh> use "Keyspace2";
cqlsh:Keyspace2> CREATE COLUMNFAMILY user_count(priKey text PRIMARY KEY, countME
counter);
Bad Request: org.apache.cassandra.config.ConfigurationException: Cannot add a 
counter column (countme) in a non counter column family
cqlsh:Keyspace2>
4

1 回答 1

2

你确定你使用的是cql 3?从您的回溯中看起来您不是,如果您不小心使用了 cql 2,这就是我所期望的错误。

该 create 语句应该在 cql 3 中工作。

编辑:您使用的是 cql 3,但您没有使用 Cassandra 1.1.2。这是 1.1.0 的一个已知错误;如果升级到 1.1.2,它应该被修复。

于 2012-07-12T18:00:48.573 回答