Ñò
ŽM×Jc
@ sž d d k Z d d k Z e i d d j o d d k Z n3 y d d k Z Wn e j
o e d ƒ ‚ n Xd e f d „ ƒ YZ d e f d „ ƒ YZ
d S(
iÿÿÿÿNi i s= Unable to determine sqlite, please make sure it is installed.t CasStorageExceptionc B s e Z RS( ( t __name__t
__module__( ( ( s* /usr/lib/python2.6/site-packages/cas/db.pyR s t
CasStoragec B s† e Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z
d „ Z d
„ Z d „ Z
d „ Z d
„ Z RS( c C s | | _ d | _ d | _ d S( sP setup database connection and return db cursor for
traversing database N( t dbt Nonet connt cursor( t selft database( ( s* /usr/lib/python2.6/site-packages/cas/db.pyt __init__ s c C sE y+ t i | i ƒ | _ | i i ƒ | _ Wn t d ƒ ‚ n Xd S( s execute connection s Cannot connect to databaseN( t sqlitet connectR R R R ( R ( ( s* /usr/lib/python2.6/site-packages/cas/db.pyR s c C s | i i ƒ d S( N( R t commit( R ( ( s* /usr/lib/python2.6/site-packages/cas/db.pyR
s
c C sN | i i d ƒ | i i d ƒ | i i d ƒ | i i d ƒ | i ƒ d S( Ns¥ create table jobs (
job_id integer primary key autoincrement,
identifier integer,
date text,
email text)
ss create table debuginfo (
debug_id integer primary key autoincrement,
rpm text)
s· create table timestamp (
timestamp_id integer primary key autoincrement,
debugpath text,
timestamp text,
debug_id integer)
s¤ create table server (
server_id integer primary key autoincrement,
arch text,
port text,
hostname text)
( R t executeR
( R ( ( s* /usr/lib/python2.6/site-packages/cas/db.pyt
buildTable# s
c C sS | f } | i i d | ƒ | i i ƒ p | i i d | ƒ n | i ƒ d S( Ns& SELECT * from debuginfo where rpm="%s"s' INSERT into debuginfo(rpm) values("%s")( R R t fetchoneR
( R t debuginfo( ( s* /usr/lib/python2.6/site-packages/cas/db.pyt addDebuginfoRPM@ s
c C s | i i d ƒ | i i ƒ S( Ns SELECT * FROM debuginfo( R R t fetchall( R ( ( s* /usr/lib/python2.6/site-packages/cas/db.pyt getAllDebuginfoRPMH s c C s\ | | | f } | i i d | f ƒ | i i ƒ p | i i d | ƒ n | i ƒ d S( s? build relation to debuginfo rpm and add debug path, timestamp s, SELECT * FROM timestamp where timestamp="%s"sR INSERT into timestamp (debug_id,debugpath,
timestamp) values(%d,"%s","%s")N( R R R R
( R t idt debugt timestampt values( ( s* /usr/lib/python2.6/site-packages/cas/db.pyt addTimestampM s
c C s* | f } | i i d | ƒ | i i ƒ S( s4 return timestamp based on extracted core timestamp sá SELECT rpm,debugpath
FROM debuginfo, timestamp
where timestamp.timestamp LIKE "%%%s%%"
AND debuginfo.debug_id = timestamp.debug_id( R R R ( R R R ( ( s* /usr/lib/python2.6/site-packages/cas/db.pyt getTimestampDebugW s c C s | i i d ƒ | i i ƒ S( s
all jobs s SELECT * FROM jobs( R R R ( R ( ( s* /usr/lib/python2.6/site-packages/cas/db.pyt
getAllJobsa s c C s$ | i i d | f ƒ | i i ƒ S( s single job s SELECT * FROM jobs where id=%d( R R R ( R R ( ( s* /usr/lib/python2.6/site-packages/cas/db.pyt
getJobByIdf s c C s d S( sF provides jobs based on creation date from
$days back
N( ( R t days( ( s* /usr/lib/python2.6/site-packages/cas/db.pyt getJobRangek s c C sZ | d j o
d } n t | ƒ t | ƒ t | ƒ f } | i i d | ƒ | i ƒ d S( s add job to db s
cas@localhostsG INSERT into jobs (date,identifier,email)
values ("%s",%d, "%s")N( R t strt intR R R
( R t
identifiert datet emailR ( ( s* /usr/lib/python2.6/site-packages/cas/db.pyt addJobq s
!
c C s\ | | | f } | i i d | f ƒ | i i ƒ p | i i d | ƒ n | i ƒ d S( s add server/arch to db s( select * from server where hostname="%s"sI INSERT into server (hostname, arch, port)
values ("%s","%s","%s")N( R R R R
( R t hostnamet portt archR ( ( s* /usr/lib/python2.6/site-packages/cas/db.pyt addServer| s
c C s | i i d ƒ | i i ƒ S( Ns' select hostname, port, arch from server( R R R ( R ( ( s* /usr/lib/python2.6/site-packages/cas/db.pyt
getServers† s ( R R R
R R
R R R R R R R R R$ R( R) ( ( ( s* /usr/lib/python2.6/site-packages/cas/db.pyR s
( i i ( t ost syst version_infot sqlite3R t ImportErrort
SystemExitt ExceptionR t objectR ( ( ( s* /usr/lib/python2.6/site-packages/cas/db.pyt s