change status logging in DB.

[rec10/rec10-git.git] / rec10 / trunk / src / dbMySQL.py

diff --git a/rec10/trunk/src/dbMySQL.py b/rec10/trunk/src/dbMySQL.py
index 394ee19..bf7fb5a 100644 (file)
--- a/rec10/trunk/src/dbMySQL.py
+++ b/rec10/trunk/src/dbMySQL.py
@@ -313,6 +313,78 @@ class DB_MySQL:
         btime < DATE_SUB(now(),INTERVAL " + dhour + " HOUR )")
         #db.commit()
         self.close_db(db)
+    def new_status(self):
+        db = self.connect_db()
+        try:
+            db[1].execute("\
+            CREATE TABLE status \
+            (\
+            ts2avi TINYINT DEFAULT 0,\
+            terec TINYINT DEFAULT 0,\
+            bscsrec TINYINT DEFAULT 0,\
+            b252ts TINYINT DEFAULT 0\
+            )")
+            db[1].execute("INSERT IGNORE into status VALUE (0,0,0,0)")
+        except:
+            ""
+
+        self.close_db(db)
+    def select_all_status(self):
+        db = self.connect_db()
+        dbexe = db[1].execute("\
+        SELECT ts2avi,terec,bscsrec,b252ts \
+        FROM status \
+        ")
+        ret = []
+        dls = []
+        if dbexe > 0:
+            dls = db[1].fetchall()
+        self.close_db(db)
+        for dl in dls:
+            r = list(dl)
+            r[0]=str(r[0])
+            r[1]=str(r[1])
+            r[2]=str(r[2])
+            r[3]=str(r[3])
+            ret.append(r)
+        return ret
+        self.close_db(db)
+    def change_ts2avi_status(self,i):
+        """
+        statuをiだけ増減する
+        iはint
+        """
+        db = self.connect_db()
+        db[1].execute("\
+        UPDATE status SET ts2avi=ts2avi+%s",i)
+        self.close_db(db)
+    def change_terec_status(self,i):
+        """
+        statuをiだけ増減する
+        iはint
+        """
+        db = self.connect_db()
+        db[1].execute("\
+        UPDATE status SET terec=terec+%s",i)
+        self.close_db(db)
+    def change_bscsrec_status(self,i):
+        """
+        statuをiだけ増減する
+        iはint
+        """
+        db = self.connect_db()
+        db[1].execute("\
+        UPDATE status SET bscsrec=bscsrec+%s",i)
+        self.close_db(db)
+    def change_b252ts_status(self,i):
+        """
+        statuをiだけ増減する
+        iはint
+        """
+        db = self.connect_db()
+        db[1].execute("\
+        UPDATE status SET b252ts=b252ts+%s",i)
+        self.close_db(db)
     def new_tv(self, bctype):
         db = self.connect_db()
         try: