Revision 5ee6b3e5 pithos/backends/lib/sqlalchemy/dbwrapper.py

b/pithos/backends/lib/sqlalchemy/dbwrapper.py
32 32 
# or implied, of GRNET S.A.
33 33 

  		





  34
  34
  
    
from sqlalchemy import create_engine


  		





  
  35
  
    
from sqlalchemy.pool import NullPool


  		





  35
  36
  
    

  		





  36
  37
  
    
class DBWrapper(object):


  		





  37
  38
  
    
    """Database connection wrapper."""


  		





  38
  39
  
    
    


  		





  39
  40
  
    
    def __init__(self, db):


  		





  40
  
  
    
        self.engine = create_engine(db)


  		





  
  41
  
    
        if db.startswith('sqlite://'):


  		





  
  42
  
    
            self.engine = create_engine(db, connect_args={'check_same_thread': False}, poolclass=NullPool)


  		





  
  43
  
    
        else:


  		





  
  44
  
    
            self.engine = create_engine(db)


  		





  41
  45
  
    
        self.conn = self.engine.connect()


  		





  42
  46
  
    
        self.trans = None


  		





  43
  47
  
    
    


  		












Also available in:
  Unified diff