Changeset 8356

Timestamp:

17/06/12 15:01:51 (8 years ago)

Author:

mnagni

Message:

Integrated a connection pool

File:

• mauRepo/HPFos/trunk/src/libs/commons_db.py (modified) (5 diffs)

mauRepo/HPFos/trunk/src/libs/commons_db.py

@@ -32 +32 @@
 '''
 from sqlalchemy import MetaData, create_engine
-from sqlalchemy.orm import sessionmaker, scoped_session
+from sqlalchemy.orm import sessionmaker
 from sqlalchemy.sql.expression import text
 class DbManagerCollection(object):
@@ -52 +52 @@
         Represents a database instance managed by an SQLAlchemy engine.        
     """
-    def __init__(self, connection, script = None, sql_echo=False, session_event_manager = None):
+    def __init__(self, connection, script = None, sql_echo=False, session_event_manager = None, ipool_size = 10):
         """
           @param connection: the URL used to open a connection to the database
@@ -58 +58 @@
           @param sql_echo: sets the SQLalchemy create_engine.echo param. Default is False 
           @param session_event_manager: a python method defining session events \
-          (see http://docs.sqlalchemy.org/en/latest/orm/events.html?highlight=session%20events#sqlalchemy.orm.events.SessionEvents)     
+          (see http://docs.sqlalchemy.org/en/latest/orm/events.html?highlight=session%20events#sqlalchemy.orm.events.SessionEvents)
+          @param ipool_size: sets the connections pool size (note that this is the maximum size not the number of the pre-allocated ones)               
         """
         self._connection = connection        
@@ -64 +65 @@
         self.engine = None
         try:
-            self.engine = create_engine(self._connection, echo=sql_echo)
+            self.engine = create_engine(self._connection, pool_size = ipool_size, pool_recycle=3600, echo=sql_echo)
         except Exception as e:
             print e
@@ -73 +74 @@
             self._script(self.metadata)
             self.metadata.create_all(bind=self.engine)
-            #self._session = scoped_session(sessionmaker())
         if self.engine:
             self.engine.connect()