X-Git-Url: https://vcs.fsf.org/?p=rainbowstream.git;a=blobdiff_plain;f=rainbowstream%2Fdb.py;h=192448fd44a941e8bb3034ee613b10da19e0be88;hp=01b91fb163fbd7e5933da975d46e878610ae87d1;hb=8141aca6b2aaa7ce8f097f689fc2241f4f7ad3af;hpb=4c025026dec3c67b7757261b14e9438b1e31d7b0 diff --git a/rainbowstream/db.py b/rainbowstream/db.py index 01b91fb..192448f 100644 --- a/rainbowstream/db.py +++ b/rainbowstream/db.py @@ -17,7 +17,6 @@ class RainbowDB(): init_db() self.engine = create_engine('sqlite:///rainbow.db', echo=False) - def tweet_store(self, tweet_id): """ Store tweet id @@ -28,7 +27,6 @@ class RainbowDB(): session.add(t) session.commit() - def rainbow_to_tweet_query(self, rid): """ Query base of rainbow id @@ -38,7 +36,6 @@ class RainbowDB(): res = session.query(Tweet).filter_by(rainbow_id=rid).all() return res - def tweet_to_rainbow_query(self, tid): """ Query base of tweet id @@ -48,7 +45,6 @@ class RainbowDB(): res = session.query(Tweet).filter_by(tweet_id=tid).all() return res - def message_store(self, message_id): """ Store message id @@ -59,7 +55,6 @@ class RainbowDB(): session.add(m) session.commit() - def rainbow_to_message_query(self, rid): """ Query base of rainbow id @@ -69,7 +64,6 @@ class RainbowDB(): res = session.query(Message).filter_by(rainbow_id=rid).all() return res - def message_to_rainbow_query(self, mid): """ Query base of message id @@ -79,7 +73,6 @@ class RainbowDB(): res = session.query(Message).filter_by(message_id=mid).all() return res - def theme_store(self, theme_name): """ Store theme @@ -90,7 +83,6 @@ class RainbowDB(): session.add(th) session.commit() - def theme_update(self, theme_name): """ Update theme @@ -102,7 +94,6 @@ class RainbowDB(): r.theme_name = theme_name session.commit() - def theme_query(self): """ Query theme @@ -112,7 +103,6 @@ class RainbowDB(): res = session.query(Theme).all() return res - def semaphore_store(self, lock, pause): """ Store semaphore lock @@ -123,7 +113,6 @@ class RainbowDB(): session.add(th) session.commit() - def semaphore_update_lock(self, lock): """ Update semaphore lock @@ -135,7 +124,6 @@ class RainbowDB(): r.lock = lock session.commit() - def semaphore_update_pause(self, pause): """ Update semaphore pause @@ -147,7 +135,6 @@ class RainbowDB(): r.pause = pause session.commit() - def semaphore_query_lock(self): """ Query semaphore lock @@ -157,7 +144,6 @@ class RainbowDB(): res = session.query(Semaphore).all() return res[0].lock - def semaphore_query_pause(self): """ Query semaphore pause