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 436 of file lumidbDDL.py.

437 def createFKConstraints(schema):
438  '''
439  '''
pass
def createFKConstraints
Definition: lumidbDDL.py:436
def lumidbDDL.createIndices (   schema)
 

Definition at line 421 of file lumidbDDL.py.

422 def createIndices(schema):
423  '''
424  '''
425  pass
426  #cmsrunsummary.createIndex('cmsrunsummary_fillnum',('FILLNUM'))
427  #cmsrunsummary.createIndex('cmsrunsummary_startime',('STARTTIME'))
def createIndices
Definition: lumidbDDL.py:421
def lumidbDDL.createNULLConstraints (   schema)
 

Definition at line 444 of file lumidbDDL.py.

445 def createNULLConstraints(schema):
446  '''
447  '''
448  #cmsrunsummary.setNotNullConstraint('HLTKEY',True)
449  #cmsrunsummary.setNotNullConstraint('FILLNUM',True)
450  #cmsrunsummary.setNotNullConstraint('SEQUENCE',True)
pass
def createNULLConstraints
Definition: lumidbDDL.py:444
def lumidbDDL.createOldSchema (   schema)
create tables of lumidb1 if not exist

Definition at line 223 of file lumidbDDL.py.

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

224 def createOldSchema(schema):
225  '''
226  create tables of lumidb1 if not exist
227  '''
228  try:
229  created=[]
230  db=dbUtil.dbUtil(schema)
231  if not schema.existsTable(nameDealer.lumivalidationTableName()):
232  lumivalidation=coral.TableDescription()
233  lumivalidation.setName( nameDealer.lumivalidationTableName() )
234  lumivalidation.insertColumn( 'RUNNUM','unsigned int' )
235  lumivalidation.insertColumn( 'CMSLSNUM','unsigned int' )
236  lumivalidation.insertColumn( 'FLAG','string' )
237  lumivalidation.insertColumn( 'COMMENT','string' )
238  lumivalidation.setPrimaryKey(('RUNNUM','CMSLSNUM'))
239  lumivalidation.setNotNullConstraint('FLAG',True)
240  db.createTable(lumivalidation,withIdTable=False)
241  created.append(nameDealer.lumivalidationTableName())
242 
243  if not schema.existsTable(nameDealer.cmsrunsummaryTableName()):
244  cmsrunsummary=coral.TableDescription()
245  cmsrunsummary.setName( nameDealer.cmsrunsummaryTableName() )
246  cmsrunsummary.insertColumn('RUNNUM','unsigned int')
247  cmsrunsummary.insertColumn('HLTKEY','string')
248  cmsrunsummary.insertColumn('FILLNUM','unsigned int')
249  cmsrunsummary.insertColumn('SEQUENCE','string')
250  cmsrunsummary.insertColumn('STARTTIME','time stamp',6)
251  cmsrunsummary.insertColumn('STOPTIME','time stamp',6)
252  cmsrunsummary.setPrimaryKey('RUNNUM')
253  cmsrunsummary.setNotNullConstraint('HLTKEY',True)
254  cmsrunsummary.setNotNullConstraint('FILLNUM',True)
255  cmsrunsummary.setNotNullConstraint('SEQUENCE',True)
256  cmsrunsummary.createIndex('cmsrunsummary_fillnum',('FILLNUM'))
257  cmsrunsummary.createIndex('cmsrunsummary_startime',('STARTTIME'))
258  db.createTable(cmsrunsummary,withIdTable=False)
259  created.append(nameDealer.cmsrunsummaryTableName())
260 
261  if not schema.existsTable(nameDealer.lumisummaryTableName()):
262  summary=coral.TableDescription()
263  summary.setName( nameDealer.lumisummaryTableName() )
264  summary.insertColumn('LUMISUMMARY_ID','unsigned long long')
265  summary.insertColumn('RUNNUM','unsigned int')
266  summary.insertColumn('CMSLSNUM','unsigned int')
267  summary.insertColumn('LUMILSNUM','unsigned int')
268  summary.insertColumn('LUMIVERSION','string')
269  summary.insertColumn('DTNORM','float')
270  summary.insertColumn('LHCNORM','float')
271  summary.insertColumn('CMSALIVE','short')
272  summary.insertColumn('INSTLUMI','float')
273  summary.insertColumn('INSTLUMIERROR','float')
274  summary.insertColumn('INSTLUMIQUALITY','short')
275  summary.insertColumn('BEAMSTATUS','string')
276  summary.insertColumn('BEAMENERGY','float')
277  summary.insertColumn('NUMORBIT','unsigned int')
278  summary.insertColumn('STARTORBIT','unsigned int')
279  summary.insertColumn('LUMISECTIONQUALITY','short')
280  summary.insertColumn('CMSBXINDEXBLOB','blob')
281  summary.insertColumn('BEAMINTENSITYBLOB_1','blob')
282  summary.insertColumn('BEAMINTENSITYBLOB_2','blob')
283  summary.setPrimaryKey('LUMISUMMARY_ID')
284  summary.setNotNullConstraint('RUNNUM',True)
285  summary.setNotNullConstraint('CMSLSNUM',True)
286  summary.setNotNullConstraint('LUMILSNUM',True)
287  summary.setNotNullConstraint('CMSALIVE',True)
288  summary.setNotNullConstraint('LUMIVERSION',True)
289  summary.setNotNullConstraint('DTNORM',True)
290  summary.setNotNullConstraint('LHCNORM',True)
291  summary.setNotNullConstraint('INSTLUMI',True)
292  summary.setNotNullConstraint('INSTLUMIERROR',True)
293  summary.setNotNullConstraint('INSTLUMIQUALITY',True)
294  summary.setNotNullConstraint('STARTORBIT',True)
295  summary.setNotNullConstraint('NUMORBIT',True)
296  summary.setNotNullConstraint('LUMISECTIONQUALITY',True)
297  summary.setNotNullConstraint('BEAMENERGY',True)
298  summary.setNotNullConstraint('BEAMSTATUS',True)
299  summary.setUniqueConstraint(('RUNNUM','LUMIVERSION','LUMILSNUM'))
300  summary.createIndex('lumisummary_runnum',('RUNNUM'))
301  db.createTable(summary,withIdTable=True)
302  created.append(nameDealer.lumisummaryTableName())
303 
304  if not schema.existsTable(nameDealer.lumidetailTableName()):
305  detail=coral.TableDescription()
306  detail.setName( nameDealer.lumidetailTableName() )
307  detail.insertColumn('LUMIDETAIL_ID','unsigned long long')
308  detail.insertColumn('LUMISUMMARY_ID','unsigned long long')
309  detail.insertColumn('BXLUMIVALUE','blob')
310  detail.insertColumn('BXLUMIERROR','blob')
311  detail.insertColumn('BXLUMIQUALITY','blob')
312  detail.insertColumn('ALGONAME','string')
313  detail.setPrimaryKey('LUMIDETAIL_ID')
314  detail.createForeignKey('DETAILSOURCE','LUMISUMMARY_ID',nameDealer.lumisummaryTableName(),'LUMISUMMARY_ID')
315  detail.setNotNullConstraint('BXLUMIVALUE',True)
316  detail.setNotNullConstraint('BXLUMIERROR',True)
317  detail.setNotNullConstraint('BXLUMIQUALITY',True)
318  detail.setNotNullConstraint('ALGONAME',True)
319  detail.setUniqueConstraint(('LUMISUMMARY_ID','ALGONAME'))
320  db.createTable(detail,withIdTable=True)
321  created.append(nameDealer.lumidetailTableName())
322 
323  if not schema.existsTable(nameDealer.trgTableName()):
324  trg=coral.TableDescription()
325  trg.setName( nameDealer.trgTableName() )
326  trg.insertColumn('TRG_ID','unsigned long long')
327  trg.insertColumn('RUNNUM','unsigned int')
328  trg.insertColumn('CMSLSNUM','unsigned int')
329  trg.insertColumn('BITNUM','unsigned int')
330  trg.insertColumn('BITNAME','string')
331  trg.insertColumn('TRGCOUNT','unsigned int')
332  trg.insertColumn('DEADTIME','unsigned long long')
333  trg.insertColumn('PRESCALE','unsigned int')
334  trg.setNotNullConstraint('RUNNUM',True)
335  trg.setNotNullConstraint('CMSLSNUM',True)
336  trg.setNotNullConstraint('BITNUM',True)
337  trg.setNotNullConstraint('BITNAME',True)
338  trg.setNotNullConstraint('TRGCOUNT',True)
339  trg.setNotNullConstraint('DEADTIME',True)
340  trg.setNotNullConstraint('PRESCALE',True)
341  trg.setPrimaryKey('TRG_ID')
342  trg.createIndex('trg_runnum',('RUNNUM'))
343  db.createTable(trg,withIdTable=True)
344  created.append( nameDealer.trgTableName() )
345 
346  if not schema.existsTable( nameDealer.hltTableName() ):
347  hlt=coral.TableDescription()
348  hlt.setName( nameDealer.hltTableName() )
349  hlt.insertColumn( 'HLT_ID','unsigned long long')
350  hlt.insertColumn( 'RUNNUM','unsigned int')
351  hlt.insertColumn( 'CMSLSNUM','unsigned int')
352  hlt.insertColumn( 'PATHNAME','string')
353  hlt.insertColumn( 'INPUTCOUNT','unsigned int')
354  hlt.insertColumn( 'ACCEPTCOUNT','unsigned int')
355  hlt.insertColumn( 'PRESCALE','unsigned int')
356  hlt.setPrimaryKey( 'HLT_ID' )
357  hlt.setNotNullConstraint('RUNNUM',True)
358  hlt.setNotNullConstraint('CMSLSNUM',True)
359  hlt.setNotNullConstraint('PATHNAME',True)
360  hlt.setNotNullConstraint('INPUTCOUNT',True)
361  hlt.setNotNullConstraint('ACCEPTCOUNT',True)
362  hlt.setNotNullConstraint('PRESCALE',True)
363  hlt.createIndex('hlt_runnum',('RUNNUM'))
364  db.createTable(hlt,withIdTable=True)
365  created.append( nameDealer.hltTableName() )
366 
367  if not schema.existsTable( nameDealer.trghltMapTableName() ):
368  trghlt=coral.TableDescription()
369  trghlt.setName( nameDealer.trghltMapTableName() )
370  trghlt.insertColumn( 'HLTKEY','string' )
371  trghlt.insertColumn( 'HLTPATHNAME','string' )
372  trghlt.insertColumn( 'L1SEED','string' )
373  trghlt.setNotNullConstraint('HLTKEY',True)
374  trghlt.setNotNullConstraint('HLTPATHNAME',True)
375  trghlt.setNotNullConstraint('L1SEED',True)
376  db.createTable(trghlt,withIdTable=False)
377  created.append( nameDealer.trghltMapTableName() )
378  return created
379  except:
380  raise
381 
382 #=======================================================
383 #
384 # MODIFY
385 #
#=======================================================
def createOldSchema
Definition: lumidbDDL.py:223
def lumivalidationTableName
Definition: nameDealer.py:56
def lumisummaryTableName
Definition: nameDealer.py:20
def trghltMapTableName
Definition: nameDealer.py:47
def hltTableName
Definition: nameDealer.py:38
def lumidetailTableName
Definition: nameDealer.py:25
def trgTableName
Definition: nameDealer.py:35
def cmsrunsummaryTableName
Definition: nameDealer.py:14
def lumidbDDL.createTables (   schema)
create new tables if not exist
revisions,revisions_id,luminorms,luminorms_entries,luminorms_entries_id,

Definition at line 8 of file lumidbDDL.py.

References nameDealer.cmsrunsummaryTableName(), 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,
13  '''
14  try:
15  created=[]
16  db=dbUtil.dbUtil(schema)
17  if not schema.existsTable(nameDealer.revisionTableName()):
18  print 'creating revisions table'
19  revisionsTab=coral.TableDescription()
20  revisionsTab.setName( nameDealer.revisionTableName() )
21  revisionsTab.insertColumn( 'REVISION_ID','unsigned long long')
22  revisionsTab.insertColumn( 'BRANCH_ID','unsigned long long')
23  revisionsTab.insertColumn( 'NAME', 'string')
24  revisionsTab.insertColumn( 'BRANCH_NAME', 'string')
25  revisionsTab.insertColumn( 'COMMENT', 'string')
26  revisionsTab.insertColumn( 'CTIME', 'time stamp',6)
27  revisionsTab.setPrimaryKey( 'REVISION_ID' )
28  revisionsTab.setUniqueConstraint(('NAME'))
29  db.createTable(revisionsTab,withIdTable=True)
30  created.append(nameDealer.revisionTableName())
31 
32  if not schema.existsTable(nameDealer.luminormTableName()):
33  print 'creating luminorms table'
34  luminormsTab=coral.TableDescription()
35  luminormsTab.setName( nameDealer.luminormTableName() )
36  luminormsTab.insertColumn( 'DATA_ID','unsigned long long')
37  luminormsTab.insertColumn( 'ENTRY_ID','unsigned long long')
38  luminormsTab.insertColumn( 'ENTRY_NAME','string')
39  luminormsTab.insertColumn( 'AMODETAG', 'string')
40  luminormsTab.insertColumn( 'NORM_1', 'float')
41  luminormsTab.insertColumn( 'EGEV_1', 'unsigned int')
42  luminormsTab.insertColumn( 'NORM_2', 'float')
43  luminormsTab.insertColumn( 'EGEV_2', 'unsigned int')
44  luminormsTab.setPrimaryKey( 'DATA_ID' )
45  db.createTable(luminormsTab,withIdTable=True,withEntryTables=True,withRevMapTable=True)
46  created.append(nameDealer.luminormTableName())
47 
48  if not schema.existsTable(nameDealer.lumidataTableName()):
49  print 'creating lumidata table'
50  lumidataTab=coral.TableDescription()
51  lumidataTab.setName( nameDealer.lumidataTableName() )
52  lumidataTab.insertColumn( 'DATA_ID','unsigned long long')
53  lumidataTab.insertColumn( 'ENTRY_ID','unsigned long long')
54  lumidataTab.insertColumn( 'ENTRY_NAME','string')
55  lumidataTab.insertColumn( 'SOURCE', 'string')
56  lumidataTab.insertColumn( 'RUNNUM', 'unsigned int')
57  lumidataTab.insertColumn( 'NOMINALEGEV', 'float')
58  lumidataTab.setPrimaryKey( 'DATA_ID' )
59  db.createTable(lumidataTab,withIdTable=True,withEntryTables=True,withRevMapTable=True)
60  created.append(nameDealer.lumidataTableName())
61 
62  if not schema.existsTable(nameDealer.lumisummaryv2TableName() ):
63  print 'creating lumisummaryv2 table'
64  summary=coral.TableDescription()
65  summary.setName( nameDealer.lumisummaryv2TableName() )
66  summary.insertColumn('DATA_ID','unsigned long long')
67  summary.insertColumn('RUNNUM','unsigned int')
68  summary.insertColumn('LUMILSNUM','unsigned int')
69  summary.insertColumn('CMSLSNUM','unsigned int')
70  summary.insertColumn('INSTLUMI','float')
71  summary.insertColumn('INSTLUMIERROR','float')
72  summary.insertColumn('INSTLUMIQUALITY','short')
73  summary.insertColumn('BEAMSTATUS','string')
74  summary.insertColumn('BEAMENERGY','float')
75  summary.insertColumn('NUMORBIT','unsigned int')
76  summary.insertColumn('STARTORBIT','unsigned int')
77  summary.insertColumn('CMSBXINDEXBLOB','blob')
78  summary.insertColumn('BEAMINTENSITYBLOB_1','blob')
79  summary.insertColumn('BEAMINTENSITYBLOB_2','blob')
80  summary.insertColumn('BXLUMIVALUE_OCC1','blob')
81  summary.insertColumn('BXLUMIVALUE_OCC2','blob')
82  summary.insertColumn('BXLUMIVALUE_ET','blob')
83  summary.insertColumn('BXLUMIERROR_OCC1','blob')
84  summary.insertColumn('BXLUMIERROR_OCC2','blob')
85  summary.insertColumn('BXLUMIERROR_ET','blob')
86  summary.insertColumn('BXLUMIQUALITY_OCC1','blob')
87  summary.insertColumn('BXLUMIQUALITY_OCC2','blob')
88  summary.insertColumn('BXLUMIQUALITY_ET','blob')
89  summary.setPrimaryKey(('DATA_ID','LUMILSNUM'))
90  db.createTable(summary,withIdTable=False)
91  created.append(nameDealer.lumisummaryv2TableName())
92 
93  #
94  # This table exists in the old schema
95  #
96  if not schema.existsTable(nameDealer.cmsrunsummaryTableName()):
97  print 'creating cmsrunsummary table'
98  cmsrunsummary=coral.TableDescription()
99  cmsrunsummary.setName( nameDealer.cmsrunsummaryTableName() )
100  cmsrunsummary.insertColumn('RUNNUM','unsigned int')
101  cmsrunsummary.insertColumn('HLTKEY','string')
102  cmsrunsummary.insertColumn('L1KEY','string')
103  cmsrunsummary.insertColumn('FILLNUM','unsigned int')
104  cmsrunsummary.insertColumn('SEQUENCE','string')
105  cmsrunsummary.insertColumn('STARTTIME','time stamp',6)
106  cmsrunsummary.insertColumn('STOPTIME','time stamp',6)
107  cmsrunsummary.insertColumn('EGEV','unsigned int')
108  cmsrunsummary.insertColumn('AMODETAG','string')
109  cmsrunsummary.setPrimaryKey('RUNNUM')
110  db.createTable(cmsrunsummary,withIdTable=False)
111  created.append(nameDealer.cmsrunsummaryTableName())
112  #
113  # This table exists in the old schema
114  #
115  if not schema.existsTable(nameDealer.trghltMapTableName()):
116  print 'creating trghltmap table'
117  trghlt=coral.TableDescription()
118  trghlt.setName( nameDealer.trghltMapTableName() )
119  trghlt.insertColumn( 'HLTKEY','string' )
120  trghlt.insertColumn( 'HLTPATHNAME','string' )
121  trghlt.insertColumn( 'L1SEED','string' )
122  trghlt.setNotNullConstraint('HLTKEY',True)
123  trghlt.setNotNullConstraint('HLTPATHNAME',True)
124  trghlt.setNotNullConstraint('L1SEED',True)
125  db.createTable(trghlt,withIdTable=False)
126  created.append(nameDealer.trghltMapTableName())
127  if not schema.existsTable(nameDealer.trgdataTableName()):
128  print 'creating trgdata table'
129  trgdataTab=coral.TableDescription()
130  trgdataTab.setName( nameDealer.trgdataTableName() )
131  trgdataTab.insertColumn( 'DATA_ID','unsigned long long')
132  trgdataTab.insertColumn( 'ENTRY_ID','unsigned long long')
133  trgdataTab.insertColumn( 'ENTRY_NAME','string')
134  trgdataTab.insertColumn( 'SOURCE', 'string')
135  trgdataTab.insertColumn( 'RUNNUM', 'unsigned int')
136  trgdataTab.insertColumn( 'BITZERONAME', 'string')
137  trgdataTab.insertColumn( 'BITNAMECLOB', 'string',6000)
138  trgdataTab.setPrimaryKey( 'DATA_ID' )
139  db.createTable(trgdataTab,withIdTable=True,withEntryTables=True,withRevMapTable=True)
140  created.append(nameDealer.trgdataTableName())
141  if not schema.existsTable(nameDealer.lstrgTableName()):
142  print 'creating lstrg table'
143  lstrgTab=coral.TableDescription()
144  lstrgTab.setName( nameDealer.lstrgTableName() )
145  lstrgTab.insertColumn( 'DATA_ID','unsigned long long')
146  lstrgTab.insertColumn( 'RUNNUM', 'unsigned int')
147  lstrgTab.insertColumn( 'CMSLSNUM', 'unsigned int')
148  lstrgTab.insertColumn( 'DEADTIMECOUNT', 'unsigned long long')
149  lstrgTab.insertColumn( 'BITZEROCOUNT', 'unsigned int')
150  lstrgTab.insertColumn( 'BITZEROPRESCALE', 'unsigned int')
151  lstrgTab.insertColumn( 'DEADFRAC', 'float')
152  lstrgTab.insertColumn( 'PRESCALEBLOB', 'blob')
153  lstrgTab.insertColumn( 'TRGCOUNTBLOB', 'blob')
154  lstrgTab.setPrimaryKey( ('DATA_ID','CMSLSNUM') )
155  db.createTable(lstrgTab,withIdTable=False)
156  created.append( nameDealer.lstrgTableName() )
157 
158  if not schema.existsTable(nameDealer.hltdataTableName()):
159  print 'creating hltdata table'
160  hltdataTab=coral.TableDescription()
161  hltdataTab.setName( nameDealer.hltdataTableName() )
162  hltdataTab.insertColumn( 'DATA_ID','unsigned long long')
163  hltdataTab.insertColumn( 'ENTRY_ID','unsigned long long')
164  hltdataTab.insertColumn( 'ENTRY_NAME','string')
165  hltdataTab.insertColumn( 'RUNNUM', 'unsigned int')
166  hltdataTab.insertColumn( 'SOURCE', 'string')
167  hltdataTab.insertColumn( 'NPATH', 'unsigned int')
168  hltdataTab.insertColumn( 'PATHNAMECLOB', 'string',6000)
169  hltdataTab.setPrimaryKey( 'DATA_ID' )
170  db.createTable(hltdataTab,withIdTable=True,withEntryTables=True,withRevMapTable=True)
171  created.append(nameDealer.hltTableName())
172 
173  if not schema.existsTable(nameDealer.lshltTableName()):
174  print 'creating lshlt table'
175  lshltTab=coral.TableDescription()
176  lshltTab.setName( nameDealer.lshltTableName() )
177  lshltTab.insertColumn( 'DATA_ID','unsigned long long')
178  lshltTab.insertColumn( 'RUNNUM', 'unsigned int')
179  lshltTab.insertColumn( 'CMSLSNUM', 'unsigned int')
180  lshltTab.insertColumn( 'PRESCALEBLOB', 'blob')
181  lshltTab.insertColumn( 'HLTCOUNTBLOB', 'blob')
182  lshltTab.insertColumn( 'HLTACCEPTBLOB', 'blob')
183  db.createTable(lshltTab,withIdTable=False)
184  lshltTab.setPrimaryKey( ('DATA_ID','CMSLSNUM') )
185  created.append(nameDealer.lshltTableName())
186 
187 
188  if not schema.existsTable(nameDealer.lumivalidationTableName()):
189  print 'creating lumivalidation table'
190  lumivalidation=coral.TableDescription()
191  lumivalidation.setName( nameDealer.lumivalidationTableName() )
192  lumivalidation.insertColumn( 'RUNNUM','unsigned int' )
193  lumivalidation.insertColumn( 'CMSLSNUM','unsigned int' )
194  lumivalidation.insertColumn( 'FLAG','string' )
195  lumivalidation.insertColumn( 'COMMENT','string' )
196  lumivalidation.setPrimaryKey( ('RUNNUM','CMSLSNUM') )
197  lumivalidation.setNotNullConstraint('FLAG',True)
198  db.createTable(lumivalidation,withIdTable=False)
199  created.append(nameDealer.lumivalidationTableName())
200  return created
201  except :
202  raise
203 
204 
205 #=======================================================
206 #
207 # DROP
208 #
#=======================================================
def lstrgTableName
Definition: nameDealer.py:32
def lumivalidationTableName
Definition: nameDealer.py:56
def trghltMapTableName
Definition: nameDealer.py:47
def revisionTableName
Definition: nameDealer.py:11
def hltTableName
Definition: nameDealer.py:38
def trgdataTableName
Definition: nameDealer.py:29
def hltdataTableName
Definition: nameDealer.py:41
def createTables
Definition: lumidbDDL.py:8
def lshltTableName
Definition: nameDealer.py:44
def lumidataTableName
Definition: nameDealer.py:17
def luminormTableName
Definition: nameDealer.py:27
def lumisummaryv2TableName
Definition: nameDealer.py:23
def cmsrunsummaryTableName
Definition: nameDealer.py:14
def lumidbDDL.createUniqueConstraints (   schema)
 

Definition at line 456 of file lumidbDDL.py.

457 def createUniqueConstraints(schema):
458  '''
459  '''
460  try:
461  revtable=schema.tableHandle(nameDealer.revisionTableName())
462  revtable.schemaEditor().setUniqueConstraint('NAME','revisions_name_uc')
463  except:
raise
def revisionTableName
Definition: nameDealer.py:11
def createUniqueConstraints
Definition: lumidbDDL.py:456
def lumidbDDL.describe (   schema)
 

Definition at line 469 of file lumidbDDL.py.

470 def describe(schema):
471  '''
472  '''
473  pass
def describe
Definition: lumidbDDL.py:469
def lumidbDDL.describeIndices (   schema)
 

Definition at line 432 of file lumidbDDL.py.

433 def describeIndices(schema):
434  '''
435  '''
pass
def describeIndices
Definition: lumidbDDL.py:432
def lumidbDDL.dropFKConstrains (   schema)
 

Definition at line 440 of file lumidbDDL.py.

441 def dropFKConstrains(schema):
442  '''
443  '''
pass
def dropFKConstrains
Definition: lumidbDDL.py:440
def lumidbDDL.dropIndices (   schema)
 

Definition at line 428 of file lumidbDDL.py.

429 def dropIndices(schema):
430  '''
431  '''
pass
def dropIndices
Definition: lumidbDDL.py:428
def lumidbDDL.dropNULLConstraints (   schema)
 

Definition at line 451 of file lumidbDDL.py.

452 def dropNULLConstraints(schema):
453  '''
454  '''
455  pass
def dropNULLConstraints
Definition: lumidbDDL.py:451
def lumidbDDL.dropTables (   schema,
  tablelist 
)

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

210 def dropTables(schema,tablelist):
211  try:
212  db=dbUtil.dbUtil(schema)
213  for tablename in tablelist:
215  db.dropTable( nameDealer.idTableName(tablename) )
216  db.dropTable( nameDealer.entryTableName(tablename) )
217  db.dropTable( nameDealer.revmapTableName(tablename) )
219  db.dropTable( nameDealer.idTableName(tablename) )
220  db.dropTable( tablename )
221  except :
222  raise
def revmapTableName
Definition: nameDealer.py:65
def lumisummaryTableName
Definition: nameDealer.py:20
def idTableName
Definition: nameDealer.py:59
def hltTableName
Definition: nameDealer.py:38
def trgdataTableName
Definition: nameDealer.py:29
def lumidetailTableName
Definition: nameDealer.py:25
def hltdataTableName
Definition: nameDealer.py:41
def entryTableName
Definition: nameDealer.py:68
def lumidataTableName
Definition: nameDealer.py:17
def dropTables
Definition: lumidbDDL.py:209
def luminormTableName
Definition: nameDealer.py:27
def lumisummaryv2TableName
Definition: nameDealer.py:23
def trgTableName
Definition: nameDealer.py:35
def lumidbDDL.dropUNIQUEConstraints (   schema)
 

Definition at line 464 of file lumidbDDL.py.

465 def dropUNIQUEConstraints(schema):
466  '''
467  '''
468  pass
def dropUNIQUEConstraints
Definition: lumidbDDL.py:464
def lumidbDDL.newToOld (   schema)

Definition at line 400 of file lumidbDDL.py.

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

401 def newToOld(schema):
402  try:
403  dropTables(schema,['REVISIONS','LUMINORMS','LUMIDATA','LUMISUMMARYV2','TRGDATA','LSTRG','HLTDATA','LSHLT'])
404  tableHandle=schema.tableHandle(nameDealer.cmsrunsummaryTableName())
405  ncol=tableHandle.description().numberOfColumns()
406  todrop=[]
407  for i in range(ncol):
408  colname=tableHandle.description().columnDescription(i).name()
409  if colname in ['L1KEY','EGEV','AMODETAG']:
410  todrop.append(colname)
411  for colname in todrop:
412  tableHandle.schemaEditor().dropColumn(colname)
413  except :
414  raise
415 
416 #=======================================================
417 #
418 # TODO
419 #
420 #=======================================================
def newToOld
Definition: lumidbDDL.py:400
def dropTables
Definition: lumidbDDL.py:209
def cmsrunsummaryTableName
Definition: nameDealer.py:14
def lumidbDDL.oldToNew (   schema)
modify old tables:cmsrunsummary
alter table cmsrunsummary add column(l1key string,egev unsigned int,amodetag string)

Definition at line 386 of file lumidbDDL.py.

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

387 def oldToNew(schema):
388  '''
389  modify old tables:cmsrunsummary
390  alter table cmsrunsummary add column(l1key string,egev unsigned int,amodetag string)
391  '''
392  try:
393  tableHandle=schema.tableHandle(nameDealer.cmsrunsummaryTableName())
394  tableHandle.schemaEditor().insertColumn('L1KEY','string')
395  tableHandle.schemaEditor().insertColumn('EGEV','unsigned int')
396  tableHandle.schemaEditor().insertColumn('AMODETAG','string')
397  createTables(schema)
398  except:
399  raise
def oldToNew
Definition: lumidbDDL.py:386
def createTables
Definition: lumidbDDL.py:8
def cmsrunsummaryTableName
Definition: nameDealer.py:14

Variable Documentation

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

Definition at line 477 of file lumidbDDL.py.

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

Definition at line 476 of file lumidbDDL.py.

tuple lumidbDDL.schema = session.nominalSchema()

Definition at line 481 of file lumidbDDL.py.

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

Definition at line 480 of file lumidbDDL.py.

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

Definition at line 479 of file lumidbDDL.py.

tuple lumidbDDL.tables = createTables(schema)

Definition at line 483 of file lumidbDDL.py.