Spring-data Cassandra 查询：缺少 EOF 异常

Question

我正在尝试查询 cassandra 表并尝试根据我的过滤器检索行数据的子集 但是因为缺少 EOF 而变得异常

@存储库-

  @Query("select * from customer_request where product_id = ?0 and date_period = ?1 WHERE token(K) > token('offset') and token(K) < token('rowNumber')")
  List<CustomerRequest> findByProduct(String productId, String datePeriod,
  Integer offset, Integer rowNumber);

我在这里做错了什么？ [试图添加逻辑 t 获取行的子集。在第一次请求时，我将通过 offset=0 和 rowNumber =10]

错误日志：-

com.datastax.driver.core.exceptions.SyntaxError：第 1:104 行在 'where' 处缺少 EOF（...'PI_NAME_CHANGE' 和receipt_period = '2016-02-06' [where] token...） 在 com.datastax.driver.core.exceptions.SyntaxError.copy(SyntaxError.java:35) 在 com.datastax.driver.core.DefaultResultSetFuture.extractCauseFromExecutionException（DefaultResultSetFuture.java:269） 在 com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:183) 在 com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:52) 在 org.springframework.cassandra.core.CqlTemplate$12.doInSession(CqlTemplate.java:503) 在 org.springframework.cassandra.core.CqlTemplate$12.doInSession(CqlTemplate.java:494) 在 org.springframework.cassandra.core.CqlTemplate.doExecute(CqlTemplate.java:471) 在 org.springframework.cassandra.core.CqlTemplate.doExecute(CqlTemplate.java:494) 在 org.springframework.cassandra.core.CqlTemplate.doExecute(CqlTemplate.java:483) 在 org.springframework.cassandra.core.CqlTemplate.query(CqlTemplate.java:393) 在 org.springframework.cassandra.core.CqlTemplate.query(CqlTemplate.java:420) 在 org.springframework.cassandra.core.CqlTemplate.query(CqlTemplate.java:414) 在 org.springframework.data.cassandra.repository.query.AbstractCassandraQuery.execute(AbstractCassandraQuery.java:122) 在 org.springframework.data.repository.core.support.RepositoryFactorySupport$QueryExecutorMethodInterceptor.doInvoke(RepositoryFactorySupport.java:454) 在 org.springframework.data.repository.core.support.RepositoryFactorySupport$QueryExecutorMethodInterceptor.invoke(RepositoryFactorySupport.java:432) 在 org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179) 在 org.springframework.data.projection.DefaultMethodInvokingMethodInterceptor.invoke（DefaultMethodInvokingMethodInterceptor.java:61） 在 org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179) 在 org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92) 在 org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179) 在 org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:207) 在 com.sun.proxy.$Proxy74.findByProductIdAndReceiptPeriod（未知来源） 在 com.fmr.docgen.service.transaction.IncomingRequestServiceImpl.findCustomerRequest(IncomingRequestServiceImpl.java:96) 在 com.fmr.docgen.controller.TransactionController.findCustomerRequest(TransactionController.java:262) 在 sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 在 sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 在 sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 在 java.lang.reflect.Method.invoke(Method.java:497) 在 org.springframework.web.method.support.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:215) 在 org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:132) 在 org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:104) 在 org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandleMethod(RequestMappingHandlerAdapter.java:749) 在 org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:689) 在 org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:83) 在 org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:938) 在 org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:870) 在 org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:961) 在 org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:852) 在 javax.servlet.http.HttpServlet.service(HttpServlet.java:624) 在 org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:837) 在 javax.servlet.http.HttpServlet.service(HttpServlet.java:731) 在 org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:303) 在 org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:208) 在 org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:52) 在 org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:241) 在 org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:208) 在 org.apache.catalina.core.StandardWrapperValve.invoke（StandardWrapperValve.java:220） 在 org.apache.catalina.core.StandardContextValve.invoke（StandardContextValve.java:122） 在 org.apache.catalina.authenticator.AuthenticatorBase.invoke（AuthenticatorBase.java:505） 在 org.apache.catalina.core.StandardHostValve.invoke（StandardHostValve.java:170） 在 org.apache.catalina.valves.ErrorReportValve.invoke（ErrorReportValve.java:103） 在 org.apache.catalina.valves.AccessLogValve.invoke（AccessLogValve.java:957） 在 org.apache.catalina.core.StandardEngineValve.invoke（StandardEngineValve.java:116） 在 org.apache.catalina.connector.CoyoteAdapter.service（CoyoteAdapter.java:423） 在 org.apache.coyote.http11.AbstractHttp11Processor.process（AbstractHttp11Processor.java:1079） 在 org.apache.coyote.AbstractProtocol$AbstractConnectionHandler.process(AbstractProtocol.java:620) 在 org.apache.tomcat.util.net.JIoEndpoint$SocketProcessor.run(JIoEndpoint.java:316) 在 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 在 org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)

Answer 1

WHERE 令牌（K）

K是您的分区键列的名称吗？

token('offset')

不应该是token(?2)吗？ token('rowNumber')

的注释相同