CMS 3D CMS Logo
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Groups Pages
List of all members | Public Member Functions | Public Attributes
conditionUploadTest.DB Class Reference

Public Member Functions

def __init__
 
def connect
 
def getLastInsertedSince
 
def removeTag
 
def setSynchronizationType
 

Public Attributes

 connStr
 
 schemaName
 
 serviceName
 

Detailed Description

Definition at line 15 of file conditionUploadTest.py.

Constructor & Destructor Documentation

def conditionUploadTest.DB.__init__ (   self,
  serviceName,
  schemaName 
)

Definition at line 16 of file conditionUploadTest.py.

16 
17  def __init__(self, serviceName, schemaName ):
18  self.serviceName = serviceName
19  self.schemaName = schemaName
20  self.connStr = None

Member Function Documentation

def conditionUploadTest.DB.connect (   self)

Definition at line 21 of file conditionUploadTest.py.

References conditionUploadTest.DB.connStr, conditionUploadTest.DB.schemaName, conditionUploadTest.DB.serviceName, and submitPVValidationJobs.split().

Referenced by o2o_db_cfgmap.DbManagerDAQ.update_hashmap().

21 
22  def connect( self ):
23  command = "cmscond_authentication_manager -s %s --list_conn | grep '%s@%s'" %(self.serviceName,self.schemaName,self.serviceName)
24  pipe = subprocess.Popen( command, shell=True,stdout=subprocess.PIPE,stderr=subprocess.STDOUT)
25  out = pipe.communicate()[0]
26  srvconn = '%s@%s' %(self.schemaName,self.serviceName)
27  rowpwd = out.split(srvconn)[1].split(self.schemaName)[1]
28  pwd = ''
29  for c in rowpwd:
30  if c != ' ' and c != '\n':
31  pwd += c
32  self.connStr = '%s/%s@%s' %(self.schemaName,pwd,self.serviceName)
def conditionUploadTest.DB.getLastInsertedSince (   self,
  tag,
  snapshot 
)

Definition at line 40 of file conditionUploadTest.py.

References conditionUploadTest.DB.connStr.

40 
41  def getLastInsertedSince( self, tag, snapshot ):
42  db = cx_Oracle.connect(self.connStr)
43  cursor = db.cursor()
44  cursor.execute('SELECT SINCE, INSERTION_TIME FROM IOV WHERE TAG_NAME =:TAG_NAME AND INSERTION_TIME >:TIME ORDER BY INSERTION_TIME DESC',(tag,snapshot))
45  row = cursor.fetchone()
46  return row
def conditionUploadTest.DB.removeTag (   self,
  tag 
)

Definition at line 47 of file conditionUploadTest.py.

References conditionUploadTest.DB.connStr.

47 
48  def removeTag( self, tag ):
49  db = cx_Oracle.connect(self.connStr)
50  cursor = db.cursor()
51  db.begin()
52  cursor.execute('DELETE FROM IOV WHERE TAG_NAME =:TAG_NAME',(tag,))
53  cursor.execute('DELETE FROM TAG_LOG WHERE TAG_NAME=:TAG_NAME',(tag,))
54  cursor.execute('DELETE FROM TAG WHERE NAME=:NAME',(tag,))
55  db.commit()
def conditionUploadTest.DB.setSynchronizationType (   self,
  tag,
  synchType 
)

Definition at line 33 of file conditionUploadTest.py.

References conditionUploadTest.DB.connStr.

33 
34  def setSynchronizationType( self, tag, synchType ):
35  db = cx_Oracle.connect(self.connStr)
36  cursor = db.cursor()
37  db.begin()
38  cursor.execute('UPDATE TAG SET SYNCHRONIZATION =:SYNCH WHERE NAME =:NAME',(synchType,tag,))
39  db.commit()

Member Data Documentation

conditionUploadTest.DB.connStr

Definition at line 19 of file conditionUploadTest.py.

Referenced by conditionUploadTest.DB.connect(), conditionUploadTest.DB.getLastInsertedSince(), conditionUploadTest.DB.removeTag(), and conditionUploadTest.DB.setSynchronizationType().

conditionUploadTest.DB.schemaName

Definition at line 18 of file conditionUploadTest.py.

Referenced by conditionUploadTest.DB.connect().

conditionUploadTest.DB.serviceName

Definition at line 17 of file conditionUploadTest.py.

Referenced by conditionUploadTest.DB.connect().

Generated for CMSSW Reference Manual by doxygen 1.8.5