Skip to content

Added tests for PYTHON-888 #910

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
beltran merged 1 commit into from
Jan 24, 2018
Merged

Added tests for PYTHON-888 #910

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
80 changes: 80 additions & 0 deletions tests/integration/cqlengine/query/test_batch_query.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
from tests.integration.cqlengine.base import BaseCassEngTestCase
from tests.integration.cqlengine import execute_count
from cassandra.cluster import Session
from cassandra.query import BatchType as cassandra_BatchType
from cassandra.cqlengine.query import BatchType as cqlengine_BatchType


class TestMultiKeyModel(Model):
Expand All @@ -37,6 +39,11 @@ class BatchQueryLogModel(Model):
k = columns.Integer(primary_key=True)
v = columns.Integer()


class CounterBatchQueryModel(Model):
k = columns.Integer(primary_key=True)
v = columns.Counter()

class BatchQueryTests(BaseCassEngTestCase):

@classmethod
Expand Down Expand Up @@ -209,3 +216,76 @@ def test_batch_execute_no_timeout(self):
with BatchQuery() as b:
BatchQueryLogModel.batch(b).create(k=2, v=2)
self.assertEqual(mock_execute.call_args[-1]['timeout'], NOT_SET)


class BatchTypeQueryTests(BaseCassEngTestCase):
def setUp(self):
sync_table(TestMultiKeyModel)
sync_table(CounterBatchQueryModel)

def tearDown(self):
drop_table(TestMultiKeyModel)
drop_table(CounterBatchQueryModel)

@execute_count(6)
def test_cassandra_batch_type(self):
"""
Tests the different types of `class: cassandra.query.BatchType`

@since 3.13
@jira_ticket PYTHON-88
@expected_result batch query succeeds and the results
are correctly readen

@test_category query
"""
with BatchQuery(batch_type=cassandra_BatchType.UNLOGGED) as b:
TestMultiKeyModel.batch(b).create(partition=1, cluster=1)
TestMultiKeyModel.batch(b).create(partition=1, cluster=2)

obj = TestMultiKeyModel.objects(partition=1)
self.assertEqual(2, len(obj))

with BatchQuery(batch_type=cassandra_BatchType.COUNTER) as b:
CounterBatchQueryModel.batch(b).create(k=1, v=1)
CounterBatchQueryModel.batch(b).create(k=1, v=2)
CounterBatchQueryModel.batch(b).create(k=1, v=10)

obj = CounterBatchQueryModel.objects(k=1)
self.assertEqual(1, len(obj))
self.assertEqual(obj[0].v, 13)

with BatchQuery(batch_type=cassandra_BatchType.LOGGED) as b:
TestMultiKeyModel.batch(b).create(partition=1, cluster=1)
TestMultiKeyModel.batch(b).create(partition=1, cluster=2)

obj = TestMultiKeyModel.objects(partition=1)
self.assertEqual(2, len(obj))

@execute_count(4)
def test_cqlengine_batch_type(self):
"""
Tests the different types of `class: cassandra.cqlengine.query.BatchType`

@since 3.13
@jira_ticket PYTHON-88
@expected_result batch query succeeds and the results
are correctly readen

@test_category query
"""
with BatchQuery(batch_type=cqlengine_BatchType.Unlogged) as b:
TestMultiKeyModel.batch(b).create(partition=1, cluster=1)
TestMultiKeyModel.batch(b).create(partition=1, cluster=2)

obj = TestMultiKeyModel.objects(partition=1)
self.assertEqual(2, len(obj))

with BatchQuery(batch_type=cqlengine_BatchType.Counter) as b:
CounterBatchQueryModel.batch(b).create(k=1, v=1)
CounterBatchQueryModel.batch(b).create(k=1, v=2)
CounterBatchQueryModel.batch(b).create(k=1, v=10)

obj = CounterBatchQueryModel.objects(k=1)
self.assertEqual(1, len(obj))
self.assertEqual(obj[0].v, 13)