--- YodaProfiler/src/GLTables.cpp 2006/11/07 12:17:44 1.16 +++ YodaProfiler/src/GLTables.cpp 2007/03/23 08:17:26 1.25 @@ -17,6 +17,7 @@ #include #include // +ClassImp(GL_TABLES); ClassImp(GL_TRK_CALIB); ClassImp(GL_RUN); ClassImp(GL_ROOT); @@ -28,6 +29,98 @@ // using namespace std; +GL_TABLES::GL_TABLES(){ +}; + +GL_TABLES::GL_TABLES(TString host, TString user, TString psw){ + fHost = new TString(host.Data()); + fUser = new TString(user.Data()); + fPsw = new TString(psw.Data()); + fSet = true; + fNquery = 0; +}; + + +void GL_TABLES::Set(TString host, TString user, TString psw){ + fHost = new TString(host.Data()); + fUser = new TString(user.Data()); + fPsw = new TString(psw.Data()); + fSet = true; + fNquery = 0; +}; + +Bool_t GL_TABLES::IsConnected(TSQLServer *dbc){ + // + // + // + if ( !fSet ){ + return true; + }; + // + // + // + // printf(" host is %s \n",fHost->Data()); + // + stringstream myquery; + myquery.str(""); + myquery << "show databases;"; + dbc->Query(myquery.str().c_str()); + fNquery++; + // + if ( dbc->GetErrorCode() != 2013 && dbc->GetErrorCode() != 2006 ){ + // is connected + return true; + } else { + // + printf(" WARNING: Lost connection to DB! try to recover... \n"); + // + TString host = fHost->Data(); + TString user = fUser->Data(); + TString psw = fPsw->Data(); + delete dbc; + dbc = TSQLServer::Connect(host.Data(),user.Data(),psw.Data()); + // + myquery.str(""); + myquery << "show databases;"; + dbc->Query(myquery.str().c_str()); + fNquery++; + // + if ( dbc->GetErrorCode() != 2013 && dbc->GetErrorCode() != 2006 ){ + // + printf(" ...connection recovered, I can continue! \n"); + // + myquery.str(""); + myquery << "SET time_zone='+0:00'"; + dbc->Query(myquery.str().c_str()); + fNquery++; + myquery.str(""); + myquery << "SET wait_timeout=173000;"; + dbc->Query(myquery.str().c_str()); + fNquery++; + return true; + }; + }; + // + printf(" GLTABLES: connection is gone away, query will fail\n"); + // + return false; + // +}; + +void GL_TABLES::ResetCounters(){ + fNquery = 0; +}; + +void GL_TABLES::AddQ(){ + if ( fSet ) fNquery++; +}; + +UInt_t GL_TABLES::GetNqueries(){ + UInt_t rn = 0; + rn += (UInt_t&)fNquery; + return(rn); +}; + GL_RUN::GL_RUN() { ID = 0; ID_RUN_FRAG = 0; @@ -154,16 +247,13 @@ obtfirst = 0; pktfirst = 0; toffset = 0; - ID = 0; - ID_RAW = 0; + // ID = 0; + // ID_RAW = 0; OBT0 = 0; TIMESYNC = 0; TYPE = 0; } -GL_TLE::GL_TLE(){ -} - // **************************************************** void GL_RUN::SetEV_FROM(UInt_t evfrom){ @@ -428,12 +518,16 @@ // // printf("1myquery is %s \n",myquery.str().c_str()); // + if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; + this->GetGLTABLES()->AddQ(); dbc->Query(myquery.str().c_str()); // // retrieve this ID_TRASH // myquery.str(""); myquery << " SELECT ID_TRASH,ID_ROOT_L0,ID_ROOT_L2 FROM GL_RUN_TRASH ORDER BY ID_TRASH DESC LIMIT 1"; + if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; + this->GetGLTABLES()->AddQ(); pResult = dbc->Query(myquery.str().c_str()); // UInt_t idtrash = 0; @@ -455,6 +549,8 @@ // // printf("2myquery is %s \n",myquery.str().c_str()); // + if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; + this->GetGLTABLES()->AddQ(); pResult = dbc->Query(myquery.str().c_str()); // Row = pResult->Next(); @@ -470,6 +566,8 @@ // // printf("3myquery is %s \n",myquery.str().c_str()); // + if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; + this->GetGLTABLES()->AddQ(); pResult = dbc->Query(myquery.str().c_str()); // Row = pResult->Next(); @@ -486,6 +584,8 @@ // // printf("4myquery is %s \n",myquery.str().c_str()); // + if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; + this->GetGLTABLES()->AddQ(); dbc->Query(myquery.str().c_str()); // myquery.str(""); @@ -495,6 +595,8 @@ // // printf("4myquery is %s \n",myquery.str().c_str()); // + if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; + this->GetGLTABLES()->AddQ(); dbc->Query(myquery.str().c_str()); // myquery.str(""); @@ -505,6 +607,8 @@ // printf("4myquery is %s \n",myquery.str().c_str()); // // + if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; + this->GetGLTABLES()->AddQ(); dbc->Query(myquery.str().c_str()); // myquery.str(""); @@ -515,6 +619,8 @@ // printf("5myquery is %s \n",myquery.str().c_str()); // // + if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; + this->GetGLTABLES()->AddQ(); dbc->Query(myquery.str().c_str()); // return 0; @@ -546,6 +652,8 @@ // printf(" qui? myquery is %s \n",myquery.str().c_str()); // + if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; + this->GetGLTABLES()->AddQ(); pResult = dbc->Query(myquery.str().c_str()); // Row = pResult->Next(); @@ -629,6 +737,8 @@ // // printf("5myquery is %s \n",myquery.str().c_str()); // + if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; + this->GetGLTABLES()->AddQ(); dbc->Query(myquery.str().c_str()); // // @@ -636,6 +746,8 @@ myquery << " DELETE FROM GL_RUN_TRASH where BELONGED_TO='GL_RUN_FRAGMENTS' AND ID="; myquery << IDRUN << ";"; // + if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; + this->GetGLTABLES()->AddQ(); dbc->Query(myquery.str().c_str()); // return 0; @@ -718,6 +830,8 @@ // // printf("myquery is %s \n",myquery.str().c_str()); // + if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; + this->GetGLTABLES()->AddQ(); dbc->Query(myquery.str().c_str()); // return 0; @@ -794,6 +908,8 @@ // // printf("myquery is %s \n",myquery.str().c_str()); // + if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; + this->GetGLTABLES()->AddQ(); dbc->Query(myquery.str().c_str()); // return 0; @@ -851,6 +967,8 @@ myquery << " from GL_RUN where ID=" << run << ";"; // // printf(" myquery is %s \n",myquery.str().c_str()); + if ( !this->IsConnected(dbc) ) return -57; + this->AddQ(); pResult = dbc->Query(myquery.str().c_str()); // // printf(" getrowcount %i \n",pResult->GetRowCount()); @@ -949,6 +1067,8 @@ // // printf(" query is %s \n",myquery.str().c_str()); // + if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; + this->GetGLTABLES()->AddQ(); pResult = dbc->Query(myquery.str().c_str()); if(!pResult->GetRowCount())return(-50); for( r=0; r < 1000; r++){ @@ -1014,6 +1134,8 @@ myquery << ",NAME"; myquery << " from GL_ROOT where ID=" << id << ";"; // + if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; + this->GetGLTABLES()->AddQ(); pResult = dbc->Query(myquery.str().c_str()); if(!pResult->GetRowCount())return (-51); for( r=0; r < 1000; r++){ @@ -1048,8 +1170,11 @@ // ---------------- myquery.str(""); myquery << "select ID,ID_ROOT_L0,EV_ROOT_CALIBTRK1,EV_ROOT_CALIBTRK2,FROM_TIME,TO_TIME,OBT1,OBT2,PKT1,PKT2,BOOT_NUMBER,VALIDATION from GL_TRK_CALIB where FROM_TIME <= "<< time; - myquery << " AND VALIDATION=1 ORDER BY FROM_TIME DESC LIMIT 1;"; +// myquery << " AND VALIDATION=1 ORDER BY FROM_TIME DESC LIMIT 1;"; // RIVEDERE LA VALIDAZIONE!!! + myquery << " ORDER BY FROM_TIME DESC LIMIT 1;"; // myquery << " ORDER BY FROM_TIME DESC LIMIT 1;"; + if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; + this->GetGLTABLES()->AddQ(); pResult = dbc->Query(myquery.str().c_str()); if(!pResult->GetRowCount())return (-53); for( r=0; r < 1000; r++){ @@ -1107,6 +1232,8 @@ myquery << " ;"; //myquery << " and VALIDATION=1;"; // + if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; + this->GetGLTABLES()->AddQ(); pResult = dbc->Query(myquery.str().c_str()); // printf(" mysquery is %s\n",myquery.str().c_str()); // @@ -1126,6 +1253,8 @@ myquery << "select ID_ROOT_L0, FROM_TIME, TO_TIME, EV_ROOT,VALIDATION from GL_CALO_CALIB where SECTION=" << section; myquery << " and FROM_TIME <= " << time; myquery << " and VALIDATION=1 ORDER BY FROM_TIME DESC LIMIT 1;"; + if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; + this->GetGLTABLES()->AddQ(); pResult = dbc->Query(myquery.str().c_str()); // printf(" mysquery is %s\n",myquery.str().c_str()); // @@ -1168,6 +1297,8 @@ myquery << "select * from GL_S4_CALIB where FROM_TIME <= "<< time; myquery << " ORDER BY FROM_TIME DESC LIMIT 1;"; // myquery << " ORDER BY FROM_TIME DESC LIMIT 1;"; + if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; + this->GetGLTABLES()->AddQ(); pResult = dbc->Query(myquery.str().c_str()); if(!pResult->GetRowCount())return (-55);//throw -55; for( r=0; r < 1000; r++){ @@ -1208,12 +1339,14 @@ // ---------------- myquery.str(""); myquery << " select "; - myquery << " ID, PATH, NAME, DESCR, TYPE, FROM_TIME,TO_TIME "; + myquery << " ID, PATH, NAME, DESCR, FROM_TIME,TO_TIME, TYPE "; myquery << " from GL_PARAM "; myquery << " where TYPE = '"<GetGLTABLES()->IsConnected(dbc) ) return -57; + this->GetGLTABLES()->AddQ(); pResult = dbc->Query(myquery.str().c_str()); if(!pResult->GetRowCount())return (-52); for( r=0; r < 1000; r++){ @@ -1267,6 +1400,9 @@ TSQLRow *Row; stringstream myquery; stringstream rname; + // pcksList packetsNames; + // pcksList::iterator Iter; + // getPacketsNames(packetsNames); rname.str(""); // ---------------- myquery.str(""); @@ -1277,6 +1413,8 @@ myquery << type.Data(); myquery << "=" << id << ";"; // + if ( !this->GetGLTABLES()->IsConnected(dbc) ) return; + this->GetGLTABLES()->AddQ(); pResult = dbc->Query(myquery.str().c_str()); if( pResult->GetRowCount() ){ Row = pResult->Next(); @@ -1300,18 +1438,40 @@ ph = eh->GetPscuHeader(); pktfirst = ph->GetCounter(); obtfirst = ph->GetOrbitalTime(); + // +// code = eh->GetCounter(); +// UInt_t en = 0; +// for(Iter = packetsNames.begin(); Iter != packetsNames.end(); Iter++){ +// en = code->Get(GetPacketType(*Iter)); +// if ( !strcmp("CalibCalPed",*Iter) || !strcmp("CalibTrk1",*Iter) || !strcmp("CalibTrk2",*Iter) || !strcmp("CalibS4",*Iter) ){ +// // +// TTree *TC = 0; +// TC = (TTree*)file->Get("CalibCalPed"); +// if ( !TC || TC->IsZombie() ) return; +// EventHeader *ehc = 0; +// PscuHeader *phc = 0; +// TC->SetBranchAddress("Header", &ehc); +// TC->GetEntry(0); +// phc = ehc->GetPscuHeader(); +// pktfirst = phc->GetCounter(); +// obtfirst = phc->GetOrbitalTime(); +// // +// }; +// }; + // }; // // look for Resurs offset // - UInt_t t0 = 0; + T0 = 0; // // stringstream oss; oss.str(""); - oss << "SELECT 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) FROM GL_RESURS_OFFSET WHERE SPECIAL_FILE='" << rname.str().c_str() << "';"; - // if ( IsDebug() ) printf(" %s \n",oss.str().c_str()); + if ( !this->GetGLTABLES()->IsConnected(dbc) ) return; + this->GetGLTABLES()->AddQ(); pResult = dbc->Query(oss.str().c_str()); Row = pResult->Next(); // @@ -1330,15 +1490,20 @@ for (Int_t i = 8; i<13; i++){ dwo.Append(name[i],1); }; - if ( dwo.IsDigit() ) dworbit = (UInt_t)dwo.Atoi(); + if ( dwo.IsDigit() ){ + dworbit = (UInt_t)dwo.Atoi(); + } else { + dworbit = 1; + }; }; - // if ( IsDebug() ) printf(" Downlink orbit is %i (dwo = %s) \n",dworbit,dwo.Data()); + // // if ( !Row ){ oss.str(""); - oss << "SELECT 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) FROM GL_RESURS_OFFSET WHERE FROM_ORBIT< " << dworbit << " order by FROM_ORBIT desc limit 1;"; - // if ( IsDebug() ) printf(" %s \n",oss.str().c_str()); + if ( !this->GetGLTABLES()->IsConnected(dbc) ) return; + this->GetGLTABLES()->AddQ(); pResult = dbc->Query(oss.str().c_str()); Row = pResult->Next(); if ( !Row ){ @@ -1347,22 +1512,25 @@ }; }; // - // - TDatime ti = TDatime(Row->GetField(0)); - TTimeStamp tu = TTimeStamp((UInt_t)ti.GetYear(),(UInt_t)ti.GetMonth(),(UInt_t)ti.GetDay(),(UInt_t)ti.GetHour(),(UInt_t)ti.GetMinute(),(UInt_t)ti.GetSecond(),0,true,0); - t0 = (UInt_t)tu.GetSec(); + 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); + T0 = (UInt_t)tu.GetSec(); // // look for the correct timesync entry // myquery.str(""); - myquery << " SELECT OBT0,TIMESYNC FROM GL_TIMESYNC " + myquery << " SELECT OBT0,TIMESYNC,TYPE FROM GL_TIMESYNC " << " WHERE ID_RAW = " << idraw << ";"; + if ( !this->GetGLTABLES()->IsConnected(dbc) ) return; + this->GetGLTABLES()->AddQ(); pResult = dbc->Query(myquery.str().c_str()); if ( pResult ){ Row = pResult->Next(); if ( (Row != NULL) && ((UInt_t)atoll(Row->GetField(0)) > 0 ) ){ - toffset = (UInt_t)atoll(Row->GetField(1)) - (UInt_t)(this->DBobt((UInt_t)atoll(Row->GetField(0)))/1000) + t0; + OBT0 = (UInt_t)atoll(Row->GetField(0)); + TIMESYNC = (UInt_t)atoll(Row->GetField(1)); + TYPE = (UInt_t)atoll(Row->GetField(2)); + toffset = (UInt_t)atoll(Row->GetField(1)) - (UInt_t)(this->DBobt((UInt_t)atoll(Row->GetField(0)))/1000) + T0; }; }; // @@ -1381,39 +1549,83 @@ // }; +/** + * + * Returns the Resurs time given the OBT needed to process inclination and orbital infos + * + */ +UInt_t GL_TIMESYNC::ResursTime(UInt_t OBT){ + // + return(((UInt_t)((Int_t)(this->DBobt(OBT)-this->DBobt(OBT0))/1000)+TIMESYNC)); + // +}; + -ULong64_t GL_TIMESYNC::DBobt(UInt_t obt){ +/** + * Return the correct packet number if we went back to zero + */ +Long64_t GL_TIMESYNC::DBpkt(UInt_t pkt_num){ // - if ( obt < (obtfirst/2) && obtfirst > (numeric_limits::max()/2) ) return((ULong64_t)(obt+numeric_limits::max())); + if ( pkt_num < (pktfirst/2) && pktfirst > (16777214/2) ){ + return((Long64_t)pkt_num+16777215LL); + }; // - if ( obt > (obtfirst*2) && obt > (numeric_limits::max()/2) ){ - if ( (obt-numeric_limits::max()) < 0 ){ - return((ULong64_t)(numeric_limits::max()-obt)); - } else { - return((ULong64_t)(obt-numeric_limits::max())); - }; + if ( pkt_num > pktfirst*2 && pkt_num > (16777214/2) ){ + return((Long64_t)pkt_num-16777215LL); }; // - return((ULong64_t)obt); + return((Long64_t)pkt_num); // }; -UInt_t GL_TIMESYNC::DBpkt(UInt_t pkt_num){ +/** + * Return the correct On Board Time if we went back to zero + */ +Long64_t GL_TIMESYNC::DBobt(UInt_t obt){ // - if ( pkt_num < (pktfirst/2) && pktfirst > (16777214/2) ) return((pkt_num+16777215)); + if ( obt < (obtfirst/2) && obtfirst > (numeric_limits::max()/2) ) return((Long64_t)(obt+numeric_limits::max())); // - if ( pkt_num > pktfirst*2 && pkt_num > (16777214/2) ){ - if ( (pkt_num-16777215) < 0 ){ - return((16777215-pkt_num)); - } else { - return((pkt_num-16777215)); - }; + if ( obt > (obtfirst*2) && obt > (numeric_limits::max()/2) ){ + return((Long64_t)obt-(Long64_t)numeric_limits::max()); }; // - return(pkt_num); - // + return((Long64_t)obt); }; + + +// ULong64_t GL_TIMESYNC::DBobt(UInt_t obt){ +// // +// if ( obt < (obtfirst/2) && obtfirst > (numeric_limits::max()/2) ) return((ULong64_t)(obt+numeric_limits::max())); +// // +// if ( obt > (obtfirst*2) && obt > (numeric_limits::max()/2) ){ +// if ( (obt-numeric_limits::max()) < 0 ){ +// return((ULong64_t)(numeric_limits::max()-obt)); +// } else { +// return((ULong64_t)(obt-numeric_limits::max())); +// }; +// }; +// // +// return((ULong64_t)obt); +// // +// }; + +// UInt_t GL_TIMESYNC::DBpkt(UInt_t pkt_num){ +// // +// if ( pkt_num < (pktfirst/2) && pktfirst > (16777214/2) ) return((pkt_num+16777215)); +// // +// if ( pkt_num > pktfirst*2 && pkt_num > (16777214/2) ){ +// if ( (pkt_num-16777215) < 0 ){ +// return((16777215-pkt_num)); +// } else { +// return((pkt_num-16777215)); +// }; +// }; +// // +// return(pkt_num); +// // +// }; + /* * * Convert the time in the DB from UInt_t to a string @@ -1531,84 +1743,113 @@ } -// **************************************************** -/** - * Function to query the GL_TLE table of the DB. - * - * time is the unix time for which a good tle is requested. - * - * Return the pointer to a cTle object that has the closest and - * previous date compared with time. - * - * If errors occurs it returns NULL. - */ -cTle* GL_TLE::Query_GL_TLE(UInt_t time, TSQLServer *dbc){ +// +// Build a query and call DoQuery. +// +// date it's an SQL datetime date and dbc is the connection to be +// used. It will query for the tle with the nearest but previous date +// and the immediatly next one. +// +Int_t GL_TLE::Query(TString date, TSQLServer *dbc){ stringstream myquery; myquery.str(""); - myquery << "SELECT TLE1, TLE2, TLE3 FROM GL_TLE " - << "WHERE FROM_TIME < FROM_UNIXTIME(" << time << ") ORDER BY FROM_TIME DESC LIMIT 1;"; + myquery << "(SELECT ID, TLE1, TLE2, TLE3, UNIX_TIMESTAMP(FROM_TIME) FROM GL_TLE " + << "WHERE FROM_TIME <= '" << date.Data() + << "' ORDER BY FROM_TIME DESC LIMIT 1) " + << "UNION " + << "(SELECT ID, TLE1, TLE2, TLE3, UNIX_TIMESTAMP(FROM_TIME) FROM GL_TLE " + << "WHERE FROM_TIME > '" << date.Data() + << "' ORDER BY FROM_TIME ASC LIMIT 1)"; - - return Query_GL_TLE_go(myquery.str(), dbc); + return DoQuery(myquery.str().c_str(), dbc); } -// **************************************************** -/** - * Function to query the GL_TLE table of the DB. - * - * date is a datetime format YYYY-MM-DD hh:mm:ss for which a good tle - * is requested. - * - * Return the pointer to a cTle object that has the closest and - * previous date compared with time. - * - * If errors occurs it returns NULL. - */ -cTle* GL_TLE::Query_GL_TLE(TString date, TSQLServer *dbc){ +// +// Build a query and call DoQuery. +// +// time is the UTC date in unix time (UTC) and dbc is the connection +// to be used. It will query for the tle with the nearest but +// previous date and the immediatly next one. +// +// Returns the value returned by DoQuery(). +// +Int_t GL_TLE::Query(UInt_t time, TSQLServer *dbc){ stringstream myquery; myquery.str(""); - myquery << "SELECT TLE1, TLE2, TLE3 FROM GL_TLE " - << "WHERE FROM_TIME < '" << date.Data() << "' ORDER BY FROM_TIME DESC LIMIT 1;"; - + myquery << "(SELECT ID, TLE1, TLE2, TLE3, UNIX_TIMESTAMP(FROM_TIME) FROM GL_TLE " + << "WHERE FROM_TIME <= FROM_UNIXTIME('" << time + << "') ORDER BY FROM_TIME DESC LIMIT 1) " + << "UNION " + << "(SELECT ID, TLE1, TLE2, TLE3, UNIX_TIMESTAMP(FROM_TIME) FROM GL_TLE " + << "WHERE FROM_TIME > FROM_UNIXTIME('" << time + << "') ORDER BY FROM_TIME ASC LIMIT 1)"; - return Query_GL_TLE_go(myquery.str(), dbc); + return DoQuery(myquery.str().c_str(), dbc); } -// **************************************************** -/** - * Private function used by Query_GL_TLE methods. - * - * myquery is the query string. - * - * Return the pointer to a cTle object that has the closest and - * previous date compared with time. - * - * If errors occurs it returns NULL. - */ -cTle* GL_TLE::Query_GL_TLE_go(TString myquery, TSQLServer *dbc){ - cTle *tle; - string tle1, tle2, tle3; - - // MySQL variables +// +// Do the query myquery on the connectio dbc. Initialize tle, +// tleFromTime and tleToTime. +// +// We should have two rows (unless the table is old). From the last +// one we only take tleToTime. +// +// Returns 0 for success, 1 for failure. +// +Int_t GL_TLE::DoQuery(TString myquery, TSQLServer *dbc){ TSQLResult *result; TSQLRow *row; + // Set the right time_zone (otherwise horrible things will occur! :) + dbc->Query("SET time_zone = '+0:00'"); + + // Do the query + if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; + this->GetGLTABLES()->AddQ(); result = dbc->Query(myquery.Data()); - if(! result->GetRowCount() ) return NULL; + if(! result->GetRowCount() ) { + cerr << "GL_TLE: query failed: " << myquery.Data() << endl; + return 1; + } + + // Get results + row = result->Next(); // first tle row + tle = GiveTle(row); + + tleFromTime = strtol(row->GetField(4), NULL, 10); + + row = result->Next(); // second tle row + if(row) + tleToTime = strtol(row->GetField(4), NULL, 10); + else { + cerr << "GL_TLE: Warning: using last avaible TLE. Please update GL_TLE table!\n"; + tleToTime = UINT_MAX; + } - row = result->Next(); - tle1 = row->GetField(0); - tle2 = row->GetField(1); - tle3 = row->GetField(2); + delete row; + delete result; - tle = new cTle(tle1, tle2, tle3); + return 0; +} - delete result; - delete row; - return tle; +// +// Build a cTle object from the GL_TLE row. +// +cTle* GL_TLE::GiveTle(TSQLRow *row) { + cTle *thistle = NULL; + string tle1, tle2, tle3; + + // Build cTle object + tle1 = row->GetField(1); + tle2 = row->GetField(2); + tle3 = row->GetField(3); + + thistle = new cTle(tle1, tle2, tle3); + + return thistle; }