java - 将变量值传递给 cassandra cql 语句

Question

我有 Java 代码来访问和处理 Cassandra 中的数据。如何将 Java 变量传递给用 Java 编写的 Cassandra CQL 查询。这是代码：

我的代码是这样的：

itemname="Item01";

com.datastax.driver.core.PreparedStatement result = 
session.execute("select itemname from demodb.retail_transaction where itemnamw = itemname;");

但它给出了以下错误：

no viable alternative at input ';'

Answer 1

我认为您应该将变量绑定到准备好的语句，如下所示：

    itemname="Item01";
    itemtype="type01";
    com.datastax.driver.core.PreparedStatement result = 
    session.execute("select itemname from demodb.retail_transaction where itemnamw = ? and 
                    itemtype =?;");
    BoundStatement boundStatement = new BoundStatement(statement);
    ResultSet results = session.execute(boundStatement.bind(
              itemname,itemtype));