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
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)
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()
"""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()
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()
"""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