diff options
author | Daniele Varrazzo <daniele.varrazzo@gmail.com> | 2017-02-04 10:57:30 +0000 |
---|---|---|
committer | Daniele Varrazzo <daniele.varrazzo@gmail.com> | 2017-02-04 10:57:30 +0000 |
commit | ca59fd8b3f7f7082e72ade390914bec5d5f944bd (patch) | |
tree | ef4dd5738e304bff72e5ac9b0ca47e66977c5c42 | |
parent | c1e016e597e1ee2b52e5277a09793caa9401f39d (diff) | |
download | psycopg2-ca59fd8b3f7f7082e72ade390914bec5d5f944bd.tar.gz |
Test looking the transactions characteristics instead of the default
So we test the effect, not the implementation. Tests pass on master too
this way, three tests fail in this branch, related to autocommit
(sort-of-obviously).
-rwxr-xr-x | tests/test_connection.py | 56 |
1 files changed, 28 insertions, 28 deletions
diff --git a/tests/test_connection.py b/tests/test_connection.py index ea8b8f5..15d99b4 100755 --- a/tests/test_connection.py +++ b/tests/test_connection.py @@ -522,7 +522,7 @@ class IsolationLevelsTestCase(ConnectingTestCase): got_name = curs.fetchone()[0] if name is None: - curs.execute('show default_transaction_isolation;') + curs.execute('show transaction_isolation;') name = curs.fetchone()[0] self.assertEqual(name, got_name) @@ -1042,13 +1042,13 @@ class TransactionControlTests(ConnectingTestCase): cur = self.conn.cursor() self.conn.set_session( psycopg2.extensions.ISOLATION_LEVEL_SERIALIZABLE) - cur.execute("SHOW default_transaction_isolation;") + cur.execute("SHOW transaction_isolation;") self.assertEqual(cur.fetchone()[0], 'serializable') self.conn.rollback() self.conn.set_session( psycopg2.extensions.ISOLATION_LEVEL_REPEATABLE_READ) - cur.execute("SHOW default_transaction_isolation;") + cur.execute("SHOW transaction_isolation;") if self.conn.server_version > 80000: self.assertEqual(cur.fetchone()[0], 'repeatable read') else: @@ -1057,13 +1057,13 @@ class TransactionControlTests(ConnectingTestCase): self.conn.set_session( isolation_level=psycopg2.extensions.ISOLATION_LEVEL_READ_COMMITTED) - cur.execute("SHOW default_transaction_isolation;") + cur.execute("SHOW transaction_isolation;") self.assertEqual(cur.fetchone()[0], 'read committed') self.conn.rollback() self.conn.set_session( isolation_level=psycopg2.extensions.ISOLATION_LEVEL_READ_UNCOMMITTED) - cur.execute("SHOW default_transaction_isolation;") + cur.execute("SHOW transaction_isolation;") if self.conn.server_version > 80000: self.assertEqual(cur.fetchone()[0], 'read uncommitted') else: @@ -1073,12 +1073,12 @@ class TransactionControlTests(ConnectingTestCase): def test_set_isolation_level_str(self): cur = self.conn.cursor() self.conn.set_session("serializable") - cur.execute("SHOW default_transaction_isolation;") + cur.execute("SHOW transaction_isolation;") self.assertEqual(cur.fetchone()[0], 'serializable') self.conn.rollback() self.conn.set_session("repeatable read") - cur.execute("SHOW default_transaction_isolation;") + cur.execute("SHOW transaction_isolation;") if self.conn.server_version > 80000: self.assertEqual(cur.fetchone()[0], 'repeatable read') else: @@ -1086,12 +1086,12 @@ class TransactionControlTests(ConnectingTestCase): self.conn.rollback() self.conn.set_session("read committed") - cur.execute("SHOW default_transaction_isolation;") + cur.execute("SHOW transaction_isolation;") self.assertEqual(cur.fetchone()[0], 'read committed') self.conn.rollback() self.conn.set_session("read uncommitted") - cur.execute("SHOW default_transaction_isolation;") + cur.execute("SHOW transaction_isolation;") if self.conn.server_version > 80000: self.assertEqual(cur.fetchone()[0], 'read uncommitted') else: @@ -1106,57 +1106,57 @@ class TransactionControlTests(ConnectingTestCase): def test_set_read_only(self): cur = self.conn.cursor() self.conn.set_session(readonly=True) - cur.execute("SHOW default_transaction_read_only;") + cur.execute("SHOW transaction_read_only;") self.assertEqual(cur.fetchone()[0], 'on') self.conn.rollback() - cur.execute("SHOW default_transaction_read_only;") + cur.execute("SHOW transaction_read_only;") self.assertEqual(cur.fetchone()[0], 'on') self.conn.rollback() cur = self.conn.cursor() self.conn.set_session(readonly=None) - cur.execute("SHOW default_transaction_read_only;") + cur.execute("SHOW transaction_read_only;") self.assertEqual(cur.fetchone()[0], 'on') self.conn.rollback() self.conn.set_session(readonly=False) - cur.execute("SHOW default_transaction_read_only;") + cur.execute("SHOW transaction_read_only;") self.assertEqual(cur.fetchone()[0], 'off') self.conn.rollback() def test_set_default(self): cur = self.conn.cursor() - cur.execute("SHOW default_transaction_isolation;") - default_isolevel = cur.fetchone()[0] - cur.execute("SHOW default_transaction_read_only;") - default_readonly = cur.fetchone()[0] + cur.execute("SHOW transaction_isolation;") + isolevel = cur.fetchone()[0] + cur.execute("SHOW transaction_read_only;") + readonly = cur.fetchone()[0] self.conn.rollback() self.conn.set_session(isolation_level='serializable', readonly=True) self.conn.set_session(isolation_level='default', readonly='default') - cur.execute("SHOW default_transaction_isolation;") - self.assertEqual(cur.fetchone()[0], default_isolevel) - cur.execute("SHOW default_transaction_read_only;") - self.assertEqual(cur.fetchone()[0], default_readonly) + cur.execute("SHOW transaction_isolation;") + self.assertEqual(cur.fetchone()[0], isolevel) + cur.execute("SHOW transaction_read_only;") + self.assertEqual(cur.fetchone()[0], readonly) @skip_before_postgres(9, 1) def test_set_deferrable(self): cur = self.conn.cursor() self.conn.set_session(readonly=True, deferrable=True) - cur.execute("SHOW default_transaction_read_only;") + cur.execute("SHOW transaction_read_only;") self.assertEqual(cur.fetchone()[0], 'on') - cur.execute("SHOW default_transaction_deferrable;") + cur.execute("SHOW transaction_deferrable;") self.assertEqual(cur.fetchone()[0], 'on') self.conn.rollback() - cur.execute("SHOW default_transaction_deferrable;") + cur.execute("SHOW transaction_deferrable;") self.assertEqual(cur.fetchone()[0], 'on') self.conn.rollback() self.conn.set_session(deferrable=False) - cur.execute("SHOW default_transaction_read_only;") + cur.execute("SHOW transaction_read_only;") self.assertEqual(cur.fetchone()[0], 'on') - cur.execute("SHOW default_transaction_deferrable;") + cur.execute("SHOW transaction_deferrable;") self.assertEqual(cur.fetchone()[0], 'off') self.conn.rollback() @@ -1258,9 +1258,9 @@ class AutocommitTests(ConnectingTestCase): self.assertEqual(self.conn.status, psycopg2.extensions.STATUS_READY) self.assertEqual(self.conn.get_transaction_status(), psycopg2.extensions.TRANSACTION_STATUS_IDLE) - cur.execute("SHOW default_transaction_isolation;") + cur.execute("SHOW transaction_isolation;") self.assertEqual(cur.fetchone()[0], 'serializable') - cur.execute("SHOW default_transaction_read_only;") + cur.execute("SHOW transaction_read_only;") self.assertEqual(cur.fetchone()[0], 'on') |