Parameterized queries with the Python Cassandra Module

Question

I've been experimenting with the CQL plugin for Python (http://code.google.com/a/apache-extras.org/p/cassandra-dbapi2/) which has support for parameterized queries. From their documentation:

import cql
connection = cql.connect(host, port, keyspace)
cursor = connection.cursor()
cursor.execute("CQL QUERY", dict(kw='Foo', kw2='Bar', etc...))

My question is whether its possible to parameterize and execute the same query multiple times in a loop, and what the methods look like to accomplish that. Sorry but documentation is scant so I'm searching about for an answer...

Philip Southam · Accepted Answer · 2013-03-28 19:13:30Z

2

Take a look at the code in tests for more examples

import cql
connection = cql.connect(host, port, keyspace)
cursor = connection.cursor()

query = "UPDATE StandardString1 SET :c1 = :v1, :c2 = :v2 WHERE KEY = :key"
cursor.execute(query, dict(c1="ca1", v1="va1", c2="col", v2="val", key="ka"))
cursor.execute(query, dict(c1="cb1", v1="vb1", c2="col", v2="val", key="kb"))
cursor.execute(query, dict(c1="cc1", v1="vc1", c2="col", v2="val", key="kc"))
cursor.execute(query, dict(c1="cd1", v1="vd1", c2="col", v2="val", key="kd"))

Or more specifically to your question about running it in a loop:

import cql
connection = cql.connect(host, port, keyspace)
cursor = connection.cursor()

query = "UPDATE StandardString1 SET :c1 = :v1, :c2 = :v2 WHERE KEY = :key"
values = [dict(c1="ca1", v1="va1", c2="col", v2="val", key="ka"),
          dict(c1="cb1", v1="vb1", c2="col", v2="val", key="kb"),
          dict(c1="cc1", v1="vc1", c2="col", v2="val", key="kc"),
          dict(c1="cd1", v1="vd1", c2="col", v2="val", key="kd")]

for value in values:
    cursor.execute(query, value)

answered Mar 28, 2013 at 19:13

Philip Southam

16.6k6 gold badges30 silver badges20 bronze badges

Sign up to request clarification or add additional context in comments.

1 Comment

stakolee Over a year ago

After posting the ticket, I started looking at the CQL code. It appears that they don't prepare statements on the server and just do simple string replacements before sending a single statement to the cassandra instance. I don't know if it is possible through this plugin to take advantage of prepared server-side statements.

Collectives™ on Stack Overflow

Parameterized queries with the Python Cassandra Module

1 Answer 1

1 Comment

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

1 Comment

Your Answer

Sign up or log in

Post as a guest

Linked

Related