implement insert or ignore database statements

[pithos] / pithos / backends / lib / sqlalchemy / dbwrapper.py

diff --git a/pithos/backends/lib/sqlalchemy/dbwrapper.py b/pithos/backends/lib/sqlalchemy/dbwrapper.py
index 2ac0e35..a4465b2 100644 (file)
--- a/pithos/backends/lib/sqlalchemy/dbwrapper.py
+++ b/pithos/backends/lib/sqlalchemy/dbwrapper.py
@@ -32,16 +32,12 @@
 # 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):
-        if db.startswith('sqlite://'):
-            self.engine = create_engine(db, connect_args={'check_same_thread': False}, poolclass=NullPool)
-        else:
-            self.engine = create_engine(db)
+        self.engine = create_engine(db)
         self.conn = self.engine.connect()
         self.trans = None