test_mdc_write.cxx File Reference

#include <iostream>
#include <string>
#include <cstdlib>
#include <time.h>
#include <stdio.h>
#include <string.h>
#include <mysql/mysql.h>
#include "TFile.h"
#include "TTree.h"
#include "TObjArray.h"
#include "TBufferFile.h"
#include <fstream>

Go to the source code of this file.

Macros
#define	TEST_SQL

Functions
int	main (int argc, char **argv)

Macro Definition Documentation

TEST_SQL

#define TEST_SQL

Definition at line 13 of file test_mdc_write.cxx.

Function Documentation

main()

int main	(	int	argc,
		char **	argv
	)

Definition at line 15 of file test_mdc_write.cxx.

                                {
  if(argc<3){
    printf("mdc.exe rootFile calConstId\n ../x86_64-slc5-gcc43-opt/mdc_write.exe /panfs/panfs.ihep.ac.cn/home/data/zhangyao/trackingStudy/calib/const2db/MdcCalibConst_newXtFun.root 414\n");
    return -1;
  }
  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 *opt_id = argv[2];
  TFile *f= new TFile(argv[1]);
  char *p; 
  int status=-1;
 
  char query_check[1024];
  sprintf(query_check,"select RunFrom,RunTo,CalParVer,SftVer from %s where SerNo=%s",opt_table_name,opt_id);
  //new xttree---------------------------------------------------------------
  TObjArray newxttrees_1;
 
  TBufferFile newxttrees_buf(TBuffer::kWrite);
 
  int nTree=0;
  for(int t_layer=0; t_layer<43; t_layer++){
    for(int t_bin=0; t_bin<18; t_bin++){
      for(int t_lr=0; t_lr<2; t_lr++){
    char newXtTreeName[20];
    sprintf(newXtTreeName,"trNewXt%02d_%02d_%d",t_layer,t_bin,t_lr);
    TTree *newXttree =  ((TTree*)f->Get(newXtTreeName))->CloneTree();
    newxttrees_1.Add(newXttree);
    nTree++;
      }
    }
  }
  newxttrees_1.Streamer(newxttrees_buf);
 
  //std::ofstream of("output.bin", std::ios::binary);
  //of.write(newxttrees_buf.Buffer(), newxttrees_buf.BufferSize());
  //of.close();
  //return 0;
 
  printf("newxttrees_1.size=%d\n",newxttrees_1.GetSize());
  printf("nTree=%d\n entry=%d\n",nTree,newxttrees_1.GetEntries());
  sprintf(query,"UPDATE %s SET NewXtTrees='",opt_table_name);
  p= query + strlen(query);
  p += mysql_escape_string(p,newxttrees_buf.Buffer(),newxttrees_buf.BufferSize());
  strcat(p,"' WHERE SerNo = ");
  p= query + strlen(query);
  strcat(p,opt_id);
 
  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);
  status = mysql_query(conn,query_check); 
  MYSQL_RES* result = mysql_store_result(conn);
  MYSQL_ROW row = mysql_fetch_row(result);
 
  char query_jc[400]; 
  char query_jc1[400];
 
  sprintf(query_jc,"select * from %s where (RunFrom between %s and %s or RunTo between %s and %s) and CalParVer='%s' and SftVer='%s'",opt_table_name,row[0],row[1],row[0],row[1],row[2],row[3]);
  sprintf(query_jc1,"select * from %s where RunFrom<=%s and RunTo>=%s and CalParVer='%s' and SftVer='%s'",opt_table_name,row[0],row[1],row[2],row[3]);
 
  mysql_free_result(result);
  status = mysql_query(conn,query_jc);
  result = mysql_store_result(conn);
  int num_fields = mysql_num_rows(result);
  if(num_fields>1) return -1;
  mysql_free_result(result);
  status = mysql_query(conn,query_jc1);
  result = mysql_store_result(conn);
  num_fields = mysql_num_rows(result);
  if(num_fields>1) return -1;
  mysql_free_result(result);
  status = mysql_query(conn,query);
  printf("status=%d\n",status);
  int kkkk=mysql_errno(conn);
  printf("err=%d\n",kkkk);
  return 0;
}