diff options
Diffstat (limited to 'lib/sqlalchemy')
| -rw-r--r-- | lib/sqlalchemy/engine/base.py | 14 | ||||
| -rw-r--r-- | lib/sqlalchemy/logging.py | 9 |
2 files changed, 13 insertions, 10 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. diff --git a/lib/sqlalchemy/logging.py b/lib/sqlalchemy/logging.py index 2ced66109..caaecf302 100644 --- a/lib/sqlalchemy/logging.py +++ b/lib/sqlalchemy/logging.py @@ -66,10 +66,15 @@ def is_info_enabled(logger): return logger.isEnabledFor(logging.INFO) def instance_logger(instance, echoflag=None): - if echoflag: + if echoflag is not None: default_logging(_get_instance_name(instance)) l = logging.getLogger(_get_instance_name(instance)) - l.setLevel(echoflag == 'debug' and logging.DEBUG or logging.INFO) + if echoflag == 'debug': + l.setLevel(logging.DEBUG) + elif echoflag is True: + l.setLevel(logging.INFO) + elif echoflag is False: + l.setLevel(logging.NOTSET) else: l = logging.getLogger(_get_instance_name(instance)) instance._should_log_debug = l.isEnabledFor(logging.DEBUG) |