openstack/deb-python-cassandra-driver
Code Issues Proposed changes

Handle v3 schema change messages

Browse Source
This commit is contained in:
Tyler Hobbs
2014-05-28 18:53:45 -05:00
parent a90996759c
commit 47e79ac668
1 changed files with 14 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
cassandra/protocol.py
View File

@@ -608,11 +608,21 @@ class ResultMessage(_MessageType):
return paging_state, column_metadata
@classmethod
def recv_results_schema_change(cls, f):
def recv_results_schema_change(cls, f, protocol_version):
change_type = read_string(f)
keyspace = read_string(f)
table = read_string(f)
return dict(change_type=change_type, keyspace=keyspace, table=table)
if protocol_version >= 3:
target = read_string(f)
keyspace = read_string(f)
if target != "KEYSPACE":
table_or_type = read_string(f)
return {'change_type': change_type, 'keyspace': keyspace, target.lower(): table_or_type}
else:
return {'change_type': change_type, 'keyspace': keyspace}
else:
keyspace = read_string(f)
table = read_string(f)
return {'change_type': change_type, 'keyspace': keyspace, 'table': table}
@classmethod
def read_type(cls, f):