/[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.7 by mocchiut, Thu Sep 7 09:17:32 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 762  Int_t GL_TRK_CALIB::Query_GL_TRK_CALIB(U Line 772  Int_t GL_TRK_CALIB::Query_GL_TRK_CALIB(U
772   * \param  run starting time   * \param  run starting time
773   * \return struct of type GL_CALO_CALIB_data, which stores the query result   * \return struct of type GL_CALO_CALIB_data, which stores the query result
774   */   */
775  Int_t GL_CALO_CALIB::Query_GL_CALO_CALIB(UInt_t time, UInt_t section, TSQLServer *dbc){  Int_t GL_CALO_CALIB::Query_GL_CALO_CALIB(UInt_t time, UInt_t &uptime,  UInt_t section, TSQLServer *dbc){
776    // MySQL variables    // MySQL variables
777    TSQLResult *pResult;    TSQLResult *pResult;
778    TSQLRow *Row;    TSQLRow *Row;
779    int t;    int t;
780    stringstream myquery;    stringstream myquery;
781      uptime = 0;
782    //    //
783    // select the correct calibration    // select the correct calibration
784    //    //
# Line 775  Int_t GL_CALO_CALIB::Query_GL_CALO_CALIB Line 786  Int_t GL_CALO_CALIB::Query_GL_CALO_CALIB
786    myquery << "select ID_ROOT_L0, FROM_TIME, TO_TIME, EV_ROOT,VALIDATION from GL_CALO_CALIB where SECTION=" << section;    myquery << "select ID_ROOT_L0, FROM_TIME, TO_TIME, EV_ROOT,VALIDATION from GL_CALO_CALIB where SECTION=" << section;
787    myquery << " and FROM_TIME <= " << time;    myquery << " and FROM_TIME <= " << time;
788    myquery << " and TO_TIME > " << time;    myquery << " and TO_TIME > " << time;
789    myquery << " and VALIDATION=1;";    myquery << " ;";
790      //myquery << " and VALIDATION=1;";
791    //    //
792    pResult = dbc->Query(myquery.str().c_str());    pResult = dbc->Query(myquery.str().c_str());
793      //  printf(" mysquery is %s\n",myquery.str().c_str());
794      //
795      if( !pResult->GetRowCount() ) return(-54);
796      Row = pResult->Next();
797      if( Row == NULL ) return (-54);
798      //
799      uptime = (UInt_t)atoll(Row->GetField(2));
800    //    //
801    // if it is corrupted validation is 0 and we have no results from the query...    // if it is corrupted validation is 0 and we have no results from the query...
802    //    //
803    if( !pResult->GetRowCount() ){    if( atoi(Row->GetField(4)) == 0 ){ // if validation = 0
     //    pResult->Delete();  
804      //      //
805      // in this case take relax the conditions and take the valid calibration that preceed the correct one      // in this case take relax the conditions and take the valid calibration that preceed the correct one
806      //      //
# Line 791  Int_t GL_CALO_CALIB::Query_GL_CALO_CALIB Line 809  Int_t GL_CALO_CALIB::Query_GL_CALO_CALIB
809      myquery << " and FROM_TIME <= " << time;      myquery << " and FROM_TIME <= " << time;
810      myquery << " and VALIDATION=1 ORDER BY FROM_TIME DESC LIMIT 1;";      myquery << " and VALIDATION=1 ORDER BY FROM_TIME DESC LIMIT 1;";
811      pResult = dbc->Query(myquery.str().c_str());      pResult = dbc->Query(myquery.str().c_str());
812        //    printf(" mysquery is %s\n",myquery.str().c_str());
813      //      //
814      // if no results yet quit with error      // if no results yet quit with error
815      //      //
816      if( !pResult->GetRowCount() ) return (-54);      if( !pResult->GetRowCount() ) return (-54);
817        //
818        Row = pResult->Next();
819        //
820    };    };
821    //    //
822    // store infos and exit    // store infos and exit
823    //    //
   Row = pResult->Next();  
824    if( Row == NULL ) return (-54);    if( Row == NULL ) return (-54);
825    for( t = 0; t < pResult->GetFieldCount(); t++){    for( t = 0; t < pResult->GetFieldCount(); t++){
826      if (t==0) ID_ROOT_L0  = (UInt_t)atoll(Row->GetField(t));      if (t==0) ID_ROOT_L0  = (UInt_t)atoll(Row->GetField(t));
# Line 827  Int_t GL_S4_CALIB::Query_GL_S4_CALIB(UIn Line 848  Int_t GL_S4_CALIB::Query_GL_S4_CALIB(UIn
848    // ----------------    // ----------------
849    myquery.str("");    myquery.str("");
850    myquery << "select * from GL_S4_CALIB where FROM_TIME <= "<< time;    myquery << "select * from GL_S4_CALIB where FROM_TIME <= "<< time;
851    myquery << " AND VALIDATION = 1 ORDER BY FROM_TIME DESC LIMIT 1;";          myquery << " ORDER BY FROM_TIME DESC LIMIT 1;";      
852    //  myquery << " ORDER BY FROM_TIME DESC LIMIT 1;";          //  myquery << " ORDER BY FROM_TIME DESC LIMIT 1;";      
853    pResult = dbc->Query(myquery.str().c_str());    pResult = dbc->Query(myquery.str().c_str());
854    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 1013  GL_TIMESYNC::GL_TIMESYNC(UInt_t id, TStr
1013        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;
1014      };      };
1015    };    };
1016      //
1017      file->Close();
1018    delete pResult;          delete pResult;      
1019  };  };
1020    
# Line 1038  UInt_t GL_TIMESYNC::DBpkt(UInt_t pkt_num Line 1061  UInt_t GL_TIMESYNC::DBpkt(UInt_t pkt_num
1061    return(pkt_num);    return(pkt_num);
1062    //    //
1063  };  };
1064    
1065    /*
1066     *
1067     * Convert the time in the DB from UInt_t to a string
1068     *
1069     * @param dbt time in the DB
1070     * @param tzone Time Zone, can be UTC,GMT,CET,CEST,MSD default is MSK
1071     *
1072     */
1073    TString GL_TIMESYNC::ConvertTime(TString tzone, UInt_t dbt){
1074      //
1075      TDatime *time = new TDatime();
1076      TString rtime;
1077      //
1078      time->Set(dbt,false); // MSK = Moscow Winter Time
1079      //
1080      if ( !strcmp(tzone.Data(),"UTC") || !strcmp(tzone.Data(),"GMT") ){
1081        //
1082        UInt_t timeUTC = time->Convert() - 60*60*3; // UTC (Coordinated Universal Time) = Moscow Winter Time - 3 hs
1083        time->Set(timeUTC,false);
1084        //
1085      };
1086      //
1087      if ( !strcmp(tzone.Data(),"CET") ){
1088        //
1089        UInt_t timeCET = time->Convert() - 60*60*2; // CET (Central European Time) = Moscow Winter Time - 2 hs
1090        time->Set(timeCET,false);
1091        //
1092      };
1093      //
1094      if ( !strcmp(tzone.Data(),"CEST") ){
1095        //
1096        UInt_t timeCEST = time->Convert() - 60*60*1; // CEST (Central European Summer Time) = Moscow Winter Time - 1 h
1097        time->Set(timeCEST,false);
1098        //
1099      };
1100      //
1101      if ( !strcmp(tzone.Data(),"MSD") ){
1102        //
1103        UInt_t timeMSD = time->Convert() + 60*60*1; // MSD (Moscow Summer Time) = Moscow Winter Time + 1 h
1104        time->Set(timeMSD,false);
1105        //
1106      };
1107      //
1108      rtime = time->AsSQLString();
1109      //
1110      return(rtime);
1111    }
1112    
1113    /*
1114     *
1115     * Convert the time in the DB from UInt_t to a string
1116     *
1117     * @param dbt time in the DB
1118     * @param tzone Time Zone, can be UTC,GMT,CET,CEST,MSD default is MSK
1119     *
1120     */
1121    TString GL_TIMESYNC::UnConvertTime(TString tzone, UInt_t dbt){
1122      //
1123      TDatime *time = new TDatime();
1124      TString rtime;
1125      //
1126      time->Set(dbt,false); // MSK = Moscow Winter Time
1127      //
1128      if ( !strcmp(tzone.Data(),"UTC") || !strcmp(tzone.Data(),"GMT") ){
1129        //
1130        UInt_t timeUTC = time->Convert() + 60*60*3; // UTC (Coordinated Universal Time) +3 hs = Moscow Winter Time
1131        time->Set(timeUTC,false);
1132        //
1133      };
1134      //
1135      if ( !strcmp(tzone.Data(),"CET") ){
1136        //
1137        UInt_t timeCET = time->Convert() + 60*60*2; // CET (Central European Time) + 2 hs = Moscow Winter Time  
1138        time->Set(timeCET,false);
1139        //
1140      };
1141      //
1142      if ( !strcmp(tzone.Data(),"CEST") ){
1143        //
1144        UInt_t timeCEST = time->Convert() + 60*60*1; // CEST (Central European Summer Time) + 1 h = Moscow Winter Time
1145        time->Set(timeCEST,false);
1146        //
1147      };
1148      //
1149      if ( !strcmp(tzone.Data(),"MSD") ){
1150        //
1151        UInt_t timeMSD = time->Convert() - 60*60*1; // MSD (Moscow Summer Time) - 1 h = Moscow Winter Time
1152        time->Set(timeMSD,false);
1153        //
1154      };
1155      //
1156      rtime = time->AsSQLString();
1157      //
1158      return(rtime);
1159    }
Legend:
Removed from v.1.1  
changed lines
  Added in v.1.7
  ViewVC Help
Powered by ViewVC 1.1.23