idDealer.idDealer Class Reference

Inheritance diagram for idDealer.idDealer:

Public Member Functions
def	__init__ (self, schema)
def	generateNextIDForTable (self, tableName)
def	getIDColumnDefinition (self)
def	getIDforTable (self, tableName)

Private Attributes
	__idTableColumnName
	__idTableColumnType
	__schema

Detailed Description

Manages the autoincremental ID values.\n
Input: coral.schema object

Definition at line 3 of file idDealer.py.

Constructor & Destructor Documentation

def idDealer.idDealer.__init__	(		self,
			schema
	)

Definition at line 7 of file idDealer.py.

    def __init__( self , schema  ):
        self.__schema = schema
        self.__idTableColumnName = nameDealer.idTableColumnDefinition()[0]
        self.__idTableColumnType = nameDealer.idTableColumnDefinition()[1]
        

Member Function Documentation

def idDealer.idDealer.generateNextIDForTable	(		self,
			tableName
	)

Set the nextID in the IDTableName to current id value + 1 .\n
Input: ID table name.

Definition at line 33 of file idDealer.py.

References idDealer.idDealer.__idTableColumnName, data, nameDealer.idTableName(), GetRecoTauVFromDQM_MC_cff.next, and str.

    def generateNextIDForTable( self, tableName ):
        """
        Set the nextID in the IDTableName to current id value + 1 .\n
        Input: ID table name.
        """
        try:
            idtableName = nameDealer.idTableName(tableName)
            tableHandle = self.__schema.tableHandle(idtableName)
            query = tableHandle.newQuery()
            query.addToOutputList(self.__idTableColumnName)
            query.setForUpdate() #lock it
            cursor = query.execute()
            result = 0
            while ( next(cursor) ):
                result = cursor.currentRow()[0].data()
            dataEditor = tableHandle.dataEditor()
            inputData = coral.AttributeList()
            dataEditor.updateRows('NEXTID = NEXTID+1','',inputData)
            del query            
            return result+1
        except Exception as e:
            raise Exception(str(e))

def idDealer.idDealer.getIDColumnDefinition

(

self

)

Definition at line 12 of file idDealer.py.

References idDealer.idDealer.__idTableColumnName, and idDealer.idDealer.__idTableColumnType.

    def getIDColumnDefinition( self ):
        return (self.__idTableColumnName, self.__idTableColumnType)
    

def idDealer.idDealer.getIDforTable	(		self,
			tableName
	)

get the new id value to use for the given table

Definition at line 15 of file idDealer.py.

References idDealer.idDealer.__idTableColumnName, data, nameDealer.idTableName(), GetRecoTauVFromDQM_MC_cff.next, and str.

    def getIDforTable( self, tableName ):
        """
        get the new id value to use for the given table
        """
        try:
            idtableName = nameDealer.idTableName(tableName)
            query = self.__schema.tableHandle(idtableName).newQuery()
            query.addToOutputList(self.__idTableColumnName)
            query.setForUpdate() #lock it
            cursor = query.execute()
            result = 0
            while ( next(cursor) ):
                result = cursor.currentRow()[self.__idTableColumnName].data()
            del query
            return result
        except Exception as e:
            raise Exception(str(e))

Member Data Documentation

idDealer.idDealer.__idTableColumnName

private

Definition at line 9 of file idDealer.py.

Referenced by idDealer.idDealer.generateNextIDForTable(), idDealer.idDealer.getIDColumnDefinition(), and idDealer.idDealer.getIDforTable().

idDealer.idDealer.__idTableColumnType

private

Definition at line 10 of file idDealer.py.

Referenced by idDealer.idDealer.getIDColumnDefinition().

idDealer.idDealer.__schema

private

Definition at line 8 of file idDealer.py.