test_mdc_read.cxx

Go to the documentation of this file.

#include <iostream>
#include <string>
#include <cstdlib>
#include <time.h>
#include <stdio.h>
#include <string.h>
#include <mysql/mysql.h>
#include "TROOT.h"
#include "TFile.h"
#include "TTree.h"
#include "TObjArray.h"
#include "TBufferFile.h"
#include <fstream>
#define TEST_SQL
 
int main(int argc, char** argv) {
  const char *opt_host_name = "202.122.37.69";
  //const char *opt_host_name = "202.122.35.37";
  const char *opt_user_name = "maqm";
  const char *opt_socket_name = NULL;
  const char *opt_db_name = "offlinedb";
  const char *opt_table_name = "MdcCalConst";
  static char query[80240000];
  unsigned int opt_port_num = 3306;
  unsigned int opt_flags = 0;
  char *p; 
  int status=-1;
 
 
  MYSQL *conn;
  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");
  if(conn!=0){
    std::cout<<"connect the database ok\n"<<std::endl;
  }else{
    std::cout<<"can't connect to the db:"<<std::endl;
    return -1;
  }
 
  unsigned long *lengths;
 
  MYSQL_RES *res_set;
  MYSQL_ROW row;
 
  char stmt1[200];
  sprintf(stmt1,"select NewXtTrees from MdcCalConst where serno = 414");
 
  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);
  //====================================
  //read the calibdata from the buffer
  //====================================
  //TBufferFile rootBuffer2(TBufferFile::kRead,lengths[0], row[0], kFALSE); 
  TBufferFile rootBuffer2(TBufferFile::kRead,lengths[0], row[0], kFALSE); 
  gROOT->cd();
  std::cout << "buffer length=" << lengths[0] << std::endl;
 
  TObjArray array;
  array.Streamer(rootBuffer2); 
  std::cout<< __FILE__ << "   " << __LINE__ << " array size  "<<array.GetSize()
    <<" entry="<<array.GetEntries()<<std::endl;
 
  //array.Print(); 
 
  //std::cout<< __FILE__ << "   " << __LINE__ << " name  "<<array.At(0)<<std::endl;
  int iTree = 0;
  for(int t_layer=0; t_layer<43; t_layer++){
    for(int t_entr=0; t_entr<18; t_entr++){
      for(int t_lr=0; t_lr<2; t_lr++){
    std::cout<<"trNewXt"<<t_layer<<"_"<<t_entr<<"_"<<t_lr<<" "<<iTree<<" name "<<((TTree*)array.At(iTree))->GetName()<<std::endl;
    iTree++;
    std::cout << ((TTree*)array.At(iTree))->GetName() << std::endl;
      }
    }
  }
 
  //TTree* t = (TTree*) (array.At(0));
  //std::cout<< __FILE__ << "   " << __LINE__ << "   "<<t<<std::endl;
  //std::cout << ((TTree*)array.At(0))->GetEntries() << std::endl;
  //((TTree*)array.At(0))->Draw();
  //t->Print();
  //t->GetEntries();
  //int nEntry = array->GetSize();
  //std::cout<< __FILE__ << "   " << __LINE__ << "   "<<std::endl;
  //TIter next(array); 
  //std::cout<< __FILE__ << "   " << __LINE__ << "   "<<std::endl;
  //TTree* myTree; 
  //std::cout<< __FILE__ << "   " << __LINE__ << "   "<<std::endl;
  //while( myTree=(TTree*)next()) {
  //std::cout<< __FILE__ << "   " << __LINE__ << "   "<<std::endl;
  //  myTree->Print();
  //}
  //std::cout<<"array size ="<<nEntry<<std::endl;
  //std::cout << ((TTree*)array->At(0))->GetName() << std::endl;
  //for (int i=0;i<nEntry;i++){
  //  std::cout << array.At(i)->GetName() << std::endl;
  //}
 
  return 0;
}