/[PAMELA software]/YodaProfiler/src/PamelaDBOperations.cpp
ViewVC logotype

Diff of /YodaProfiler/src/PamelaDBOperations.cpp

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 1.39 by mocchiut, Mon Apr 30 10:23:36 2007 UTC revision 1.55 by mocchiut, Fri Mar 7 10:35:16 2008 UTC
# Line 24  Line 24 
24  #include <RunHeaderEvent.h>  #include <RunHeaderEvent.h>
25  #include <RunTrailerEvent.h>  #include <RunTrailerEvent.h>
26  #include <CalibCalPedEvent.h>  #include <CalibCalPedEvent.h>
27    #include <CalibCalPulse1Event.h>
28    #include <CalibCalPulse2Event.h>
29  #include <CalibS4Event.h>  #include <CalibS4Event.h>
30  #include <CalibTrk1Event.h>  #include <CalibTrk1Event.h>
31  #include <CalibTrk2Event.h>  #include <CalibTrk2Event.h>
# Line 56  string getTleDatetime(cTle*); Line 58  string getTleDatetime(cTle*);
58   * @param debug        debug flag.   * @param debug        debug flag.
59   * @param tlefilename  ascii file with TLE 3 line elements.   * @param tlefilename  ascii file with TLE 3 line elements.
60   */   */
61  PamelaDBOperations::PamelaDBOperations(TString host, TString user, TString password, TString filerawname, TString filerootname, UInt_t boot, UInt_t tsync, UInt_t obt0, Bool_t debug, TString tlefilename, UInt_t dwinput, Bool_t staticp){  PamelaDBOperations::PamelaDBOperations(TString host, TString user, TString password, TString filerawname, TString filerootname, UInt_t boot, UInt_t tsync, UInt_t obt0, Bool_t debug, TString tlefilename, UInt_t dwinput, Bool_t staticp, Bool_t gpamela){
62    //    //
63    STATIC=false;    STATIC=false;
64    if ( staticp ) STATIC=true;    if ( staticp ) STATIC=true;
# Line 68  PamelaDBOperations::PamelaDBOperations(T Line 70  PamelaDBOperations::PamelaDBOperations(T
70    glrun = new GL_RUN();    glrun = new GL_RUN();
71    //    //
72    if ( !boot ) SetNOBOOT(false);    if ( !boot ) SetNOBOOT(false);
73    SetBOOTnumber(boot);    SetTsync(tsync,gpamela);
74    SetTsync(tsync);    SetBOOTnumber(boot,gpamela);
75    SetObt0(obt0);    SetObt0(obt0);
76    //    //
77    SetTLEPath(tlefilename);    SetTLEPath(tlefilename);
# Line 167  void PamelaDBOperations::SetAutoBoot(Boo Line 169  void PamelaDBOperations::SetAutoBoot(Boo
169  };  };
170    
171  /**  /**
172     * Set the pedantic flag
173     *
174     */
175    void PamelaDBOperations::SetPedantic(Bool_t dbg){
176      PEDANTIC = dbg;
177    };
178    
179    /**
180   * Set the nofrag flag   * Set the nofrag flag
181   *   *
182   */   */
# Line 179  void PamelaDBOperations::SetNoFrag(Bool_ Line 189  void PamelaDBOperations::SetNoFrag(Bool_
189   * @param boot    BOOT number of the RAW file   * @param boot    BOOT number of the RAW file
190   */   */
191  void PamelaDBOperations::SetBOOTnumber(UInt_t boot){  void PamelaDBOperations::SetBOOTnumber(UInt_t boot){
192      this->SetBOOTnumber(boot,false);
193    };
194    
195    /**
196     * Store the BOOT number of the RAW file.
197     * @param boot    BOOT number of the RAW file
198     */
199    void PamelaDBOperations::SetBOOTnumber(UInt_t boot, Bool_t gpamela){
200    BOOTNO=boot;    BOOTNO=boot;
201      if ( gpamela ){
202        stringstream oss;
203        TSQLResult *result = 0;
204        TSQLRow    *row    = 0;    
205        if ( !boot ){
206          //
207          BOOTNO = 1;
208          //
209          // look in the DB for the last timesync and the last run
210          //
211          oss.str("");
212          oss << "SELECT BOOT_NUMBER FROM GL_RUN order by RUNHEADER_TIME desc limit 1;";
213          result = conn->Query(oss.str().c_str());
214          if ( result ){
215            row = result->Next();
216            if ( row ){
217              BOOTNO = (UInt_t)atoll(row->GetField(0)) + 1;
218            };
219          };
220        };
221      };
222  };  };
223    
224  /**  /**
# Line 187  void PamelaDBOperations::SetBOOTnumber(U Line 226  void PamelaDBOperations::SetBOOTnumber(U
226   * @param boot    time sync   * @param boot    time sync
227   */   */
228  void PamelaDBOperations::SetTsync(UInt_t ts){  void PamelaDBOperations::SetTsync(UInt_t ts){
229      this->SetTsync(ts,false);
230    };
231    
232    /**
233     * Store the time sync of the RAW file.
234     * @param boot    time sync
235     */
236    void PamelaDBOperations::SetTsync(UInt_t ts, Bool_t gpamela){
237      //
238      // if not gpamela or given tsync file set ts
239      //
240    tsync=ts;    tsync=ts;
241      if ( gpamela ){
242        stringstream oss;
243        TSQLResult *result = 0;
244        TSQLRow    *row    = 0;    
245        TSQLResult *result2 = 0;
246        TSQLRow    *row2    = 0;    
247        if ( !ts ){
248          //
249          tsync = 1;
250          //
251          // look in the DB for the last timesync and the last run
252          //
253          oss.str("");
254          oss << "SELECT TIMESYNC FROM GL_TIMESYNC order by TIMESYNC desc limit 1;";
255          result = conn->Query(oss.str().c_str());
256          if ( result ){
257            row = result->Next();
258            if ( row ){
259              tsync = (UInt_t)atoll(row->GetField(0)) + 1;
260              oss.str("");
261              oss << "SELECT (RUNTRAILER_TIME-RUNHEADER_TIME) FROM GL_RUN order by RUNHEADER_TIME desc limit 1;";
262              result2 = conn->Query(oss.str().c_str());
263              if ( result2 ){
264                row2 = result2->Next();
265                if ( row2 ){
266                  tsync += (UInt_t)atoll(row2->GetField(0));
267                };
268              }
269            };
270          };
271        };
272      };
273  };  };
274    
275  /**  /**
# Line 308  Bool_t PamelaDBOperations::SetID_RAW(){ Line 390  Bool_t PamelaDBOperations::SetID_RAW(){
390    if ( result == NULL ) throw -4;    if ( result == NULL ) throw -4;
391    row = result->Next();    row = result->Next();
392    if ( !row ) return(false);    if ( !row ) return(false);
   delete result;  
393    id = (UInt_t)atoll(row->GetField(0));    id = (UInt_t)atoll(row->GetField(0));
394      delete result;
395    return(true);    return(true);
396  }  }
397    
# Line 416  Int_t PamelaDBOperations::SetUpperLimits Line 498  Int_t PamelaDBOperations::SetUpperLimits
498    if ( (PKT(pktlast) < PKT(pktfirst) && OBT(obtlast) < OBT(obtfirst)) || (labs(PKT(pktlast)-PKT(pktfirst))<deltapkt && labs(OBT(obtlast)-OBT(obtfirst))<deltaobt) && nevent > deltapkt ){    if ( (PKT(pktlast) < PKT(pktfirst) && OBT(obtlast) < OBT(obtfirst)) || (labs(PKT(pktlast)-PKT(pktfirst))<deltapkt && labs(OBT(obtlast)-OBT(obtfirst))<deltaobt) && nevent > deltapkt ){
499      //      //
500      if ( IsDebug() ) printf(" starting jump %i \n",jump);      if ( IsDebug() ) printf(" starting jump %i \n",jump);
501        if ( PEDANTIC ) throw -66;
502      // go back      // go back
503      zomp = nevent - 2;      zomp = nevent - 2;
504      //      //
# Line 555  Int_t PamelaDBOperations::SetUpperLimits Line 638  Int_t PamelaDBOperations::SetUpperLimits
638        //    if ( IsDebug() ) printf(" k %i rhev before %i ph %u upperp %u oh %u uppero %u \n",k,rhev,pkth,spkth,obth,sobth);        //    if ( IsDebug() ) printf(" k %i rhev before %i ph %u upperp %u oh %u uppero %u \n",k,rhev,pkth,spkth,obth,sobth);
639        //        //
640        if ( pkth < spkth && obth < sobth ){        if ( pkth < spkth && obth < sobth ){
641            if ( PEDANTIC ) throw -66;
642          if ( IsDebug() ) printf(" RH PROBLEMS determining the event repetition at the end of the file lasthead %i  \n",rhev);          if ( IsDebug() ) printf(" RH PROBLEMS determining the event repetition at the end of the file lasthead %i  \n",rhev);
643          //          //
644          rhev = k-1;          rhev = k-1;
# Line 614  Int_t PamelaDBOperations::SetUpperLimits Line 698  Int_t PamelaDBOperations::SetUpperLimits
698        //    if ( IsDebug() ) printf(" k %i rtev beforev %i  pt %i upperp %i ot %llu uppero %llu \n",k,rtev,pktt,spktt,obtt,sobtt);        //    if ( IsDebug() ) printf(" k %i rtev beforev %i  pt %i upperp %i ot %llu uppero %llu \n",k,rtev,pktt,spktt,obtt,sobtt);
699        //        //
700        if ( pktt < spktt && obtt < sobtt ){        if ( pktt < spktt && obtt < sobtt ){
701            if ( PEDANTIC ) throw -66;
702          if ( IsDebug() ) printf(" RT PROBLEMS determining the event repetition at the end of the file lasttrail %i \n",rtev);          if ( IsDebug() ) printf(" RT PROBLEMS determining the event repetition at the end of the file lasttrail %i \n",rtev);
703          //          //
704          rtev = k-1;          rtev = k-1;
# Line 885  Long64_t PamelaDBOperations::OBT(UInt_t Line 970  Long64_t PamelaDBOperations::OBT(UInt_t
970    if ( IsDebug() ) printf(" obt conversion: obt is %u obtfirst is %u  (numeric_limits<UInt_t>::max()/2) is %u  \n",obt,pobtfirst,(UInt_t)(numeric_limits<UInt_t>::max()/2));    if ( IsDebug() ) printf(" obt conversion: obt is %u obtfirst is %u  (numeric_limits<UInt_t>::max()/2) is %u  \n",obt,pobtfirst,(UInt_t)(numeric_limits<UInt_t>::max()/2));
971    //    //
972    if ( obt < (pobtfirst/2) && pobtfirst > (numeric_limits<UInt_t>::max()/2) ){    if ( obt < (pobtfirst/2) && pobtfirst > (numeric_limits<UInt_t>::max()/2) ){
973      if ( IsDebug() ) printf(" rise up obt %lld \n",(Long64_t)(obt+numeric_limits<UInt_t>::max()));      if ( IsDebug() ) printf(" rise up obt %lld \n",(Long64_t)obt+(Long64_t)numeric_limits<UInt_t>::max());
974      return((Long64_t)(obt+numeric_limits<UInt_t>::max()));      return((Long64_t)obt+(Long64_t)numeric_limits<UInt_t>::max());
975    };    };
976    //    //
977    if ( obt > ((Long64_t)pobtfirst*2) && obt > (numeric_limits<UInt_t>::max()/2) ){    if ( obt > ((Long64_t)pobtfirst*2) && obt > (numeric_limits<UInt_t>::max()/2) ){
# Line 1036  Int_t PamelaDBOperations::insertPamelaGL Line 1121  Int_t PamelaDBOperations::insertPamelaGL
1121    TSQLRow *row = 0;    TSQLRow *row = 0;
1122    UInt_t t0 = 0;    UInt_t t0 = 0;
1123    Int_t signal = 0;    Int_t signal = 0;
1124      UInt_t idresof = 0;
1125    //    //
1126    signal = this->SetUpperLimits();    signal = this->SetUpperLimits();
1127    //    //
# Line 1044  Int_t PamelaDBOperations::insertPamelaGL Line 1130  Int_t PamelaDBOperations::insertPamelaGL
1130    if ( this->GetID_RAW() == 0 )  throw -11;    if ( this->GetID_RAW() == 0 )  throw -11;
1131    //    //
1132    oss.str("");    oss.str("");
1133    oss << "SELECT YEAR(OFFSET_DATE),MONTH(OFFSET_DATE),DAY(OFFSET_DATE),HOUR(OFFSET_DATE),MINUTE(OFFSET_DATE),SECOND(OFFSET_DATE) FROM GL_RESURS_OFFSET WHERE SPECIAL_FILE='"    oss << "SELECT YEAR(OFFSET_DATE),MONTH(OFFSET_DATE),DAY(OFFSET_DATE),HOUR(OFFSET_DATE),MINUTE(OFFSET_DATE),SECOND(OFFSET_DATE),ID FROM GL_RESURS_OFFSET WHERE SPECIAL_FILE='"
1134        << this->GetRawFile().Data() << "';";        << this->GetRawFile().Data() << "';";
1135    if ( IsDebug() ) printf(" %s \n",oss.str().c_str());    if ( IsDebug() ) printf(" %s \n",oss.str().c_str());
1136    result = conn->Query(oss.str().c_str());    result = conn->Query(oss.str().c_str());
# Line 1053  Int_t PamelaDBOperations::insertPamelaGL Line 1139  Int_t PamelaDBOperations::insertPamelaGL
1139    //    //
1140    if ( !row ){    if ( !row ){
1141      oss.str("");      oss.str("");
1142      oss << "SELECT YEAR(OFFSET_DATE),MONTH(OFFSET_DATE),DAY(OFFSET_DATE),HOUR(OFFSET_DATE),MINUTE(OFFSET_DATE),SECOND(OFFSET_DATE) FROM GL_RESURS_OFFSET WHERE FROM_ORBIT< "      oss << "SELECT YEAR(OFFSET_DATE),MONTH(OFFSET_DATE),DAY(OFFSET_DATE),HOUR(OFFSET_DATE),MINUTE(OFFSET_DATE),SECOND(OFFSET_DATE),ID FROM GL_RESURS_OFFSET WHERE FROM_ORBIT< "
1143          << dworbit << " order by FROM_ORBIT desc limit 1;";          << dworbit << " order by FROM_ORBIT desc limit 1;";
1144      if ( IsDebug() ) printf(" %s \n",oss.str().c_str());      if ( IsDebug() ) printf(" %s \n",oss.str().c_str());
1145      result = conn->Query(oss.str().c_str());      result = conn->Query(oss.str().c_str());
# Line 1062  Int_t PamelaDBOperations::insertPamelaGL Line 1148  Int_t PamelaDBOperations::insertPamelaGL
1148      if ( !row ) throw -10;      if ( !row ) throw -10;
1149    };    };
1150    //    //
1151      idresof = (UInt_t)atoll(row->GetField(6));
1152      //
1153    TTimeStamp tu = TTimeStamp((UInt_t)atoi(row->GetField(0)),(UInt_t)atoi(row->GetField(1)),(UInt_t)atoi(row->GetField(2)),(UInt_t)atoi(row->GetField(3)),(UInt_t)atoi(row->GetField(4)),(UInt_t)atoi(row->GetField(5)),0,true,0);    TTimeStamp tu = TTimeStamp((UInt_t)atoi(row->GetField(0)),(UInt_t)atoi(row->GetField(1)),(UInt_t)atoi(row->GetField(2)),(UInt_t)atoi(row->GetField(3)),(UInt_t)atoi(row->GetField(4)),(UInt_t)atoi(row->GetField(5)),0,true,0);
1154    t0 = (UInt_t)tu.GetSec();    t0 = (UInt_t)tu.GetSec();
1155    if ( IsDebug() ) printf(" t0 is %u ti is %s %s %s %s %s %s\n",t0,row->GetField(0),row->GetField(1),row->GetField(2),row->GetField(3),row->GetField(4),row->GetField(5));    if ( IsDebug() ) printf(" t0 is %u ti is %s %s %s %s %s %s %s\n",t0,row->GetField(0),row->GetField(1),row->GetField(2),row->GetField(3),row->GetField(4),row->GetField(5),row->GetField(6));
1156    //    //
1157    /*    /*
1158     * Verify that the TIMESYNC have been not already processed     * Verify that the TIMESYNC have been not already processed
# Line 1086  Int_t PamelaDBOperations::insertPamelaGL Line 1174  Int_t PamelaDBOperations::insertPamelaGL
1174      tsync = (UInt_t)atoll(row->GetField(2));      tsync = (UInt_t)atoll(row->GetField(2));
1175      obt0 = (UInt_t)atoll(row->GetField(1));      obt0 = (UInt_t)atoll(row->GetField(1));
1176      //      //
1177        if ( PEDANTIC ) throw -67;
1178      return(1);      return(1);
1179    };    };
1180    //    //
# Line 1255  Int_t PamelaDBOperations::insertPamelaGL Line 1344  Int_t PamelaDBOperations::insertPamelaGL
1344    //    //
1345    if ( !existsts && obt0 ){ // insert timesync by hand    if ( !existsts && obt0 ){ // insert timesync by hand
1346      //      //
1347        if ( PEDANTIC ) throw -68;
1348      if ( IsDebug() ) printf(" No incl mcmd \n");      if ( IsDebug() ) printf(" No incl mcmd \n");
1349      signal = 30;      signal = 30;
1350      //      //
# Line 1270  Int_t PamelaDBOperations::insertPamelaGL Line 1360  Int_t PamelaDBOperations::insertPamelaGL
1360    if ( !existsts ) throw -3;    if ( !existsts ) throw -3;
1361    //    //
1362    oss.str("");    oss.str("");
1363    oss << "INSERT INTO GL_TIMESYNC (ID_RAW,TYPE,OBT0,TIMESYNC) VALUES ('"    oss << "INSERT INTO GL_TIMESYNC (ID_RAW,TYPE,OBT0,TIMESYNC,ID_RESURS_OFFSET) VALUES ('"
1364        << this->GetID_RAW() << "','"//224'"        << this->GetID_RAW() << "','"//224'"
1365        << dec << (UInt_t)TYPE << "','"        << dec << (UInt_t)TYPE << "','"
1366        << dec << (UInt_t)OBT << "','"        << dec << (UInt_t)OBT << "','"
1367        << dec << (UInt_t)TSYNC << "');";        << dec << (UInt_t)TSYNC << "','"
1368          << dec << (UInt_t)idresof << "');";
1369    conn->Query(oss.str().c_str());    conn->Query(oss.str().c_str());
1370    if ( IsDebug() ) printf(" Query the GL_TIMESYNC table to fill it:\n %s \n",oss.str().c_str());    if ( IsDebug() ) printf(" Query the GL_TIMESYNC table to fill it:\n %s \n",oss.str().c_str());
1371      if ( conn->GetErrorCode() ){
1372        printf(" OK, you got an error because the database structure you are using is not up to date\n Using backward compability code, hence you can continue safetly \n");
1373        oss.str("");
1374        oss << "INSERT INTO GL_TIMESYNC (ID_RAW,TYPE,OBT0,TIMESYNC) VALUES ('"
1375            << this->GetID_RAW() << "','"//224'"
1376            << dec << (UInt_t)TYPE << "','"
1377            << dec << (UInt_t)OBT << "','"
1378            << dec << (UInt_t)TSYNC << "');";
1379        conn->Query(oss.str().c_str());
1380        if ( IsDebug() ) printf(" Query the GL_TIMESYNC table to fill it:\n %s \n",oss.str().c_str());
1381      };
1382    //    //
1383    if ( IsDebug() ) printf(" found a timesync t0 is %u \n",t0);    if ( IsDebug() ) printf(" found a timesync t0 is %u \n",t0);
1384      //
1385    toffset = (UInt_t)TSYNC - (UInt_t)(this->OBT(OBT)/1000) + t0;    toffset = (UInt_t)TSYNC - (UInt_t)(this->OBT(OBT)/1000) + t0;
1386    //    //
1387    tsync = TSYNC;    tsync = TSYNC;
# Line 1516  Int_t PamelaDBOperations::insertPamelaRU Line 1619  Int_t PamelaDBOperations::insertPamelaRU
1619    rt->SetBranchAddress("RunTrailer", &runt);    rt->SetBranchAddress("RunTrailer", &runt);
1620    rt->SetBranchAddress("Header", &eht);    rt->SetBranchAddress("Header", &eht);
1621    //    //
1622      TTree *T = (TTree*)file->Get("Physics");
1623      if ( !T || T->IsZombie() ) throw -16;
1624      EventHeader *eh = 0;
1625      T->SetBranchAddress("Header", &eh);
1626      //
1627      if ( !(rh->GetEntries()) && !(rt->GetEntries()) && !(T->GetEntries()) ) return(16);
1628      //
1629    UInt_t obtt = 0;    UInt_t obtt = 0;
1630    UInt_t obth = 0;    UInt_t obth = 0;
1631    UInt_t pktt = 0;    UInt_t pktt = 0;
# Line 1590  Int_t PamelaDBOperations::insertPamelaRU Line 1700  Int_t PamelaDBOperations::insertPamelaRU
1700          //          //
1701          if ( PKT(pkth)>PKT(pktfirst) && OBT(obth)>OBT(obtfirst) && !ptt ){          if ( PKT(pkth)>PKT(pktfirst) && OBT(obth)>OBT(obtfirst) && !ptt ){
1702            //            //
1703            if ( IsDebug() ) printf(" Piece of run at the beginning of the file WITH NO RUNTRAILER \n");            if ( IsDebug() ) printf(" Piece of run at the beginning of the file WITH NO RUNTRAILER evbefh = %u \n",evbefh);        
1704            //            //
1705            if ( (evbefh-1) == 1 ) {            if ( evbefh == 0 ) {
1706              //              //
1707              signal = 8;              signal = 8;
1708              if ( IsDebug() ) printf(" Not supported yet: run with no events, no runtrailer, no runheader \n");              if ( IsDebug() ) printf(" Not supported yet: run with no events, no runtrailer, no runheader \n");
# Line 1710  Bool_t PamelaDBOperations::IsRunAlreadyI Line 1820  Bool_t PamelaDBOperations::IsRunAlreadyI
1820    //                                  ( runhead_time <= _our_runhead_time &&  runtrail_time >= _our_runtrail_time) &&    //                                  ( runhead_time <= _our_runhead_time &&  runtrail_time >= _our_runtrail_time) &&
1821    //                                  ( runhead_obt <= _our_runheadobt || runhead_pkt <= _our_runheadpkt ) &&    //                                  ( runhead_obt <= _our_runheadobt || runhead_pkt <= _our_runheadpkt ) &&
1822    //                                  ( runtrail_obt <= _our_runtrailobt || runtrail_pkt <= _our_runtrailpkt ) )    //                                  ( runtrail_obt <= _our_runtrailobt || runtrail_pkt <= _our_runtrailpkt ) )
1823      //                                  ||
1824      //                                  ( runhead_time = _our_runhead_time &&  runtrail_time = _our_runtrail_time && nevents > 100 )
1825      //                                  )
1826      //                                  ||
1827      //                                  ( runhead_time = _our_runhead_time &&  runtrail_time > _our_runtrail_time && nevents > 100 )
1828      //                                  )
1829      //                                  ||
1830      //                                  ( runhead_time < _our_runhead_time &&  runtrail_time = _our_runtrail_time && nevents > 100 )
1831    //                                  )    //                                  )
1832    //    //
1833    oss << " SELECT ID,NEVENTS,TRK_CALIB_USED,PKT_COUNTER FROM GL_RUN WHERE "    oss << " SELECT ID,NEVENTS,TRK_CALIB_USED,PKT_COUNTER FROM GL_RUN WHERE "
# Line 1725  Bool_t PamelaDBOperations::IsRunAlreadyI Line 1843  Bool_t PamelaDBOperations::IsRunAlreadyI
1843        << " RUNHEADER_OBT<=" << glrun->GetRUNHEADER_OBT() << " OR "        << " RUNHEADER_OBT<=" << glrun->GetRUNHEADER_OBT() << " OR "
1844        << " RUNHEADER_PKT<=" << glrun->GetRUNHEADER_PKT() << ") AND ("        << " RUNHEADER_PKT<=" << glrun->GetRUNHEADER_PKT() << ") AND ("
1845        << " RUNTRAILER_OBT>=" << glrun->GetRUNTRAILER_OBT() << " OR "        << " RUNTRAILER_OBT>=" << glrun->GetRUNTRAILER_OBT() << " OR "
1846        << " RUNTRAILER_PKT>=" << glrun->GetRUNTRAILER_PKT() << ") ));";        << " RUNTRAILER_PKT>=" << glrun->GetRUNTRAILER_PKT() << ") OR "
1847          << " (RUNHEADER_TIME=" << (UInt_t)glrun->GetRUNHEADER_TIME() << " AND "                //  these two lines in a certain way disable the patch below...
1848          << " RUNTRAILER_TIME=" << (UInt_t)glrun->GetRUNTRAILER_TIME() <<" AND NEVENTS>100) OR"    //
1849          << " (RUNHEADER_TIME=" << (UInt_t)glrun->GetRUNHEADER_TIME() << " AND "                //
1850          << " RUNTRAILER_TIME>" << (UInt_t)glrun->GetRUNTRAILER_TIME() <<" AND NEVENTS>100) OR"    //
1851          << " (RUNHEADER_TIME<" << (UInt_t)glrun->GetRUNHEADER_TIME() << " AND "                //
1852          << " RUNTRAILER_TIME=" << (UInt_t)glrun->GetRUNTRAILER_TIME() <<" AND NEVENTS>100)"    //
1853          << " ));";
1854    //    //
1855    if ( IsDebug() ) printf(" check if run has been inserted: query is \n %s \n",oss.str().c_str());    if ( IsDebug() ) printf(" check if run has been inserted: query is \n %s \n",oss.str().c_str());
1856    result = conn->Query(oss.str().c_str());    result = conn->Query(oss.str().c_str());
# Line 1747  Bool_t PamelaDBOperations::IsRunAlreadyI Line 1872  Bool_t PamelaDBOperations::IsRunAlreadyI
1872      //      //
1873      // the run has already been inserted      // the run has already been inserted
1874      //      //
1875      //    return(true);  //<<<<<<<<<<<<<<<<<<<<<<<< patch follows, uncomment here      if ( signal && IsDebug() ) printf(" The run has already been inserted \n");    
1876        return(true);  //<<<<<<<<<<<<<<<<<<<<<<<< patch follows, uncomment here
1877      //      //
1878      // PATCH!      // PATCH!
1879      // we keep the processing run if (in order of growing importance) 1) we have the runtrailer while the old run doesn't have it 2) we have the runheader      // we keep the processing run if (in order of growing importance) 1) we have the runtrailer while the old run doesn't have it 2) we have the runheader
# Line 1925  void PamelaDBOperations::HandleRunFragme Line 2051  void PamelaDBOperations::HandleRunFragme
2051      //      //
2052    } else {    } else {
2053      if ( IsDebug() ) printf(" The run is already present in the fragment table \n");      if ( IsDebug() ) printf(" The run is already present in the fragment table \n");
2054        if ( PEDANTIC ) throw -69;
2055      return;      return;
2056    };    };
2057    //    //
# Line 2075  void PamelaDBOperations::HandleRunFragme Line 2202  void PamelaDBOperations::HandleRunFragme
2202          bpkt = PKT(ph->GetCounter());          bpkt = PKT(ph->GetCounter());
2203          bobt = OBT(ph->GetOrbitalTime());                bobt = OBT(ph->GetOrbitalTime());      
2204          firstev++;          firstev++;
2205            if ( PEDANTIC ) throw -71;
2206        };        };
2207        if ( IsDebug() ) printf(" Check overlapping events done: %u %u %llu %llu firstev is %i\n",apkt,bpkt,aobt,bobt,firstev);        if ( IsDebug() ) printf(" Check overlapping events done: %u %u %llu %llu firstev is %i\n",apkt,bpkt,aobt,bobt,firstev);
2208        //        //
# Line 2272  void PamelaDBOperations::HandleRunFragme Line 2400  void PamelaDBOperations::HandleRunFragme
2400          apkt = PKT(ph->GetCounter());          apkt = PKT(ph->GetCounter());
2401          aobt = OBT(ph->GetOrbitalTime());                aobt = OBT(ph->GetOrbitalTime());      
2402          lastev--;          lastev--;
2403            if ( PEDANTIC ) throw -72;
2404        };        };
2405        if ( IsDebug() ) printf(" Check overlapping events done: %u %u %llu %llu lastev is %i\n",apkt,bpkt,aobt,bobt,lastev);        if ( IsDebug() ) printf(" Check overlapping events done: %u %u %llu %llu lastev is %i\n",apkt,bpkt,aobt,bobt,lastev);
2406        //        //
# Line 2358  void PamelaDBOperations::HandleRunFragme Line 2487  void PamelaDBOperations::HandleRunFragme
2487      //      //
2488      if ( row ){      if ( row ){
2489        if ( IsDebug() ) printf(" The run is already present in the GL_RUN table \n");        if ( IsDebug() ) printf(" The run is already present in the GL_RUN table \n");
2490          if ( PEDANTIC ) throw -70;
2491      } else {      } else {
2492        if ( NoFrag() ){        if ( NoFrag() ){
2493          glrun->SetID_RUN_FRAG(glrun->GetID());          glrun->SetID_RUN_FRAG(glrun->GetID());
# Line 2901  Int_t PamelaDBOperations::insertCALO_CAL Line 3031  Int_t PamelaDBOperations::insertCALO_CAL
3031            if ( row ){            if ( row ){
3032              //              //
3033              if ( IsDebug() ) printf(" Calo calibration already inserted in the DB\n");              if ( IsDebug() ) printf(" Calo calibration already inserted in the DB\n");
3034                if ( PEDANTIC ) throw -73;
3035              //              //
3036            } else {            } else {
3037              //              //
# Line 2988  Int_t PamelaDBOperations::insertCALO_CAL Line 3119  Int_t PamelaDBOperations::insertCALO_CAL
3119          } else {          } else {
3120            //            //
3121            if ( IsDebug() ) printf(" Repeated calo calibration for section %i at time %u obt %u pkt %u \n",section,fromtime,obt,pkt);            if ( IsDebug() ) printf(" Repeated calo calibration for section %i at time %u obt %u pkt %u \n",section,fromtime,obt,pkt);
3122              if ( PEDANTIC ) throw -74;
3123            //            //
3124          };                };      
3125          //                //      
# Line 2998  Int_t PamelaDBOperations::insertCALO_CAL Line 3130  Int_t PamelaDBOperations::insertCALO_CAL
3130    return(0);    return(0);
3131  };  };
3132    
3133    
3134    /**
3135     * Scan calorimeter calibrations packets, fill the GL_CALO_CALIB table
3136     */
3137    Int_t PamelaDBOperations::insertCALOPULSE_CALIB(){
3138      //
3139      TSQLResult *result = 0;
3140      TSQLRow    *row    = 0;
3141      //
3142      stringstream oss;
3143      oss.str("");
3144      //
3145      oss << " DESCRIBE GL_CALOPULSE_CALIB;";
3146      if ( IsDebug() ) printf(" Check if the GL_CALOPULSE_CALIB table exists: query is \n %s \n",oss.str().c_str());
3147      result = conn->Query(oss.str().c_str());
3148      //
3149      if ( conn->GetErrorCode() ){
3150        if ( IsDebug() ) printf(" The GL_CALOPULSE_CALIB table does not exists! \n");
3151        throw -30;
3152      };
3153      //
3154      // CaloPulse1
3155      //
3156      CalibCalPulse1Event *cp1 = 0;
3157      TTree *tr = 0;
3158      EventHeader *eh = 0;
3159      PscuHeader *ph = 0;
3160      //
3161      UInt_t nevents = 0;
3162      UInt_t fromtime = 0;
3163      UInt_t totime = 0;
3164      UInt_t obt = 0;
3165      UInt_t pkt = 0;
3166      //
3167      tr = (TTree*)file->Get("CalibCalPulse1");
3168      if ( !tr || tr->IsZombie() ) throw -31;
3169      //
3170      tr->SetBranchAddress("CalibCalPulse1", &cp1);
3171      tr->SetBranchAddress("Header", &eh);
3172      nevents = tr->GetEntries();
3173      //
3174      if ( nevents > 0 ){
3175        //
3176        for (UInt_t i=0; i < nevents; i++){
3177          tr->GetEntry(i);
3178          for (UInt_t section = 0; section < 4; section++){
3179            //
3180            if ( cp1->pstwerr[section] && cp1->unpackError == 0 ){
3181              valid = 1;
3182              if ( cp1->pperror[section] ) valid = 0;
3183              ph = eh->GetPscuHeader();
3184              obt = ph->GetOrbitalTime();  
3185              pkt = ph->GetCounter();  
3186              fromtime = this->GetAbsTime(ph->GetOrbitalTime());  
3187              if ( this->PKT(pkt) >= this->PKT(pktfirst) && this->OBT(obt) >= this->OBT(obtfirst) ){
3188                //
3189                if ( IsDebug() ) printf(" Calo pulse1 calibration for section %i at time %u obt %u pkt %u \n",section,fromtime,obt,pkt);
3190                //
3191                // check if the calibration has already been inserted
3192                //
3193                oss.str("");
3194                oss << " SELECT ID FROM GL_CALOPULSE_CALIB WHERE "
3195                    << " SECTION = "<< section << " AND "
3196                    << " PULSE_AMPLITUDE = 0 AND "
3197                    << " BOOT_NUMBER = "<< this->GetBOOTnumber() << " AND "
3198                    << " OBT = "<< obt << " AND "
3199                    << " PKT = "<< pkt << ";";
3200                //
3201                if ( IsDebug() ) printf(" Check if the calo pulse1 calibration has already been inserted: query is \n %s \n",oss.str().c_str());
3202                result = conn->Query(oss.str().c_str());
3203                //
3204                if ( !result ) throw -4;
3205                //
3206                row = result->Next();
3207                //
3208                if ( row ){
3209                  //
3210                  if ( IsDebug() ) printf(" Calo pulse1 calibration already inserted in the DB\n");
3211                  if ( PEDANTIC ) throw -75;
3212                  //
3213                } else {
3214                  //
3215                  // we have to insert a new calibration, check where to place it
3216                  //
3217                  oss.str("");
3218                  oss << " SELECT ID,TO_TIME FROM GL_CALOPULSE_CALIB WHERE "
3219                      << " SECTION = "<< section << " AND "
3220                      << " PULSE_AMPLITUDE = 0 AND "
3221                      << " SECTION = "<< section << " AND "
3222                      << " FROM_TIME < "<< fromtime << " AND "
3223                      << " TO_TIME > "<< fromtime << ";";
3224                  //
3225                  if ( IsDebug() ) printf(" Check where to place the pulse1 calo calibration: query is \n %s \n",oss.str().c_str());
3226                  result = conn->Query(oss.str().c_str());
3227                  //
3228                  if ( !result ) throw -4;
3229                  //
3230                  row = result->Next();
3231                  //
3232                  if ( !row ){
3233                    //
3234                    // no calibrations in the db contain our calibration
3235                    //
3236                    if ( IsDebug() ) printf(" Pulse1 calibration with fromtime lower than others to be inserted in the DB for section %i \n",section);
3237                    if ( fromtime < 1150871000 ){ //1150866904
3238                      if ( IsDebug() ) printf(" First PAMELA flight calibration at time %u \n",fromtime);
3239                      fromtime = 0;// the first flight calibration was taken at about  1156429100 s, this line allow to analyze first runs in raw mode
3240                    };
3241                    //
3242                    oss.str("");
3243                    oss << " SELECT FROM_TIME FROM GL_CALOPULSE_CALIB WHERE "
3244                        << " PULSE_AMPLITUDE = 0 AND "
3245                        << " SECTION = "<< section << " AND "
3246                        << " FROM_TIME > "<< fromtime << " ORDER BY FROM_TIME ASC LIMIT 1;";
3247                    //
3248                    if ( IsDebug() ) printf(" Check the upper limit for pulse1 calibration: query is \n %s \n",oss.str().c_str());
3249                    result = conn->Query(oss.str().c_str());
3250                    //
3251                    if ( !result ) throw -4;
3252                    //
3253                    row = result->Next();
3254                    if ( !row ){
3255                      totime = numeric_limits<UInt_t>::max();
3256                    } else {
3257                      totime = (UInt_t)atoll(row->GetField(0));
3258                    };
3259                    //
3260                  } else {
3261                    //
3262                    // determine upper and lower limits and make space for the new calibration
3263                    //
3264                    totime = (UInt_t)atoll(row->GetField(1));
3265                    //
3266                    oss.str("");
3267                    oss << " UPDATE GL_CALOPULSE_CALIB SET "  
3268                        << " TO_TIME = "<< fromtime << " WHERE "  // NOTICE: to_time is equal to from_time of the calibration before, so the interval is: [from_time,to_time[
3269                        << " ID = "<< row->GetField(0) << ";";
3270                    //
3271                    if ( IsDebug() ) printf(" Make space for the new pulse1 calibration: query is \n %s \n",oss.str().c_str());
3272                    result = conn->Query(oss.str().c_str());
3273                    //
3274                    if ( !result ) throw -4;
3275                    //
3276                  };
3277                  //
3278                  oss.str("");
3279                  oss << " INSERT INTO GL_CALOPULSE_CALIB (ID,ID_ROOT_L0,EV_ROOT,FROM_TIME,TO_TIME,SECTION,PULSED_STRIP,PULSE_AMPLITUDE,OBT,PKT,BOOT_NUMBER,VALIDATION) "
3280                      << " VALUES (NULL,' "
3281                      << idroot << "','"
3282                      << i << "','"
3283                      << fromtime << "','"
3284                      << totime << "','"
3285                      << section << "',NULL,'0','"
3286                      << obt << "','"
3287                      << pkt << "','"
3288                      << this->GetBOOTnumber() << "','"
3289                      << valid << "');";
3290                  //
3291                  if ( IsDebug() ) printf(" Insert the new pulse1 calibration: query is \n %s \n",oss.str().c_str());
3292                  //
3293                  result = conn->Query(oss.str().c_str());
3294                  //
3295                  if ( !result ) throw -4;
3296                  //
3297                };
3298                //
3299              } else {
3300                //
3301                if ( IsDebug() ) printf(" Repeated pulse1 calo calibration for section %i at time %u obt %u pkt %u \n",section,fromtime,obt,pkt);
3302                if ( PEDANTIC ) throw -76;
3303                //
3304              };      
3305              //      
3306            };
3307          };
3308        };
3309      };
3310      //
3311      // CaloPulse2
3312      //
3313      tr->Reset();
3314      CalibCalPulse2Event *cp2 = 0;
3315      tr = 0;
3316      //
3317      nevents = 0;
3318      fromtime = 0;
3319      totime = 0;
3320      obt = 0;
3321      pkt = 0;
3322      //
3323      tr = (TTree*)file->Get("CalibCalPulse2");
3324      if ( !tr || tr->IsZombie() ) throw -32;
3325      //
3326      tr->SetBranchAddress("CalibCalPulse2", &cp2);
3327      tr->SetBranchAddress("Header", &eh);
3328      nevents = tr->GetEntries();
3329      //
3330      if ( nevents > 0 ){
3331        //
3332        for (UInt_t i=0; i < nevents; i++){
3333          tr->GetEntry(i);
3334          for (UInt_t section = 0; section < 4; section++){
3335            //
3336            if ( cp2->pstwerr[section] && cp2->unpackError == 0 ){
3337              valid = 1;
3338              if ( cp2->pperror[section] ) valid = 0;
3339              ph = eh->GetPscuHeader();
3340              obt = ph->GetOrbitalTime();  
3341              pkt = ph->GetCounter();  
3342              fromtime = this->GetAbsTime(ph->GetOrbitalTime());  
3343              if ( this->PKT(pkt) >= this->PKT(pktfirst) && this->OBT(obt) >= this->OBT(obtfirst) ){
3344                //
3345                if ( IsDebug() ) printf(" Calo pulse2 calibration for section %i at time %u obt %u pkt %u \n",section,fromtime,obt,pkt);
3346                //
3347                // check if the calibration has already been inserted
3348                //
3349                oss.str("");
3350                oss << " SELECT ID FROM GL_CALOPULSE_CALIB WHERE "
3351                    << " SECTION = "<< section << " AND "
3352                    << " PULSE_AMPLITUDE != 0 AND "
3353                    << " BOOT_NUMBER = "<< this->GetBOOTnumber() << " AND "
3354                    << " OBT = "<< obt << " AND "
3355                    << " PKT = "<< pkt << ";";
3356                //
3357                if ( IsDebug() ) printf(" Check if the calo pulse2 calibration has already been inserted: query is \n %s \n",oss.str().c_str());
3358                result = conn->Query(oss.str().c_str());
3359                //
3360                if ( !result ) throw -4;
3361                //
3362                row = result->Next();
3363                //
3364                if ( row ){
3365                  //
3366                  if ( IsDebug() ) printf(" Calo pulse2 calibration already inserted in the DB\n");
3367                  if ( PEDANTIC ) throw -77;
3368                  //
3369                } else {
3370                  //
3371                  // we have to insert a new calibration
3372                  //
3373                  //
3374                  // Determine the amplitude of the pulse
3375                  //
3376                  UInt_t pampli = 1;
3377                  UInt_t pstrip = 0;
3378                  UInt_t se = 0;
3379                  if ( section == 1 ) se = 2;
3380                  if ( section == 2 ) se = 3;
3381                  if ( section == 3 ) se = 1;
3382                  for (Int_t ii=0;ii<16;ii++){
3383                    if ( cp2->calpuls[se][0][ii] > 10000. ){
3384                      pampli = 2;
3385                      pstrip = ii;
3386                    };
3387                  };
3388                  if ( pampli == 1 ){
3389                    Bool_t found = false;
3390                    Float_t delta=0.;
3391                    UInt_t cstr = 0;
3392                    while ( !found && cstr < 16 ){
3393                      for (Int_t ii=0;ii<16;ii++){
3394                        delta = cp2->calpuls[se][0][ii] - cp2->calpuls[se][0][cstr];
3395                        if ( IsDebug() ) printf(" cstr is %u ii is %i delta is %f \n",cstr,ii,delta);
3396                        if ( delta > 500. ){
3397                          pampli = 1;
3398                          pstrip = ii;
3399                          found = true;
3400                          if ( IsDebug() ) printf(" FOUND cstr is %u ii is %i delta is %f \n",cstr,ii,delta);
3401                        };
3402                      };
3403                      cstr++;
3404                    };
3405                    if ( !found ) pstrip = 100;
3406                  };
3407                  if ( IsDebug() ) printf(" The amplitude of the pulser is %u (where 1 = low pulse, 2 = high pulse), pulsed strip is %u \n",pampli,pstrip);
3408                  //
3409                  // we have to insert a new calibration, check where to place it
3410                  //
3411                  oss.str("");
3412                  oss << " SELECT ID,TO_TIME FROM GL_CALOPULSE_CALIB WHERE "
3413                      << " SECTION = "<< section << " AND "
3414                      << " PULSE_AMPLITUDE = " << pampli << " AND "
3415                      << " SECTION = "<< section << " AND "
3416                      << " FROM_TIME < "<< fromtime << " AND "
3417                      << " TO_TIME > "<< fromtime << ";";
3418                  //
3419                  if ( IsDebug() ) printf(" Check where to place the pulse2 calo calibration: query is \n %s \n",oss.str().c_str());
3420                  result = conn->Query(oss.str().c_str());
3421                  //
3422                  if ( !result ) throw -4;
3423                  //
3424                  row = result->Next();
3425                  //
3426                  if ( !row ){
3427                    //
3428                    // no calibrations in the db contain our calibration
3429                    //
3430                    if ( IsDebug() ) printf(" Pulse2 calibration with fromtime lower than others to be inserted in the DB for section %i \n",section);
3431                    if ( fromtime < 1150871000 ){ //1150866904
3432                      if ( IsDebug() ) printf(" First PAMELA flight calibration at time %u \n",fromtime);
3433                      fromtime = 0;// the first flight calibration was taken at about  1156429100 s, this line allow to analyze first runs in raw mode
3434                    };
3435                    //
3436                    oss.str("");
3437                    oss << " SELECT FROM_TIME FROM GL_CALOPULSE_CALIB WHERE "
3438                        << " PULSE_AMPLITUDE = " << pampli << " AND "
3439                        << " SECTION = "<< section << " AND "
3440                        << " FROM_TIME > "<< fromtime << " ORDER BY FROM_TIME ASC LIMIT 1;";
3441                    //
3442                    if ( IsDebug() ) printf(" Check the upper limit for pulse2 calibration: query is \n %s \n",oss.str().c_str());
3443                    result = conn->Query(oss.str().c_str());
3444                    //
3445                    if ( !result ) throw -4;
3446                    //
3447                    row = result->Next();
3448                    if ( !row ){
3449                      totime = numeric_limits<UInt_t>::max();
3450                    } else {
3451                      totime = (UInt_t)atoll(row->GetField(0));
3452                    };
3453                    //
3454                  } else {
3455                    //
3456                    // determine upper and lower limits and make space for the new calibration
3457                    //
3458                    totime = (UInt_t)atoll(row->GetField(1));
3459                    //
3460                    oss.str("");
3461                    oss << " UPDATE GL_CALOPULSE_CALIB SET "  
3462                        << " TO_TIME = "<< fromtime << " WHERE "  // NOTICE: to_time is equal to from_time of the calibration before, so the interval is: [from_time,to_time[
3463                        << " ID = "<< row->GetField(0) << ";";
3464                    //
3465                    if ( IsDebug() ) printf(" Make space for the new pulse2 calibration: query is \n %s \n",oss.str().c_str());
3466                    result = conn->Query(oss.str().c_str());
3467                    //
3468                    if ( !result ) throw -4;
3469                    //
3470                  };
3471                  //
3472                  // Fill the DB
3473                  //
3474                  oss.str("");
3475                  //              oss << " INSERT INTO GL_CALOPULSE_CALIB (ID,ID_ROOT_L0,EV_ROOT,FROM_TIME,TO_TIME,SECTION,OBT,PKT,BOOT_NUMBER,VALIDATION) "
3476                  oss << " INSERT INTO GL_CALOPULSE_CALIB (ID,ID_ROOT_L0,EV_ROOT,FROM_TIME,TO_TIME,SECTION,PULSED_STRIP,PULSE_AMPLITUDE,OBT,PKT,BOOT_NUMBER,VALIDATION) "
3477                      << " VALUES (NULL,' "
3478                      << idroot << "','"
3479                      << i << "','"
3480                      << fromtime << "','"
3481                      << totime << "','"
3482                      << section << "','"
3483                      << pstrip << "','"
3484                      << pampli << "','"
3485                      << obt << "','"
3486                      << pkt << "','"
3487                      << this->GetBOOTnumber() << "','"
3488                      << valid << "');";
3489                  //
3490                  if ( IsDebug() ) printf(" Insert the new pulse2 calibration: query is \n %s \n",oss.str().c_str());
3491                  //
3492                  result = conn->Query(oss.str().c_str());
3493                  //
3494                  if ( !result ) throw -4;
3495                  //
3496                };
3497                //
3498              } else {
3499                //
3500                if ( IsDebug() ) printf(" Repeated pulse2 calo calibration for section %i at time %u obt %u pkt %u \n",section,fromtime,obt,pkt);
3501                if ( PEDANTIC ) throw -78;
3502                //
3503              };      
3504              //      
3505            };
3506          };
3507        };
3508      };
3509      //
3510      return(0);
3511    };
3512    
3513  /**  /**
3514   * Fill the GL_TRK_CALIB table   * Fill the GL_TRK_CALIB table
3515   */   */
# Line 3047  void PamelaDBOperations::HandleTRK_CALIB Line 3559  void PamelaDBOperations::HandleTRK_CALIB
3559    if ( row ){    if ( row ){
3560      //      //
3561      if ( IsDebug() ) printf(" Trk calibration already inserted in the DB\n");      if ( IsDebug() ) printf(" Trk calibration already inserted in the DB\n");
3562        if ( PEDANTIC ) throw -80;
3563      //      //
3564    } else {    } else {
3565      //      //
# Line 3312  Int_t PamelaDBOperations::insertTRK_CALI Line 3825  Int_t PamelaDBOperations::insertTRK_CALI
3825      } else {      } else {
3826        //        //
3827        if ( IsDebug() ) printf(" Repetead trk calibration1 at time %u obt %u pkt %u \n",fromtime,obt1,pkt1);        if ( IsDebug() ) printf(" Repetead trk calibration1 at time %u obt %u pkt %u \n",fromtime,obt1,pkt1);
3828          if ( PEDANTIC ) throw -79;
3829        //        //
3830      };      };
3831      //          //    
# Line 3410  Int_t PamelaDBOperations::insertS4_CALIB Line 3924  Int_t PamelaDBOperations::insertS4_CALIB
3924        if ( row ){        if ( row ){
3925          //          //
3926          if ( IsDebug() ) printf(" S4 calibration already inserted in the DB\n");          if ( IsDebug() ) printf(" S4 calibration already inserted in the DB\n");
3927            if ( PEDANTIC ) throw -81;
3928          //          //
3929        } else {        } else {
3930          //          //
# Line 3493  Int_t PamelaDBOperations::insertS4_CALIB Line 4008  Int_t PamelaDBOperations::insertS4_CALIB
4008      } else {      } else {
4009        //        //
4010        if ( IsDebug() ) printf(" Repeated S4 calibration at time %u obt %u pkt %u \n",fromtime,obt,pkt);        if ( IsDebug() ) printf(" Repeated S4 calibration at time %u obt %u pkt %u \n",fromtime,obt,pkt);
4011          if ( PEDANTIC ) throw -82;
4012        //        //
4013      };            };      
4014      //            //      
# Line 3629  Int_t PamelaDBOperations::CleanGL_RUN_FR Line 4145  Int_t PamelaDBOperations::CleanGL_RUN_FR
4145          //          //
4146        } else {        } else {
4147          if ( IsDebug() ) printf(" The already exist in the GL_RUN table! \n");          if ( IsDebug() ) printf(" The already exist in the GL_RUN table! \n");
4148            if ( PEDANTIC ) throw -83;
4149        };        };
4150        if ( IsDebug() ) printf(" Delete run %s from the GL_RUN_FRAGMENTS table \n",row->GetField(0));              if ( IsDebug() ) printf(" Delete run %s from the GL_RUN_FRAGMENTS table \n",row->GetField(0));      
4151        //        //
# Line 4429  void PamelaDBOperations::RemoveCALIBS(){ Line 4946  void PamelaDBOperations::RemoveCALIBS(){
4946        //        //
4947      };      };
4948    };    };
4949      Bool_t OLDDB = false;
4950      for (Int_t section = 0; section < 4; section++){
4951        myquery.str("");
4952        myquery << " SELECT MIN(FROM_TIME),MAX(TO_TIME) FROM GL_CALOPULSE_CALIB WHERE ID_ROOT_L0="<< this->GetID_ROOT() <<" AND ";
4953        myquery << " SECTION=" << section << ";";
4954        //
4955        pResult = conn->Query(myquery.str().c_str());
4956        //
4957        if ( conn->GetErrorCode() ){
4958          printf(" Section %i : warning, old databse structure no GL_CALOPULSE_CALIB table!\n",section);
4959          OLDDB=true;
4960        } else {
4961          Row = pResult->Next();      
4962          if( !Row->GetField(0) || !Row->GetField(1) ){
4963            //
4964            if ( IsDebug() ) printf(" NO PULSE CALO CALIBRATION SECTION %i ASSOCIATED TO THIS FILE! \n",section);
4965            //
4966          } else {
4967            //
4968            myquery.str("");
4969            myquery << " UPDATE GL_CALOPULSE_CALIB SET TO_TIME=" << Row->GetField(1);
4970            myquery << " WHERE TO_TIME="<< Row->GetField(0) << " AND ";
4971            myquery << " SECTION=" << section << ";";
4972            //
4973            pResult = conn->Query(myquery.str().c_str());
4974            //
4975            if( !pResult ){
4976              //
4977              if ( IsDebug() ) printf(" ERROR DELETING CALO PULSE CALIBRATIONS \n");
4978              //
4979              throw -4;
4980              //
4981            };
4982            //
4983          };
4984        };
4985      };
4986    myquery.str("");    myquery.str("");
4987    myquery << " DELETE FROM GL_CALO_CALIB WHERE ID_ROOT_L0=" << this->GetID_ROOT();    myquery << " DELETE FROM GL_CALO_CALIB WHERE ID_ROOT_L0=" << this->GetID_ROOT() << ";";
4988    //    //
4989    pResult = conn->Query(myquery.str().c_str());    pResult = conn->Query(myquery.str().c_str());
4990    //    //
# Line 4442  void PamelaDBOperations::RemoveCALIBS(){ Line 4996  void PamelaDBOperations::RemoveCALIBS(){
4996      //      //
4997    };    };
4998    //    //
4999      myquery.str("");
5000      myquery << " DELETE FROM GL_CALOPULSE_CALIB WHERE ID_ROOT_L0=" << this->GetID_ROOT() << ";";
5001      //
5002      pResult = conn->Query(myquery.str().c_str());
5003      if ( IsDebug() ) printf(" Delete from GL_CALOPULSE_CALIB query is %s \n",myquery.str().c_str());
5004      if ( !OLDDB ){
5005        //
5006        if( !pResult ){
5007          //
5008          if ( IsDebug() ) printf(" ERROR DELETING PULSE CALO CALIBRATIONS \n");
5009          //
5010          throw -4;
5011          //
5012        };
5013      };
5014      //
5015    // Tracker    // Tracker
5016    //    //
5017    myquery.str("");    myquery.str("");
# Line 4471  void PamelaDBOperations::RemoveCALIBS(){ Line 5041  void PamelaDBOperations::RemoveCALIBS(){
5041      };      };
5042      //      //
5043      myquery.str("");      myquery.str("");
5044      myquery << " DELETE FROM GL_TRK_CALIB WHERE ID_ROOT_L0=" << this->GetID_ROOT();      myquery << " DELETE FROM GL_TRK_CALIB WHERE ID_ROOT_L0=" << this->GetID_ROOT() << ";";
5045      //      //
5046      pResult = conn->Query(myquery.str().c_str());      pResult = conn->Query(myquery.str().c_str());
5047      //      //
# Line 4514  void PamelaDBOperations::RemoveCALIBS(){ Line 5084  void PamelaDBOperations::RemoveCALIBS(){
5084      };      };
5085      //      //
5086      myquery.str("");      myquery.str("");
5087      myquery << " DELETE FROM GL_S4_CALIB WHERE ID_ROOT_L0=" << this->GetID_ROOT();      myquery << " DELETE FROM GL_S4_CALIB WHERE ID_ROOT_L0=" << this->GetID_ROOT() << ";";
5088      //      //
5089      pResult = conn->Query(myquery.str().c_str());      pResult = conn->Query(myquery.str().c_str());
5090      //      //
# Line 4671  UInt_t PamelaDBOperations::Check(){ Line 5241  UInt_t PamelaDBOperations::Check(){
5241    TSQLRow    *row    = 0;    TSQLRow    *row    = 0;
5242    TSQLResult *result2 = 0;    TSQLResult *result2 = 0;
5243    TSQLRow    *row2    = 0;    TSQLRow    *row2    = 0;
5244      TSQLResult *result3 = 0;
5245      TSQLRow    *row3    = 0;
5246    oss.str("");    oss.str("");
5247    oss << "SELECT ID,ID_ROOT_L0,RUNHEADER_TIME,RUNTRAILER_TIME FROM GL_RUN order by RUNHEADER_TIME asc;";    oss << "SELECT ID,ID_ROOT_L0,RUNHEADER_TIME,RUNTRAILER_TIME,NEVENTS FROM GL_RUN order by RUNHEADER_TIME asc;";
5248    //  oss << "SELECT ID,RUNHEADER_TIME,RUNTRAILER_TIME FROM GL_RUN where ID>10170 and ID<10190 order by RUNHEADER_TIME asc;";    //  oss << "SELECT ID,RUNHEADER_TIME,RUNTRAILER_TIME FROM GL_RUN where ID>10170 and ID<10190 order by RUNHEADER_TIME asc;";
5249    result = conn->Query(oss.str().c_str());    result = conn->Query(oss.str().c_str());
5250    //    //
5251    if ( !result ) throw -4;;    if ( !result ) throw -4;;
5252    //    //
5253    row = result->Next();    row = result->Next();
5254      UInt_t nid = 0;
5255    //    //
5256    while ( row ){    while ( row ){
5257        nid++;
5258        if ( !(nid%1000) && nid ) printf(" %iK run scanned \n",nid/1000);
5259      thisid = (UInt_t)atoll(row->GetField(0));      thisid = (UInt_t)atoll(row->GetField(0));
5260      thisl0id = (UInt_t)atoll(row->GetField(1));      thisl0id = (UInt_t)atoll(row->GetField(1));
5261      thisrht = (UInt_t)atoll(row->GetField(2));      thisrht = (UInt_t)atoll(row->GetField(2));
5262      thisrtt = (UInt_t)atoll(row->GetField(3));      thisrtt = (UInt_t)atoll(row->GetField(3));
5263      //      //
5264        if ( (UInt_t)atoll(row->GetField(4)) > 1 ){
5265          //
5266          //
5267          //
5268          oss.str("");
5269          oss << "SELECT ID,ID_ROOT_L0,RUNHEADER_TIME,RUNTRAILER_TIME FROM GL_RUN WHERE ID!="
5270              << thisid << " AND ( RUNHEADER_TIME="
5271              << thisrht << " OR RUNTRAILER_TIME="
5272              << thisrtt << " ) AND NEVENTS!=0 AND NEVENTS!=1 order by RUNHEADER_TIME asc;";
5273          result3 = conn->Query(oss.str().c_str());
5274          if ( IsDebug() ) printf(" query is %s \n",oss.str().c_str());
5275          if ( result3 ){
5276            //
5277            oss.str("");
5278            oss << "SELECT ID,ID_ROOT_L0,RUNHEADER_TIME,RUNTRAILER_TIME FROM GL_RUN WHERE ID!="
5279                << thisid << " AND RUNHEADER_TIME="
5280                << thisrht << " AND RUNTRAILER_TIME!="
5281                << thisrtt << " AND NEVENTS!=0 AND NEVENTS!=1 order by RUNHEADER_TIME asc;";
5282            result3 = conn->Query(oss.str().c_str());
5283            if ( IsDebug() ) printf(" query is %s \n",oss.str().c_str());
5284            if ( result3 ){
5285              row3 = result3->Next();
5286              //
5287              while ( row3 ){
5288                //
5289                // 2 runs with same runheader
5290                //
5291                printf(" CHECK n.4 RUNs %u and %u HAVE SAME RUNHEADER \n",thisid,(UInt_t)atoll(row3->GetField(0)));  
5292                row3 = result3->Next();
5293              };
5294            };
5295            //
5296            oss.str("");
5297            oss << "SELECT ID,ID_ROOT_L0,RUNHEADER_TIME,RUNTRAILER_TIME FROM GL_RUN WHERE ID!="
5298                << thisid << " AND RUNHEADER_TIME!="
5299                << thisrht << " AND RUNTRAILER_TIME="
5300                << thisrtt << " AND NEVENTS!=0 AND NEVENTS!=1 order by RUNHEADER_TIME asc;";
5301            result3 = conn->Query(oss.str().c_str());
5302            if ( IsDebug() ) printf(" query is %s \n",oss.str().c_str());
5303            if ( result3 ){
5304              row3 = result3->Next();
5305              //
5306              while ( row3 ){
5307                //
5308                // 2 runs with same runtrailer
5309                //
5310                printf(" CHECK n.5 RUNs %u and %u HAVE SAME RUNTRAILER \n",thisid,(UInt_t)atoll(row3->GetField(0)));
5311                row3 = result3->Next();
5312              };
5313            };
5314            //
5315            oss.str("");
5316            oss << "SELECT ID,ID_ROOT_L0,RUNHEADER_TIME,RUNTRAILER_TIME FROM GL_RUN WHERE ID!="
5317                << thisid << " AND RUNHEADER_TIME="
5318                << thisrht << " AND RUNTRAILER_TIME="
5319                << thisrtt << " AND ID_RUN_FRAG!="
5320                << thisid << " order by RUNHEADER_TIME asc;";
5321            result3 = conn->Query(oss.str().c_str());
5322            if ( result3 ){
5323              row3 = result3->Next();
5324              //
5325              while ( row3 ){
5326                //
5327                // duplicated run
5328                //
5329                printf(" CHECK n.7 RUNs %u and %u HAVE SAME RUNTRAILER AND RUNHEADER (ARE THE SAME?) \n",thisid,(UInt_t)atoll(row3->GetField(0)));
5330                row3 = result3->Next();
5331              };
5332            };
5333          };
5334          //
5335          oss.str("");
5336          oss << "SELECT ID,ID_ROOT_L0,RUNHEADER_TIME,RUNTRAILER_TIME FROM GL_RUN WHERE ID!="
5337              << thisid << " AND RUNHEADER_TIME>"
5338              << thisrht << " AND RUNTRAILER_TIME<"
5339              << thisrtt << " order by RUNHEADER_TIME asc;";
5340          result3 = conn->Query(oss.str().c_str());
5341          if ( result3 ){
5342            row3 = result3->Next();
5343            //
5344            while ( row3 ){
5345              //
5346              // run contained in the checked one
5347              //
5348              printf(" CHECK n.6 RUN %u CONTAINS RUN %u  \n",thisid,(UInt_t)atoll(row3->GetField(0)));
5349              row3 = result3->Next();
5350            };
5351          };
5352          //
5353        };
5354        //
5355      //    if ( thisrht < prevrtt || thisrtt < prevrht || thisrht > thisrtt && !(!prevrht && !prevrtt &&!previd) ){      //    if ( thisrht < prevrtt || thisrtt < prevrht || thisrht > thisrtt && !(!prevrht && !prevrtt &&!previd) ){
5356      //    if ( (thisrht < prevrtt || thisrtt < prevrht || thisrht > thisrtt) && (thisrht != prevrht) ){      //    if ( (thisrht < prevrtt || thisrtt < prevrht || thisrht > thisrtt) && (thisrht != prevrht) ){
5357      if ( (thisrht < prevrtt) && (thisrht != prevrht) ){      if ( (thisrht < prevrtt) && (thisrht != prevrht) ){
5358        if ( IsDebug() ) printf(" IDprev %u ID %u    prevrht %u prevrtt %u  thisrht %u thisrtt %u \n",previd,thisid,prevrht,prevrtt,thisrht,thisrtt);        if ( IsDebug() ) printf(" IDprev %u ID %u    prevrht %u prevrtt %u  thisrht %u thisrtt %u \n",previd,thisid,prevrht,prevrtt,thisrht,thisrtt);
5359        printf(" CHECK n.1 TIME SCREW of %u s AROUND RUNs %u and %u \n",(thisrht-prevrtt),previd,thisid);        printf(" CHECK n.1 TIME SCREW of %i s AROUND RUNs %u and %u \n",(thisrht-prevrtt),previd,thisid);
5360        TString prevf = "";        TString prevf = "";
5361        TString thisf = "";        TString thisf = "";
5362        oss.str("");        oss.str("");
# Line 4711  UInt_t PamelaDBOperations::Check(){ Line 5377  UInt_t PamelaDBOperations::Check(){
5377      //      //
5378      if ( (thisrtt < prevrht) && (thisrht != prevrht) ){      if ( (thisrtt < prevrht) && (thisrht != prevrht) ){
5379        if ( IsDebug() ) printf(" IDprev %u ID %u    prevrht %u prevrtt %u  thisrht %u thisrtt %u \n",previd,thisid,prevrht,prevrtt,thisrht,thisrtt);        if ( IsDebug() ) printf(" IDprev %u ID %u    prevrht %u prevrtt %u  thisrht %u thisrtt %u \n",previd,thisid,prevrht,prevrtt,thisrht,thisrtt);
5380        printf(" CHECK n.2 TIME SCREW of %u s AROUND RUNs %u and %u \n",(thisrtt-prevrht),previd,thisid);        printf(" CHECK n.2 TIME SCREW of %i s AROUND RUNs %u and %u \n",(thisrtt-prevrht),previd,thisid);
5381        TString prevf = "";        TString prevf = "";
5382        TString thisf = "";        TString thisf = "";
5383        oss.str("");        oss.str("");
5384        oss << "SELECT NAME FROM GL_ROOT where ID=" << (UInt_t)prevl0id <<";";        oss << "SELECT NAME FROM GL_ROOT where ID=" << (UInt_t)prevl0id <<";";
5385        result2 = conn->Query(oss.str().c_str());        result2 = conn->Query(oss.str().c_str());
5386        if ( !result2 ) throw -4;;        if ( !result2 ) throw -4;
5387        row2 = result2->Next();        row2 = result2->Next();
5388        prevf = (TString)row2->GetField(0);        prevf = (TString)row2->GetField(0);
5389        oss.str("");        oss.str("");
# Line 4732  UInt_t PamelaDBOperations::Check(){ Line 5398  UInt_t PamelaDBOperations::Check(){
5398      //      //
5399      if ( (thisrht > thisrtt) && (thisrht != prevrht) ){      if ( (thisrht > thisrtt) && (thisrht != prevrht) ){
5400        if ( IsDebug() ) printf(" IDprev %u ID %u    prevrht %u prevrtt %u  thisrht %u thisrtt %u \n",previd,thisid,prevrht,prevrtt,thisrht,thisrtt);        if ( IsDebug() ) printf(" IDprev %u ID %u    prevrht %u prevrtt %u  thisrht %u thisrtt %u \n",previd,thisid,prevrht,prevrtt,thisrht,thisrtt);
5401        printf(" CHECK n.3 TIME SCREW of %u s AROUND RUNs %u and %u \n",(thisrht-thisrtt),previd,thisid);        printf(" CHECK n.3 TIME SCREW of %i s AROUND RUNs %u and %u \n",(thisrht-thisrtt),previd,thisid);
5402        TString prevf = "";        TString prevf = "";
5403        TString thisf = "";        TString thisf = "";
5404        oss.str("");        oss.str("");
Legend:
Removed from v.1.39  
changed lines
  Added in v.1.55
  ViewVC Help
Powered by ViewVC 1.1.23