summaryrefslogtreecommitdiff
path: root/bin/sql_db.py
diff options
context:
space:
mode:
authorOlivier Laurent <olt@tinyerp.com>2008-12-15 17:25:07 +0100
committerOlivier Laurent <olt@tinyerp.com>2008-12-15 17:25:07 +0100
commit8deaf883c75ff71e3bee3a871df89f12dafb87b2 (patch)
treee26af93546384b88297639526063fbdf391632f7 /bin/sql_db.py
parent9f9f2ff78e08cd826f09f3f7dab0a80723112bbf (diff)
parentbe2a0a76bbd95ce83cc68a10ce25e5b60279a0e6 (diff)
merge
bzr revid: olt@tinyerp.com-20081215162507-8oox01yssbfbbetf
Diffstat (limited to 'bin/sql_db.py')
-rw-r--r--bin/sql_db.py8
1 files changed, 4 insertions, 4 deletions
diff --git a/bin/sql_db.py b/bin/sql_db.py
index 08b6a25da79..3f4e23cc392 100644
--- a/bin/sql_db.py
+++ b/bin/sql_db.py
@@ -117,7 +117,7 @@ class Cursor(object):
if self.sql_log:
now = mdt.now()
-
+
res = self._obj.execute(query, p or None)
if self.sql_log:
@@ -213,15 +213,15 @@ class PoolManager(object):
logger = netsvc.Logger()
try:
logger.notifyChannel('dbpool', netsvc.LOG_INFO, 'Connecting to %s' % (db_name,))
- PoolManager._pools[db_name] = ConnectionPool(ThreadedConnectionPool(0, PoolManager.maxconn, PoolManager.dsn(db_name)), db_name)
+ PoolManager._pools[db_name] = ConnectionPool(ThreadedConnectionPool(1, PoolManager.maxconn, PoolManager.dsn(db_name)), db_name)
except Exception, e:
- logger.notifyChannel('dbpool', netsvc.LOG_CRITICAL, 'Unable to connect to %s: %r' % (db_name, e))
+ logger.notifyChannel('dbpool', netsvc.LOG_CRITICAL, 'Unable to connect to %s: %s' % (db_name, e.message))
raise
return PoolManager._pools[db_name]
get = staticmethod(get)
def close(db_name):
- if db_name is PoolManager._pools:
+ if db_name in PoolManager._pools:
logger.notifyChannel('dbpool', netsvc.LOG_INFO, 'Closing all connections to %s' % (db_name,))
PoolManager._pools[db_name].closeall()
del PoolManager._pools[db_name]