Fix connection parameters for sqlite through sqlalchemy.
authorSofia Papagiannaki <papagian@gmail.com>
Mon, 12 Sep 2011 10:29:34 +0000 (13:29 +0300)
committerSofia Papagiannaki <papagian@gmail.com>
Mon, 12 Sep 2011 10:29:34 +0000 (13:29 +0300)
pithos/backends/lib/sqlalchemy/dbwrapper.py

index a4465b2..2ac0e35 100644 (file)
 # or implied, of GRNET S.A.
 
 from sqlalchemy import create_engine
+from sqlalchemy.pool import NullPool
 
 class DBWrapper(object):
     """Database connection wrapper."""
     
     def __init__(self, db):
-        self.engine = create_engine(db)
+        if db.startswith('sqlite://'):
+            self.engine = create_engine(db, connect_args={'check_same_thread': False}, poolclass=NullPool)
+        else:
+            self.engine = create_engine(db)
         self.conn = self.engine.connect()
         self.trans = None