32 |
printf("\n -v | --verbose be verbose [default: print nothing on STDOUT]\n"); |
printf("\n -v | --verbose be verbose [default: print nothing on STDOUT]\n"); |
33 |
printf("\n -idRun ID_RUN: ID number of the run \n"); |
printf("\n -idRun ID_RUN: ID number of the run \n"); |
34 |
printf("\n -filename output yoda filename \n"); |
printf("\n -filename output yoda filename \n"); |
35 |
printf("\n -host name for the host [default = mysql://localhost/pamelaprod]\n"); |
printf("\n -host name for the host [default = $PAM_DBHOST or mysql://localhost/pamelaprod]\n"); |
36 |
printf("\n -user username for the DB [default = anonymous] \n"); |
printf("\n -user username for the DB [default = $PAM_DBUSER or \"anonymous\"] \n"); |
37 |
printf("\n -psw password for the DB [default = \"\"]\n"); |
printf("\n -psw password for the DB [default = $PAM_DBPSW or \"\"]\n"); |
38 |
printf("\n -convert [ -tzone timezone -dbtime dbtime ] \n"); |
printf("\n -convert [ -tzone timezone -dbtime dbtime ] \n"); |
39 |
printf("\n convert the dbtime given in seconds (from the DB) to a string for\n"); |
printf("\n convert the dbtime given in seconds (from the DB) to a string for\n"); |
40 |
printf("\n the given time zone (UTC,GMT,MSK,MSD,CET,CEST are accepted) \n"); |
printf("\n the given time zone (UTC,GMT,MSK,MSD,CET,CEST are accepted) \n"); |
41 |
printf("\n -runat \"yyyy-mm-dd hh:mm:ss\" \n"); |
printf("\n -runat [ -tzone timezone -time \"yyyy-mm-dd hh:mm:ss\" ] \n"); |
42 |
printf("\n returns run number which contain the given date in MSK (if any)\n"); |
printf("\n returns run number which contains the given date in the given time zone \n"); |
43 |
printf("\nExamples: \n"); |
printf("\nExamples: \n"); |
44 |
printf("\n R2-D2 -idRun 1085 \n"); |
printf("\n R2-D2 -idRun 1085 \n"); |
45 |
printf("\n R2-D2 -filename DW_050208_00900.root \n"); |
printf("\n R2-D2 -filename DW_050208_00900.root \n"); |
63 |
TString host = "mysql://localhost/pamelaprod"; |
TString host = "mysql://localhost/pamelaprod"; |
64 |
TString user = "anonymous"; |
TString user = "anonymous"; |
65 |
TString psw = ""; |
TString psw = ""; |
66 |
|
// |
67 |
|
const char *pamdbhost=gSystem->Getenv("PAM_DBHOST"); |
68 |
|
const char *pamdbuser=gSystem->Getenv("PAM_DBUSER"); |
69 |
|
const char *pamdbpsw=gSystem->Getenv("PAM_DBPSW"); |
70 |
|
if ( strcmp(pamdbhost,"") ) host = pamdbhost; |
71 |
|
if ( strcmp(pamdbuser,"") ) user = pamdbuser; |
72 |
|
if ( strcmp(pamdbpsw,"") ) psw = pamdbpsw; |
73 |
|
// |
74 |
|
// printf(" host %s user %s psw %s \n",host.Data(),user.Data(),psw.Data()); |
75 |
|
// |
76 |
TString tzone = "MSK"; |
TString tzone = "MSK"; |
77 |
|
TString tzone2 = "MSK"; |
78 |
TString runtime = "1970-01-01 00:00:00"; |
TString runtime = "1970-01-01 00:00:00"; |
79 |
UInt_t dbti = 0; |
UInt_t dbti = 0; |
80 |
Bool_t convert = false; |
Bool_t convert = false; |
81 |
Bool_t ruti = false; |
Bool_t ruti = false; |
82 |
// |
// |
83 |
|
TSQLResult *pResult; |
84 |
|
TSQLRow *Row; |
85 |
|
int t; |
86 |
|
int r; |
87 |
|
stringstream myquery; |
88 |
// |
// |
89 |
// Checking input parameters |
// Checking input parameters |
90 |
// |
// |
135 |
psw = (TString)inps[i+1]; |
psw = (TString)inps[i+1]; |
136 |
}; |
}; |
137 |
// |
// |
|
if ( !strcmp(inps[i],"-runat") ) { |
|
|
ruti = true; |
|
|
if ( numinp-1 < i+1 ){ |
|
|
r2d2usage(); |
|
|
exit(-3); |
|
|
}; |
|
|
runtime = (TString)inps[i+1]; |
|
|
}; |
|
|
// |
|
138 |
if ( !strcmp(inps[i],"-convert") ) { |
if ( !strcmp(inps[i],"-convert") ) { |
139 |
convert = true; |
convert = true; |
140 |
if ( numinp >= i+2 && !strcmp(inps[i+1],"[") ){ |
if ( numinp >= i+2 && !strcmp(inps[i+1],"[") ){ |
167 |
}; |
}; |
168 |
}; |
}; |
169 |
// |
// |
170 |
|
if ( !strcmp(inps[i],"-runat") ) { |
171 |
|
ruti = true; |
172 |
|
if ( numinp >= i+2 && !strcmp(inps[i+1],"[") ){ |
173 |
|
if ( numinp < i+2 ){ |
174 |
|
r2d2usage(); |
175 |
|
throw -3; |
176 |
|
}; |
177 |
|
i += 2; |
178 |
|
while ( strcmp(inps[i],"]") ){ |
179 |
|
if ( !strcmp(inps[i],"-tzone") ) { |
180 |
|
if ( numinp-1 < i+1 ){ |
181 |
|
r2d2usage(); |
182 |
|
exit(-3); |
183 |
|
}; |
184 |
|
tzone2 = (TString)inps[i+1]; |
185 |
|
}; |
186 |
|
if ( !strcmp(inps[i],"-time") ) { |
187 |
|
if ( numinp-1 < i+1 ){ |
188 |
|
r2d2usage(); |
189 |
|
exit(-3); |
190 |
|
}; |
191 |
|
runtime = (TString)inps[i+1]; |
192 |
|
}; |
193 |
|
i++; |
194 |
|
if ( i > numinp-1 ){ |
195 |
|
r2d2usage(); |
196 |
|
throw -3; |
197 |
|
}; |
198 |
|
}; |
199 |
|
}; |
200 |
|
}; |
201 |
|
// |
202 |
i++; |
i++; |
203 |
}; |
}; |
204 |
// |
// |
229 |
// At which date correspond the DB time "dbti"? |
// At which date correspond the DB time "dbti"? |
230 |
// |
// |
231 |
if ( convert ){ |
if ( convert ){ |
232 |
printf("\n Time %u is %s %s \n",dbti,dbtime->ConvertTime(tzone.Data(),dbti).Data(),tzone.Data()); |
printf("\n DB time %u is %s %s \n",dbti,dbtime->ConvertTime(tzone.Data(),dbti).Data(),tzone.Data()); |
233 |
}; |
}; |
234 |
// |
// |
235 |
// Which run contains the date "runtime"? |
// Which run contains the date "runtime"? |
236 |
// |
// |
237 |
if ( ruti ){ |
if ( ruti ){ |
238 |
|
// |
239 |
|
TDatime *time = new TDatime(runtime.Data()); |
240 |
|
UInt_t dbti = time->Convert(); |
241 |
|
// |
242 |
|
TString thetime = dbtime->UnConvertTime(tzone2.Data(),dbti); |
243 |
|
// |
244 |
|
TDatime *time2 = new TDatime(thetime.Data()); |
245 |
|
UInt_t mytime = time2->Convert(); |
246 |
|
// |
247 |
|
myquery.str(""); |
248 |
|
myquery << "select "; |
249 |
|
myquery << " ID "; |
250 |
|
myquery << " from GL_RUN where RUNHEADER_TIME<=" << mytime << " AND " |
251 |
|
<< " RUNTRAILER_TIME>=" << mytime << " ;"; |
252 |
|
// printf("myquery is %s \n",myquery.str().c_str()); |
253 |
|
pResult = dbc->Query(myquery.str().c_str()); |
254 |
|
for( r=0; r < 1000; r++){ |
255 |
|
Row = pResult->Next(); |
256 |
|
if ( !r && !Row ){ |
257 |
|
printf("\n No run contains date %s %s (DB time %u )\n",runtime.Data(),tzone2.Data(),mytime); |
258 |
|
}; |
259 |
|
if( Row == NULL ) break; |
260 |
|
printf("\n Date %s %s (DB time %u ) is contained in run %u \n",runtime.Data(),tzone2.Data(),mytime,(UInt_t)atoll(Row->GetField(0))); |
261 |
|
}; |
262 |
}; |
}; |
263 |
// |
// |
264 |
// To which file the run "run" belongs? |
// To which file the run "run" belongs? |
282 |
// Which runs are contained in the file "filename"? |
// Which runs are contained in the file "filename"? |
283 |
// |
// |
284 |
if ( strcmp(filename.Data(),"") ){ |
if ( strcmp(filename.Data(),"") ){ |
|
TSQLResult *pResult; |
|
|
TSQLRow *Row; |
|
|
int t; |
|
|
int r; |
|
|
stringstream myquery; |
|
285 |
// ---------------- |
// ---------------- |
286 |
Int_t ID = 0; |
Int_t ID = 0; |
287 |
Int_t ID_RAW = 0; |
Int_t ID_RAW = 0; |
297 |
myquery << ",NAME"; |
myquery << ",NAME"; |
298 |
myquery << " from GL_ROOT where NAME=\"" << filename.Data() << "\";"; |
myquery << " from GL_ROOT where NAME=\"" << filename.Data() << "\";"; |
299 |
pResult = dbc->Query(myquery.str().c_str()); |
pResult = dbc->Query(myquery.str().c_str()); |
|
if(!pResult->GetRowCount()) return (-51); |
|
300 |
for( r=0; r < 1000; r++){ |
for( r=0; r < 1000; r++){ |
301 |
Row = pResult->Next(); |
Row = pResult->Next(); |
302 |
if( Row == NULL ) break; |
if( Row == NULL ) break; |
314 |
myquery << " ID,RUNHEADER_TIME,RUNTRAILER_TIME "; |
myquery << " ID,RUNHEADER_TIME,RUNTRAILER_TIME "; |
315 |
myquery << " from GL_RUN where ID_ROOT_L0=" << ID << ";"; |
myquery << " from GL_RUN where ID_ROOT_L0=" << ID << ";"; |
316 |
pResult = dbc->Query(myquery.str().c_str()); |
pResult = dbc->Query(myquery.str().c_str()); |
|
if(!pResult->GetRowCount()) return (-51); |
|
317 |
for( r=0; r < 1000; r++){ |
for( r=0; r < 1000; r++){ |
318 |
Row = pResult->Next(); |
Row = pResult->Next(); |
319 |
if ( !r && !Row ){ |
if ( !r && !Row ){ |
320 |
printf(" No run associated to the file %s \n",filename.Data()); |
printf("\n No run associated to the file %s \n",filename.Data()); |
321 |
}; |
}; |
322 |
if( Row == NULL ) break; |
if( Row == NULL ) break; |
323 |
if ( !r ) printf("\n File %s contains the following runs: \n",filename.Data()); |
if ( !r ) printf("\n File %s contains the following runs: \n\n",filename.Data()); |
324 |
printf(" => %i -> Start at %s UTC end at %s UTC \n",(UInt_t)atoll(Row->GetField(0)),dbtime->ConvertTime("UTC",(UInt_t)atoll(Row->GetField(1))).Data(),dbtime->ConvertTime("UTC",(UInt_t)atoll(Row->GetField(2))).Data()); |
printf(" => ID = %i _-_-_ the run started at %s UTC ended at %s UTC \n\n",(UInt_t)atoll(Row->GetField(0)),dbtime->ConvertTime("UTC",(UInt_t)atoll(Row->GetField(1))).Data(),dbtime->ConvertTime("UTC",(UInt_t)atoll(Row->GetField(2))).Data()); |
325 |
}; |
}; |
326 |
delete pResult; |
delete pResult; |
327 |
myquery.str(""); |
myquery.str(""); |
329 |
myquery << " PATH,NAME"; |
myquery << " PATH,NAME"; |
330 |
myquery << " from GL_RAW where ID=" << ID_RAW << ";"; |
myquery << " from GL_RAW where ID=" << ID_RAW << ";"; |
331 |
pResult = dbc->Query(myquery.str().c_str()); |
pResult = dbc->Query(myquery.str().c_str()); |
|
if(!pResult->GetRowCount()) return (-51); |
|
332 |
for( r=0; r < 1000; r++){ |
for( r=0; r < 1000; r++){ |
333 |
Row = pResult->Next(); |
Row = pResult->Next(); |
334 |
if( Row == NULL ) break; |
if( Row == NULL ) break; |
338 |
}; |
}; |
339 |
}; |
}; |
340 |
delete pResult; |
delete pResult; |
341 |
printf(" File %s belongs to raw data file %s/%s \n",filename.Data(),rawpath,rawname); |
printf("\n File %s belongs to raw data file %s/%s \n",filename.Data(),rawpath,rawname); |
342 |
}; |
}; |
343 |
}; |
}; |
344 |
// |
// |