ó îs©Uc@sÖdZddlmZddlmZeeƒZdefd„ƒYZdej fd„ƒYZ d e fd „ƒYZ d e fd „ƒYZ d e fd„ƒYZ de fd„ƒYZ dejfd„ƒYZdS(sB .. module:: sqlite_backend :synopsis: SQLite storage backend. i(t base_backendiÿÿÿÿ(t getLoggert SqlRowProxycBseZd„Zd„ZRS(cCsJd„t|jd|dƒDƒ}tj||ƒ||_||_dS(Ncss'|]\\}}}||fVqdS(N((t.0tktktypetv((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pys si(tzipt_columnstdictt__init__t_tablet_key(tselfttabletkeytrowtli((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyR s$ cCs'tj|||ƒ||j|jt|tƒst‚||j}t|||ƒ}||fS(N(t isinstancettupletAssertionErrorRR(R RRtrow_keyt row_value((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyt _row_to_value's cCs-d|j}|jj|ƒ}|jƒdS(NsSELECT count() FROM %si(RRt run_querytfetchone(R tquerytret((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyt__len__-s cCs5d|j|j|f}|jj|ƒ}|dk S(NsSELECT * FROM %s WHERE %s='%s'(RRRt fetch_onetNone(R RR+R((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyt __contains__2sc CsPt|tƒst‚t|ƒt|jdƒ}}|| sVtt||ƒƒ‚|| swtt||ƒƒ‚t|ƒt|jdƒksËtdtt|ƒƒtt|jdƒƒfƒ‚|gg|jdD]}||^qß}dj|jƒ}djd„|Dƒƒ}d|j||f} |jj | |ƒ} dS(sCreate or update a rowis%s %ss, css|] }dVqdS(t?N((Rtx((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pys Fss*INSERT OR REPLACE INTO %s (%s) VALUES (%s)N( R#R R%tsetRtreprtjoinRRtrun_query_using_conversion( R RRRtcnRt col_valuest col_namestquestion_marksR+R,((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyR9s !!%/+cCsZd|j|j|f}|jj|ƒ}|dkrFt|ƒ‚n|j||ƒdS(NsSELECT * FROM %s WHERE %s='%s'i(RRRR.R/tKeyErrorR((R RR+R((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyt __getitem__Ms  ccsFd|j|jf}|jj|ƒ}x|D]}|dVq/WdS(s#Iterate over table index key valuessSELECT %s FROM %siN(RRRR)(R R+tresultR((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyt__iter__Ws ccsjd|j}|jj|ƒ}xD|D]<}tt|j|ƒƒ}|j|jƒ|j|fVq&WdS(sIterate over table rowssSELECT * FROM %sN(RRR)R RRtpopR(R R+R=Rtd((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyt iteritems^s   cCs<|j|ƒ}d|j|j|f}|jj|ƒ|S(NsDELETE FROM %s WHERE %s='%s'(R<RRRR.(R RR@R+((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyR?hs cCs t‚dS(N(tNotImplementedError(R R@((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pytinsertpscCs t‚dS(N(RB(R ((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyt empty_tablesscCs¸g}xy|jD]n\}}|tkr1d}n|tkrFd}n||jkr^d}nd}|jd|||fƒqWdj|ƒ}d|j|f}|jj|ƒdS( sIssue table creationtINTEGERtTEXTsPRIMARY KEY ASCts%s %s %st,sCREATE TABLE %s (%s)N( RtinttstrRtappendR5RRR)(R tcctcol_nametcol_typetextrasR+((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyt create_tablevs     (RRt__doc__R R(R-R0RR<R>RAR?RCRDRP(((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyRs        tSingleValueTablecBs#eZd„Zd„Zd„ZRS(cGs*tt|ƒj|Œ|jd|_dS(Ni(tsuperRRR Rt _value_col(R targs((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyR ŒscCsWt|tƒ st‚d|j|j|jf}||f}|jj||ƒ}dS(sCreate or update a rows0INSERT OR REPLACE INTO %s (%s, %s) VALUES (?, ?)N(R#R R%RRRTRR6(R RRR+R8R,((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyRs  cCsTd|j|j|j|f}|jj|ƒ}|dkrLt|ƒ‚n|dS(NsSELECT %s FROM %s WHERE %s='%s'i(RTRRRR.R/R;(R RR+R((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyR<™s  (RRR RR<(((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyRR‹s  t UsersTablecBseZd„ZRS(cOsedtfdtfdtfdtfdtfdtfdtff|_tt|ƒj||ŽdS(Ntusernametrolethasht email_addrtdesct creation_datet last_login(RJRRSRVR (R RUtkwargs((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyR £s      (RRR (((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyRV¢st RolesTablecBseZd„ZRS(cOs8dtfdtff|_tt|ƒj||ŽdS(NRXtlevel(RJRIRRSR_R (R RUR^((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyR °s (RRR (((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyR_¯stPendingRegistrationsTablecBseZd„ZRS(cOsedtfdtfdtfdtfdtfdtfdtff|_tt|ƒj||ŽdS(NtcodeRWRXRYRZR[R\(RJRRSRaR (R RUR^((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyR ¸s      (RRR (((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyRa·st SQLiteBackendcBsteZddded„Zed„ƒZd„Zd„Zd„Zd„Z d „Z d „Z d „Z d „Z RS( tuserstrolestregistercCs€||_t||ƒ|_t||ƒ|_t||ƒ|_|r||jjƒ|jjƒ|jjƒtj dƒndS(NsTables created( t _filenameRVRdR_ReRatpending_registrationsRPtlogtdebug(R tfilenamet users_tnamet roles_tnametpending_reg_tnamet initialize((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyR És    cCsNy |jSWn<tk rIddl}|j|jddƒ|_|jSXdS(Niÿÿÿÿtisolation_level(t _connectiontAttributeErrortsqlite3tconnectRgR/(R Rs((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyRØs    cCs|jj|ƒS(N(Rqtexecute(R R+((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyR)áscCs|jj||ƒS(N(RqRu(R R+RU((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyR6äscCs|jj|ƒjƒS(N(RqRuR*(R R+((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyR.çscCs t‚dS(N(RB(R tdb_name((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyt_initialize_storageêscCs t‚dS(N(RB(R ((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyt_drop_all_tablesíscCsdS(N((R ((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyt save_usersðscCsdS(N((R ((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyt save_rolesñscCsdS(N((R ((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pytsave_pending_registrationsòs(RRtFalseR tpropertyRR)R6R.RwRxRyRzR{(((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyRcÇs       N(RQRGRtloggingRRRiR RRRRRVR_RatBackendRc(((sD/home/fede/newhome/projects/bottle-cork/tests/cork/sqlite_backend.pyts  p