as torndb.
"""
-
-
import itertools
import logging
import psycopg2
+# Setup logging
+log = logging.getLogger("pakfire.buildservice.database")
+
class Connection(object):
"""
A lightweight wrapper around MySQLdb DB-API connections.
try:
self.reconnect()
except Exception:
- logging.error("Cannot connect to database on %s", self.host, exc_info=True)
+ log.error("Cannot connect to database on %s", self.host, exc_info=True)
def __del__(self):
self.close()
return self._db.cursor()
def _execute(self, cursor, query, parameters, kwparameters):
- logging.debug("Executing SQL: %s" % (query % (kwparameters or parameters)))
+ log.debug("Executing SQL: %s" % (query % (kwparameters or parameters)))
try:
return cursor.execute(query, kwparameters or parameters)
except OperationalError:
- logging.error("Error connecting to database on %s", self.host)
+ log.error("Error connecting to database on %s", self.host)
self.close()
raise