Using SingletonThreadPool for MySQL connection for thread safety and …

…connection recycling
NerdfighterSean · Apr 19, 2013 · 6a82729 · 6a82729
1 parent 3416c50
commit 6a82729
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/btctip/db.py b/src/btctip/db.py
@@ -1,6 +1,7 @@
 #!/usr/bin/env python
 
 from sqlalchemy import create_engine, Table, Column, Integer, String, MetaData, ForeignKey, Numeric, UnicodeText
+from sqlalchemy.pool import SingletonThreadPool
 
 class BitcointipDatabase:
 
@@ -73,6 +74,6 @@ def __init__(self, dsn_url):
 
   def connect(self):
     '''Return a connection object'''
-    engine = create_engine(self.dsn_url)
+    engine = create_engine(self.dsn_url, echo_pool=True, pool_recycle=60, poolclass=SingletonThreadPool)
     self.metadata.create_all(engine)
-    return engine
+    return engine