Skip to content

Commit

Permalink
Merge pull request #43 from nickmbailey/add-cql3
Browse files Browse the repository at this point in the history
Add CQL query methods.
  • Loading branch information
thobbs committed Apr 22, 2013
2 parents 8ab706d + b471855 commit 94d2450
Showing 1 changed file with 13 additions and 0 deletions.
13 changes: 13 additions & 0 deletions telephus/client.py
Expand Up @@ -391,3 +391,16 @@ def system_update_keyspace(self, ksDef, retries=None, block=True):
def describe_version(self, retries=None):
req = ManagedThriftRequest('describe_version')
return self.manager.pushRequest(req, retries=retries)

def set_cql_version(self, version, retries=None):
req = ManagedThriftRequest('set_cql_version', version)
return self.manager.pushRequest(req, retries=retries)

def execute_cql_query(self, query, compression=ttypes.Compression.NONE, retries=None):
req = ManagedThriftRequest('execute_cql_query', query, compression)
return self.manager.pushRequest(req, retries=retries)

def execute_cql3_query(self, query, consistency=None, compression=ttypes.Compression.NONE, retries=None):
consistency = consistency or self.consistency
req = ManagedThriftRequest('execute_cql3_query', query, compression, consistency)
return self.manager.pushRequest(req, retries=retries)

0 comments on commit 94d2450

Please sign in to comment.