Open and close database connection explicitly.

coldsweat/app.py

@@ -12,6 +12,8 @@
 from webob import Request, Response
 from webob.exc import *
 
+from models import connect, close
+
 from utilities import *
 from coldsweat import *
 
@@ -70,9 +72,11 @@ def __call__(self, environ, start_response):
         self.request            = request
         self.application_url    = request.application_url
 
+        connect()
         response = handler(*args)
         if not response:
             response = Response() # Provide an empty response
+        close()
 
         return response(environ, start_response)
 

coldsweat/commands.py

@@ -247,9 +247,14 @@ def run():
 
     command_name, command_args = args[0].lower(), args[1:]
 
+    connect()
     cc = CommandController()
     try:
         cc.run_command(command_name, command_options, command_args)
     except CommandError, ex:
         parser.error(ex)
-
+    finally:
+        close()
+        # Flush and close all logging handlers
+        import logging
+        logging.shutdown()

coldsweat/controllers.py

@@ -25,15 +25,7 @@
 from fetcher import *
 
 
-class BaseController(object):
-
-    def __init__(self):
-        connect()
-
-    def __del__(self):
-        close()
-
-class UserController(BaseController):
+class UserController(object):
     '''
     Base user controller class. Derived classes may need to override the user property
     '''
@@ -155,7 +147,7 @@ def _q(*select):
 
 
 
-class FeedController(BaseController):
+class FeedController(object):
     '''
     Feed controller class
     '''

coldsweat/session.py

@@ -88,9 +88,10 @@ def session_response(status, headers, exc_info=None):
             if manager.is_new: 
                 return initial_response(environ, start_response)
             return self.app(environ, start_response)
-        # Always close session
         finally:
+            # Always close session and database connection 
             manager.close()
+            close()
 
 class SessionManager(object):