[IMP] sql_db: simplify TestCursor, given that method execute() does not need overriding
bzr revid: rco@openerp.com-20140409130825-rnc9hqh9t16hqcaq
This commit is contained in:
parent
fd8fd0906f
commit
dda229273d
|
@ -389,7 +389,7 @@ class TestCursor(Cursor):
|
||||||
# in order to simulate commit and rollback, the cursor maintains a
|
# in order to simulate commit and rollback, the cursor maintains a
|
||||||
# savepoint at its last commit
|
# savepoint at its last commit
|
||||||
super(TestCursor, self).__init__(*args, **kwargs)
|
super(TestCursor, self).__init__(*args, **kwargs)
|
||||||
super(TestCursor, self).execute("SAVEPOINT test_cursor")
|
self.execute("SAVEPOINT test_cursor")
|
||||||
self._lock = threading.RLock()
|
self._lock = threading.RLock()
|
||||||
|
|
||||||
def acquire(self):
|
def acquire(self):
|
||||||
|
@ -398,9 +398,6 @@ class TestCursor(Cursor):
|
||||||
def release(self):
|
def release(self):
|
||||||
self._lock.release()
|
self._lock.release()
|
||||||
|
|
||||||
def execute(self, *args, **kwargs):
|
|
||||||
super(TestCursor, self).execute(*args, **kwargs)
|
|
||||||
|
|
||||||
def close(self, force=False):
|
def close(self, force=False):
|
||||||
if force:
|
if force:
|
||||||
super(TestCursor, self).close()
|
super(TestCursor, self).close()
|
||||||
|
@ -412,12 +409,12 @@ class TestCursor(Cursor):
|
||||||
_logger.debug("TestCursor.autocommit(%r) does nothing", on)
|
_logger.debug("TestCursor.autocommit(%r) does nothing", on)
|
||||||
|
|
||||||
def commit(self):
|
def commit(self):
|
||||||
super(TestCursor, self).execute("RELEASE SAVEPOINT test_cursor")
|
self.execute("RELEASE SAVEPOINT test_cursor")
|
||||||
super(TestCursor, self).execute("SAVEPOINT test_cursor")
|
self.execute("SAVEPOINT test_cursor")
|
||||||
|
|
||||||
def rollback(self):
|
def rollback(self):
|
||||||
super(TestCursor, self).execute("ROLLBACK TO SAVEPOINT test_cursor")
|
self.execute("ROLLBACK TO SAVEPOINT test_cursor")
|
||||||
super(TestCursor, self).execute("SAVEPOINT test_cursor")
|
self.execute("SAVEPOINT test_cursor")
|
||||||
|
|
||||||
class PsycoConnection(psycopg2.extensions.connection):
|
class PsycoConnection(psycopg2.extensions.connection):
|
||||||
pass
|
pass
|
||||||
|
|
Loading…
Reference in New Issue