CheckMySQL.cxx

Go to the documentation of this file.

#include "CheckMySQL.h"
#include "TBufferFile.h"
#include "TH1F.h"
CheckMYSQL::CheckMYSQL( const std::string& name, ISvcLocator* pSvcLocator )
    : Algorithm( name, pSvcLocator ) {
  // Declare properties here.
}
 
StatusCode CheckMYSQL::initialize() {
  StatusCode sc;
  MsgStream  log( msgSvc(), name() );
  log << MSG::INFO << "Initialize()" << endmsg;
 
  return StatusCode::SUCCESS;
}
 
StatusCode CheckMYSQL::execute() {
  MsgStream log( msgSvc(), name() );
  // int i;
  char* opt_host_name = "bes3db2.ihep.ac.cn";
  // char *opt_host_name = "koala.ihep.ac.cn";
  char*        opt_user_name   = "maqm";
  char*        opt_password    = "maqm_offline";
  unsigned int opt_port_num    = 3306;
  char*        opt_socket_name = NULL;
  char*        opt_db_name     = "offlinedb";
  unsigned int opt_flags       = 0;
  MYSQL*       conn;
 
  // calibUtil::Metadata *meta = new calibUtil::Metadata(opt_host_name, "*",opt_db_name);
  conn = mysql_init( NULL );
 
  mysql_real_connect( conn, opt_host_name, opt_user_name, opt_password, opt_db_name,
                      opt_port_num, opt_socket_name, opt_flags );
  printf( "connect the database ok\n" );
 
  time_t     now;
  struct tm* timenow;
  timenow = localtime( &now );
  printf( "Local time is %s\n", asctime( timenow ) );
 
  TFile* f = new TFile( "/ihepbatch/besd12/max/bBhabha_EsTime_run6018.root" );
  cout << "step11111111" << endl;
 
  TTree*      Level0 = (TTree*)f->Get( "h2" );
  TBufferFile Level0_buf( TBuffer::kWrite );
  Level0->Streamer( Level0_buf );
 
  cout << "step22222222" << endl;
 
  TTree*      Level1 = (TTree*)f->Get( "calibconst" );
  TBufferFile Level1_buf( TBuffer::kWrite );
  Level1->Streamer( Level1_buf );
 
  /*
     TH1F* LayerCntMap_1 = (TH1F*)f->Get("LayerCntMap");
  //   TH1F* LayerCntMap = new TH1F((TH1F)f->Get("LayerCntMap"));
  //   LayerCntMap->Copy(f->Get("LayerCntMap"));
  //   const double* con = LayerCntMap_1->GetBuffer();
  //   int size = LayerCntMap_1->GetBufferSize();
     std::cout<<""step5555555555"<<std::endl;
     TAxis* xaxis =  LayerCntMap_1->GetXaxis();
      double xmin = xaxis->GetXmin();
      double xmax = xaxis->GetXmax();
      double xbins = xaxis->GetNbins();
      std::cout<<""step6666666"<<std::endl;
      std::cout<<"xbins=="<<xbins<<"xmin=="<<xmin<<"xmax=="<<xmax<<std::endl;
     TH1F* LayerCntMap = new TH1F("LayerCntMap","LayerCntMap",xbins,xmin,xmax);
     for(int i=0;i<size;i++){
       LayerCntMap->Fill(con[i]);
     }
 
     TBuffer LayerCntMap_buf(TBuffer::kWrite);
     LayerCntMap->Copy(*(f->Get("LayerCntMap")));
     LayerCntMap->Streamer(LayerCntMap_buf);
     std::cout<<"55555555555555"<<std::endl;
     f->Close();
     TFile* check = new TFile("check.root","recreate");
  //   LayerCntMap->Write();
     check->Write();
  */
  /*   int size = 4096;
     int bins = 10;
     int xmin = 0;
     int xmax = 10;
     TH1F* histogramU16_ = new TH1F ("histogramU16_", "U16 data", bins, xmin, xmax);
     histogramU16_->SetBit (TH1::kCanRebin); // allow automatic rebinning
 
     for (int i = 0; i < 10; i++) {
       histogramU16_->Fill(i);
     }
 
     char buffer[1024000];
     TBuffer LayerCntMap_buf(TBuffer::kWrite, 1024000, buffer, true);
     std::cout<<"aaaaaaaaa"<<std::endl;
     histogramU16_->Streamer(LayerCntMap_buf);
 
     cout<<"step55555555555"<<endl;
     TH1F* BoxCntMap = (TH1F*)f->Get("BoxCntMap");
     char buffer_1[52400];
     TBuffer BoxCntMap_buf(TBuffer::kWrite,524000,buffer_1,true);
     BoxCntMap->Streamer(BoxCntMap_buf);
 
     cout<<"step66666666"<<std::endl;
     TH1F* StripCntMap = (TH1F*)f->Get("StripCntMap");
     char buffer_2[52400];
     TBuffer StripCntMap_buf(TBuffer::kWrite,524000,buffer_2,true);
     StripCntMap->Streamer(StripCntMap_buf);
      cout<<"step7777777777"<<std::endl;
 
     TH1F* LayerProMap = (TH1F*)f->Get("LayerProMap");
      char buffer_3[52400];
     TBuffer LayerProMap_buf(TBuffer::kWrite,524000,buffer_3,true);
     LayerProMap->Streamer(LayerProMap_buf);
 
     cout<<"step88888888888888"<<std::endl;
 
     TH1F* BoxProMap = (TH1F*)f->Get("BoxProMap");
     char buffer_4[52400];
     TBuffer BoxProMap_buf(TBuffer::kWrite,524000,buffer_4,true);
     BoxProMap->Streamer(BoxProMap_buf);
 
      cout<<"step9999999999999"<<std::endl;
     */
  char         query[5024000], buf[1024 * 1000], buf1[1024 * 1000], *p, *p1;
  unsigned int from_len, from_len1;
 
  int status;
  int id = 60034;
 
  sprintf( query,
           "INSERT INTO  EsTimeCalConst(SerNo,RunFrom,RunTo,EsTimeH2,EsTimeH9) "
           "VALUES(%d,'100','1000','",
           id );
 
  printf( "%s\n", query );
  p = query + strlen( query );
  p += mysql_escape_string( p, Level0_buf.Buffer(), Level0_buf.BufferSize() );
 
  strcat( p, "','" );
  cout << "strlen(query)22222222222=" << strlen( query ) << endl;
 
  p = query + strlen( query );
  p += mysql_escape_string( p, Level1_buf.Buffer(), Level1_buf.BufferSize() );
  strcat( p, "')" );
  status = mysql_query( conn, query );
  printf( "%d\n", status );
 
  // cout<<"status================"<<status<<endl;
 
  unsigned long* lengths;
 
  MYSQL_RES* res_set;
  MYSQL_ROW  row;
 
  // char *p1;
  char stmt1[200]; //="select context from mytesttable where id = %d,";
  int  serno = 1;
  // sprintf(stmt1,"select BarTofPar,EndTofPar,RunFrom,RunTo from TofCalConst where
  // SerNo=%d",serno);
  sprintf( stmt1, "select EsTimeH2,EsTimeH9,RunFrom,RunTo from TofCalConst where SerNo=%d",
           serno );
 
  // char stmt1[100]="select  tree1,tree2 from TofCalConst where ser_no = 10026";
  printf( "%s\n", stmt1 );
  if ( mysql_real_query( conn, stmt1, strlen( stmt1 ) ) != 0 ) printf( "query error\n" );
  res_set = mysql_store_result( conn );
  mysql_field_seek( res_set, 0 );
 
  row     = mysql_fetch_row( res_set );
  lengths = mysql_fetch_lengths( res_set );
  for ( int i = 0; i < 8; i++ )
  {
    // cout<<"size of row["<<i<<"]"<<sizeof(row[i])<<endl;
    cout << "lengths[" << i << "]=" << lengths[i] << endl;
  }
  /*
  //string ss(row[0]);
  //const char *pp = ss.c_str();
 
   TTree* newHist= new TTree();
    TBuffer rootBuffer2(TBuffer::kRead,lengths[0], row[0], kFALSE);
  //  TBuffer rootBuffer2(TBuffer::kRead,lengths[0], void pp, kFALSE);
   newHist->Streamer(rootBuffer2);
     newHist->Print();
    int  nentri = newHist -> GetEntries();*/
  //  double xtpar;
  //  int xtkey;
  /*double atten,w3;
    newHist -> SetBranchAddress("Atten", &atten);
    newHist -> SetBranchAddress("W3", &w3);
    cout<<"nentri="<<nentri<<endl;
    for(int ii=0;ii<nentri;ii++){
      newHist->GetEntry(ii);
      cout<<"Atten="<<atten<<"W3="<<w3<<endl;
    }
    */
  /* TTree* newHist1= new TTree();
    TBuffer rootBuffer3(TBuffer::kRead,lengths[1], row[1], kFALSE);
    newHist1->Streamer(rootBuffer3);
     newHist1->Print();
    int  nentri1 = newHist1 -> GetEntries();
  //  double xtpar;
  //  int xtkey;
  //double atten,w3;
    double p6;
    newHist1 -> SetBranchAddress("Atten", &atten);
    newHist1 -> SetBranchAddress("P6", &p6);
    cout<<"nentri1="<<nentri1<<endl;
    for(int ii=0;ii<nentri1;ii++){
      newHist1->GetEntry(ii);
      cout<<"Atten="<<atten<<"P6="<<p6<<endl;
    }
    */
  return StatusCode::SUCCESS;
}
StatusCode CheckMYSQL::finalize() {
 
  MsgStream log( msgSvc(), name() );
  log << MSG::INFO << "        CheckMYSQL FINALIZE!! " << endmsg;
 
  return StatusCode::SUCCESS;
}