diff options
Diffstat (limited to 'trove/guestagent/utils/mysql.py')
| -rw-r--r-- | trove/guestagent/utils/mysql.py | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/trove/guestagent/utils/mysql.py b/trove/guestagent/utils/mysql.py index d3511fa7..0c6d8a1d 100644 --- a/trove/guestagent/utils/mysql.py +++ b/trove/guestagent/utils/mysql.py @@ -26,14 +26,14 @@ FLUSH = text(sql_query.FLUSH) class SqlClient(object): """A sqlalchemy wrapper to manage transactions.""" - def __init__(self, engine, use_flush=True): + def __init__(self, engine, use_flush=False): self.engine = engine self.use_flush = use_flush def __enter__(self): self.conn = self.engine.connect() self.trans = self.conn.begin() - return self.conn + return self def __exit__(self, type, value, traceback): if self.trans: @@ -49,10 +49,11 @@ class SqlClient(object): LOG.debug('Execute SQL: %s', t) try: return self.conn.execute(t, kwargs) - except Exception: + except Exception as err: + LOG.error(f'Failed to execute SQL {t}, error: {err}') self.trans.rollback() self.trans = None - raise + raise err class BaseKeepAliveConnection(interfaces.PoolListener): |