Change QuotaholderSync to QuotaholderSerial
authorSofia Papagiannaki <papagian@gmail.com>
Tue, 11 Sep 2012 13:54:13 +0000 (16:54 +0300)
committerSofia Papagiannaki <papagian@gmail.com>
Tue, 11 Sep 2012 13:54:13 +0000 (16:54 +0300)
snf-pithos-backend/pithos/backends/lib/sqlalchemy/quotaholder_serials.py
snf-pithos-backend/pithos/backends/lib/sqlite/quotaholder_serials.py

index b952781..055f669 100644 (file)
@@ -42,7 +42,7 @@ def create_tables(engine):
     metadata = MetaData()
     columns = []
     columns.append(Column('serial', BigInteger, primary_key=True))
-    config = Table('qh_sync', metadata, *columns, mysql_engine='InnoDB')
+    config = Table('qh_serials', metadata, *columns, mysql_engine='InnoDB')
     
     metadata.create_all(engine)
     return metadata.sorted_tables
@@ -55,7 +55,7 @@ class QuotaholderSerial(DBWorker):
         DBWorker.__init__(self, **params)
         try:
             metadata = MetaData(self.engine)
-            self.qh_sync = Table('qh_sync', metadata, autoload=True)
+            self.qh_serials = Table('qh_serials', metadata, autoload=True)
         except NoSuchTableError:
             tables = create_tables(self.engine)
             map(lambda t: self.__setattr__(t.name, t), tables)
@@ -63,8 +63,8 @@ class QuotaholderSerial(DBWorker):
     def get_lower(self, serial):
         """Return entries lower than serial."""
 
-        s = select([self.qh_sync.c.serial])
-        s = s.where(self.qh_sync.c.serial < serial)
+        s = select([self.qh_serials.c.serial])
+        s = s.where(self.qh_serials.c.serial < serial)
         r = self.conn.execute(s)
         rows = r.fetchall()
         r.close()
@@ -74,7 +74,7 @@ class QuotaholderSerial(DBWorker):
         """Insert a serial.
         """
 
-        s = self.qh_sync.insert()
+        s = self.qh_serials.insert()
         r = self.conn.execute(s, serial=serial)
         inserted_primary_key = r.inserted_primary_key[0]
         r.close()
index 68ccf68..fc470ee 100644 (file)
@@ -41,13 +41,13 @@ class QuotaholderSerial(DBWorker):
         DBWorker.__init__(self, **params)
         execute = self.execute
 
-        execute(""" create table if not exists qh_sync
+        execute(""" create table if not exists qh_serials
                           ( serial bigint primary key) """)
     
     def get_lower(self, serial):
         """Return entries lower than serial."""
 
-        q = "select serial from qh_sync where serial < ?"
+        q = "select serial from qh_serials where serial < ?"
         self.execute(q, (serial,))
         return self.fetchall()
     
@@ -55,6 +55,6 @@ class QuotaholderSerial(DBWorker):
         """Insert a serial.
         """
 
-        q = "insert or ignore into qh_sync (serial) values (?)"
+        q = "insert or ignore into qh_serials (serial) values (?)"
         return self.execute(q, (serial,)).lastrowid
         
\ No newline at end of file