ppf: Populate skeleton methods for *DatabaseAccess classes.
authorRazvan Deaconescu <razvan.deaconescu@cs.pub.ro>
Sun, 21 Aug 2011 19:03:01 +0000 (22:03 +0300)
committerRazvan Deaconescu <razvan.deaconescu@cs.pub.ro>
Sun, 21 Aug 2011 19:03:01 +0000 (22:03 +0300)
ppf/new/storage.py

index 37f71c8..d87076c 100644 (file)
@@ -8,6 +8,7 @@ import os
 import os.path
 import re
 import logging
+import sqlite3
 
 #
 # Logging code heavily inspired by Logging HOWTO documentation:
@@ -437,17 +438,56 @@ class DatabaseAccess(SwarmDataAccess):
         pass
 
     def connect(self, database):
+        self.database = database
         self.conn = None
         self.cursor = None
-        return self.conn
 
     def disconnect(self):
-        pass
+        self.cursor.close()
+        self.conn.close()
 
 class SQLiteDatabaseAccess(DatabaseAccess):
     def __init___(self):
         pass
 
+    def connect(self, database):
+        self.database = database
+        self.conn = sqlite3.connect(self.database)
+        self.cursor = self.conn.cursor()
+
+    def add_swarm(self, swarm):
+        pass
+
+    def add_client_session(self, session):
+        pass
+
+    def add_peer_status_message(self, msg):
+        pass
+
+    def add_status_message(self, msg):
+        pass
+
+    def add_verbose_message(self, msg):
+        pass
+
 class MySQLDatabaseAccess(DatabaseAccess):
     def __init___(self):
         pass
+
+    def connect(self, database):
+        pass
+
+    def add_swarm(self, swarm):
+        pass
+
+    def add_client_session(self, session):
+        pass
+
+    def add_peer_status_message(self, msg):
+        pass
+
+    def add_status_message(self, msg):
+        pass
+
+    def add_verbose_message(self, msg):
+        pass