当使用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：[主机= 10.65.240.89（10.65.240.89）：9160，等待时间= 237（342），尝试= 1] InvalidRequestException（为什么：没有索引列存在于与“等于”运算符的by-columns子句中）在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（ThriftSyncConnectionFactory Impl.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（本地方法） at sun.reflect.NativeMethodAccessorImpl.invoke（Unknown Source） at sun.reflect.DelegatingMethodAccessorImpl.invoke（Unknown Source） at java.lang.reflect.Method.invoke（Unknown Source） at org.junit.runners.model.FrameworkMethod $ 1.runReflectiveCall（FrameworkMethod.java:47） at org.junit.internal.runners.model.ReflectiveCallable.run（ReflectiveCallable.java:12） at org.junit.runners .model.FrameworkMethod.invokeExplosively（FrameworkMethod.java:44） at org.junit.internal.runners.statements.InvokeMethod.evaluate（InvokeMethod.java:17） at 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） at org.springframework.test.context.junit4.statements.SpringRepeat.evaluat E（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。 （org.junit.runners.java:236） at org.junit.runners.ParentRunner.access $ 000 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） at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run（JUnit4TestReference.java:50） at org.eclipse.jdt.internal.junit.runner .TestExecution.run（TestExecution.java:38） at org.eclipse.jdt。internal.junit.runner.RemoteTestRunner.runTests（RemoteTestRunner.java:467） at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests（RemoteTestRunner.java:683） at org.eclipse.jdt.internal。 junit.runner.RemoteTestRunner.run（RemoteTestRunner.java:390） at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main（RemoteTestRunner.java:197） 引起：InvalidRequestException（原因：没有索引列存在在“等于”运算符的by-columns子句中） at org.apache.cassandra.thrift.Cassandra $ execute_cql_query_result.read（Cassandra.java:36625） at org.apache.thrift.TServiceClient.receiveBase（TServiceClient.java:78 ） at org.apache.cassandra.thrift.Cassandra $ Client.recv_execute_cql_query（Cassandra.java:1525） at org.apache.cassand在com.netflix.astyanax.thrift.ThriftCqlQuery.execute_cql_query（ThriftCqlQuery.java:33） at 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的角度来看，主键的名字可能是“关键”。