implement mysql function.(RC1)

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

diff --git a/rec10/trunk/src/dbSQLite.py b/rec10/trunk/src/dbSQLite.py
index 5d88284..eab4f31 100644 (file)
--- a/rec10/trunk/src/dbSQLite.py
+++ b/rec10/trunk/src/dbSQLite.py
@@ -13,7 +13,7 @@ class DB_SQLite():
         self.dbpath = dbpath
         db = self.connect_db(480)
         try:
-            db.execute('create table rectime (type TEXT,chtxt TEXT,title TEXT,btime TEXT,etime TEXT,deltatime TEXT,deltaday TEXT,opt TEXT,id INTEGER PRIMARY KEY,UNIQUE(type,chtxt,title,btime,deltaday))')
+            db.execute('CREATE TABLW rectime (type TEXT,chtxt TEXT,title TEXT,btime TEXT,etime TEXT,deltatime TEXT,deltaday TEXT,opt TEXT,id INTEGER PRIMARY KEY,UNIQUE(type,chtxt,title,btime,deltaday))')
         except:
             ""
         db.commit
@@ -31,19 +31,19 @@ class DB_SQLite():
     def new_chdata(self):
         db = self.connect_db(480)
         try:
-            db.execute('drop table chdata')
+            db.execute('DROP TABLE chdata')
             db.commit()
         except:
             ""
         try:
-            db.execute('create table chdata (bctype TEXT,ontv TEXT,chtxt TEXT,ch TEXT,csch TEXT,station TEXT,station_name TEXT,updatetime TEXT)')
+            db.execute('CREATE TABLE chdata (bctype TEXT,ontv TEXT,chtxt TEXT,ch TEXT,csch TEXT,station TEXT,station_name TEXT,updatetime TEXT)')
         except:
             ""
         db.commit()
         self.close_db(db)
     def add_chdata(self,bctype, ontv, chtxt, ch, csch, station, station_name,updatetime):
         db = self.connect_db(480)
-        db.execute('insert into chdata values (?,?,?,?,?,?,?,datetime(?))',(bctype,ontv,chtxt,ch,csch,station,station_name,updatetime))
+        db.execute('INSERT OR IGNORE INTO chdata VALUES (?,?,?,?,?,?,?,datetime(?))',(bctype,ontv,chtxt,ch,csch,station,station_name,updatetime))
         db.commit()
         self.close_db(db)
     def select_by_ontv_chdata(self,ontv):
@@ -94,7 +94,7 @@ class DB_SQLite():
         self.close_db(db)
     def add_rectime(self,type="", chtxt="", title="", btime="", etime="", deltatime="", deltaday="", opt=""):
         db = self.connect_db(480)
-        db.execute('insert into rectime (type,chtxt,title,btime,etime,deltatime,deltaday,opt) values (?,?,?,datetime(?),datetime(?),?,?,?)', (type, chtxt, title, btime, etime, deltatime, deltaday, opt))
+        db.execute('INSERT OR IGNORE INTO rectime (type,chtxt,title,btime,etime,deltatime,deltaday,opt) values (?,?,?,datetime(?),datetime(?),?,?,?)', (type, chtxt, title, btime, etime, deltatime, deltaday, opt))
         db.commit()
         self.close_db(db)
     def del_rectime(self,type="", title="", chtxt="", btime=""):
@@ -102,7 +102,7 @@ class DB_SQLite():
         
         """
         db=self.connect_db(480)
-        db.execute("delete from rectime where type = ? AND title = ? AND chtxt = ? AND btime = datetime(?)", (type, title, chtxt, btime))
+        db.execute("DELETE FROM rectime where type = ? AND title = ? AND chtxt = ? AND btime = datetime(?)", (type, title, chtxt, btime))
         db.commit()
         self.close_db(db)
     def select_all_rectime(self):
@@ -116,6 +116,8 @@ class DB_SQLite():
             ret['btime']=btime
             ret['etime']=etime
             ret['opt']=opt
+            ret['deltatime']=""
+            ret['deltaday']=""
             if deltatime == None:
                 deltatime="3"
             if deltaday == None:
@@ -159,26 +161,26 @@ class DB_SQLite():
     def new_tv(self,bctype):
         db=self.connect_db(480)
         try:
-            db.execute("delete from tv where bctype = ?", (bctype,))
+            db.execute("DELETE FROM tv WHERE bctype = ?", (bctype,))
         except:
             ""
         try:
-            db.execute('create table tv (bctype TEXT,channel TEXT NOT NULL,start TEXT,stop  TEXT,title TEXT,desc  TEXT, UNIQUE (bctype,channel,start,stop,title,desc))')
+            db.execute('CREATE TABLE tv (bctype TEXT,channel TEXT NOT NULL,start TEXT,stop  TEXT,title TEXT,exp  TEXT, UNIQUE (bctype,channel,start,stop,title,exp))')
         except:
             ""
         db.commit()
         self.close_db(db)
-    def add_tv(self,bctype, channel, start, stop, title, desc):
+    def add_tv(self,bctype, channel, start, stop, title, exp):
         db=self.connect_db(480)
-        db.execute('insert into tv (bctype,channel,start,stop,title,desc) values (?,?,?,?,?,?)', (bctype, channel, start, stop, title, desc))
+        db.execute('INSERT OR IGNORE INTO tv (bctype,channel,start,stop,title,exp) values (?,?,?,?,?,?)', (bctype, channel, start, stop, title, exp))
         db.commit()
         self.close_db(db)
     def add_multi_tv(self,tvlists):
         """
-        tvlists is (bctype,channel,start,stop,title,desc) lists.
+        tvlists is (bctype,channel,start,stop,title,exp) lists.
         """
         db=self.connect_db(480)
-        db.executemany('insert into tv (bctype,channel,start,stop,title,desc) values (?,?,?,?,?,?)', tvlists)
+        db.executemany('INSERT OR IGNORE INTO tv (bctype,channel,start,stop,title,exp) values (?,?,?,?,?,?)', tvlists)
         db.commit()
         self.close_db(db)
     def select_by_title_tv(self,title):
@@ -206,18 +208,18 @@ class DB_SQLite():
     def new_ch(self,bctype):
         db=self.connect_db(480)
         try:
-            db.execute("delete from ch where bctype = ?",(bctype,))
+            db.execute("DELETE FROM ch WHERE bctype = ?",(bctype,))
         except:
             ""
         try:
-            db.execute('create table ch (bctype TEXT,channel TEXT NOT NULL,display TEXT,UNIQUE (bctype,channel))')
+            db.execute('CREATE TABLE ch (bctype TEXT,channel TEXT NOT NULL,display TEXT,UNIQUE (bctype,channel))')
         except:
             ""
         db.commit()
         self.close_db(db)
     def add_ch(self,bctype, channel, display):
         db=self.connect_db(480)
-        db.execute('insert into ch values (?,?,?)', (bctype, channel, display))
+        db.execute('INSERT OR IGNORE INTO ch values (?,?,?)', (bctype, channel, display))
         db.commit()
         self.close_db(db)
     def add_multi_ch(self,chlists):
@@ -225,6 +227,6 @@ class DB_SQLite():
         chlists is (bctype,channel,display) lists
         """
         db=self.connect_db(480)
-        db.executemany('insert into ch values (?,?,?)', chlists)
+        db.executemany('INSERT OR IGNORE INTO ch values (?,?,?)', chlists)
         db.commit()
         self.close_db(db)