natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge 9cd20fe677 into 10557d7ffe

This commit is contained in:
pranavchaurasia18 2026-08-01 14:09:24 +03:00 committed by GitHub
parent 10557d7ffe 9cd20fe677
commit d5cd8a40b7
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 19 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
pylib/cqlshlib/cql3handling.py
View File

@ -495,6 +495,7 @@ def ks_prop_val_completer(ctxt, cass):
def ks_prop_val_mapkey_completer(ctxt, cass): def ks_prop_val_mapkey_completer(ctxt, cass):
session = cass.session if hasattr(cass, 'session') else cass
optname = ctxt.get_binding('propname')[-1] optname = ctxt.get_binding('propname')[-1]
if optname != 'replication': if optname != 'replication':
return () return ()
@ -509,7 +510,24 @@ def ks_prop_val_mapkey_completer(ctxt, cass):
if repclass == 'SimpleStrategy': if repclass == 'SimpleStrategy':
opts = {'replication_factor'} opts = {'replication_factor'}
elif repclass == 'NetworkTopologyStrategy': elif repclass == 'NetworkTopologyStrategy':
return [Hint('<dc_name>')] try:
resultLocal = session.execute("SELECT data_center FROM system.local")
row = resultLocal.one()
local_dc = row['data_center'] if row else None
resultPeer = session.execute("SELECT data_center FROM system.peers")
peer_dc = [row['data_center'] for row in resultPeer if row['data_center']]
# dummy_dcs = ['dc_dummy1', 'dc_dummy2', 'dc_dummy3']
# dc_list = sorted(set([dc for dc in [local_dc] + peer_dc + dummy_dcs if dc]))
dc_list = sorted(set([dc for dc in [local_dc] + peer_dc if dc]))
return list(map(escape_value, dc_list)) if dc_list else [Hint('<dc_name_not_available>')]
except Exception as e:
print(f"Query failed: {e}")
return [Hint('<dc_name_not_available>')]
return list(map(escape_value, opts.difference(keysseen))) return list(map(escape_value, opts.difference(keysseen)))