add unit tests for setting the connection pool size
This commit is contained in:
parent
3f31666796
commit
2579ed754f
@ -285,8 +285,7 @@ class ConnectionTest(unittest.TestCase):
|
|||||||
self.assertTrue(isinstance(conn, pymongo.mongo_client.MongoClient))
|
self.assertTrue(isinstance(conn, pymongo.mongo_client.MongoClient))
|
||||||
|
|
||||||
def test_connection_kwargs(self):
|
def test_connection_kwargs(self):
|
||||||
"""Ensure that connection kwargs get passed to pymongo.
|
"""Ensure that connection kwargs get passed to pymongo."""
|
||||||
"""
|
|
||||||
connect('mongoenginetest', alias='t1', tz_aware=True)
|
connect('mongoenginetest', alias='t1', tz_aware=True)
|
||||||
conn = get_connection('t1')
|
conn = get_connection('t1')
|
||||||
|
|
||||||
@ -296,6 +295,29 @@ class ConnectionTest(unittest.TestCase):
|
|||||||
conn = get_connection('t2')
|
conn = get_connection('t2')
|
||||||
self.assertFalse(get_tz_awareness(conn))
|
self.assertFalse(get_tz_awareness(conn))
|
||||||
|
|
||||||
|
def test_connection_pool_via_kwarg(self):
|
||||||
|
"""Ensure we can specify a max connection pool size using
|
||||||
|
a connection kwarg.
|
||||||
|
"""
|
||||||
|
# Use "max_pool_size" or "maxpoolsize" depending on PyMongo version
|
||||||
|
# (former was changed to the latter as described in
|
||||||
|
# https://jira.mongodb.org/browse/PYTHON-854).
|
||||||
|
# TODO remove once PyMongo < 3.0 support is dropped
|
||||||
|
if pymongo.version_tuple[0] >= 3:
|
||||||
|
pool_size_kwargs = {'maxpoolsize': 100}
|
||||||
|
else:
|
||||||
|
pool_size_kwargs = {'max_pool_size': 100}
|
||||||
|
|
||||||
|
conn = connect('mongoenginetest', alias='t1', **pool_size_kwargs)
|
||||||
|
self.assertEqual(conn.max_pool_size, 100)
|
||||||
|
|
||||||
|
def test_connection_pool_via_uri(self):
|
||||||
|
"""Ensure we can specify a max connection pool size using
|
||||||
|
an option in a connection URI.
|
||||||
|
"""
|
||||||
|
conn = connect(host='mongodb://localhost/test?maxpoolsize=100')
|
||||||
|
self.assertEqual(conn.max_pool_size, 100)
|
||||||
|
|
||||||
def test_write_concern(self):
|
def test_write_concern(self):
|
||||||
"""Ensure write concern can be specified in connect() via
|
"""Ensure write concern can be specified in connect() via
|
||||||
a kwarg or as part of the connection URI.
|
a kwarg or as part of the connection URI.
|
||||||
|
Loading…
x
Reference in New Issue
Block a user