35 |
printf("\n -host name for the host [default = mysql://localhost/pamelaprod]\n"); |
printf("\n -host name for the host [default = mysql://localhost/pamelaprod]\n"); |
36 |
printf("\n -user username for the DB [default = anonymous] \n"); |
printf("\n -user username for the DB [default = anonymous] \n"); |
37 |
printf("\n -psw password for the DB [default = \"\"]\n"); |
printf("\n -psw password for the DB [default = \"\"]\n"); |
38 |
|
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"); |
40 |
|
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"); |
42 |
|
printf("\n returns run number which contain the given date in MSK (if any)\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"); |
55 |
TString message; |
TString message; |
56 |
Int_t error = 0; |
Int_t error = 0; |
57 |
// |
// |
58 |
ULong64_t run = 0ULL; |
UInt_t run = 0ULL; |
59 |
// |
// |
60 |
TString filename = ""; |
TString filename = ""; |
61 |
// |
// |
63 |
TString host = "mysql://localhost/pamelaprod"; |
TString host = "mysql://localhost/pamelaprod"; |
64 |
TString user = "anonymous"; |
TString user = "anonymous"; |
65 |
TString psw = ""; |
TString psw = ""; |
66 |
|
TString tzone = "MSK"; |
67 |
|
TString runtime = "1970-01-01 00:00:00"; |
68 |
|
UInt_t dbti = 0; |
69 |
|
Bool_t convert = false; |
70 |
|
Bool_t ruti = false; |
71 |
// |
// |
72 |
// |
// |
73 |
// Checking input parameters |
// Checking input parameters |
88 |
r2d2usage(); |
r2d2usage(); |
89 |
exit(-3); |
exit(-3); |
90 |
}; |
}; |
91 |
char *pEnd; |
run = (UInt_t)atoll(inps[i+1]); |
|
run = strtoull(inps[i+1],&pEnd,0); |
|
92 |
}; |
}; |
93 |
if ( !strcmp(inps[i],"-filename") ) { |
if ( !strcmp(inps[i],"-filename") ) { |
94 |
if ( numinp-1 < i+1 ){ |
if ( numinp-1 < i+1 ){ |
118 |
}; |
}; |
119 |
psw = (TString)inps[i+1]; |
psw = (TString)inps[i+1]; |
120 |
}; |
}; |
121 |
|
// |
122 |
|
if ( !strcmp(inps[i],"-runat") ) { |
123 |
|
ruti = true; |
124 |
|
if ( numinp-1 < i+1 ){ |
125 |
|
r2d2usage(); |
126 |
|
exit(-3); |
127 |
|
}; |
128 |
|
runtime = (TString)inps[i+1]; |
129 |
|
}; |
130 |
|
// |
131 |
|
if ( !strcmp(inps[i],"-convert") ) { |
132 |
|
convert = true; |
133 |
|
if ( numinp >= i+2 && !strcmp(inps[i+1],"[") ){ |
134 |
|
if ( numinp < i+2 ){ |
135 |
|
r2d2usage(); |
136 |
|
throw -3; |
137 |
|
}; |
138 |
|
i += 2; |
139 |
|
while ( strcmp(inps[i],"]") ){ |
140 |
|
if ( !strcmp(inps[i],"-tzone") ) { |
141 |
|
if ( numinp-1 < i+1 ){ |
142 |
|
r2d2usage(); |
143 |
|
exit(-3); |
144 |
|
}; |
145 |
|
tzone = (TString)inps[i+1]; |
146 |
|
}; |
147 |
|
if ( !strcmp(inps[i],"-dbtime") ) { |
148 |
|
if ( numinp-1 < i+1 ){ |
149 |
|
r2d2usage(); |
150 |
|
exit(-3); |
151 |
|
}; |
152 |
|
dbti = (UInt_t)atoll(inps[i+1]); |
153 |
|
}; |
154 |
|
i++; |
155 |
|
if ( i > numinp-1 ){ |
156 |
|
r2d2usage(); |
157 |
|
throw -3; |
158 |
|
}; |
159 |
|
}; |
160 |
|
}; |
161 |
|
}; |
162 |
|
// |
163 |
i++; |
i++; |
164 |
}; |
}; |
165 |
// |
// |
185 |
// |
// |
186 |
GL_ROOT *glroot = new GL_ROOT(); |
GL_ROOT *glroot = new GL_ROOT(); |
187 |
GL_RUN *glrun = new GL_RUN(); |
GL_RUN *glrun = new GL_RUN(); |
188 |
|
GL_TIMESYNC *dbtime = new GL_TIMESYNC(); |
189 |
|
// |
190 |
|
// At which date correspond the DB time "dbti"? |
191 |
|
// |
192 |
|
if ( convert ){ |
193 |
|
printf("\n Time %u is %s %s \n",dbti,dbtime->ConvertTime(tzone.Data(),dbti).Data(),tzone.Data()); |
194 |
|
}; |
195 |
// |
// |
196 |
if ( run != 0ULL ){ |
// Which run contains the date "runtime"? |
197 |
|
// |
198 |
|
if ( ruti ){ |
199 |
|
|
200 |
|
}; |
201 |
|
// |
202 |
|
// To which file the run "run" belongs? |
203 |
|
// |
204 |
|
if ( run != 0 ){ |
205 |
|
glrun->Clear(); |
206 |
error = glrun->Query_GL_RUN(run,dbc); |
error = glrun->Query_GL_RUN(run,dbc); |
207 |
error = glroot->Query_GL_ROOT(glrun->ID_REG_RUN,dbc); |
glroot->Clear(); |
208 |
|
error = glroot->Query_GL_ROOT(glrun->ID_ROOT_L0,dbc); |
209 |
if ( error ){ |
if ( error ){ |
210 |
printf(" Error querying the DB! \n"); |
printf(" Error querying the DB! \n"); |
211 |
exit(-4); |
exit(-4); |
212 |
}; |
}; |
213 |
printf("\n Run %llu belongs to file %s \n",run,(glroot->PATH+glroot->NAME).Data()); |
if ( !glrun->ID ){ |
214 |
|
printf("\n No run with ID=%u in the DB!\n",run); |
215 |
|
} else { |
216 |
|
printf("\n Run %u belongs to file %s \n",run,(glroot->PATH+glroot->NAME).Data()); |
217 |
|
}; |
218 |
}; |
}; |
219 |
|
// |
220 |
|
// Which runs are contained in the file "filename"? |
221 |
|
// |
222 |
if ( strcmp(filename.Data(),"") ){ |
if ( strcmp(filename.Data(),"") ){ |
223 |
TSQLResult *pResult; |
TSQLResult *pResult; |
224 |
TSQLRow *Row; |
TSQLRow *Row; |
250 |
}; |
}; |
251 |
}; |
}; |
252 |
delete pResult; |
delete pResult; |
253 |
printf("\n File %s contains the following runs: \n",filename.Data()); |
if ( !ID && !ID_RAW ){ |
254 |
myquery.str(""); |
printf("\n No file with name %s in the DB!\n",filename.Data()); |
255 |
myquery << "select "; |
} else { |
256 |
myquery << " ID"; |
myquery.str(""); |
257 |
myquery << " from GL_RUN where ID_REG_RUN=" << ID << ";"; |
myquery << "select "; |
258 |
pResult = dbc->Query(myquery.str().c_str()); |
myquery << " ID,RUNHEADER_TIME,RUNTRAILER_TIME "; |
259 |
if(!pResult->GetRowCount()) return (-51); |
myquery << " from GL_RUN where ID_ROOT_L0=" << ID << ";"; |
260 |
for( r=0; r < 1000; r++){ |
pResult = dbc->Query(myquery.str().c_str()); |
261 |
Row = pResult->Next(); |
if(!pResult->GetRowCount()) return (-51); |
262 |
if( Row == NULL ) break; |
for( r=0; r < 1000; r++){ |
263 |
for( t = 0; t < pResult->GetFieldCount(); t++){ |
Row = pResult->Next(); |
264 |
if (t==0) printf(" => %i \n",atoi(Row->GetField(t))); |
if ( !r && !Row ){ |
265 |
|
printf(" No run associated to the file %s \n",filename.Data()); |
266 |
|
}; |
267 |
|
if( Row == NULL ) break; |
268 |
|
if ( !r ) printf("\n File %s contains the following runs: \n",filename.Data()); |
269 |
|
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()); |
270 |
}; |
}; |
271 |
}; |
delete pResult; |
272 |
delete pResult; |
myquery.str(""); |
273 |
myquery.str(""); |
myquery << "select "; |
274 |
myquery << "select "; |
myquery << " PATH,NAME"; |
275 |
myquery << " PATH,NAME"; |
myquery << " from GL_RAW where ID=" << ID_RAW << ";"; |
276 |
myquery << " from GL_RAW where ID=" << ID_RAW << ";"; |
pResult = dbc->Query(myquery.str().c_str()); |
277 |
pResult = dbc->Query(myquery.str().c_str()); |
if(!pResult->GetRowCount()) return (-51); |
278 |
if(!pResult->GetRowCount()) return (-51); |
for( r=0; r < 1000; r++){ |
279 |
for( r=0; r < 1000; r++){ |
Row = pResult->Next(); |
280 |
Row = pResult->Next(); |
if( Row == NULL ) break; |
281 |
if( Row == NULL ) break; |
for( t = 0; t < pResult->GetFieldCount(); t++){ |
282 |
for( t = 0; t < pResult->GetFieldCount(); t++){ |
if(t==0) rawpath = Row->GetField(t); |
283 |
if(t==0) rawpath = Row->GetField(t); |
if(t==1) rawname = Row->GetField(t); |
284 |
if(t==1) rawname = Row->GetField(t); |
}; |
285 |
}; |
}; |
286 |
|
delete pResult; |
287 |
|
printf(" File %s belongs to raw data file %s/%s \n",filename.Data(),rawpath,rawname); |
288 |
}; |
}; |
|
delete pResult; |
|
|
printf(" and belongs to raw data file %s/%s \n",rawpath,rawname); |
|
289 |
}; |
}; |
290 |
// |
// |
291 |
// Close the DB connection |
// Close the DB connection |