微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

JBOSS -CASSANDRA :com.datastax.oss.driver.api.core.servererrors.InvalidQueryException: 列水果的未设置值无效

如何解决JBOSS -CASSANDRA :com.datastax.oss.driver.api.core.servererrors.InvalidQueryException: 列水果的未设置值无效

我正在使用使用 cassandra 的 spring 应用程序,我使用 jboss 进行部署。我可以通过 jboss 建立从我的应用程序到 cassandra 的连接。但是当使用绑定变量查询时,我收到以下错误

ERROR [org.springframework.boot.web.servlet.support.ErrorPageFilter] (default task-1) Forwarding to error page from request [/sampleJboss] due to exception [Invalid unset value for column fruit]: com.datastax.oss.driver.api.core.servererrors.InvalidQueryException: Invalid unset value for column fruit
        at com.datastax.oss.driver.api.core.servererrors.InvalidQueryException.copy(InvalidQueryException.java:48)
        at com.datastax.oss.driver.internal.core.util.concurrent.CompletableFutures.getUninterruptibly(CompletableFutures.java:149)
        at com.datastax.oss.driver.internal.core.cql.CqlRequestSyncProcessor.process(CqlRequestSyncProcessor.java:53)
        at com.datastax.oss.driver.internal.core.cql.CqlRequestSyncProcessor.process(CqlRequestSyncProcessor.java:30)
        at com.datastax.oss.driver.internal.core.session.DefaultSession.execute(DefaultSession.java:230)
        at com.datastax.oss.driver.api.core.cql.SyncCqlSession.execute(SyncCqlSession.java:54)
        at com.companyName.org.Table.select_table(Table.java:91)
        at com.companyName.org.Controller.sampleJboss(Controller.java:57)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:498)..............
        

下面是我使用的代码

     CqlSession session = CqlSession.builder().addContactPoint(new InetSocketAddress(contactpoint,port))
               .withLocalDatacenter("datacenter1").withKeyspace(CqlIdentifier.fromCql(keyspace)).build();
PreparedStatement statement =session.prepare("select market_name from market where fruit= :fruit");
         BoundStatement boundStatement = statement.bind();
         boundStatement.setString("fruit","apple")
             results = session.execute(boundStatement);

我正在使用

*datastax java-driver-core,*java-driver-query-builder,*java-driver-runtime-mapper 

用于与 cassandra 建立连接。

我对这个环境很陌生。请帮助我解决这个问题。非常感谢您的帮助。

提前致谢.......

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。