test
CMS 3D CMS Logo
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Pages
Functions | Variables
lumidbDDL Namespace Reference

Functions

def createFKConstraints
 
def createIndices
 
def createNULLConstraints
 
def createOldSchema
 
def createTables
 
def createUniqueConstraints
 
def describe
 
def describeIndices
 
def dropFKConstrains
 
def dropIndices
 
def dropNULLConstraints
 
def dropTables
 
def dropUNIQUEConstraints
 
def newToOld
 
def oldToNew
 

Variables

string authpath = '/afs/cern.ch/user/x/xiezhen'
 
string myconstr = 'oracle://devdb10/cms_xiezhen_dev'
 
tuple schema = session.nominalSchema()
 
tuple session = svc.openSession(isReadOnly=False,cpp2sqltype=[('unsigned int','NUMBER(10)'),('unsigned long long','NUMBER(20)')])
 
tuple svc = sessionManager.sessionManager(myconstr,authpath=authpath,debugON=False)
 
tuple tables = createTables(schema)
 

Function Documentation

def lumidbDDL.createFKConstraints (   schema) 
 

Definition at line 449 of file lumidbDDL.py.


  449 


  450 def createFKConstraints(schema):


  451     '''


  452     '''

    pass


lumidbDDL.createFKConstraints
def createFKConstraints
Definition: lumidbDDL.py:449












      

        

          def lumidbDDL.createIndices 
          (
           
          schema)
          
        

      




 

Definition at line 434 of file lumidbDDL.py.


  434 


  435 def createIndices(schema):


  436     '''


  437     '''


  438     pass


  439     #cmsrunsummary.createIndex('cmsrunsummary_fillnum',('FILLNUM'))


  440     #cmsrunsummary.createIndex('cmsrunsummary_startime',('STARTTIME'))




lumidbDDL.createIndices
def createIndices
Definition: lumidbDDL.py:434











      

        

          def lumidbDDL.createNULLConstraints 
          (
           
          schema)
          
        

      




 

Definition at line 457 of file lumidbDDL.py.


  457 


  458 def createNULLConstraints(schema):


  459     '''


  460     '''


  461     #cmsrunsummary.setNotNullConstraint('HLTKEY',True)


  462     #cmsrunsummary.setNotNullConstraint('FILLNUM',True)


  463     #cmsrunsummary.setNotNullConstraint('SEQUENCE',True)

    pass


lumidbDDL.createNULLConstraints
def createNULLConstraints
Definition: lumidbDDL.py:457











      

        

          def lumidbDDL.createOldSchema 
          (
           
          schema)
          
        

      




create tables of lumidb1 if not exist

 

Definition at line 236 of file lumidbDDL.py.



References nameDealer.cmsrunsummaryTableName(), nameDealer.hltTableName(), nameDealer.lumidetailTableName(), nameDealer.lumisummaryTableName(), nameDealer.lumivalidationTableName(), nameDealer.trghltMapTableName(), and nameDealer.trgTableName().


  236 


  237 def createOldSchema(schema):


  238     '''


  239     create tables of lumidb1 if not exist


  240     '''


  241     try:


  242         created=[]


  243         db=dbUtil.dbUtil(schema)


  244         if not schema.existsTable(nameDealer.lumivalidationTableName()):


  245             lumivalidation=coral.TableDescription()


  246             lumivalidation.setName( nameDealer.lumivalidationTableName() )


  247             lumivalidation.insertColumn( 'RUNNUM','unsigned int' )


  248             lumivalidation.insertColumn( 'CMSLSNUM','unsigned int' )


  249             lumivalidation.insertColumn( 'FLAG','string',28,False )


  250             lumivalidation.insertColumn( 'COMMENT','string',1024,False )


  251             lumivalidation.setPrimaryKey(('RUNNUM','CMSLSNUM'))


  252             lumivalidation.setNotNullConstraint('FLAG',True)


  253             db.createTable(lumivalidation,withIdTable=False)


  254             created.append(nameDealer.lumivalidationTableName())


  255             


  256         if not schema.existsTable(nameDealer.cmsrunsummaryTableName()):


  257             cmsrunsummary=coral.TableDescription()


  258             cmsrunsummary.setName( nameDealer.cmsrunsummaryTableName() )


  259             cmsrunsummary.insertColumn('RUNNUM','unsigned int')


  260             cmsrunsummary.insertColumn('HLTKEY','string',128,False)


  261             cmsrunsummary.insertColumn('FILLNUM','unsigned int')


  262             cmsrunsummary.insertColumn('SEQUENCE','string',56,False)


  263             cmsrunsummary.insertColumn('STARTTIME','time stamp',6)


  264             cmsrunsummary.insertColumn('STOPTIME','time stamp',6)


  265             cmsrunsummary.setPrimaryKey('RUNNUM')


  266             cmsrunsummary.setNotNullConstraint('HLTKEY',True)


  267             cmsrunsummary.setNotNullConstraint('FILLNUM',True)


  268             cmsrunsummary.setNotNullConstraint('SEQUENCE',True)


  269             cmsrunsummary.createIndex('cmsrunsummary_fillnum',('FILLNUM'))


  270             cmsrunsummary.createIndex('cmsrunsummary_startime',('STARTTIME'))


  271             db.createTable(cmsrunsummary,withIdTable=False)


  272             created.append(nameDealer.cmsrunsummaryTableName())


  273             


  274         if not schema.existsTable(nameDealer.lumisummaryTableName()):


  275             summary=coral.TableDescription()


  276             summary.setName( nameDealer.lumisummaryTableName() )


  277             summary.insertColumn('LUMISUMMARY_ID','unsigned long long')


  278             summary.insertColumn('RUNNUM','unsigned int')


  279             summary.insertColumn('CMSLSNUM','unsigned int')


  280             summary.insertColumn('LUMILSNUM','unsigned int')


  281             summary.insertColumn('LUMIVERSION','string',28,False)


  282             summary.insertColumn('DTNORM','float')


  283             summary.insertColumn('LHCNORM','float')


  284             summary.insertColumn('CMSALIVE','short')


  285             summary.insertColumn('INSTLUMI','float')


  286             summary.insertColumn('INSTLUMIERROR','float')


  287             summary.insertColumn('INSTLUMIQUALITY','short')


  288             summary.insertColumn('BEAMSTATUS','string',28,False)


  289             summary.insertColumn('BEAMENERGY','float')


  290             summary.insertColumn('NUMORBIT','unsigned int')


  291             summary.insertColumn('STARTORBIT','unsigned int')


  292             summary.insertColumn('LUMISECTIONQUALITY','short')


  293             summary.insertColumn('CMSBXINDEXBLOB','blob')


  294             summary.insertColumn('BEAMINTENSITYBLOB_1','blob')


  295             summary.insertColumn('BEAMINTENSITYBLOB_2','blob')           


  296             summary.setPrimaryKey('LUMISUMMARY_ID')


  297             summary.setNotNullConstraint('RUNNUM',True)


  298             summary.setNotNullConstraint('CMSLSNUM',True)


  299             summary.setNotNullConstraint('LUMILSNUM',True)


  300             summary.setNotNullConstraint('CMSALIVE',True)


  301             summary.setNotNullConstraint('LUMIVERSION',True)


  302             summary.setNotNullConstraint('DTNORM',True)


  303             summary.setNotNullConstraint('LHCNORM',True)


  304             summary.setNotNullConstraint('INSTLUMI',True)


  305             summary.setNotNullConstraint('INSTLUMIERROR',True)


  306             summary.setNotNullConstraint('INSTLUMIQUALITY',True)


  307             summary.setNotNullConstraint('STARTORBIT',True)


  308             summary.setNotNullConstraint('NUMORBIT',True)


  309             summary.setNotNullConstraint('LUMISECTIONQUALITY',True)


  310             summary.setNotNullConstraint('BEAMENERGY',True)


  311             summary.setNotNullConstraint('BEAMSTATUS',True)


  312             summary.setUniqueConstraint(('RUNNUM','LUMIVERSION','LUMILSNUM'))


  313             summary.createIndex('lumisummary_runnum',('RUNNUM'))


  314             db.createTable(summary,withIdTable=True)


  315             created.append(nameDealer.lumisummaryTableName())


  316             


  317         if not schema.existsTable(nameDealer.lumidetailTableName()):


  318             detail=coral.TableDescription()


  319             detail.setName( nameDealer.lumidetailTableName() )


  320             detail.insertColumn('LUMIDETAIL_ID','unsigned long long')


  321             detail.insertColumn('LUMISUMMARY_ID','unsigned long long')


  322             detail.insertColumn('BXLUMIVALUE','blob')


  323             detail.insertColumn('BXLUMIERROR','blob')


  324             detail.insertColumn('BXLUMIQUALITY','blob')


  325             detail.insertColumn('ALGONAME','string',28,False)


  326             detail.setPrimaryKey('LUMIDETAIL_ID')


  327             detail.createForeignKey('DETAILSOURCE','LUMISUMMARY_ID',nameDealer.lumisummaryTableName(),'LUMISUMMARY_ID')


  328             detail.setNotNullConstraint('BXLUMIVALUE',True)


  329             detail.setNotNullConstraint('BXLUMIERROR',True)


  330             detail.setNotNullConstraint('BXLUMIQUALITY',True)


  331             detail.setNotNullConstraint('ALGONAME',True)


  332             detail.setUniqueConstraint(('LUMISUMMARY_ID','ALGONAME'))


  333             db.createTable(detail,withIdTable=True)


  334             created.append(nameDealer.lumidetailTableName())


  335             


  336         if  not schema.existsTable(nameDealer.trgTableName()):


  337             trg=coral.TableDescription()


  338             trg.setName( nameDealer.trgTableName() )


  339             trg.insertColumn('TRG_ID','unsigned long long')


  340             trg.insertColumn('RUNNUM','unsigned int')


  341             trg.insertColumn('CMSLSNUM','unsigned int')


  342             trg.insertColumn('BITNUM','unsigned int')


  343             trg.insertColumn('BITNAME','string',56,False)


  344             trg.insertColumn('TRGCOUNT','unsigned int')


  345             trg.insertColumn('DEADTIME','unsigned long long')


  346             trg.insertColumn('PRESCALE','unsigned int')


  347             trg.setNotNullConstraint('RUNNUM',True)


  348             trg.setNotNullConstraint('CMSLSNUM',True)


  349             trg.setNotNullConstraint('BITNUM',True)


  350             trg.setNotNullConstraint('BITNAME',True)


  351             trg.setNotNullConstraint('TRGCOUNT',True)


  352             trg.setNotNullConstraint('DEADTIME',True)


  353             trg.setNotNullConstraint('PRESCALE',True)


  354             trg.setPrimaryKey('TRG_ID')


  355             trg.createIndex('trg_runnum',('RUNNUM'))        


  356             db.createTable(trg,withIdTable=True)


  357             created.append( nameDealer.trgTableName() )


  358 


  359         if not schema.existsTable( nameDealer.hltTableName() ): 


  360             hlt=coral.TableDescription()


  361             hlt.setName( nameDealer.hltTableName() )


  362             hlt.insertColumn( 'HLT_ID','unsigned long long')


  363             hlt.insertColumn( 'RUNNUM','unsigned int')


  364             hlt.insertColumn( 'CMSLSNUM','unsigned int')


  365             hlt.insertColumn( 'PATHNAME','string',256,False)


  366             hlt.insertColumn( 'INPUTCOUNT','unsigned int')


  367             hlt.insertColumn( 'ACCEPTCOUNT','unsigned int')


  368             hlt.insertColumn( 'PRESCALE','unsigned int')


  369             hlt.setPrimaryKey( 'HLT_ID' )


  370             hlt.setNotNullConstraint('RUNNUM',True)


  371             hlt.setNotNullConstraint('CMSLSNUM',True)


  372             hlt.setNotNullConstraint('PATHNAME',True)


  373             hlt.setNotNullConstraint('INPUTCOUNT',True)


  374             hlt.setNotNullConstraint('ACCEPTCOUNT',True)


  375             hlt.setNotNullConstraint('PRESCALE',True)


  376             hlt.createIndex('hlt_runnum',('RUNNUM'))


  377             db.createTable(hlt,withIdTable=True)


  378             created.append( nameDealer.hltTableName() )


  379             


  380         if not schema.existsTable( nameDealer.trghltMapTableName() ): 


  381             trghlt=coral.TableDescription()


  382             trghlt.setName( nameDealer.trghltMapTableName() )


  383             trghlt.insertColumn( 'HLTKEY','string',128,False )


  384             trghlt.insertColumn( 'HLTPATHNAME','string',256,False )


  385             trghlt.insertColumn( 'L1SEED','string',1024,false )


  386             trghlt.setNotNullConstraint('HLTKEY',True)


  387             trghlt.setNotNullConstraint('HLTPATHNAME',True)


  388             trghlt.setNotNullConstraint('L1SEED',True)


  389             db.createTable(trghlt,withIdTable=False)


  390             created.append( nameDealer.trghltMapTableName() )


  391         return created


  392     except:


  393         raise


  394         


  395 #=======================================================


  396 #


  397 #   MODIFY


  398 #

#=======================================================


lumidbDDL.createOldSchema
def createOldSchema
Definition: lumidbDDL.py:236


nameDealer.lumivalidationTableName
def lumivalidationTableName
Definition: nameDealer.py:85


nameDealer.lumisummaryTableName
def lumisummaryTableName
Definition: nameDealer.py:25


nameDealer.trghltMapTableName
def trghltMapTableName
Definition: nameDealer.py:76


nameDealer.hltTableName
def hltTableName
Definition: nameDealer.py:55


nameDealer.lumidetailTableName
def lumidetailTableName
Definition: nameDealer.py:34



nameDealer.trgTableName
def trgTableName
Definition: nameDealer.py:52


nameDealer.cmsrunsummaryTableName
def cmsrunsummaryTableName
Definition: nameDealer.py:16











      

        

          def lumidbDDL.createTables 
          (
           
          schema)
          
        

      




create new tables if not exist
revisions,revisions_id,luminorms,luminorms_entries,luminorms_entries_id,fillscheme

 

Definition at line 8 of file lumidbDDL.py.



References nameDealer.cmsrunsummaryTableName(), nameDealer.fillschemeTableName(), nameDealer.hltdataTableName(), nameDealer.hltTableName(), nameDealer.lshltTableName(), nameDealer.lstrgTableName(), nameDealer.lumidataTableName(), nameDealer.luminormTableName(), nameDealer.lumisummaryv2TableName(), nameDealer.lumivalidationTableName(), nameDealer.revisionTableName(), nameDealer.trgdataTableName(), and nameDealer.trghltMapTableName().



Referenced by lumidb2Schema.createLumi(), and oldToNew().


    8 


    9 def createTables(schema):


   10     '''


   11     create new tables if not exist


   12     revisions,revisions_id,luminorms,luminorms_entries,luminorms_entries_id,fillscheme


   13     '''


   14     try:


   15         created=[]


   16         db=dbUtil.dbUtil(schema)


   17         if not schema.existsTable(nameDealer.fillschemeTableName()):


   18             print 'creating fillscheme table'


   19             fillschemeTab=coral.TableDescription()


   20             fillschemeTab.setName( nameDealer.fillschemeTableName() )


   21             fillschemeTab.insertColumn( 'FILLSCHEME_ID','unsigned long long' )


   22             fillschemeTab.insertColumn( 'FILLSCHEMEPATTERN','string',128,False )


   23             fillschemeTab.insertColumn( 'CORRECTIONFACTOR','float' )


   24             fillschemeTab.setPrimaryKey( 'FILLSCHEME_ID' )


   25             db.createTable(fillschemeTab,withIdTable=True)


   26             created.append( nameDealer.fillschemeTableName() )


   27             


   28         if not schema.existsTable(nameDealer.revisionTableName()):


   29             print 'creating revisions table'


   30             revisionsTab=coral.TableDescription()


   31             revisionsTab.setName( nameDealer.revisionTableName() )


   32             revisionsTab.insertColumn( 'REVISION_ID','unsigned long long')


   33             revisionsTab.insertColumn( 'BRANCH_ID','unsigned long long')


   34             revisionsTab.insertColumn( 'NAME', 'string',56,False)


   35             revisionsTab.insertColumn( 'BRANCH_NAME', 'string',56,False)


   36             revisionsTab.insertColumn( 'COMMENT', 'string',1024,False)


   37             revisionsTab.insertColumn( 'CTIME', 'time stamp',6)


   38             revisionsTab.setPrimaryKey( 'REVISION_ID' )


   39             revisionsTab.setUniqueConstraint(('NAME'))


   40             db.createTable(revisionsTab,withIdTable=True)


   41             created.append(nameDealer.revisionTableName())


   42             


   43         if not schema.existsTable(nameDealer.luminormTableName()):


   44             print 'creating luminorms table'


   45             luminormsTab=coral.TableDescription()


   46             luminormsTab.setName( nameDealer.luminormTableName() )


   47             luminormsTab.insertColumn( 'DATA_ID','unsigned long long')


   48             luminormsTab.insertColumn( 'ENTRY_ID','unsigned long long')


   49             luminormsTab.insertColumn( 'ENTRY_NAME','string',56,False)


   50             luminormsTab.insertColumn( 'AMODETAG', 'string',28,False)


   51             luminormsTab.insertColumn( 'NORM_1', 'float')


   52             luminormsTab.insertColumn( 'EGEV_1', 'unsigned int')


   53             luminormsTab.insertColumn( 'NORM_2', 'float')


   54             luminormsTab.insertColumn( 'EGEV_2', 'unsigned int')


   55             luminormsTab.setPrimaryKey( 'DATA_ID' )


   56             db.createTable(luminormsTab,withIdTable=True,withEntryTables=True,withRevMapTable=True)


   57             created.append(nameDealer.luminormTableName())


   58   


   59         if not schema.existsTable(nameDealer.lumidataTableName()):


   60             print 'creating lumidata table'


   61             lumidataTab=coral.TableDescription()


   62             lumidataTab.setName( nameDealer.lumidataTableName() )


   63             lumidataTab.insertColumn( 'DATA_ID','unsigned long long')


   64             lumidataTab.insertColumn( 'ENTRY_ID','unsigned long long')


   65             lumidataTab.insertColumn( 'ENTRY_NAME','string',56,False)


   66             lumidataTab.insertColumn( 'SOURCE', 'string',128,False)


   67             lumidataTab.insertColumn( 'RUNNUM', 'unsigned int')


   68             lumidataTab.insertColumn( 'NOMINALEGEV', 'float')


   69             lumidataTab.setPrimaryKey( 'DATA_ID' )


   70             db.createTable(lumidataTab,withIdTable=True,withEntryTables=True,withRevMapTable=True)


   71             created.append(nameDealer.lumidataTableName())


   72 


   73         if not schema.existsTable(nameDealer.lumisummaryv2TableName() ):


   74             print 'creating lumisummaryv2 table'


   75             summary=coral.TableDescription()


   76             summary.setName( nameDealer.lumisummaryv2TableName() )


   77             summary.insertColumn('DATA_ID','unsigned long long')


   78             summary.insertColumn('RUNNUM','unsigned int')


   79             summary.insertColumn('LUMILSNUM','unsigned int')


   80             summary.insertColumn('CMSLSNUM','unsigned int')


   81             summary.insertColumn('INSTLUMI','float')


   82             summary.insertColumn('INSTLUMIERROR','float')


   83             summary.insertColumn('INSTLUMIQUALITY','short')


   84             summary.insertColumn('BEAMSTATUS','string',28,False)


   85             summary.insertColumn('BEAMENERGY','float')


   86             summary.insertColumn('NUMORBIT','unsigned int')


   87             summary.insertColumn('STARTORBIT','unsigned int')


   88             summary.insertColumn('CMSBXINDEXBLOB','blob')


   89             summary.insertColumn('BEAMINTENSITYBLOB_1','blob')


   90             summary.insertColumn('BEAMINTENSITYBLOB_2','blob')


   91             summary.insertColumn('BXLUMIVALUE_OCC1','blob')


   92             summary.insertColumn('BXLUMIVALUE_OCC2','blob')


   93             summary.insertColumn('BXLUMIVALUE_ET','blob')


   94             summary.insertColumn('BXLUMIERROR_OCC1','blob')


   95             summary.insertColumn('BXLUMIERROR_OCC2','blob')


   96             summary.insertColumn('BXLUMIERROR_ET','blob')


   97             summary.insertColumn('BXLUMIQUALITY_OCC1','blob')


   98             summary.insertColumn('BXLUMIQUALITY_OCC2','blob')


   99             summary.insertColumn('BXLUMIQUALITY_ET','blob')


  100             summary.setPrimaryKey(('DATA_ID','LUMILSNUM'))


  101             db.createTable(summary,withIdTable=False)            


  102             created.append(nameDealer.lumisummaryv2TableName())


  103             


  104         #


  105         # This table exists in the old schema


  106         #


  107         if not schema.existsTable(nameDealer.cmsrunsummaryTableName()):


  108             print 'creating cmsrunsummary table'


  109             cmsrunsummary=coral.TableDescription()


  110             cmsrunsummary.setName( nameDealer.cmsrunsummaryTableName() )


  111             cmsrunsummary.insertColumn('RUNNUM','unsigned int')


  112             cmsrunsummary.insertColumn('HLTKEY','string',128,False)


  113             cmsrunsummary.insertColumn('L1KEY','string',128,False)


  114             cmsrunsummary.insertColumn('FILLNUM','unsigned int')


  115             cmsrunsummary.insertColumn('SEQUENCE','string',56,False)


  116             cmsrunsummary.insertColumn('STARTTIME','time stamp',6)


  117             cmsrunsummary.insertColumn('STOPTIME','time stamp',6)


  118             cmsrunsummary.insertColumn('EGEV','unsigned int')


  119             cmsrunsummary.insertColumn('AMODETAG','string',28,False)


  120             cmsrunsummary.insertColumn('FILLSCHEME','string',128,False)


  121             cmsrunsummary.insertColumn('NCOLLIDINGBUNCHES','usigned int')


  122             cmsrunsummary.setPrimaryKey('RUNNUM')


  123             db.createTable(cmsrunsummary,withIdTable=False)


  124             created.append(nameDealer.cmsrunsummaryTableName())


  125         #


  126         #  This table exists in the old schema


  127         #


  128         if not schema.existsTable(nameDealer.trghltMapTableName()):


  129             print 'creating trghltmap table'


  130             trghlt=coral.TableDescription()


  131             trghlt.setName( nameDealer.trghltMapTableName() )


  132             trghlt.insertColumn( 'HLTKEY','string',128,False )


  133             trghlt.insertColumn( 'HLTPATHNAME','string',256,False )


  134             trghlt.insertColumn( 'L1SEED','string' ,1024,False)


  135             trghlt.setNotNullConstraint('HLTKEY',True)


  136             trghlt.setNotNullConstraint('HLTPATHNAME',True)


  137             trghlt.setNotNullConstraint('L1SEED',True)


  138             db.createTable(trghlt,withIdTable=False)


  139             created.append(nameDealer.trghltMapTableName())      


  140         if not schema.existsTable(nameDealer.trgdataTableName()):


  141             print 'creating trgdata table'


  142             trgdataTab=coral.TableDescription()


  143             trgdataTab.setName( nameDealer.trgdataTableName() )


  144             trgdataTab.insertColumn( 'DATA_ID','unsigned long long')


  145             trgdataTab.insertColumn( 'ENTRY_ID','unsigned long long')


  146             trgdataTab.insertColumn( 'ENTRY_NAME','string',56,False)


  147             trgdataTab.insertColumn( 'SOURCE', 'string',128,False)


  148             trgdataTab.insertColumn( 'RUNNUM', 'unsigned int')


  149             trgdataTab.insertColumn( 'BITZERONAME', 'string',56,False)


  150             trgdataTab.insertColumn( 'BITNAMECLOB', 'string',6000)


  151             trgdataTab.setPrimaryKey( 'DATA_ID' )


  152             db.createTable(trgdataTab,withIdTable=True,withEntryTables=True,withRevMapTable=True)


  153             created.append(nameDealer.trgdataTableName())


  154         if not schema.existsTable(nameDealer.lstrgTableName()):


  155             print 'creating lstrg table'


  156             lstrgTab=coral.TableDescription()


  157             lstrgTab.setName( nameDealer.lstrgTableName() )


  158             lstrgTab.insertColumn( 'DATA_ID','unsigned long long')


  159             lstrgTab.insertColumn( 'RUNNUM', 'unsigned int')


  160             lstrgTab.insertColumn( 'CMSLSNUM', 'unsigned int')


  161             lstrgTab.insertColumn( 'DEADTIMECOUNT', 'unsigned long long')


  162             lstrgTab.insertColumn( 'BITZEROCOUNT', 'unsigned int')


  163             lstrgTab.insertColumn( 'BITZEROPRESCALE', 'unsigned int')


  164             lstrgTab.insertColumn( 'DEADFRAC', 'float')


  165             lstrgTab.insertColumn( 'PRESCALEBLOB', 'blob')


  166             lstrgTab.insertColumn( 'TRGCOUNTBLOB', 'blob')


  167             lstrgTab.setPrimaryKey( ('DATA_ID','CMSLSNUM') )


  168             db.createTable(lstrgTab,withIdTable=False)            


  169             created.append( nameDealer.lstrgTableName() )


  170 


  171         if not schema.existsTable(nameDealer.hltdataTableName()):


  172             print 'creating hltdata table'


  173             hltdataTab=coral.TableDescription()


  174             hltdataTab.setName( nameDealer.hltdataTableName() )


  175             hltdataTab.insertColumn( 'DATA_ID','unsigned long long')


  176             hltdataTab.insertColumn( 'ENTRY_ID','unsigned long long')


  177             hltdataTab.insertColumn( 'ENTRY_NAME','string',56,False)


  178             hltdataTab.insertColumn( 'RUNNUM', 'unsigned int')


  179             hltdataTab.insertColumn( 'SOURCE', 'string',128,False)


  180             hltdataTab.insertColumn( 'NPATH', 'unsigned int')


  181             hltdataTab.insertColumn( 'PATHNAMECLOB', 'string',6000)


  182             hltdataTab.setPrimaryKey( 'DATA_ID' )


  183             db.createTable(hltdataTab,withIdTable=True,withEntryTables=True,withRevMapTable=True)


  184             created.append(nameDealer.hltTableName())


  185             


  186         if not schema.existsTable(nameDealer.lshltTableName()):


  187             print 'creating lshlt table'


  188             lshltTab=coral.TableDescription()


  189             lshltTab.setName( nameDealer.lshltTableName() )


  190             lshltTab.insertColumn( 'DATA_ID','unsigned long long')


  191             lshltTab.insertColumn( 'RUNNUM', 'unsigned int')


  192             lshltTab.insertColumn( 'CMSLSNUM', 'unsigned int')


  193             lshltTab.insertColumn( 'PRESCALEBLOB', 'blob')


  194             lshltTab.insertColumn( 'HLTCOUNTBLOB', 'blob')


  195             lshltTab.insertColumn( 'HLTACCEPTBLOB', 'blob')


  196             db.createTable(lshltTab,withIdTable=False)


  197             lshltTab.setPrimaryKey( ('DATA_ID','CMSLSNUM') )


  198             created.append(nameDealer.lshltTableName())          


  199 


  200             


  201         if not schema.existsTable(nameDealer.lumivalidationTableName()):


  202             print 'creating lumivalidation  table'


  203             lumivalidation=coral.TableDescription()


  204             lumivalidation.setName( nameDealer.lumivalidationTableName() )


  205             lumivalidation.insertColumn( 'RUNNUM','unsigned int' )


  206             lumivalidation.insertColumn( 'CMSLSNUM','unsigned int' )


  207             lumivalidation.insertColumn( 'FLAG','string',28,False )


  208             lumivalidation.insertColumn( 'COMMENT','string',1024,False )


  209             lumivalidation.setPrimaryKey( ('RUNNUM','CMSLSNUM') )


  210             lumivalidation.setNotNullConstraint('FLAG',True)


  211             db.createTable(lumivalidation,withIdTable=False)


  212             created.append(nameDealer.lumivalidationTableName())


  213         return created


  214     except :


  215         raise 


  216 


  217    


  218 #=======================================================


  219 #


  220 #   DROP


  221 #

#=======================================================    


nameDealer.lstrgTableName
def lstrgTableName
Definition: nameDealer.py:49


nameDealer.lumivalidationTableName
def lumivalidationTableName
Definition: nameDealer.py:85


nameDealer.trghltMapTableName
def trghltMapTableName
Definition: nameDealer.py:76


nameDealer.revisionTableName
def revisionTableName
Definition: nameDealer.py:11


nameDealer.hltTableName
def hltTableName
Definition: nameDealer.py:55


nameDealer.trgdataTableName
def trgdataTableName
Definition: nameDealer.py:46


nameDealer.hltdataTableName
def hltdataTableName
Definition: nameDealer.py:58


lumidbDDL.createTables
def createTables
Definition: lumidbDDL.py:8


nameDealer.lshltTableName
def lshltTableName
Definition: nameDealer.py:61


nameDealer.lumidataTableName
def lumidataTableName
Definition: nameDealer.py:19


nameDealer.luminormTableName
def luminormTableName
Definition: nameDealer.py:37



nameDealer.fillschemeTableName
def fillschemeTableName
Definition: nameDealer.py:13


nameDealer.lumisummaryv2TableName
def lumisummaryv2TableName
Definition: nameDealer.py:28


nameDealer.cmsrunsummaryTableName
def cmsrunsummaryTableName
Definition: nameDealer.py:16











      

        

          def lumidbDDL.createUniqueConstraints 
          (
           
          schema)
          
        

      




 

Definition at line 469 of file lumidbDDL.py.


  469 


  470 def createUniqueConstraints(schema):


  471     '''


  472     '''


  473     try:


  474         revtable=schema.tableHandle(nameDealer.revisionTableName())


  475         revtable.schemaEditor().setUniqueConstraint('NAME','revisions_name_uc')


  476     except:

        raise


nameDealer.revisionTableName
def revisionTableName
Definition: nameDealer.py:11


lumidbDDL.createUniqueConstraints
def createUniqueConstraints
Definition: lumidbDDL.py:469











      

        

          def lumidbDDL.describe 
          (
           
          schema)
          
        

      




 

Definition at line 482 of file lumidbDDL.py.


  482 


  483 def describe(schema):


  484     '''


  485     '''


  486     pass




lumidbDDL.describe
def describe
Definition: lumidbDDL.py:482











      

        

          def lumidbDDL.describeIndices 
          (
           
          schema)
          
        

      




 

Definition at line 445 of file lumidbDDL.py.


  445 


  446 def describeIndices(schema):


  447     '''


  448     '''

    pass


lumidbDDL.describeIndices
def describeIndices
Definition: lumidbDDL.py:445











      

        

          def lumidbDDL.dropFKConstrains 
          (
           
          schema)
          
        

      




 

Definition at line 453 of file lumidbDDL.py.


  453 


  454 def dropFKConstrains(schema):


  455     '''


  456     '''

    pass


lumidbDDL.dropFKConstrains
def dropFKConstrains
Definition: lumidbDDL.py:453











      

        

          def lumidbDDL.dropIndices 
          (
           
          schema)
          
        

      




 

Definition at line 441 of file lumidbDDL.py.


  441 


  442 def dropIndices(schema):


  443     '''


  444     '''

    pass


lumidbDDL.dropIndices
def dropIndices
Definition: lumidbDDL.py:441











      

        

          def lumidbDDL.dropNULLConstraints 
          (
           
          schema)
          
        

      




 

Definition at line 464 of file lumidbDDL.py.


  464 


  465 def dropNULLConstraints(schema):


  466     '''


  467     '''


  468     pass




lumidbDDL.dropNULLConstraints
def dropNULLConstraints
Definition: lumidbDDL.py:464











      

        

          def lumidbDDL.dropTables 
          (
           
          schema, 
        

        

          
          
           
          tablelist 
        

        

          
          )
          
        

      





Definition at line 222 of file lumidbDDL.py.



References nameDealer.entryTableName(), nameDealer.hltdataTableName(), nameDealer.hltTableName(), nameDealer.idTableName(), nameDealer.lumidataTableName(), nameDealer.lumidetailTableName(), nameDealer.luminormTableName(), nameDealer.lumisummaryTableName(), nameDealer.lumisummaryv2TableName(), nameDealer.revmapTableName(), nameDealer.trgdataTableName(), and nameDealer.trgTableName().



Referenced by lumidb2Schema.dropLumi(), and newToOld().


  222 


  223 def dropTables(schema,tablelist):


  224     try:


  225         db=dbUtil.dbUtil(schema)


  226         for tablename in tablelist:


  227             if tablename in [nameDealer.luminormTableName(),nameDealer.lumidataTableName(),nameDealer.trgdataTableName(),nameDealer.hltdataTableName()]:


  228                 db.dropTable( nameDealer.idTableName(tablename) )


  229                 db.dropTable( nameDealer.entryTableName(tablename) )


  230                 db.dropTable( nameDealer.revmapTableName(tablename) )            


  231             if tablename in [nameDealer.trgTableName(),nameDealer.lumisummaryTableName(),nameDealer.lumisummaryv2TableName(),nameDealer.lumidetailTableName(),nameDealer.hltTableName()]:


  232                 db.dropTable( nameDealer.idTableName(tablename) )


  233             db.dropTable( tablename )


  234     except :


  235         raise 

    


nameDealer.revmapTableName
def revmapTableName
Definition: nameDealer.py:100


nameDealer.lumisummaryTableName
def lumisummaryTableName
Definition: nameDealer.py:25


nameDealer.idTableName
def idTableName
Definition: nameDealer.py:94


nameDealer.hltTableName
def hltTableName
Definition: nameDealer.py:55


nameDealer.trgdataTableName
def trgdataTableName
Definition: nameDealer.py:46


nameDealer.lumidetailTableName
def lumidetailTableName
Definition: nameDealer.py:34


nameDealer.hltdataTableName
def hltdataTableName
Definition: nameDealer.py:58


nameDealer.entryTableName
def entryTableName
Definition: nameDealer.py:103


nameDealer.lumidataTableName
def lumidataTableName
Definition: nameDealer.py:19


lumidbDDL.dropTables
def dropTables
Definition: lumidbDDL.py:222


nameDealer.luminormTableName
def luminormTableName
Definition: nameDealer.py:37



nameDealer.lumisummaryv2TableName
def lumisummaryv2TableName
Definition: nameDealer.py:28


nameDealer.trgTableName
def trgTableName
Definition: nameDealer.py:52











      

        

          def lumidbDDL.dropUNIQUEConstraints 
          (
           
          schema)
          
        

      




 

Definition at line 477 of file lumidbDDL.py.


  477 


  478 def dropUNIQUEConstraints(schema):


  479     '''


  480     '''


  481     pass




lumidbDDL.dropUNIQUEConstraints
def dropUNIQUEConstraints
Definition: lumidbDDL.py:477











      

        

          def lumidbDDL.newToOld 
          (
           
          schema)
          
        

      





Definition at line 413 of file lumidbDDL.py.



References nameDealer.cmsrunsummaryTableName(), dropTables(), and mergeVDriftHistosByStation.name.



Referenced by PrimaryVertexSorter< ParticlesCollection >.produce().


  413 


  414 def newToOld(schema):


  415     try:


  416         dropTables(schema,['REVISIONS','LUMINORMS','LUMIDATA','LUMISUMMARYV2','TRGDATA','LSTRG','HLTDATA','LSHLT'])


  417         tableHandle=schema.tableHandle(nameDealer.cmsrunsummaryTableName())


  418         ncol=tableHandle.description().numberOfColumns()


  419         todrop=[]


  420         for i in range(ncol):


  421             colname=tableHandle.description().columnDescription(i).name()


  422             if colname in ['L1KEY','EGEV','AMODETAG']:


  423                 todrop.append(colname)


  424         for colname in todrop:


  425             tableHandle.schemaEditor().dropColumn(colname)            


  426     except :


  427         raise 


  428 


  429 #=======================================================


  430 #


  431 #   TODO


  432 #


  433 #=======================================================   




lumidbDDL.newToOld
def newToOld
Definition: lumidbDDL.py:413



lumidbDDL.dropTables
def dropTables
Definition: lumidbDDL.py:222


nameDealer.cmsrunsummaryTableName
def cmsrunsummaryTableName
Definition: nameDealer.py:16











      

        

          def lumidbDDL.oldToNew 
          (
           
          schema)
          
        

      




modify old tables:cmsrunsummary
alter table cmsrunsummary add column(l1key string,egev unsigned int,amodetag string)

 

Definition at line 399 of file lumidbDDL.py.



References nameDealer.cmsrunsummaryTableName(), and createTables().



Referenced by PrimaryVertexSorter< ParticlesCollection >.produce().


  399 


  400 def oldToNew(schema):


  401     '''


  402     modify old tables:cmsrunsummary


  403     alter table cmsrunsummary add column(l1key string,egev unsigned int,amodetag string)


  404     '''


  405     try:


  406         tableHandle=schema.tableHandle(nameDealer.cmsrunsummaryTableName())


  407         tableHandle.schemaEditor().insertColumn('L1KEY','string',128,False)


  408         tableHandle.schemaEditor().insertColumn('EGEV','unsigned int')


  409         tableHandle.schemaEditor().insertColumn('AMODETAG','string',28,False)


  410         createTables(schema)


  411     except:


  412         raise

    


lumidbDDL.oldToNew
def oldToNew
Definition: lumidbDDL.py:399


lumidbDDL.createTables
def createTables
Definition: lumidbDDL.py:8


nameDealer.cmsrunsummaryTableName
def cmsrunsummaryTableName
Definition: nameDealer.py:16







Variable Documentation






      

        

          string lumidbDDL.authpath = '/afs/cern.ch/user/x/xiezhen'
        

      





Definition at line 490 of file lumidbDDL.py.











      

        

          string lumidbDDL.myconstr = 'oracle://devdb10/cms_xiezhen_dev'
        

      





Definition at line 489 of file lumidbDDL.py.











      

        

          tuple lumidbDDL.schema = session.nominalSchema()
        

      





Definition at line 494 of file lumidbDDL.py.











      

        

          tuple lumidbDDL.session = svc.openSession(isReadOnly=False,cpp2sqltype=[('unsigned int','NUMBER(10)'),('unsigned long long','NUMBER(20)')])
        

      





Definition at line 493 of file lumidbDDL.py.











      

        

          tuple lumidbDDL.svc = sessionManager.sessionManager(myconstr,authpath=authpath,debugON=False)
        

      





Definition at line 492 of file lumidbDDL.py.











      

        

          tuple lumidbDDL.tables = createTables(schema)
        

      





Definition at line 496 of file lumidbDDL.py.









Generated for CMSSW Reference Manual by doxygen 1.8.5