diff options
| author | Mike Bayer <mike_mp@zzzcomputing.com> | 2010-12-30 14:22:43 -0500 |
|---|---|---|
| committer | Mike Bayer <mike_mp@zzzcomputing.com> | 2010-12-30 14:22:43 -0500 |
| commit | 426c4356eba28f8bb25b7685e43e49e2ed1131e6 (patch) | |
| tree | cbb0ac64aa40905e96005393636a153217d724ba /lib/sqlalchemy/interfaces.py | |
| parent | ecf1571ba79a81567428d345a4ec10255305de97 (diff) | |
| download | sqlalchemy-426c4356eba28f8bb25b7685e43e49e2ed1131e6.tar.gz | |
- removes the "on_" prefix.
Diffstat (limited to 'lib/sqlalchemy/interfaces.py')
| -rw-r--r-- | lib/sqlalchemy/interfaces.py | 32 |
1 files changed, 16 insertions, 16 deletions
diff --git a/lib/sqlalchemy/interfaces.py b/lib/sqlalchemy/interfaces.py index 26910a5e6..f30602a1e 100644 --- a/lib/sqlalchemy/interfaces.py +++ b/lib/sqlalchemy/interfaces.py @@ -78,13 +78,13 @@ class PoolListener(object): listener = util.as_interface(listener, methods=('connect', 'first_connect', 'checkout', 'checkin')) if hasattr(listener, 'connect'): - event.listen(self, 'on_connect', listener.connect) + event.listen(self, 'connect', listener.connect) if hasattr(listener, 'first_connect'): - event.listen(self, 'on_first_connect', listener.first_connect) + event.listen(self, 'first_connect', listener.first_connect) if hasattr(listener, 'checkout'): - event.listen(self, 'on_checkout', listener.checkout) + event.listen(self, 'checkout', listener.checkout) if hasattr(listener, 'checkin'): - event.listen(self, 'on_checkin', listener.checkin) + event.listen(self, 'checkin', listener.checkin) def connect(self, dbapi_con, con_record): @@ -187,7 +187,7 @@ class ConnectionProxy(object): clauseelement, *multiparams, **params) - event.listen(self, 'on_before_execute', adapt_execute) + event.listen(self, 'before_execute', adapt_execute) def adapt_cursor_execute(conn, cursor, statement, parameters,context, executemany, ): @@ -209,7 +209,7 @@ class ConnectionProxy(object): executemany, ) - event.listen(self, 'on_before_cursor_execute', adapt_cursor_execute) + event.listen(self, 'before_cursor_execute', adapt_cursor_execute) def do_nothing_callback(*arg, **kw): pass @@ -221,23 +221,23 @@ class ConnectionProxy(object): return util.update_wrapper(go, fn) - event.listen(self, 'on_begin', adapt_listener(listener.begin)) - event.listen(self, 'on_rollback', + event.listen(self, 'begin', adapt_listener(listener.begin)) + event.listen(self, 'rollback', adapt_listener(listener.rollback)) - event.listen(self, 'on_commit', adapt_listener(listener.commit)) - event.listen(self, 'on_savepoint', + event.listen(self, 'commit', adapt_listener(listener.commit)) + event.listen(self, 'savepoint', adapt_listener(listener.savepoint)) - event.listen(self, 'on_rollback_savepoint', + event.listen(self, 'rollback_savepoint', adapt_listener(listener.rollback_savepoint)) - event.listen(self, 'on_release_savepoint', + event.listen(self, 'release_savepoint', adapt_listener(listener.release_savepoint)) - event.listen(self, 'on_begin_twophase', + event.listen(self, 'begin_twophase', adapt_listener(listener.begin_twophase)) - event.listen(self, 'on_prepare_twophase', + event.listen(self, 'prepare_twophase', adapt_listener(listener.prepare_twophase)) - event.listen(self, 'on_rollback_twophase', + event.listen(self, 'rollback_twophase', adapt_listener(listener.rollback_twophase)) - event.listen(self, 'on_commit_twophase', + event.listen(self, 'commit_twophase', adapt_listener(listener.commit_twophase)) |