使用 where 子句时 Cassandra astyanax sql 查询出错

Question

select with where 子句在 cassandra cqlsh 中可以正常工作> 但在 Astyanax 中不行。但是，没有 where 子句的 SLQ 子句在 astyanax 中可以正常工作。不确定我错过了什么想法？

CREATE TABLE personalization1 (
                       username text primary key,
                      incidentPage text,
                      timelinePage text,
                      );

insert into personalization1 (username,incidentpage,timelinepage) values ('3cd70b90-d211-11e3-8774-14109fdb7013','3cd70b90-d211-11e3-8774-14109fdb7013','3cd70b90-d211-11e3-8774-14109fdb7013');

SELECT * FROM personalization1 where username='3cd70b90-d211-11e3-8774-14109fdb7013' ;

com.netflix.astyanax.connectionpool.exceptions.BadRequestException：BadRequestException：[host=10.65.240.89(10.65.240.89):9160，latency=237(342)，尝试=1]InvalidRequestException（为什么：没有索引列存在在带有“等于”运算符的分列子句中） 在 com.netflix.astyanax.thrift.ThriftConverter.ToConnectionPoolException（ThriftConverter.java:159） 在 com.netflix.astyanax.thrift.AbstractOperationImpl.execute（AbstractOperationImpl.java:65） 在 com.netflix.astyanax.thrift.AbstractOperationImpl.execute（AbstractOperationImpl.java:28） 在 com.netflix.astyanax.thrift.ThriftSyncConnectionFactoryImpl$ThriftConnection.execute(ThriftSyncConnectionFactoryImpl.java:151) 在 com.netflix.astyanax.connectionpool.impl.AbstractExecuteWithFailoverImpl.tryOperation（AbstractExecuteWithFailoverImpl.java:119） 在 com.netflix.astyanax.connectionpool.impl.AbstractHostPartitionConnectionPool.executeWithFailover（AbstractHostPartitionConnectionPool.java:338） 在 com.netflix.astyanax.thrift.AbstractThriftCqlQuery.execute（AbstractThriftCqlQuery.java:41） 在 com.ebay.timeline.dao.PersonaliztionDAOTest.test(PersonaliztionDAOTest.java:83) 在 sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 在 sun.reflect.NativeMethodAccessorImpl.invoke（未知来源） 在 sun.reflect.DelegatingMethodAccessorImpl.invoke（未知来源） 在 java.lang.reflect.Method.invoke（未知来源） 在 org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47) 在 org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) 在 org.junit.runners.model.FrameworkMethod.invokeExplosively（FrameworkMethod.java:44） 在 org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) 在 org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26) 在 org.springframework.test.context.junit4.statements.RunBeforeTestMethodCallbacks.evaluate(RunBeforeTestMethodCallbacks.java:74) 在 org.springframework.test.context.junit4.statements.RunAfterTestMethodCallbacks.evaluate(RunAfterTestMethodCallbacks.java:83) 在 org.springframework.test.context.junit4.statements.SpringRepeat.evaluate(SpringRepeat.java:72) 在 org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:232) 在 org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:89) 在 org.junit.runners.ParentRunner$3.run(ParentRunner.java:238) 在 org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63) 在 org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236) 在 org.junit.runners.ParentRunner.access$000(ParentRunner.java:53) 在 org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229) 在 org.springframework.test.context.junit4.statements.RunBeforeTestClassCallbacks.evaluate(RunBeforeTestClassCallbacks.java:61) 在 org.springframework.test.context.junit4.statements.RunAfterTestClassCallbacks.evaluate(RunAfterTestClassCallbacks.java:71) 在 org.junit.runners.ParentRunner.run(ParentRunner.java:309) 在 org.springframework.test.context.junit4.SpringJUnit4ClassRunner.run(SpringJUnit4ClassRunner.java:175) 在 org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:50) 在 org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38) 在 org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:467) 在 org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:683) 在 org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:390) 在 org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:197) 原因：InvalidRequestException（为什么：使用“等于”运算符的 by-columns 子句中没有索引列） 在 org.apache.cassandra.thrift.Cassandra$execute_cql_query_result.read(Cassandra.java:36625) 在 org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78) 在 org.apache.cassandra.thrift.Cassandra$Client.recv_execute_cql_query(Cassandra.java:1525) 在 org.apache.cassandra.thrift.Cassandra$Client.execute_cql_query(Cassandra.java:1511) 在 com.netflix.astyanax.thrift.ThriftCqlQuery.execute_cql_query(ThriftCqlQuery.java:33) 在 com.netflix.astyanax.thrift.AbstractThriftCqlQuery$1.internalExecute(AbstractThriftCqlQuery.java:46) 在 com.netflix.astyanax.thrift.AbstractThriftCqlQuery$1.internalExecute(AbstractThriftCqlQuery.java:43) 在 com.netflix.astyanax.thrift.AbstractOperationImpl.execute(AbstractOperationImpl.java:60)

Answer 1

我从堆栈跟踪中注意到正在使用“execute_cql_query”函数，而不是“execute_cql3_query”，因此正在运行的查询就像在cqlsh -2 中执行一样运行，这很可能是问题所在。从cql2的角度来看，主键的名字大概就是“key”吧。