diff options
Diffstat (limited to 'lib/sqlalchemy/engine/base.py')
| -rw-r--r-- | lib/sqlalchemy/engine/base.py | 14 |
1 files changed, 6 insertions, 8 deletions
diff --git a/lib/sqlalchemy/engine/base.py b/lib/sqlalchemy/engine/base.py index c13c1d946..496af751b 100644 --- a/lib/sqlalchemy/engine/base.py +++ b/lib/sqlalchemy/engine/base.py @@ -672,7 +672,8 @@ class Connection(Connectable): def _begin_impl(self): if self.__connection.is_valid: - self.__engine.logger.info("BEGIN") + if self.__engine._should_log_info: + self.__engine.logger.info("BEGIN") try: self.__engine.dialect.do_begin(self.connection) except Exception, e: @@ -680,7 +681,8 @@ class Connection(Connectable): def _rollback_impl(self): if self.__connection.is_valid: - self.__engine.logger.info("ROLLBACK") + if self.__engine._should_log_info: + self.__engine.logger.info("ROLLBACK") try: self.__engine.dialect.do_rollback(self.connection) except Exception, e: @@ -689,7 +691,8 @@ class Connection(Connectable): def _commit_impl(self): if self.__connection.is_valid: - self.__engine.logger.info("COMMIT") + if self.__engine._should_log_info: + self.__engine.logger.info("COMMIT") try: self.__engine.dialect.do_commit(self.connection) except Exception, e: @@ -1168,11 +1171,6 @@ class Engine(Connectable): return self.pool.unique_connection() - def log(self, msg): - """Log a message using this SQLEngine's logger stream.""" - - self.logger.info(msg) - class ResultProxy(object): """Wraps a DB-API cursor object to provide easier access to row columns. |