c.execute("DELETE FROM kv WHERE last_refresh < ?", (t, ))
self.conn.commit()
+ def keyStats(self):
+ """Count the total number of keys and values in the database.
+ @rtype: (C{int), C{int})
+ @return: the number of distinct keys and total values in the database
+ """
+ c = self.conn.cursor()
+ c.execute("SELECT COUNT(DISTINCT key) as num_keys, COUNT(value) as num_values FROM kv")
+ keys, values = 0, 0
+ row = c.fetchone()
+ if row:
+ keys, values = row[0], row[1]
+ return keys, values
+
class TestDB(unittest.TestCase):
"""Tests for the khashmir database."""