CMS 3D CMS Logo

Functions | Variables
lumidbDDL Namespace Reference

Functions

def createFKConstraints (schema)
 
def createIndices (schema)
 
def createNULLConstraints (schema)
 
def createOldSchema (schema)
 
def createTables (schema)
 
def createUniqueConstraints (schema)
 
def describe (schema)
 
def describeIndices (schema)
 
def dropFKConstrains (schema)
 
def dropIndices (schema)
 
def dropNULLConstraints (schema)
 
def dropTables (schema, tablelist)
 
def dropUNIQUEConstraints (schema)
 
def newToOld (schema)
 
def oldToNew (schema)
 

Variables

 authpath
 
 cpp2sqltype
 
 debugON
 
 False
 
 isReadOnly
 
 myconstr
 
 schema
 
 session
 
 svc
 
 tables
 

Function Documentation

def lumidbDDL.createFKConstraints (   schema)
 

Definition at line 450 of file lumidbDDL.py.

451  '''
452  '''
453  pass
def createFKConstraints(schema)
Definition: lumidbDDL.py:450
def lumidbDDL.createIndices (   schema)
 

Definition at line 435 of file lumidbDDL.py.

435 def createIndices(schema):
436  '''
437  '''
438  pass
439  #cmsrunsummary.createIndex('cmsrunsummary_fillnum',('FILLNUM'))
440  #cmsrunsummary.createIndex('cmsrunsummary_startime',('STARTTIME'))
441 
def createIndices(schema)
Definition: lumidbDDL.py:435
def lumidbDDL.createNULLConstraints (   schema)
 

Definition at line 458 of file lumidbDDL.py.

459  '''
460  '''
461  #cmsrunsummary.setNotNullConstraint('HLTKEY',True)
462  #cmsrunsummary.setNotNullConstraint('FILLNUM',True)
463  #cmsrunsummary.setNotNullConstraint('SEQUENCE',True)
464  pass
def createNULLConstraints(schema)
Definition: lumidbDDL.py:458
def lumidbDDL.createOldSchema (   schema)
create tables of lumidb1 if not exist

Definition at line 237 of file lumidbDDL.py.

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

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 #
399 #=======================================================
def createOldSchema(schema)
Definition: lumidbDDL.py:237
def lumidetailTableName()
Definition: nameDealer.py:34
def trgTableName()
Definition: nameDealer.py:52
def lumisummaryTableName()
Definition: nameDealer.py:25
def lumivalidationTableName()
Definition: nameDealer.py:85
def hltTableName()
Definition: nameDealer.py:55
def cmsrunsummaryTableName()
Definition: nameDealer.py:16
def trghltMapTableName()
Definition: nameDealer.py:76
def lumidbDDL.createTables (   schema)
create new tables if not exist
revisions,revisions_id,luminorms,luminorms_entries,luminorms_entries_id,fillscheme

Definition at line 9 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(), edm.print(), nameDealer.revisionTableName(), nameDealer.trgdataTableName(), and nameDealer.trghltMapTableName().

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

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 #
222 #=======================================================
def createTables(schema)
Definition: lumidbDDL.py:9
def lumisummaryv2TableName()
Definition: nameDealer.py:28
S & print(S &os, JobReport::InputFile const &f)
Definition: JobReport.cc:65
def luminormTableName()
Definition: nameDealer.py:37
def lumivalidationTableName()
Definition: nameDealer.py:85
def lshltTableName()
Definition: nameDealer.py:61
def revisionTableName()
Definition: nameDealer.py:11
def lstrgTableName()
Definition: nameDealer.py:49
def trgdataTableName()
Definition: nameDealer.py:46
def hltTableName()
Definition: nameDealer.py:55
def fillschemeTableName()
Definition: nameDealer.py:13
def hltdataTableName()
Definition: nameDealer.py:58
def cmsrunsummaryTableName()
Definition: nameDealer.py:16
def trghltMapTableName()
Definition: nameDealer.py:76
def lumidataTableName()
Definition: nameDealer.py:19
def lumidbDDL.createUniqueConstraints (   schema)
 

Definition at line 470 of file lumidbDDL.py.

471  '''
472  '''
473  try:
474  revtable=schema.tableHandle(nameDealer.revisionTableName())
475  revtable.schemaEditor().setUniqueConstraint('NAME','revisions_name_uc')
476  except:
477  raise
def revisionTableName()
Definition: nameDealer.py:11
def createUniqueConstraints(schema)
Definition: lumidbDDL.py:470
def lumidbDDL.describe (   schema)
 

Definition at line 483 of file lumidbDDL.py.

483 def describe(schema):
484  '''
485  '''
486  pass
487 
def describe(schema)
Definition: lumidbDDL.py:483
def lumidbDDL.describeIndices (   schema)
 

Definition at line 446 of file lumidbDDL.py.

446 def describeIndices(schema):
447  '''
448  '''
449  pass
def describeIndices(schema)
Definition: lumidbDDL.py:446
def lumidbDDL.dropFKConstrains (   schema)
 

Definition at line 454 of file lumidbDDL.py.

454 def dropFKConstrains(schema):
455  '''
456  '''
457  pass
def dropFKConstrains(schema)
Definition: lumidbDDL.py:454
def lumidbDDL.dropIndices (   schema)
 

Definition at line 442 of file lumidbDDL.py.

442 def dropIndices(schema):
443  '''
444  '''
445  pass
def dropIndices(schema)
Definition: lumidbDDL.py:442
def lumidbDDL.dropNULLConstraints (   schema)
 

Definition at line 465 of file lumidbDDL.py.

466  '''
467  '''
468  pass
469 
def dropNULLConstraints(schema)
Definition: lumidbDDL.py:465
def lumidbDDL.dropTables (   schema,
  tablelist 
)

Definition at line 223 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().

223 def dropTables(schema,tablelist):
224  try:
225  db=dbUtil.dbUtil(schema)
226  for tablename in tablelist:
228  db.dropTable( nameDealer.idTableName(tablename) )
229  db.dropTable( nameDealer.entryTableName(tablename) )
230  db.dropTable( nameDealer.revmapTableName(tablename) )
232  db.dropTable( nameDealer.idTableName(tablename) )
233  db.dropTable( tablename )
234  except :
235  raise
236 
def dropTables(schema, tablelist)
Definition: lumidbDDL.py:223
def lumisummaryv2TableName()
Definition: nameDealer.py:28
def lumidetailTableName()
Definition: nameDealer.py:34
def trgTableName()
Definition: nameDealer.py:52
def lumisummaryTableName()
Definition: nameDealer.py:25
def entryTableName(dataTableName)
Definition: nameDealer.py:103
def luminormTableName()
Definition: nameDealer.py:37
def revmapTableName(dataTableName)
Definition: nameDealer.py:100
def trgdataTableName()
Definition: nameDealer.py:46
def hltTableName()
Definition: nameDealer.py:55
def hltdataTableName()
Definition: nameDealer.py:58
def idTableName(dataTableName)
Definition: nameDealer.py:94
def lumidataTableName()
Definition: nameDealer.py:19
def lumidbDDL.dropUNIQUEConstraints (   schema)
 

Definition at line 478 of file lumidbDDL.py.

479  '''
480  '''
481  pass
482 
def dropUNIQUEConstraints(schema)
Definition: lumidbDDL.py:478
def lumidbDDL.newToOld (   schema)

Definition at line 414 of file lumidbDDL.py.

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

Referenced by PFCandidateMuonUntagger.produce(), PrimaryVertexSorter< ParticlesCollection >.produce(), and PFCandidateRecalibrator.produce().

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 #=======================================================
434 
def dropTables(schema, tablelist)
Definition: lumidbDDL.py:223
def cmsrunsummaryTableName()
Definition: nameDealer.py:16
def newToOld(schema)
Definition: lumidbDDL.py:414
def lumidbDDL.oldToNew (   schema)
modify old tables:cmsrunsummary
alter table cmsrunsummary add column(l1key string,egev unsigned int,amodetag string)

Definition at line 400 of file lumidbDDL.py.

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

Referenced by PFCandidateMuonUntagger.produce(), PrimaryVertexSorter< ParticlesCollection >.produce(), and PFCandidateRecalibrator.produce().

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
413 
def createTables(schema)
Definition: lumidbDDL.py:9
def oldToNew(schema)
Definition: lumidbDDL.py:400
def cmsrunsummaryTableName()
Definition: nameDealer.py:16

Variable Documentation

lumidbDDL.authpath

Definition at line 491 of file lumidbDDL.py.

lumidbDDL.cpp2sqltype

Definition at line 494 of file lumidbDDL.py.

lumidbDDL.debugON

Definition at line 493 of file lumidbDDL.py.

lumidbDDL.False

Definition at line 494 of file lumidbDDL.py.

lumidbDDL.isReadOnly

Definition at line 494 of file lumidbDDL.py.

lumidbDDL.myconstr

Definition at line 490 of file lumidbDDL.py.

lumidbDDL.schema

Definition at line 495 of file lumidbDDL.py.

lumidbDDL.session

Definition at line 494 of file lumidbDDL.py.

lumidbDDL.svc

Definition at line 493 of file lumidbDDL.py.

lumidbDDL.tables

Definition at line 497 of file lumidbDDL.py.