test_sql.cxx

Go to the documentation of this file.

// $Header: /bes/bes/BossCvs/Calibration/rdbModel/src/test/test_build.cxx,v 1.1.1.1 2005/10/17 06:10:53 maqm Exp $
// Test program for rdbModel primitive buiding blocks
 
#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 "TBufferFile.h"
#define TEST_SQL
 
int main(int argc, char** argv) {
 // char *opt_host_name = "202.122.33.53";   
 //char *opt_user_name = "maqm";   
 //unsigned int opt_port_num = 3306;   
 //char *opt_socket_name = NULL;   
 //char *opt_db_name = "offlinedb";
 char *opt_host_name=argv[1];
 unsigned int opt_port_num = 3306;
    //sscanf(agv[2],"%d",opt_port_name);
 char *opt_socket_name = NULL;
 char *opt_db_name = argv[3];
 char *opt_user_name = argv[4];
 char *opt_password = argv[5];
 
 char *opt_table_name = argv[7];
   
 unsigned int opt_flags = 0;   
 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");
 
time_t now;
struct tm  *timenow;
timenow = localtime(&now);
printf("Local time is %s\n",asctime(timenow));
 
//=================================
//read the TFile of MDC calibData
//=================================
 
 
     std::cout<<"host="<<argv[1]<<std::endl;
     std::cout<<"path ="<<argv[6]<<std::endl;
// if(argv[1]=='mdc'){ 
   std::cout<<"11111111"<<std::endl;
   TFile *f= new TFile(argv[6]); 
   TTree *qttree =  (TTree*)f-> Get("QtTree");
   TBufferFile qttree_buf(TBufferFile::kWrite);
   qttree->Streamer(qttree_buf); 
 
   TTree *sdtree =  (TTree*)f-> Get("SdTree");
   TBufferFile sdtree_buf(TBufferFile::kWrite);
   sdtree->Streamer(sdtree_buf); 
 
   TTree *t0tree =  (TTree*)f-> Get("T0Tree");
   TBufferFile t0tree_buf(TBufferFile::kWrite);
   t0tree->Streamer(t0tree_buf); 
 
   TTree *xttree =  (TTree*)f-> Get("XtTree");
   TBufferFile xttree_buf(TBufferFile::kWrite);
   xttree->Streamer(xttree_buf); 
 
 
char  query[5024000],buf[1024*1000],buf1[1024*1000],*p,*p1;
char  query1[5024];
unsigned int from_len,from_len1;
 
int status=-1;
int id =10;
std::cout<<"qttreesize"<<qttree_buf.BufferSize()<<std::endl;
std::cout<<"sdtree====="<<sdtree_buf.BufferSize()<<std::endl;
std::cout<<"t0tree====="<<t0tree_buf.BufferSize()<<std::endl;
std::cout<<"xttree====="<<xttree_buf.BufferSize()<<std::endl;
 
//============================
//insert the data the MYSQL
//===========================
//sprintf(query,"INSERT INTO  MdcCalConst(serNo,QtTree,XtTree,T0Tree,SdTree) VALUES(%d,'",id);
 
//sprintf(query,"UPDATE MdcCalConst SET RunFrom =100,QtTree='");
 sprintf(query,"UPDATE %s SET QtTree='",opt_table_name);
 
    printf("%s\n",query);
    p= query + strlen(query);
p += mysql_escape_string(p,qttree_buf.Buffer(),qttree_buf.BufferSize());
 
    strcat(p,"',XtTree='");
//cout<<"strlen(query)22222222222="<<strlen(query)<<endl;
     
     p= query + strlen(query);
     p +=mysql_escape_string(p,xttree_buf.Buffer(),xttree_buf.BufferSize());
    strcat(p,"',T0Tree='");
 
     p= query + strlen(query);
     p +=mysql_escape_string(p,t0tree_buf.Buffer(),t0tree_buf.BufferSize());
     strcat(p,"',SdTree='");
 
     p= query + strlen(query);
     p +=mysql_escape_string(p,sdtree_buf.Buffer(),sdtree_buf.BufferSize());
    strcat(p,"' WHERE SerNo = ");
    p= query + strlen(query);
    sprintf(query1,"%d",id);
    strcat(p,query1);   
//  p+=id;
//printf("%s\n",query);
     status = mysql_query(conn,query);
         printf("status==%d\n",status);
// }
 
 
 
/*
    std::cout<<"status================"<<status<<std::endl;
 
unsigned long *lengths;
 
 MYSQL_RES *res_set;
 MYSQL_ROW row;
 
 
 //====================================
 //search in the MYSQL 
 //=====================================
 char stmt1[200];//="select context from mytesttable where id = %d,";
 sprintf(stmt1,"select  XtTree,QtTree,T0Tree,SdTree from MdcCalConst where ser_no = %d",id);
 
 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<5;i++){ 
  std::cout<<"lengths["<<i<<"]="<<lengths[i]<<std::endl;
  }
 
//====================================
//read the calibdata from the buffer
//====================================
 TTree* newHist= new TTree(); 
  TBufferFile rootBuffer2(TBufferFile::kRead,lengths[0], row[0], kFALSE); 
 newHist->Streamer(rootBuffer2); 
   newHist->Print(); 
  int  nentri = newHist -> GetEntries();
*/
  return 0;
}