From: Sofia Papagiannaki Date: Tue, 11 Sep 2012 13:54:13 +0000 (+0300) Subject: Change QuotaholderSync to QuotaholderSerial X-Git-Url: https://code.grnet.gr/git/pithos/commitdiff_plain/6a5ca4453c60c4b25fa0acd358776167e0dd03d3 Change QuotaholderSync to QuotaholderSerial --- diff --git a/snf-pithos-backend/pithos/backends/lib/sqlalchemy/quotaholder_serials.py b/snf-pithos-backend/pithos/backends/lib/sqlalchemy/quotaholder_serials.py index b952781..055f669 100644 --- a/snf-pithos-backend/pithos/backends/lib/sqlalchemy/quotaholder_serials.py +++ b/snf-pithos-backend/pithos/backends/lib/sqlalchemy/quotaholder_serials.py @@ -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() diff --git a/snf-pithos-backend/pithos/backends/lib/sqlite/quotaholder_serials.py b/snf-pithos-backend/pithos/backends/lib/sqlite/quotaholder_serials.py index 68ccf68..fc470ee 100644 --- a/snf-pithos-backend/pithos/backends/lib/sqlite/quotaholder_serials.py +++ b/snf-pithos-backend/pithos/backends/lib/sqlite/quotaholder_serials.py @@ -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