Public Member Functions
def	__init__ (self, serviceName, schemaName)

def	connect (self)

def	getLastInsertedSince (self, tag, snapshot)

def	removeTag (self, tag)

def	setSynchronizationType (self, tag, synchType)

Public Attributes
	connStr

	schemaName

	serviceName

Detailed Description

Definition at line 15 of file conditionUploadTest.py.

Constructor & Destructor Documentation

◆ init()

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

Definition at line 16 of file conditionUploadTest.py.

     def __init__(self, serviceName, schemaName ):
         self.serviceName = serviceName
         self.schemaName = schemaName
         self.connStr = None
  

Member Function Documentation

◆ connect()

def conditionUploadTest.DB.connect ( self )

Definition at line 21 of file conditionUploadTest.py.

     def connect( self ):
         command = "cmscond_authentication_manager -s %s --list_conn | grep '%s@%s'" %(self.serviceName,self.schemaName,self.serviceName)
         pipe = subprocess.Popen( command, shell=True,stdout=subprocess.PIPE,stderr=subprocess.STDOUT)
         out = pipe.communicate()[0]
         srvconn = '%s@%s' %(self.schemaName,self.serviceName)
         rowpwd = out.split(srvconn)[1].split(self.schemaName)[1]
         pwd = ''
         for c in rowpwd:
             if c != ' ' and c != '\n':
                 pwd += c
         self.connStr =  '%s/%s@%s' %(self.schemaName,pwd,self.serviceName)
  

References conditionUploadTest.DB.connStr, conditionUploadTest.DB.schemaName, conditionUploadTest.DB.serviceName, and cms::dd.split().

Referenced by o2o_db_cfgmap.DbManagerDAQ.update_hashmap().

◆ getLastInsertedSince()

def conditionUploadTest.DB.getLastInsertedSince	(	self,
		tag,
		snapshot
	)

Definition at line 40 of file conditionUploadTest.py.

     def getLastInsertedSince( self, tag, snapshot ):
         db = cx_Oracle.connect(self.connStr)
         cursor = db.cursor()
         cursor.execute('SELECT SINCE, INSERTION_TIME FROM IOV WHERE TAG_NAME =:TAG_NAME AND INSERTION_TIME >:TIME ORDER BY INSERTION_TIME DESC',(tag,snapshot))
         row = cursor.fetchone()
         return row
  

References conditionUploadTest.DB.connStr.

◆ removeTag()

def conditionUploadTest.DB.removeTag	(	self,
		tag
	)

Definition at line 47 of file conditionUploadTest.py.

     def removeTag( self, tag ):
         db = cx_Oracle.connect(self.connStr)
         cursor = db.cursor()
         db.begin()
         cursor.execute('DELETE FROM IOV WHERE TAG_NAME =:TAG_NAME',(tag,))
         cursor.execute('DELETE FROM TAG_LOG WHERE TAG_NAME=:TAG_NAME',(tag,))
         cursor.execute('DELETE FROM TAG WHERE NAME=:NAME',(tag,))
         db.commit()
  

References conditionUploadTest.DB.connStr.

◆ setSynchronizationType()

def conditionUploadTest.DB.setSynchronizationType	(	self,
		tag,
		synchType
	)

Definition at line 33 of file conditionUploadTest.py.

     def setSynchronizationType( self, tag, synchType ):
         db = cx_Oracle.connect(self.connStr)
         cursor = db.cursor()
         db.begin()
         cursor.execute('UPDATE TAG SET SYNCHRONIZATION =:SYNCH WHERE NAME =:NAME',(synchType,tag,))
         db.commit()
  