diff options
Diffstat (limited to 'test/engine/test_pool.py')
-rw-r--r-- | test/engine/test_pool.py | 86 |
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 |