ó
ÒñTc           @   ss   d  Z  d d l Z d d l Z d d l Z d d l m Z d „  Z d e f d „  ƒ  YZ e d k ro e ƒ  n  d S(   s.   
Created on Aug 13, 2010

@author: JohnnyFive
iÿÿÿÿN(   t   Threadc          C   s4   t  t j j t j j t j d ƒ ƒ ƒ }  |  GHd  S(   Ni    (   t   sqlDBt   ost   patht   realpatht   dirnamet   syst   argv(   t   sq(    (    s   /home/thedrx/pywhatauto/db.pyt   main
   s    +R   c           B   s,   e  Z d  „  Z d „  Z d „  Z d „  Z RS(   c         C   s/   t  j |  ƒ | |  _ | |  _ t ƒ  |  _ d  S(   N(   R    t   __init__t   qt   loadloct   listt   verified(   t   selfR   t   queue(    (    s   /home/thedrx/pywhatauto/db.pyR
      s    		c         C   su   t  j t j j |  j d ƒ ƒ |  _ |  j j ƒ  |  _ x8 t	 rp |  j
 j ƒ  } |  j | d | d | d ƒ q9 Wd  S(   Ns
   example.dbi    i   i   (   t   sqlite3t   connectR   R   t   joinR   t   connt   cursort   ct   TrueR   t   gett   addAnnounce(   R   t   info(    (    s   /home/thedrx/pywhatauto/db.pyt   run   s
    $	c         C   sV   |  j  j d | f ƒ |  j  j ƒ  d  k rB |  j  j d | ƒ n  |  j j | ƒ d  S(   Ns+   SELECT name FROM sqlite_master WHERE name=?s^   CREATE TABLE %s (token numeric, id integer PRIMARY KEY, announcement text, downloadid integer)(   R   t   executet   fetchonet   NoneR   t   append(   R   t   site(    (    s   /home/thedrx/pywhatauto/db.pyt   verifyTable   s    c         C   s   | |  j  k r |  j | ƒ n  | f } |  j j d | ƒ |  j j ƒ  } | d  k r} | | f } |  j j d | | ƒ n |  j j d | ƒ | d } | d k r° d } n
 | d 7} | t | d d d ƒ| f } |  j j d	 | | ƒ |  j j ƒ  d  S(
   Ns    SELECT * from %s WHERE token='1's&   insert into %s values ('1', '1', ?, ?)s#   UPDATE %s SET token=0 WHERE token=1i   id   s   utf-8t   errorst   ignores/   INSERT OR REPLACE INTO %s VALUES ('1', ?, ?, ?)(	   R   R!   R   R   R   R   t   unicodeR   t   commit(   R   R    t   announcementt
   downloadidt   vart   xt   currID(    (    s   /home/thedrx/pywhatauto/db.pyR   '   s     	
	
(   t   __name__t
   __module__R
   R   R!   R   (    (    (    s   /home/thedrx/pywhatauto/db.pyR      s   				t   __main__(	   t   __doc__R   R   R   t	   threadingR    R	   R   R+   (    (    (    s   /home/thedrx/pywhatauto/db.pyt   <module>   s   $	7