iro/model/utils.py
branchdevel
changeset 117 351a02310dd8
parent 115 323d06431100
child 122 b55754aa4f96
--- a/iro/model/utils.py	Fri Jan 27 21:14:18 2012 +0100
+++ b/iro/model/utils.py	Fri Jan 27 21:21:41 2012 +0100
@@ -1,32 +1,5 @@
 from sqlalchemy.orm import sessionmaker
 
-from twisted.internet import threads
-from twisted.python.threadpool import ThreadPool
-
-from functools import wraps
-
-POOL_SIZE=5     #how many threads should the db connector pool should have
-
-class Data:
-    def __init__(self):
-        self.pool =  ThreadPool(minthreads=1, maxthreads=POOL_SIZE, name='database')
-        self.reactor = None
-
-d = Data()
-
-def startPool(reactor): 
-    d.pool.start()
-    d.reactor = reactor
-    d.reactor.addSystemEventTrigger('before', 'shutdown', d.pool.stop)
-
-def run_in_db_thread(f):
-    """Decorator to run DB queries in Twisted's thread pool"""
-    @wraps(f)
-    def wrapper(*args, **kwargs):
-        return threads.deferToThreadPool(d.reactor, d.pool, f, *args, **kwargs)
-    return wrapper
-
-
 class WithSession(object):
     '''a with statement for a database session connection'''
     def __init__(self, engine, autocommit=False):
@@ -45,19 +18,5 @@
             self.session.rollback()
         self.session.close()
 
-class DBDefer(object):
-    '''a twisted sqlalchemy connector this Decorator adds a session parameter, with a valid session connection'''
-    def __init__(self, engine, autocommit=False):
-        self.autocommit=autocommit
-        self.engine = engine
 
-    def __call__(self, func):
-        @run_in_db_thread
-        @wraps(func)
-        def wrapper(*args, **kwargs):
-            with WithSession(self.engine, self.autocommit) as session:
-                return func(*args, session=session, **kwargs)
-        return wrapper
 
-def vTyp(value,field):
-    return value