ReadRuntripFromDb.cxx

Go to the documentation of this file.

#include "MdcTripSvc/ReadRuntripFromDb.h"
#include <string.h>
 
using namespace std;
 
ReadRuntripFromDb::ReadRuntripFromDb() :
  m_isTrip(false){
  }
 
ReadRuntripFromDb::~ReadRuntripFromDb()
{
  timest.clear();
  timend.clear();
}
 
MYSQL* ReadRuntripFromDb::OpenDb() const {
 
  const char host[]     = "bes3db2.ihep.ac.cn";
  const char user[]     = "guest";
  const char passwd[]   = "guestpass";
  const char db[]       = "offlinedb";
  unsigned int port_num = 3306;
 
  MYSQL* mysql = mysql_init(NULL);
  mysql = mysql_real_connect(mysql, host, user, passwd, db, port_num,
      NULL,  // socket
      0);    // client_flag
 
  if (mysql == NULL) {
    fprintf(stderr, "can not open database: offlinedb\n");
  }
 
  return mysql;
}
 
void ReadRuntripFromDb::CloseDb(MYSQL* mysql) const {
  mysql_close(mysql);
}
 
 
void ReadRuntripFromDb::ReadDb(int run)
{
  MYSQL* mysql=OpenDb();
  char stmt[1024];
 
  snprintf(stmt, 1024,
      "select trip_start, trip_stop "
      "from RunParams where run_number = %d", run);
  //printf("--------- %s -------\n",stmt);
  if (mysql_real_query(mysql, stmt, strlen(stmt))) 
  {
    fprintf(stderr, "query error\n");
    m_isTrip = false;    
    CloseDb(mysql);
    return;  
  }
  MYSQL_RES* result_set = mysql_store_result(mysql);
  MYSQL_ROW row = mysql_fetch_row(result_set);
  if (row[0]==NULL || row[1]==NULL) 
  {
    fprintf(stderr, "can't find trip information for tripped run: %d\n", run);
    mysql_free_result(result_set);
    CloseDb(mysql);
    m_isTrip = false;
    return;
  }
 
  timest.clear();
  timend.clear();
  char *token;  
  char *doken;
  token = strtok(row[0],",");
  string tripst(token);
  timest.push_back(tripst);
  while((token =strtok(NULL,","))!= NULL){
    string tripst(token);
    timest.push_back(tripst);
  }
  doken = strtok(row[1],",");
  string tripnd(doken);
  timend.push_back(tripnd); 
  while((doken = strtok(NULL,","))!= NULL){
    string tripnd(doken);
    timend.push_back(tripnd);
  }
 
  // Free the memory to prevent memory leak!
  mysql_free_result(result_set);
  CloseDb(mysql);
  m_isTrip = true;
}
 
bool ReadRuntripFromDb::isRunTripped() 
{
  return m_isTrip;
}
 
string ReadRuntripFromDb::gettimest(int i)
{
  return timest[i];
}
string ReadRuntripFromDb::gettimend(int i)
{
  return timend[i];
}
 
int ReadRuntripFromDb::getstSize()
{
  return timest.size();
}
 
int ReadRuntripFromDb::getndSize()
{
  return timend.size();
}