4

这是我的列族定义：

CREATE TABLE columnfamily (column1 int PRIMARY KEY, column2 text);

我正在使用 python cassandra-dbapi2 1.4.0 连接到 Cassandra 1.1.6，使用 CQL 3 语法。我想对以下查询使用查询替换，但它似乎不适用于 WHERE... IN (...,...)：

cql = "SELECT * FROM columnfamily WHERE column1 IN (:x) and column2 = :y;"
q = cursor.prepare_query(cql)

cursor.execute_prepared(q, {'x':(1,2,3), 'y':'abc'}

尝试上述方法后出现以下错误：

Traceback (most recent call last):
  File "test_cassandra.py", line 17, in <module>
    cursor.execute_prepared(q, params)
  File "/usr/local/lib/python2.7/dist-packages/cql/cursor.py", line 89, in execute_prepared
    response = self.get_response_prepared(prepared_query, params, cl)
  File "/usr/local/lib/python2.7/dist-packages/cql/thrifteries.py", line 83, in get_response_prepared
    paramvals = prepared_query.encode_params(params)
  File "/usr/local/lib/python2.7/dist-packages/cql/query.py", line 60, in encode_params
    return [t.to_binary(t.validate(params[n])) for (n, t) in zip(self.paramnames, self.vartypes)]
  File "/usr/local/lib/python2.7/dist-packages/cql/cqltypes.py", line 225, in to_binary
    return cls.serialize(val)
struct.error: cannot convert argument to integer

我也尝试过使用以下内容：

cursor.execute_prepared(q, {'x':','.join([str(i) for i in (1,2,3)]), 'y':'abc'}

发生了同样的错误。有谁知道在 WHERE ... IN (...,...) 语句中进行查询替换的正确方法是什么？

谢谢！

4

1 回答 1

3

Cassandra 是在准备好的查询上插入绑定值的部分，在这里，它不支持绑定一系列值，所以答案几乎是，“你不能这样做（还）”。

如果您想密切关注那里的情况，请参阅https://issues.apache.org/jira/browse/CASSANDRA-4210 。

可以在普通调用的 python-cql 驱动程序中支持这种结构execute()，其中查询插值是在 Python 端完成的，但是您不会获得准备好的查询的任何好处，而且它不会不仅仅是

cursor.execute('SELECT * FROM a WHERE b IN (%s)'
               % ', '.join(map(cql.query.cql_quote, your_list_of_values)))
于 2012-11-30T17:37:41.127 回答