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

Add a test for TokenAware against a local table.

Browse Source 
Fixed in 61b4fad, would previously blow up with KeyError
This commit is contained in:
Adam Holmberg
2014-12-23 16:17:35 -06:00
parent 0d9bf65691
commit f739fda8bc
1 changed files with 13 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
tests/integration/long/test_loadbalancingpolicies.py
View File

@@ -452,6 +452,19 @@ class LoadBalancingPolicyTests(unittest.TestCase):
self.coordinator_stats.assert_query_count_equals(self, 2, 0) self.coordinator_stats.assert_query_count_equals(self, 2, 0)
self.coordinator_stats.assert_query_count_equals(self, 3, 12) self.coordinator_stats.assert_query_count_equals(self, 3, 12)
def test_token_aware_with_local_table(self):
use_singledc()
cluster = Cluster(
load_balancing_policy=TokenAwarePolicy(RoundRobinPolicy()),
protocol_version=PROTOCOL_VERSION)
session = cluster.connect()
p = session.prepare("SELECT * FROM system.local WHERE key=?")
# this would blow up prior to 61b4fad
r = session.execute(p, ('local',))
self.assertEqual(len(r), 1)
self.assertEqual(r[0].key, 'local')
def test_white_list(self): def test_white_list(self):
use_singledc() use_singledc()
keyspace = 'test_white_list' keyspace = 'test_white_list'