1

Я пытаюсь запросить Кассандре таблицы и пытаюсь получить подмножество данных строк на основе моего фильтра Но я получаю exceptin как отсутствующий EOFвесна-данные Cassandra запрос: отсутствует исключение EOF

@ repository-

@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 получить подмножество строки. на 1-ом запросе пройду смещение = 0, и ROWNUMBER = 10] Журнал

ошибка: -

com.datastax.driver.core.exceptions.SyntaxError: линия 1: 104 отсутствует EOF в 'где' (... 'PI_NAME_CHANGE' и receipt_period = '2016-02-06' [где] токен ...) по адресу com.datastax.driver.core.exceptions.SyntaxError.copy (SyntaxError.java:35) at 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) at org.springframework.cassandra.core.CqlTemplate.doExecute (CqlTemplate.java:494) at 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) at org.springframework.data.cassandra.repository.query.AbstractCassandraQ uery.execute (AbstractCassandraQuery.java:122) at org.springframework.data.repository.core.support.RepositoryFactorySupport $ QueryExecutorMethodInterceptor.doInvoke (RepositoryFactorySupport.java:454) at 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) at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed (ReflectiveMethodInvocation.java:179) at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke (ExposeInvocationInterceptor.j AVA: 92) на org.springframework.aop.framework.ReflectiveMethodInvocation.proceed (ReflectiveMethodInvocation.java:179) на org.springframework.aop.framework.JdkDynamicAopProxy.invoke (JdkDynamicAopProxy.java:207) в com.sun. прокси $ Proxy74.findByProductIdAndReceiptPeriod (Unknown Source) на com.fmr.docgen.service.transaction.IncomingRequestServiceImpl.findCustomerRequest (IncomingRequestServiceImpl.java:96) на com.fmr.docgen.controller.TransactionController.findCustomerRequest (TransactionController.java.: 262) на sun.reflect.NativeMethodAccessorImpl.invoke0 (нативный метод) на sun.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.java:62) на sun.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.java: 43) at java.lang.reflect.Method.invoke (Method.java:497) at 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) на или g.springframework.web.servlet.DispatcherServlet.doService (DispatcherServlet.java:870) at org.springframework.web.servlet.FrameworkServlet.processRequest (FrameworkServlet.java:961) at 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) at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter (ApplicationFilterChain.java:303) at org.apache.catalina.core.ApplicationFilterChain.doFilter (ApplicationFilterChain. java: 208) at org.apache.tomcat.websocket.server.WsFilter.doFilter (WsFilt er.java:52) на org.apache.catalina.core.ApplicationFilterChain.internalDoFilter (ApplicationFilterChain.java:241) в org.apache.catalina.core.ApplicationFilterChain.doFilter (ApplicationFilterChain.java:208) в орг. 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) в орг. 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) at org.apache.coyote.AbstractProtocol $ AbstractConnectionHandler.process (AbstractProtocol.java:620) at 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)

+0

Можете ли вы разместить полную трассировку стека исключений? – doanduyhai

ответ

1

WHERE token(K)

K название вашего столбца ключа раздела?

token('offset')

Если это не будет маркер (? 2) вместо этого? То же замечание для токена ('rowNumber')

+0

Спасибо за разъяснение. – JOGO

Смежные вопросы