summaryrefslogtreecommitdiff
path: root/test/engine/test_pool.py
diff options
context:
space:
mode:
Diffstat (limited to 'test/engine/test_pool.py')
-rw-r--r--test/engine/test_pool.py86
1 files changed, 0 insertions, 86 deletions
diff --git a/test/engine/test_pool.py b/test/engine/test_pool.py
index f29373e95..3c2257331 100644
--- a/test/engine/test_pool.py
+++ b/test/engine/test_pool.py
@@ -1817,92 +1817,6 @@ class ResetOnReturnTest(PoolTestBase):
assert not dbapi.connect().rollback.called
assert not dbapi.connect().commit.called
- def test_agent_rollback(self):
- dbapi, p = self._fixture(reset_on_return="rollback")
-
- class Agent(object):
- def __init__(self, conn):
- self.conn = conn
-
- is_active = True
-
- def rollback(self):
- self.conn.special_rollback()
-
- def commit(self):
- self.conn.special_commit()
-
- c1 = p.connect()
- c1._reset_agent = Agent(c1)
- c1.close()
-
- assert dbapi.connect().special_rollback.called
- assert not dbapi.connect().special_commit.called
-
- assert not dbapi.connect().rollback.called
- assert not dbapi.connect().commit.called
-
- c1 = p.connect()
- c1.close()
- eq_(dbapi.connect().special_rollback.call_count, 1)
- eq_(dbapi.connect().special_commit.call_count, 0)
-
- assert dbapi.connect().rollback.called
- assert not dbapi.connect().commit.called
-
- def test_agent_commit(self):
- dbapi, p = self._fixture(reset_on_return="commit")
-
- class Agent(object):
- def __init__(self, conn):
- self.conn = conn
-
- is_active = True
-
- def rollback(self):
- self.conn.special_rollback()
-
- def commit(self):
- self.conn.special_commit()
-
- c1 = p.connect()
- c1._reset_agent = Agent(c1)
- c1.close()
- assert not dbapi.connect().special_rollback.called
- assert dbapi.connect().special_commit.called
-
- assert not dbapi.connect().rollback.called
- assert not dbapi.connect().commit.called
-
- c1 = p.connect()
- c1.close()
-
- eq_(dbapi.connect().special_rollback.call_count, 0)
- eq_(dbapi.connect().special_commit.call_count, 1)
- assert not dbapi.connect().rollback.called
- assert dbapi.connect().commit.called
-
- def test_reset_agent_disconnect(self):
- dbapi, p = self._fixture(reset_on_return="rollback")
-
- class Agent(object):
- def __init__(self, conn):
- self.conn = conn
-
- def rollback(self):
- p._invalidate(self.conn)
- raise Exception("hi")
-
- def commit(self):
- self.conn.commit()
-
- c1 = p.connect()
- c1._reset_agent = Agent(c1)
- c1.close()
-
- # no warning raised. We know it would warn due to
- # QueuePoolTest.test_no_double_checkin
-
class SingletonThreadPoolTest(PoolTestBase):
@testing.requires.threading_with_mock