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

Diff of /YodaProfiler/src/GLTables.cpp

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

revision 1.1 by mocchiut, Wed Aug 30 11:18:13 2006 UTC revision 1.5 by mocchiut, Wed Sep 6 11:04:39 2006 UTC
# Line 403  Int_t GL_RUN::Fill_GL_RUN(TSQLServer *db Line 403  Int_t GL_RUN::Fill_GL_RUN(TSQLServer *db
403    myquery << (UInt_t)BOOT_NUMBER << "','";    myquery << (UInt_t)BOOT_NUMBER << "','";
404    myquery << (UInt_t)VALIDATION << "');";    myquery << (UInt_t)VALIDATION << "');";
405    //    //
406    //printf("myquery is %s \n",myquery.str().c_str());    //  printf("myquery is %s \n",myquery.str().c_str());
407    //    //
408    dbc->Query(myquery.str().c_str());    dbc->Query(myquery.str().c_str());
409    //    //
# Line 537  Int_t GL_RUN::Query_GL_RUN(UInt_t run, T Line 537  Int_t GL_RUN::Query_GL_RUN(UInt_t run, T
537    myquery << ",VALIDATION";    myquery << ",VALIDATION";
538    myquery << " from GL_RUN where ID=" << run << ";";    myquery << " from GL_RUN where ID=" << run << ";";
539    //    //
540      //  printf(" myquery is %s \n",myquery.str().c_str());
541    pResult = dbc->Query(myquery.str().c_str());    pResult = dbc->Query(myquery.str().c_str());
542    if(!pResult->GetRowCount())return(-50);    //
543      //  printf(" getrowcount %i \n",pResult->GetRowCount());
544      //
545      if( !pResult->GetRowCount() ) return(-50);
546      //
547    for( r=0; r < 1000; r++){    for( r=0; r < 1000; r++){
548        Row = pResult->Next();              Row = pResult->Next();      
549        if( Row == NULL ) break;        if( Row == NULL ) break;
# Line 575  Int_t GL_RUN::Query_GL_RUN(UInt_t run, T Line 580  Int_t GL_RUN::Query_GL_RUN(UInt_t run, T
580            if (t==29) VALIDATION        = (UInt_t)atoll(Row->GetField(t));            if (t==29) VALIDATION        = (UInt_t)atoll(Row->GetField(t));
581        };        };
582    };    };
583    delete pResult;    //  delete pResult;
584      return(0);
   return 0;  
   
585  };  };
586    
587  /**  /**
# Line 589  Int_t GL_RUN::Query_GL_RUN(UInt_t run, T Line 592  Int_t GL_RUN::Query_GL_RUN(UInt_t run, T
592   *   *
593   */   */
594  Int_t GL_RUN::Query_GL_RUN_FRAGMENTS(TString where, TSQLServer *dbc){  Int_t GL_RUN::Query_GL_RUN_FRAGMENTS(TString where, TSQLServer *dbc){
   //    Bool_t debug = 1;  
595    // MySQL variables    // MySQL variables
596    TSQLResult *pResult;    TSQLResult *pResult;
597    TSQLRow *Row;    TSQLRow *Row;
# Line 597  Int_t GL_RUN::Query_GL_RUN_FRAGMENTS(TSt Line 599  Int_t GL_RUN::Query_GL_RUN_FRAGMENTS(TSt
599    int r;    int r;
600    stringstream myquery;    stringstream myquery;
601    // ----------------    // ----------------
   // NB! unsigned long long integers: when set to a number use ULL to store the correct number  
602    myquery.str("");    myquery.str("");
603    myquery << " select ";    myquery << " select ";
   //    myquery << " * ";  
604    myquery << "ID";    myquery << "ID";
605      myquery << ",ID_RUN_FRAG";
606    myquery << ",ID_ROOT_L0";    myquery << ",ID_ROOT_L0";
607      myquery << ",ID_ROOT_L2";
608    myquery << ",RUNHEADER_TIME";    myquery << ",RUNHEADER_TIME";
609    myquery << ",RUNTRAILER_TIME";    myquery << ",RUNTRAILER_TIME";
610    myquery << ",RUNHEADER_OBT";    myquery << ",RUNHEADER_OBT";
# Line 628  Int_t GL_RUN::Query_GL_RUN_FRAGMENTS(TSt Line 630  Int_t GL_RUN::Query_GL_RUN_FRAGMENTS(TSt
630    myquery << ",TRK_CALIB_USED";    myquery << ",TRK_CALIB_USED";
631    myquery << ",CAL_DSP_MASK";    myquery << ",CAL_DSP_MASK";
632    myquery << ",BOOT_NUMBER";    myquery << ",BOOT_NUMBER";
633      myquery << ",VALIDATION";
634    myquery << " from GL_RUN_FRAGMENTS where " << where.Data() << ";";    myquery << " from GL_RUN_FRAGMENTS where " << where.Data() << ";";
635    //    //
636      //  printf(" query is %s \n",myquery.str().c_str());
637      //
638    pResult = dbc->Query(myquery.str().c_str());    pResult = dbc->Query(myquery.str().c_str());
639    if(!pResult->GetRowCount())return(-50);    if(!pResult->GetRowCount())return(-50);
640    for( r=0; r < 1000; r++){    for( r=0; r < 1000; r++){
641        Row = pResult->Next();            Row = pResult->Next();      
642        if( Row == NULL ) break;      if( Row == NULL ) break;
643        for( t = 0; t < pResult->GetFieldCount(); t++){      for( t = 0; t < pResult->GetFieldCount(); t++){
644            if (t== 0) ID               = (UInt_t)atoll(Row->GetField(t));        if (t== 0) ID                = (UInt_t)atoll(Row->GetField(t));
645            if (t== 1) ID_ROOT_L0          = (UInt_t)atoll(Row->GetField(t));        if (t== 1) ID_RUN_FRAG       = (UInt_t)atoll(Row->GetField(t));
646            if (t== 2) RUNHEADER_TIME   = (UInt_t)atoll(Row->GetField(t));        if (t== 2) ID_ROOT_L0        = (UInt_t)atoll(Row->GetField(t));
647            if (t== 3) RUNTRAILER_TIME  = (UInt_t)atoll(Row->GetField(t));        if (t== 3) ID_ROOT_L2        = (UInt_t)atoll(Row->GetField(t));
648            if (t== 4) RUNHEADER_OBT   = (UInt_t)atoll(Row->GetField(t));        if (t== 4) RUNHEADER_TIME    = (UInt_t)atoll(Row->GetField(t));
649            if (t== 5) RUNTRAILER_OBT  = (UInt_t)atoll(Row->GetField(t));        if (t== 5) RUNTRAILER_TIME   = (UInt_t)atoll(Row->GetField(t));
650            if (t== 6) RUNHEADER_PKT   = (UInt_t)atoll(Row->GetField(t));        if (t== 6) RUNHEADER_OBT     = (UInt_t)atoll(Row->GetField(t));
651            if (t== 7) RUNTRAILER_PKT  = (UInt_t)atoll(Row->GetField(t));        if (t== 7) RUNTRAILER_OBT    = (UInt_t)atoll(Row->GetField(t));
652            if (t== 8) EV_FROM = (UInt_t)atoll(Row->GetField(t));        if (t== 8) RUNHEADER_PKT     = (UInt_t)atoll(Row->GetField(t));
653            if (t== 9) EV_TO = (UInt_t)atoll(Row->GetField(t));        if (t== 9) RUNTRAILER_PKT    = (UInt_t)atoll(Row->GetField(t));
654            if (t==10) NEVENTS = (UInt_t)atoll(Row->GetField(t));        if (t==10) EV_FROM           = (UInt_t)atoll(Row->GetField(t));
655            if (t==11) LAST_TIMESYNC = (UInt_t)atoll(Row->GetField(t));        if (t==11) EV_TO             = (UInt_t)atoll(Row->GetField(t));
656            if (t==12) OBT_TIMESYNC = (UInt_t)atoll(Row->GetField(t));        if (t==12) NEVENTS           = (UInt_t)atoll(Row->GetField(t));
657            if (t==13) COMPILATIONTIMESTAMP = (UInt_t)atoll(Row->GetField(t));        if (t==13) LAST_TIMESYNC     = (UInt_t)atoll(Row->GetField(t));
658            if (t==14) FAV_WRK_SCHEDULE  = (UInt_t)atoll(Row->GetField(t));        if (t==14) OBT_TIMESYNC      = (UInt_t)atoll(Row->GetField(t));
659            if (t==15) EFF_WRK_SCHEDULE  = (UInt_t)atoll(Row->GetField(t));        if (t==15) COMPILATIONTIMESTAMP = (UInt_t)atoll(Row->GetField(t));
660            if (t==16) PRH_VAR_TRG_MODE_A      = (UInt_t)atoll(Row->GetField(t));        if (t==16) FAV_WRK_SCHEDULE  = (UInt_t)atoll(Row->GetField(t));
661            if (t==17) PRH_VAR_TRG_MODE_B      = (UInt_t)atoll(Row->GetField(t));        if (t==17) EFF_WRK_SCHEDULE  = (UInt_t)atoll(Row->GetField(t));
662            if (t==18) ACQ_BUILD_INFO   = (UInt_t)atoll(Row->GetField(t));        if (t==18) PRH_VAR_TRG_MODE_A= (UInt_t)atoll(Row->GetField(t));
663            if (t==19) ACQ_VAR_INFO     = (UInt_t)atoll(Row->GetField(t));        if (t==19) PRH_VAR_TRG_MODE_B= (UInt_t)atoll(Row->GetField(t));
664            if (t==20) RM_ACQ_AFTER_CALIB   = (UInt_t)atoll(Row->GetField(t));        if (t==20) ACQ_BUILD_INFO    = (UInt_t)atoll(Row->GetField(t));
665            if (t==21) RM_ACQ_SETTING_MODE     = (UInt_t)atoll(Row->GetField(t));        if (t==21) ACQ_VAR_INFO      = (UInt_t)atoll(Row->GetField(t));
666            if (t==22) PKT_COUNTER   = (UInt_t)atoll(Row->GetField(t));        if (t==22) RM_ACQ_AFTER_CALIB= (UInt_t)atoll(Row->GetField(t));
667            if (t==23) PKT_READY_COUNTER    = (UInt_t)atoll(Row->GetField(t));        if (t==23) RM_ACQ_SETTING_MODE = (UInt_t)atoll(Row->GetField(t));
668            if (t==24) TRK_CALIB_USED   = (UInt_t)atoll(Row->GetField(t));        if (t==24) PKT_COUNTER       = (UInt_t)atoll(Row->GetField(t));
669            if (t==25) CAL_DSP_MASK   = (UInt_t)atoll(Row->GetField(t));        if (t==25) PKT_READY_COUNTER = (UInt_t)atoll(Row->GetField(t));
670            if (t==26) BOOT_NUMBER   = (UInt_t)atoll(Row->GetField(t));        if (t==26) TRK_CALIB_USED    = (UInt_t)atoll(Row->GetField(t));
671        };        if (t==27) CAL_DSP_MASK      = (UInt_t)atoll(Row->GetField(t));
672          if (t==28) BOOT_NUMBER       = (UInt_t)atoll(Row->GetField(t));
673          if (t==29) VALIDATION        = (UInt_t)atoll(Row->GetField(t));
674        };
675    };    };
676    delete pResult;    //  delete pResult;
677      return(0);
   return 0;  
   
678  };// ****************************************************  };// ****************************************************
679    
680  /**  /**
681   * Function to query the GL_ROOT table of the DB.   * Function to query the GL_ROOT table of the DB.
682   *   *
# Line 734  Int_t GL_TRK_CALIB::Query_GL_TRK_CALIB(U Line 741  Int_t GL_TRK_CALIB::Query_GL_TRK_CALIB(U
741        Row = pResult->Next();            Row = pResult->Next();    
742        if( Row == NULL ) break;        if( Row == NULL ) break;
743        for( t = 0; t < pResult->GetFieldCount(); t++){        for( t = 0; t < pResult->GetFieldCount(); t++){
744              stringstream row;
745              row.str("");
746              row << "0" << Row->GetField(t); // add leading 0 since we have two fields that could be "null" and we want to avoid crashes due to atoll
747            if (t==0) ID               = (UInt_t)atoll(Row->GetField(t));            if (t==0) ID               = (UInt_t)atoll(Row->GetField(t));
748            if (t==1) ID_ROOT_L0  = (UInt_t)atoll(Row->GetField(t));            if (t==1) ID_ROOT_L0  = (UInt_t)atoll(Row->GetField(t));
749            if (t==2) EV_ROOT_CALIBTRK1 = (UInt_t)atoll(Row->GetField(t));            if (t==2) EV_ROOT_CALIBTRK1 = (UInt_t)atoll(row.str().c_str());
750            if (t==3) EV_ROOT_CALIBTRK2 = (UInt_t)atoll(Row->GetField(t));            if (t==3) EV_ROOT_CALIBTRK2 = (UInt_t)atoll(row.str().c_str());
751            if (t==4) FROM_TIME = (UInt_t)atoll(Row->GetField(t));            if (t==4) FROM_TIME = (UInt_t)atoll(Row->GetField(t));
752            if (t==5) TO_TIME   = (UInt_t)atoll(Row->GetField(t));                          if (t==5) TO_TIME   = (UInt_t)atoll(Row->GetField(t));              
753            //            //
# Line 827  Int_t GL_S4_CALIB::Query_GL_S4_CALIB(UIn Line 837  Int_t GL_S4_CALIB::Query_GL_S4_CALIB(UIn
837    // ----------------    // ----------------
838    myquery.str("");    myquery.str("");
839    myquery << "select * from GL_S4_CALIB where FROM_TIME <= "<< time;    myquery << "select * from GL_S4_CALIB where FROM_TIME <= "<< time;
840    myquery << " AND VALIDATION = 1 ORDER BY FROM_TIME DESC LIMIT 1;";          myquery << " ORDER BY FROM_TIME DESC LIMIT 1;";      
841    //  myquery << " ORDER BY FROM_TIME DESC LIMIT 1;";          //  myquery << " ORDER BY FROM_TIME DESC LIMIT 1;";      
842    pResult = dbc->Query(myquery.str().c_str());    pResult = dbc->Query(myquery.str().c_str());
843    if(!pResult->GetRowCount())return (-55);//throw -55;    if(!pResult->GetRowCount())return (-55);//throw -55;
# Line 992  GL_TIMESYNC::GL_TIMESYNC(UInt_t id, TStr Line 1002  GL_TIMESYNC::GL_TIMESYNC(UInt_t id, TStr
1002        toffset = (UInt_t)atoll(Row->GetField(1)) - (UInt_t)(this->DBobt((UInt_t)atoll(Row->GetField(0)))/1000) + t0;        toffset = (UInt_t)atoll(Row->GetField(1)) - (UInt_t)(this->DBobt((UInt_t)atoll(Row->GetField(0)))/1000) + t0;
1003      };      };
1004    };    };
1005      //
1006      file->Close();
1007    delete pResult;          delete pResult;      
1008  };  };
1009    
# Line 1038  UInt_t GL_TIMESYNC::DBpkt(UInt_t pkt_num Line 1050  UInt_t GL_TIMESYNC::DBpkt(UInt_t pkt_num
1050    return(pkt_num);    return(pkt_num);
1051    //    //
1052  };  };
1053    
1054    /*
1055     *
1056     * Convert the time in the DB from UInt_t to a string
1057     *
1058     * @param dbt time in the DB
1059     * @param tzone Time Zone, can be UTC,GMT,CET,CEST,MSD default is MSK
1060     *
1061     */
1062    TString GL_TIMESYNC::ConvertTime(TString tzone, UInt_t dbt){
1063      //
1064      TDatime *time = new TDatime();
1065      TString rtime;
1066      //
1067      time->Set(dbt,false); // MSK = Moscow Winter Time
1068      //
1069      if ( !strcmp(tzone.Data(),"UTC") || !strcmp(tzone.Data(),"GMT") ){
1070        //
1071        UInt_t timeUTC = time->Convert() - 60*60*3; // UTC (Coordinated Universal Time) = Moscow Winter Time - 3 hs
1072        time->Set(timeUTC,false);
1073        //
1074      };
1075      //
1076      if ( !strcmp(tzone.Data(),"CET") ){
1077        //
1078        UInt_t timeCET = time->Convert() - 60*60*2; // CET (Central European Time) = Moscow Winter Time - 2 hs
1079        time->Set(timeCET,false);
1080        //
1081      };
1082      //
1083      if ( !strcmp(tzone.Data(),"CEST") ){
1084        //
1085        UInt_t timeCEST = time->Convert() - 60*60*1; // CEST (Central European Summer Time) = Moscow Winter Time - 1 h
1086        time->Set(timeCEST,false);
1087        //
1088      };
1089      //
1090      if ( !strcmp(tzone.Data(),"MSD") ){
1091        //
1092        UInt_t timeMSD = time->Convert() + 60*60*1; // MSD (Moscow Summer Time) = Moscow Winter Time + 1 h
1093        time->Set(timeMSD,false);
1094        //
1095      };
1096      //
1097      rtime = time->AsSQLString();
1098      //
1099      return(rtime);
1100    }
Legend:
Removed from v.1.1  
changed lines
  Added in v.1.5
  ViewVC Help
Powered by ViewVC 1.1.23