rec10/trunk/src/dbMySQL.py

   1 #!/usr/bin/python
   2 # coding: UTF-8
   3 # Rec10 TS Recording Tools
   4 # Copyright (C) 2009 Yukikaze
   5 import MySQLdb
   6 from decimal import Decimal
   7 class DB_MySQL:
   8     dbname = ""
   9     dbhost = ""
  10     dbusr = ""
  11     dbpasswd = ""
  12     dbport = 0
  13     def __init__(self, dbname, user, passwd, host="localhost", port=3306):
  14         self.dbname = dbname
  15         self.dbhost = host
  16         self.dbusr = user
  17         self.dbpasswd = passwd
  18         self.dbport = port
  19         try:
  20             con = MySQLdb.connect(user=user, passwd=passwd)
  21             cur = con.cursor()
  22             cur.execute('CREATE DATABASE ' + dbname + " DEFAULT CHARACTER SET utf8")
  23             cur.close()
  24             con.close()
  25         except:
  26             ""
  27         db = self.connect_db()
  28         try:
  29             db[1].execute('\
  30             CREATE TABLE rectime \
  31             (\
  32             id INT UNSIGNED AUTO_INCREMENT NOT NULL PRIMARY KEY,\
  33             type VARCHAR(20),\
  34             chtxt VARCHAR(20),\
  35             title VARCHAR(100),\
  36             btime DATETIME,\
  37             etime DATETIME,\
  38             deltatime VARCHAR(5),\
  39             deltaday VARCHAR(5),\
  40             opt VARCHAR(20),\
  41             UNIQUE uni (type,chtxt,title,btime,deltaday)\
  42             )')
  43         except:
  44             ""
  45         self.close_db(db)
  46         self.new_tv("")
  47         self.new_ch("")
  48         self.new_reclog()
  49         self.new_bayeskey()
  50     def connect_db(self):
  51         """
  52         dbへの接続
  53         """
  54         con = MySQLdb.connect(db=self.dbname, host=self.dbhost, port=self.dbport, user=self.dbusr, passwd=self.dbpasswd, charset="utf8")
  55         cur = con.cursor()
  56         cur.execute('set names utf8;')
  57         return [con, cur]
  58     def close_db(self, db):
  59         db[1].close()
  60         db[0].close()
  61     def new_chdata(self):
  62         db = self.connect_db()
  63         try:
  64             db[1].execute('drop table chdata')
  65         except:
  66             ""
  67         try:
  68             db[1].execute('\
  69             CREATE TABLE chdata \
  70             (\
  71             bctype VARCHAR(15),\
  72             ontv VARCHAR(30) PRIMARY KEY,\
  73             chtxt VARCHAR(15),\
  74             ch VARCHAR(20),\
  75             csch VARCHAR(20),\
  76             updatetime DATETIME,\
  77             status TINYINT\
  78             )')
  79         except:
  80             ""
  81         self.close_db(db)
  82     def add_chdata(self, bctype, ontv, chtxt, ch, csch, updatetime):
  83         db = self.connect_db()
  84         db[1].execute('\
  85         INSERT INTO chdata \
  86         VALUES (%s,%s,%s,%s,%s,%s,%s)', \
  87                       (bctype, ontv, chtxt, ch, csch, updatetime, "1"))
  88         self.close_db(db)
  89     def select_by_ontv_chdata(self, ontv):
  90         db = self.connect_db()
  91         dbexe = db[1].execute("\
  92         SELECT bctype,ontv,chtxt,ch,csch,updatetime \
  93         FROM chdata \
  94         WHERE ontv = %s", \
  95                               (ontv,))
  96         ret = []
  97         dls = []
  98         if dbexe > 0:
  99             dls = db[1].fetchall()
 100         self.close_db(db)
 101         for dl in dls:
 102             r = list(dl)
 103             r[5] = r[5].strftime("%Y-%m-%d %H:%M:%S")
 104             ret.append(r)
 105         return ret
 106     def select_by_chtxt_chdata(self, chtxt):
 107         db = self.connect_db()
 108         dbexe = db[1].execute("\
 109         SELECT bctype,ontv,chtxt,ch,csch,updatetime \
 110         FROM chdata \
 111         WHERE chtxt = %s", \
 112                               (chtxt,))
 113         ret = []
 114         dls = []
 115         if dbexe > 0:
 116             dls = db[1].fetchall()
 117         self.close_db(db)
 118         for dl in dls:
 119             r = list(dl)
 120             r[5] = r[5].strftime("%Y-%m-%d %H:%M:%S")
 121             ret.append(r)
 122         return ret
 123     def select_by_bctype_chdata(self, bctype):
 124         db = self.connect_db()
 125         dbexe = db[1].execute("\
 126         SELECT bctype,ontv,chtxt,ch,csch,updatetime,status \
 127         FROM chdata \
 128         WHERE bctype = %s", \
 129                               (bctype,))
 130         ret = []
 131         dls = []
 132         if dbexe > 0:
 133             dls = db[1].fetchall()
 134         self.close_db(db)
 135         for dl in dls:
 136             #print dl
 137             r = list(dl)
 138             r[5] = r[5].strftime("%Y-%m-%d %H:%M:%S")
 139             r[6] = str(r[6])
 140             ret.append(r)
 141         return ret
 142     def select_by_ch_chdata(self, ch):
 143         db = self.connect_db()
 144         dbexe = db[1].execute("\
 145         SELECT \
 146         bctype,ontv,chtxt,ch,csch,updatetime \
 147         FROM chdata \
 148         WHERE ch = %s", \
 149                               (ch,))
 150         ret = []
 151         dls = []
 152         if dbexe > 0:
 153             dls = db[1].fetchall()
 154         self.close_db(db)
 155         for dl in dls:
 156             r = list(dl)
 157             r[5] = r[5].strftime("%Y-%m-%d %H:%M:%S")
 158             ret.append(r)
 159         return ret
 160     def select_all_chdata(self):
 161         db = self.connect_db()
 162         dbexe = db[1].execute("\
 163         SELECT bctype,ontv,chtxt,ch,csch,updatetime \
 164         FROM chdata \
 165         ")
 166         ret = []
 167         dls = []
 168         if dbexe > 0:
 169             dls = db[1].fetchall()
 170         self.close_db(db)
 171         for dl in dls:
 172             r = list(dl)
 173             r[5] = r[5].strftime("%Y-%m-%d %H:%M:%S")
 174             ret.append(r)
 175         return ret
 176     def select_get_update_chdata(self, dhour):
 177         db = self.connect_db()
 178         dbexe = db[1].execute("SELECT bctype,chtxt,status FROM chdata \
 179         WHERE \
 180         ( \
 181         updatetime < DATE_SUB(now(),INTERVAL " + dhour + " HOUR) \
 182         AND \
 183         status = 1 \
 184         ) \
 185         OR \
 186         status > 1 \
 187         ORDER BY status DESC")
 188         ret = []
 189         #print dbexe
 190         if dbexe > 0:
 191             ret = db[1].fetchall()
 192         self.close_db(db)
 193         return ret
 194     def update_by_bctype_chdata(self, bctype):
 195         db = self.connect_db()
 196         db[1].execute("\
 197         UPDATE chdata \
 198         SET \
 199         updatetime=now() , \
 200         status = 1 \
 201         WHERE bctype = %s", (bctype,))
 202         self.close_db(db)
 203     def update_by_bctype_and_chtxt_chdata(self, bctype, chtxt):
 204         db = self.connect_db()
 205         db[1].execute("\
 206         UPDATE chdata \
 207         SET \
 208         updatetime=now() , \
 209         status = 1\
 210         WHERE bctype = %s AND chtxt = %s", (bctype, chtxt))
 211         self.close_db(db)
 212     def update_status_by_bctype_chdata(self, bctype, status):
 213         db = self.connect_db()
 214         db[1].execute("\
 215         UPDATE chdata \
 216         SET \
 217         status=%s \
 218         WHERE bctype = %s", \
 219                       (status, bctype)\
 220                       )
 221         self.close_db(db)
 222     def add_reclog(self , chtxt="", title="", btime="", etime="", opt="", exp="", longexp="", category=""):
 223         db = self.connect_db()
 224         db[1].execute('\
 225         INSERT IGNORE into reclog \
 226         (chtxt,title,btime,etime,opt,exp,longexp,category) \
 227         values (%s,%s,%s,%s,%s,%s,%s,%s)', \
 228                       ( chtxt, title, btime, etime, opt,exp,longexp,category))
 229         ##db.commit()
 230         self.close_db(db)
 231     def del_reclog(self, title="", chtxt="", btime=""):
 232         """
 233
 234         """
 235         db = self.connect_db()
 236         db[1].execute("\
 237         DELETE FROM reclog \
 238         WHERE title = %s AND chtxt = %s AND btime = %s", \
 239                       (title, chtxt, btime))
 240         #db.commit()
 241         self.close_db(db)
 242     def new_reclog(self):
 243         db = self.connect_db()
 244         try:
 245             db[1].execute('\
 246             CREATE TABLE reclog \
 247             (\
 248             id INT UNSIGNED AUTO_INCREMENT NOT NULL PRIMARY KEY,\
 249             chtxt VARCHAR(20),\
 250             title VARCHAR(100),\
 251             btime DATETIME,\
 252             etime DATETIME,\
 253             opt VARCHAR(20),\
 254             exp VARCHAR(200),\
 255             longexp TEXT,\
 256             category VARCHAR(100),\
 257             UNIQUE uni (chtxt,title,btime,category)\
 258             )')
 259         except:
 260             ""
 261         self.close_db(db)
 262     def add_rectime(self, type="", chtxt="", title="", btime="", etime="", deltatime="", deltaday="", opt=""):
 263         db = self.connect_db()
 264         db[1].execute('\
 265         INSERT IGNORE into rectime \
 266         (type,chtxt,title,btime,etime,deltatime,deltaday,opt) \
 267         values (%s,%s,%s,%s,%s,%s,%s,%s)', \
 268                       (type, chtxt, title, btime, etime, deltatime, deltaday, opt))
 269         ##db.commit()
 270         self.close_db(db)
 271     def del_rectime(self, type="", title="", chtxt="", btime=""):
 272         """
 273
 274         """
 275         db = self.connect_db()
 276         db[1].execute("\
 277         DELETE FROM rectime \
 278         WHERE type = %s AND title = %s AND chtxt = %s AND btime = %s", \
 279                       (type, title, chtxt, btime))
 280         #db.commit()
 281         self.close_db(db)
 282     def select_all_rectime(self):
 283         db = self.connect_db()
 284         recdata = []
 285         dbr = db[1].execute("\
 286         SELECT type, chtxt, title, btime, etime, deltatime ,deltaday ,opt \
 287         FROM rectime")
 288         dbl = db[1].fetchall()
 289         self.close_db(db)
 290         if dbr > 0:
 291             for typet, chtxt, title, btime, etime, deltatime, deltaday, opt in dbl:
 292                 ret = {}
 293                 ret['type'] = typet
 294                 ret['chtxt'] = chtxt
 295                 ret['title'] = title.encode('utf-8')
 296                 btime = btime.strftime("%Y-%m-%d %H:%M:%S")
 297                 etime = etime.strftime("%Y-%m-%d %H:%M:%S")
 298                 ret['btime'] = btime
 299                 ret['etime'] = etime
 300                 ret['opt'] = opt
 301                 ret['deltatime'] = ""
 302                 ret['deltaday'] = ""
 303                 if deltatime == None:
 304                     deltatime = "3"
 305                 if deltaday == None:
 306                     deltaday = "7"
 307                 if typet == 'key':
 308                     ret['deltatime'] = deltatime
 309                 elif typet == 'keyevery':
 310                     ret['deltatime'] = deltatime
 311                     ret['deltaday'] = deltaday
 312                 recdata.append(ret)
 313         self.close_db(db)
 314         return recdata
 315     def select_bytime_rectime(self, dminutes):
 316         db = self.connect_db()
 317         recdatum = []
 318         #dbr=db[1].execute("SELECT type, chtxt, title, btime, etime, deltatime ,deltaday ,opt FROM rectime WHERE btime < DATE_SUB(now(),INTERVAL "+dminutes+" MINUTE ) AND btime > DATE_ADD(now(),INTERVAL "+dminutes+" MINUTE )")
 319         dbr = db[1].execute("SELECT \
 320         type, chtxt, title, btime, etime, deltatime ,deltaday ,opt \
 321         FROM rectime \
 322         WHERE btime BETWEEN DATE_SUB(now(),INTERVAL " + dminutes + " MINUTE ) AND \
 323         DATE_ADD(now(),INTERVAL " + dminutes + " MINUTE )")
 324         dbl = db[1].fetchall()
 325         self.close_db(db)
 326         #print dbl
 327         if dbr > 0:
 328             for typet, chtxt, title, btime, etime, deltatime, deltaday, opt in dbl:
 329                 ret = {}
 330                 ret['type'] = typet
 331                 ret['chtxt'] = chtxt
 332                 ret['title'] = title.encode('utf-8')
 333                 btime = btime.strftime("%Y-%m-%d %H:%M:%S")
 334                 etime = etime.strftime("%Y-%m-%d %H:%M:%S")
 335                 ret['btime'] = btime
 336                 ret['etime'] = etime
 337                 ret['opt'] = opt
 338                 if deltatime == None or deltatime == "":
 339                     deltatime = "3"
 340                 if deltaday == None or deltaday == "":
 341                     deltaday = "7"
 342                 if typet == 'key':
 343                     ret['deltatime'] = deltatime
 344                 elif typet == 'keyevery':
 345                     ret['deltatime'] = deltatime
 346                     ret['deltaday'] = deltaday
 347                 recdatum.append(ret)
 348         return recdatum
 349     def delete_old_rectime(self, dhour):
 350         db = self.connect_db()
 351         db[1].execute("\
 352         DELETE FROM rectime \
 353         WHERE \
 354         btime < DATE_SUB(now(),INTERVAL " + dhour + " HOUR )")
 355         #db.commit()
 356         self.close_db(db)
 357     def new_status(self):
 358         db = self.connect_db()
 359         try:
 360             db[1].execute("\
 361             CREATE TABLE status \
 362             (\
 363             ts2avi TINYINT DEFAULT 0,\
 364             terec TINYINT DEFAULT 0,\
 365             bscsrec TINYINT DEFAULT 0,\
 366             b252ts TINYINT DEFAULT 0\
 367             )")
 368             db[1].execute("INSERT IGNORE into status VALUE (0,0,0,0)")
 369         except:
 370             ""
 371
 372         self.close_db(db)
 373     def select_all_status(self):
 374         db = self.connect_db()
 375         dbexe = db[1].execute("\
 376         SELECT ts2avi,terec,bscsrec,b252ts \
 377         FROM status \
 378         ")
 379         ret = []
 380         dls = []
 381         if dbexe > 0:
 382             dls = db[1].fetchall()
 383         self.close_db(db)
 384         for dl in dls:
 385             r = list(dl)
 386             r[0]=str(r[0])
 387             r[1]=str(r[1])
 388             r[2]=str(r[2])
 389             r[3]=str(r[3])
 390             ret.append(r)
 391         return ret
 392         self.close_db(db)
 393     def change_ts2avi_status(self,i):
 394         """
 395         statuをiだけ増減する
 396         iはint
 397         """
 398         db = self.connect_db()
 399         db[1].execute("\
 400         UPDATE status SET ts2avi=ts2avi+%s",i)
 401         self.close_db(db)
 402     def change_terec_status(self,i):
 403         """
 404         statuをiだけ増減する
 405         iはint
 406         """
 407         db = self.connect_db()
 408         db[1].execute("\
 409         UPDATE status SET terec=terec+%s",i)
 410         self.close_db(db)
 411     def change_bscsrec_status(self,i):
 412         """
 413         statuをiだけ増減する
 414         iはint
 415         """
 416         db = self.connect_db()
 417         db[1].execute("\
 418         UPDATE status SET bscsrec=bscsrec+%s",i)
 419         self.close_db(db)
 420     def change_b252ts_status(self,i):
 421         """
 422         statuをiだけ増減する
 423         iはint
 424         """
 425         db = self.connect_db()
 426         db[1].execute("\
 427         UPDATE status SET b252ts=b252ts+%s",i)
 428         self.close_db(db)
 429     def new_tv(self, bctype):
 430         db = self.connect_db()
 431         try:
 432             db[1].execute("\
 433             DELETE FROM tv \
 434             WHERE bctype = %s", \
 435                           (bctype,))
 436         except:
 437             ""
 438         try:
 439             db[1].execute("\
 440             CREATE TABLE tv \
 441             (\
 442             bctype VARCHAR(20),\
 443             channel VARCHAR(100) NOT NULL,\
 444             start VARCHAR(30),\
 445             stop  VARCHAR(30),\
 446             title VARCHAR(100),\
 447             exp VARCHAR(200),\
 448             longexp TEXT,\
 449             category VARCHAR(100),\
 450             UNIQUE unitv(bctype,channel,start,stop,title)\
 451             )")
 452         except:
 453             ""
 454         #db.commit()
 455         self.close_db(db)
 456     def add_tv(self, bctype, channel, start, stop, title, desc,longdesc, category):
 457         db = self.connect_db()
 458         db[1].execute('\
 459         INSERT IGNORE INTO tv \
 460         VALUES (%s,%s,%s,%s,%s,%s,%s,%s)', \
 461                       (bctype, channel, start, stop, title, desc,longdesc,category))
 462         #db.commit()
 463         self.close_db(db)
 464     def add_multi_tv(self, tvlists):
 465         """
 466         tvlists is (bctype,channel,start,stop,title,desc,longdesc,category) lists.
 467         """
 468         db = self.connect_db()
 469         db[1].executemany('\
 470         INSERT IGNORE INTO tv \
 471         (bctype,channel,start,stop,title,exp,longexp,category) \
 472         values(%s,%s,%s,%s,%s,%s,%s,%s)', \
 473                           tvlists)
 474         #db.commit()
 475         self.close_db(db)
 476     def select_by_time_ngram_tv(self, btime, etime, chtxt):
 477         db = self.connect_db()
 478         dbexe = "\
 479         SELECT \
 480         chdata.chtxt,title,start,stop,exp,longexp,category \
 481         FROM tv \
 482         INNER JOIN chdata \
 483         WHERE chdata.ontv=tv.channel \
 484         AND \
 485         start >= %s \
 486         AND \
 487         start <= %s \
 488         AND \
 489         chdata.chtxt=%s"
 490         dbcmd = db[1].execute(dbexe, (btime, etime, chtxt))
 491         retall = []
 492         if dbcmd > 0:
 493             retall = db[1].fetchall()
 494         self.close_db(db)
 495         return retall
 496     def select_by_time_auto_suggest_tv(self,keyword,btime,etime,chtxt):
 497         db = self.connect_db()
 498         dbexe = "\
 499         SELECT \
 500         chdata.chtxt,title,start,stop,exp,longexp,category \
 501         FROM tv \
 502         INNER JOIN chdata \
 503         WHERE chdata.ontv=tv.channel \
 504         AND \
 505         start >= %s \
 506         AND \
 507         start <= %s \
 508         AND \
 509         chdata.chtxt=%s \
 510         AND \
 511         (\
 512         title LIKE \%%s\% \
 513         OR \
 514         exp LIKE \%%s\% \
 515         OR \
 516         longexp LIKE \%%s\% \
 517         )"
 518         dbcmd = db[1].execute(dbexe, (btime, etime, chtxt,keyword,keyword,keyword))
 519         retall = []
 520         if dbcmd > 0:
 521             retall = db[1].fetchall()
 522         self.close_db(db)
 523         return retall
 524     def new_ch(self, bctype):
 525         db = self.connect_db()
 526         try:
 527             db[1].execute("DELETE FROM ch WHERE bctype = %s", (bctype,))
 528         except:
 529             ""
 530         try:
 531             db[1].execute('\
 532             CREATE TABLE ch \
 533             (\
 534             bctype VARCHAR(20),\
 535             channel VARCHAR(20) NOT NULL,\
 536             display VARCHAR(100),\
 537             UNIQUE unich(bctype,channel)\
 538             )')
 539         except:
 540             ""
 541         #db.commit()
 542         self.close_db(db)
 543     def add_ch(self, bctype, channel, display):
 544         db = self.connect_db()
 545         db[1].execute('INSERT IGNORE INTO ch VALUES (%s,%s,%s)', (bctype, channel, display))
 546         #db.commit()
 547         self.close_db(db)
 548     def add_multi_ch(self, chlists):
 549         """
 550         chlists is (bctype,channel,display) lists
 551         """
 552         db = self.connect_db()
 553         db[1].executemany('INSERT IGNORE INTO ch VALUES (%s,%s,%s)', chlists)
 554         self.close_db(db)
 555     def new_bayeskey(self):
 556         db = self.connect_db()
 557         try:
 558             db[1].execute('CREATE TABLE bayeskey \
 559             (\
 560             keychar VARCHAR(10),\
 561             chtxt VARCHAR(20),\
 562             ratio_rec DECIMAL(32,14),\
 563             ratio_all DECIMAL(32,14),\
 564             UNIQUE unibayeskey(keychar,chtxt)\
 565             )')
 566             db[1].execute('CREATE INDEX keycharindex ON bayeskey(keychar)')
 567         except:
 568             ""
 569         self.close_db(db)
 570
 571     def add_bayeskey(self,key,chtxt,ratio_rec,ratio_all):
 572         db = self.connect_db()
 573         ratio_rec=str(ratio_rec)
 574         ratio_all=str(ratio_all)
 575         db[1].execute('\
 576         INSERT IGNORE INTO bayeskey \
 577         (keychar,chtxt,ratio_rec,ratio_all) \
 578         values (%s,%s,%s,%s)',\
 579         (key,chtxt,ratio_rec,ratio_all))
 580         self.close_db(db)
 581     def add_num_bayeskey(self,chtxt,add_rec_num,add_all_num):
 582         db = self.connect_db()
 583         add_rec_num=str(add_rec_num)
 584         add_all_num=str(add_all_num)
 585         db[1].execute("\
 586         UPDATE bayeskey SET ratio_rec=ratio_rec+%s,ratio_all=ratio_all+%s WHERE keychar=\"NUM\" AND chtxt=%s",\
 587         (add_rec_num,add_all_num,chtxt))
 588         self.close_db(db)
 589     def change_bayeskey(self,key,chtxt,new_ratio_rec,new_ratio_all):
 590         """
 591         """
 592         db = self.connect_db()
 593         db[1].execute("\
 594         UPDATE bayeskey SET ratio_rec=%s,ratio_all=%s WHERE keychar=%s AND chtxt=%s",(str(new_ratio_rec),str(new_ratio_all),key,chtxt)\
 595         )
 596         self.close_db(db)
 597     def change_ratio_all_reduce_bayeskey(self,chtxt,beforenum,newnum):
 598         beforenum=str(beforenum)
 599         newnum=str(newnum)
 600         db = self.connect_db()
 601         db[1].execute("\
 602         UPDATE bayeskey SET ratio_all=ratio_all*%s/(%s+%s) WHERE chtxt=%s AND NOT (keychar=\"NUM\")",(beforenum,newnum,beforenum,chtxt)\
 603         )
 604         self.close_db(db)
 605     def change_ratio_all_bayeskey(self,key,chtxt,beforenum,addnum):
 606         db = self.connect_db()
 607         beforenumf=beforenum
 608         beforenum=str(beforenum)
 609         #addnum=str(addnum)
 610         #db[1].execute("\
 611         #UPDATE bayeskey SET ratio_all=(ratio_all*%s+%s)/%s WHERE chtxt=%s AND keychar=%s",\
 612         #(beforenum,addnum,beforenum,chtxt,key)\
 613         #)
 614         db[1].execute("INSERT INTO bayeskey (keychar,chtxt,ratio_rec,ratio_all) \
 615         VALUES (%s,%s,%s,%s)\
 616         ON DUPLICATE KEY UPDATE \
 617         ratio_all=(ratio_all*%s+%s)/%s",(key,chtxt,"0",str(Decimal(addnum)/beforenumf),beforenum,chtxt,key))
 618         self.close_db(db)
 619     def change_many_ratio_all_bayeskey(self,chtxt,beforenum,list):
 620         """
 621         list={key:addnum}のリスト
 622         """
 623         retlist=[]
 624         beforenumf=beforenum
 625         beforenum=str(beforenum)
 626         db = self.connect_db()
 627         for i,j in list.items():
 628             retl=(i,chtxt,"0",str(Decimal(j)/beforenumf),beforenum,str(j),beforenum)
 629             db[1].execute("INSERT INTO bayeskey (keychar,chtxt,ratio_rec,ratio_all) \
 630             VALUES (%s,%s,%s,%s)\
 631             ON DUPLICATE KEY UPDATE \
 632             ratio_all=(ratio_all*%s+%s)/%s",retl)
 633         self.close_db(db)
 634     def change_ratio_rec_bayeskey(self,key,chtxt,beforenum,addnum):
 635         db = self.connect_db()
 636         beforenum=str(beforenum)
 637         addnum=str(addnum)
 638         db[1].execute("\
 639         UPDATE bayeskey SET ratio_rec=(ratio_rec*%s+%s)/%s WHERE chtxt=%s AND keychar=%s",\
 640         (beforenum,addnum,beforenum,chtxt,key)\
 641         )
 642         self.close_db(db)
 643     def select_by_key_bayeskey(self,key,chtxt):
 644         db = self.connect_db()
 645         dbexe = db[1].execute("\
 646         SELECT keychar,chtxt,ratio_rec,ratio_all \
 647         FROM bayeskey \
 648         WHERE keychar = %s AND chtxt = %s", \
 649                               (key,chtxt))
 650         dls = []
 651         if dbexe > 0:
 652             dls = db[1].fetchall()
 653         self.close_db(db)
 654         if len(dls)>0:
 655             return dls[0]
 656         else:
 657             return dls