summaryrefslogtreecommitdiff
path: root/tests/pipeline.py
diff options
context:
space:
mode:
authorKonstantin Merenkov <kmerenkov@gmail.com>2010-04-12 15:07:31 +0800
committerAndy McCurdy <andy@andymccurdy.com>2010-04-12 15:54:21 +0800
commit4dec96f235d3d1ef9fd1eb8a1549b75caae36c59 (patch)
treeec81f231b43d4d116e1f4fc87f10c15e772d95e8 /tests/pipeline.py
parent4efa5de487363b7c1d86b0a6a6719dee7fe507b4 (diff)
downloadredis-py-4dec96f235d3d1ef9fd1eb8a1549b75caae36c59.tar.gz
[issue 29] Redis instance doesn't use shared connection pool by default
* Redis constructor accepts connection_pool keyword argument, that defaults to None (no shared connection pool). However, you can create ConnectionManager instance yourself and pass it to as many Redis instances as you want, making them use shared connection pool. * Renamed ConnectionManager to ConnectionPool. * Exported ConnectionPool, so now you can import it in your code and create instances. * Removed test_pipeline_with_fresh_connection test, since all redis instances don't use shared pool by default now. * corrected few typos in comments. * repaired the rest of tests.
Diffstat (limited to 'tests/pipeline.py')
-rw-r--r--tests/pipeline.py13
1 files changed, 3 insertions, 10 deletions
diff --git a/tests/pipeline.py b/tests/pipeline.py
index f9c8dfa..dcbfb0a 100644
--- a/tests/pipeline.py
+++ b/tests/pipeline.py
@@ -24,20 +24,13 @@ class PipelineTestCase(unittest.TestCase):
]
)
- def test_pipeline_with_fresh_connection(self):
- redis.client.connection_manager.connections.clear()
- self.client = redis.Redis(host='localhost', port=6379, db=9)
- pipe = self.client.pipeline()
- pipe.set('a', 'b')
- self.assertEquals(pipe.execute(), [True])
-
def test_invalid_command_in_pipeline(self):
# all commands but the invalid one should be excuted correctly
self.client['c'] = 'a'
pipe = self.client.pipeline()
pipe.set('a', 1).set('b', 2).lpush('c', 3).set('d', 4)
result = pipe.execute()
-
+
self.assertEquals(result[0], True)
self.assertEquals(self.client['a'], '1')
self.assertEquals(result[1], True)
@@ -48,11 +41,11 @@ class PipelineTestCase(unittest.TestCase):
self.assertEquals(self.client['c'], 'a')
self.assertEquals(result[3], True)
self.assertEquals(self.client['d'], '4')
-
+
# make sure the pipe was restored to a working state
self.assertEquals(pipe.set('z', 'zzz').execute(), [True])
self.assertEquals(self.client['z'], 'zzz')
-
+
def test_pipeline_cannot_select(self):
pipe = self.client.pipeline()
self.assertRaises(redis.RedisError,