DQA_TO_DB.cxx File Reference

#include <stdlib.h>
#include <string.h>
#include <iostream>
#include <fstream>
#include "TH1F.h"
#include "TFile.h"
#include "db_mysql.h"
#include "TF1.h"

Go to the source code of this file.

Functions
int	main (int argc, char *argv[])
int	WriteLumDB ()
int	WriteBeamParToDb ()
int	ReWriteBeamParToDb ()
int	ReadFromDB ()
int	WriteLumTauDB ()

Variables
db_mysql	sqlonline
db_mysql	sqloffline
int	runNo
char *	offline_user
char *	offline_passwd
char *	file
const char *	server_ip = "bes3db1.ihep.ac.cn"
char *	Creator =getenv("USER")
char *	SftVer =getenv("BES_RELEASE")
char *	ParVer
char *	LumTau_txt
bool	ISNeedReFit =0
bool	ISNeedReFitX =0
bool	ISNeedReFitY =0
bool	ISNeedReFitZ =0

Function Documentation

main()

int main	(	int	argc,
		char *	argv[]
	)

Definition at line 25 of file DQA_TO_DB.cxx.

                                {
    //define:
    int WriteLumDB();
    int WriteBeamParToDb();
    int ReWriteBeamParToDb();   
    int ReadFromDB();
    int WriteLumTauDB();
    //Execute:
    offline_user=argv[1];
    offline_passwd=argv[2];
    char* runNo_temp=argv[3];
    runNo=atoi(runNo_temp);
    ParVer=argv[4];
    file=argv[5];
    LumTau_txt = argv[6];
    std::cout<<"-----------------------------------"<<runNo<<"-------------------------"<<std::endl;
    sqloffline.Init(server_ip,offline_user,offline_passwd);
    sqloffline.Connect();
    sqloffline.SelectDB("offlinedb");
 
    WriteLumDB();
    WriteBeamParToDb();
    if(ISNeedReFit){ReWriteBeamParToDb();}
    ReadFromDB();
    WriteLumTauDB();
 
    sqloffline.Close();
 
    return 1;
}

ReadFromDB()

int ReadFromDB

(

)

Definition at line 215 of file DQA_TO_DB.cxx.

                {
    std::cout<<"--------------check RUN LUM and Vertex info -----------------------------------"<<std::endl;
    char sql_input[550];
    sprintf(sql_input,"select SerNo,RunNo,IntLumEndcapEE,OfflineTwoGam,SftVer,ParVer,Creator,CreateTime,Notes from OfflineLum where RunNo=%d && SftVer='%s' && ParVer='%s'",runNo,SftVer,ParVer);
    sqloffline.Execute(sql_input);
    std::cout<<"LUM is:"<<"SerNo,RunNo,IntLumEndcapEE,OfflineTwoGam,SftVer,ParVer,Creator,CreateTime,Notes"<<std::endl;
    if(sqloffline.GetRow(0)){
        std::cout<<sqloffline.GetField(0)<<","<<sqloffline.GetField(1)<<","<<sqloffline.GetField(2)<<","<<sqloffline.GetField(3)<<","
            <<sqloffline.GetField(4)<<","<<sqloffline.GetField(5)<<","<<sqloffline.GetField(6)<<","<<sqloffline.GetField(7)<<","
            <<sqloffline.GetField(8)<<std::endl;
        std::cout<<"---------------------------------------------------------------LUM is OK!"<<std::endl;
    }
    else std::cout<<"-----------------------------------------ERROR to read LUM from OfflineLum db"<<std::endl;
 
    sprintf(sql_input, "select BeamParSerNo,RunNo,Vx,Vy,Vz,SigmaVx,SigmaVy,SigmaVz,VerFitFunc,DistFitFunc,SftVer,Creator,AcSigmaVx,AcSigmaVy,ParVer FROM BeamPar where RunNo ='%d' && SftVer='%s' && ParVer='%s'", runNo,SftVer,ParVer);
    sqloffline.Execute(sql_input);
    std::cout<<"BeamPar is:"<<"BeamParSerNo,RunNo,Vx,Vy,Vz,SigmaVx,SigmaVy,SigmaVz,VerFitFunc,DistFitFunc,SftVer,Creator,AcSigmaVx,AcSigmaVy,ParVer"<<std::endl;
    if(sqloffline.GetRow(0)){
        std::cout<<sqloffline.GetField(0)<<","<<sqloffline.GetField(1)<<","<<sqloffline.GetField(2)<<","<<sqloffline.GetField(3)<<","
            <<sqloffline.GetField(4)<<","<<sqloffline.GetField(5)<<","<<sqloffline.GetField(6)<<","<<sqloffline.GetField(7)<<","
            <<sqloffline.GetField(8)<<","<<sqloffline.GetField(9)<<","<<sqloffline.GetField(10)<<","<<sqloffline.GetField(11)<<","
            <<sqloffline.GetField(12)<<","<<sqloffline.GetField(13)<<","<<sqloffline.GetField(14)<<std::endl;
        std::cout<<"-------------------------------------------------------BeamPar is OK!"<<std::endl;
    }
    else std::cout<<"-----------------------------------------ERROR to read Vertex  from BeamPar db"<<std::endl;
    return 1;
}

Referenced by main().

ReWriteBeamParToDb()

int ReWriteBeamParToDb

(

)

Definition at line 168 of file DQA_TO_DB.cxx.

                        {
    char query[1024*100];
    int irun=1;
    std::string Vx;
    std::string Vy;
    std::string Vz;
    std::string SigmaVx;
    std::string SigmaVy;
    std::string SigmaVz;
    bool Runloop=0;
    do{
        sprintf(query,"select Vx,Vy,Vz,SigmaVx,SigmaVy,SigmaVz,RunNo,SftVer,ParVer from BeamPar where RunNo='%d' && SftVer='%s' && ParVer='%s'",runNo-irun,SftVer,ParVer);
        sqloffline.Execute(query);
        if(sqloffline.GetRow(0)){
            Vx=sqloffline.GetField(0);
            Vy=sqloffline.GetField(1);
            Vz=sqloffline.GetField(2);
            SigmaVx=sqloffline.GetField(3);
            SigmaVy=sqloffline.GetField(4);
            SigmaVz=sqloffline.GetField(5);
            Runloop=0;
        }
        else Runloop=1;
        irun++;
    }while(Runloop);
    if(ISNeedReFitX){
        sprintf(query,"update BeamPar set Vx='%s',SigmaVx='%s' where RunNo='%d' && SftVer='%s' && ParVer='%s'",Vx.c_str(),SigmaVx.c_str(),runNo,SftVer,ParVer);
        sqloffline.Execute(query);
        //   std::cout<<query<<std::endl;
        std::cout<<"------------------update Vx,SigmaVx successful!--------"<<std::endl;
    }
    if(ISNeedReFitY){
        sprintf(query,"update BeamPar set Vy='%s',SigmaVy='%s' where RunNo='%d' && SftVer='%s' && ParVer='%s'",Vy.c_str(),SigmaVy.c_str(),runNo,SftVer,ParVer);
        sqloffline.Execute(query);
        // std::cout<<query<<std::endl;
        std::cout<<"------------------update Vy,SigmaVy successful!---------"<<std::endl;
    }
    if(ISNeedReFitZ){
        sprintf(query,"update BeamPar set Vz='%s',SigmaVz='%s' where RunNo='%d' && SftVer='%s' && ParVer='%s'",Vz.c_str(),SigmaVz.c_str(),runNo,SftVer,ParVer);
        sqloffline.Execute(query);
        //std::cout<<query<<std::endl;
        std::cout<<"------------------update Vz,SigmaVz successful!---------"<<std::endl;
    }
 
 
    return 1;
}

Referenced by main().

WriteBeamParToDb()

int WriteBeamParToDb

(

)

Definition at line 86 of file DQA_TO_DB.cxx.

                      {
    TFile f(file);
    TH1D* x_of_vertex_in_kal;
    TH1D* y_of_vertex_in_kal;
    TH1D* z_of_vertex_in_kal;
    f.GetObject("/zhsVER/x_of_vertex_in_kal",x_of_vertex_in_kal);
    f.GetObject("/zhsVER/y_of_vertex_in_kal",y_of_vertex_in_kal);
    f.GetObject("/zhsVER/z_of_vertex_in_kal",z_of_vertex_in_kal);
    TF1 *func;
    TF1 *funcY;
    TF1 *funcZ;
    if(runNo<=10878 || runNo>20433){ //jpsi,psip
        func = new TF1("func", "gaus", -0.6, 0.6);
        funcY = new TF1("funcY", "gaus", -0.6, 0.2);
        funcZ = new TF1("funcZ", "gaus", -6, 6);
    }
    else if(runNo >10878 && runNo<= 20433){//psipp
        func = new TF1("func", "gaus", 0., 1.8);
        funcY = new TF1("funcY", "gaus", -1., 1.);
        funcZ = new TF1("funcZ", "gaus", -6, 6);
    }
    x_of_vertex_in_kal->Fit("func", "RQ");
    Double_t MeanXKal = func->GetParameter(1);
    Double_t SigmaXKal = func->GetParameter(2);
 
    y_of_vertex_in_kal->Fit("funcY", "RQ");
    Double_t MeanYKal = funcY->GetParameter(1);
    Double_t SigmaYKal = funcY->GetParameter(2);
 
    z_of_vertex_in_kal->Fit("funcZ", "RQ");
    Double_t MeanZKal = funcZ->GetParameter(1);
    Double_t SigmaZKal = funcZ->GetParameter(2); 
    if(runNo<=10878 || runNo>20433){
        if(MeanXKal<-0.05 || MeanXKal>0.25 || SigmaXKal>0.12 || SigmaXKal<0.){
            std::cout<<"--------------x_of_vertex_in_kal-------out of range--runID is:"<<runNo<<std::endl;
            ISNeedReFitX=1;ISNeedReFit=1;
        }
        if(MeanYKal<-0.4 || MeanYKal>0 || SigmaYKal>0.12 || SigmaYKal<0)
        {
            std::cout<<"--------------y_of_vertex_in_kal-------out of range--runID is:"<<runNo<<std::endl;
            ISNeedReFitY=1;ISNeedReFit=1;
        }
        if(MeanZKal<-1 || MeanZKal>1.0 || SigmaZKal>1.5 || SigmaZKal<0)
        {
            std::cout<<"--------------z_of_vertex_in_kal-------out of range--runID is:"<<runNo<<std::endl;
            ISNeedReFitZ=1;ISNeedReFit=1;
        }
    }
    else{
        if(MeanXKal<0.6 || MeanXKal>1.2 || SigmaXKal>0.18 || SigmaXKal<0.){
            std::cout<<"--------------x_of_vertex_in_kal-------out of range--runID is:"<<runNo<<std::endl;
            ISNeedReFitX=1;ISNeedReFit=1;
        }
        if(MeanYKal<-0.4 || MeanYKal>0 || SigmaYKal>0.12 || SigmaYKal<0.)
        {
            std::cout<<"--------------y_of_vertex_in_kal-------out of range--runID is:"<<runNo<<std::endl;
            ISNeedReFitY=1;ISNeedReFit=1;
        }
        if(MeanZKal<-0.8 || MeanZKal>0.8 || SigmaZKal>1.5 || SigmaZKal<0.)
        {
            std::cout<<"--------------z_of_vertex_in_kal-------out of range--runID is:"<<runNo<<std::endl;
            ISNeedReFitZ=1;ISNeedReFit=1;
        }
 
    }
    char VerFitFunc[] = "Kalman"; 
    char DistFitFunc[] = "single Gaussian";
 
    double AcSigmaVx, AcSigmaVy;
 
    AcSigmaVx = 0.038;
    AcSigmaVy = 0.00057;
    char query[1024*100];
    
    sprintf(query, "DELETE FROM BeamPar where RunNo = '%d' && SftVer='%s' && ParVer='%s'", runNo,SftVer,ParVer);
    sqloffline.Execute(query);
    sprintf(query,"INSERT INTO BeamPar(BeamParSerNo,RunNo,Vx,Vy,Vz,SigmaVx,SigmaVy,SigmaVz,VerFitFunc,DistFitFunc,SftVer,Creator,AcSigmaVx,AcSigmaVy,ParVer) values('','%d','%f','%f','%f','%f','%f','%f','%s','%s','%s','%s','%f','%f','%s')",runNo,MeanXKal,MeanYKal,MeanZKal,SigmaXKal,SigmaYKal,SigmaZKal,VerFitFunc,DistFitFunc,SftVer,Creator,AcSigmaVx,AcSigmaVy,ParVer);        
    sqloffline.Execute(query);
    
    return 1;
 
}

Referenced by main().

WriteLumDB()

int WriteLumDB

(

)

Definition at line 56 of file DQA_TO_DB.cxx.

                {
    char Notes[]="";
    TFile f(file);
    double LumValue;
    TH1F* lum;
    f.GetObject("/zhsLUM/lum",lum);
    LumValue=lum->GetBinContent(3);
    char sql_input[350];
    sqlonline.Init("202.122.33.123","guest","guestpass");
    sqlonline.Connect();
    sqlonline.SelectDB("RunInfo");
    sprintf(sql_input,"select IntLumEndcapEE from OnlineLum where run_number='%d'",runNo);
    sqlonline.Execute(sql_input);
    std::string intLumEndcapEE;
    if(sqlonline.GetRow(0)){
        intLumEndcapEE=sqlonline.GetField(0);
    }
    else intLumEndcapEE="-0";
    sqlonline.Close();
 
    //LumValue ,intLumEndCapEE write to database;
 
    sprintf(sql_input,"delete from OfflineLum where RunNo=%d && SftVer='%s' && ParVer='%s'",runNo,SftVer,ParVer);
    sqloffline.Execute(sql_input);
 
    sprintf(sql_input,"insert into OfflineLum(SerNo,RunNo,IntLumEndcapEE,OfflineTwoGam,SftVer,ParVer,Creator,CreateTime,Notes) values('','%d','%s','%f','%s','%s','%s',now(),'%s')",runNo,intLumEndcapEE.c_str(),LumValue,SftVer,ParVer,Creator,Notes);
    sqloffline.Execute(sql_input);
    return 1;
}

Referenced by main().

WriteLumTauDB()

int WriteLumTauDB

(

)

Definition at line 243 of file DQA_TO_DB.cxx.

                   {
    ifstream rwite;
    rwite.open(LumTau_txt);
    bool file_open = 1;
    if(!rwite){
        cout<<"************************************"<<endl;
        cout<<LumTau_txt<<" not exist!"<<endl;
        cout<<"************************************"<<endl;
        file_open = 0;
    }
    if(!file_open) return -1;
 
    int m_runNo = -1;
    double runTime = -1;
    double Lum_start = -1;
    double Lum_end = -1;
    double Tau_Value = -1;
 
    while(!rwite.eof()){
        rwite>>m_runNo>>runTime>>Lum_start>>Lum_end>>Tau_Value;
        if( Tau_Value<0 )
            Tau_Value = 99999;  
        char sql_input[350];
        sprintf(sql_input,"update OfflineLum set runTime=%f, Lum_start=%f, Lum_end=%f, Tau_Value=%f where runNo=%d && SftVer='%s' && ParVer='%s' ",runTime,Lum_start,Lum_end,Tau_Value,m_runNo,SftVer,ParVer);
        sqloffline.Execute(sql_input);
 
        cout<<"************************************"<<endl;
        cout<<"LumTau FOR RUN "<<m_runNo<<" is OK!"<<endl;
        cout<<"************************************"<<endl;
 
        //              cout<<endl<<m_runNo<<"  "<<runTime<<"   "<<Lum_start<<" "<<Lum_end<<"   "<<Tau_Value<<" "<<SftVer<<"    "<<ParVer<<endl;
        return 1;
    }
}

Referenced by main().

Variable Documentation

Creator

char* Creator =getenv("USER")

Definition at line 17 of file DQA_TO_DB.cxx.

Referenced by WriteBeamParToDb(), and WriteLumDB().

file

char* file

Definition at line 15 of file DQA_TO_DB.cxx.

Referenced by RootInterface::addInput(), RootInterface::addOutput(), calib_conv2root(), UseMdcCalibData::execute(), RootInterface::f_addOutput(), TofCalibFit::fillRoot(), TofCalibration::fillRoot(), TofCalib::fillTxt(), TofCalibFit::fillTxt(), TofCalibration::fillTxt(), EvtMultiChannelParser::getDecayMode(), BesAboutHelp::GetPic(), BesClient::GetPic(), DetVerSvcPack::getRunFromFileList(), EvtXsection::ini_data_diy(), main(), mwCalloc(), mwFree(), mwMalloc(), mwMark(), mwRealloc(), mwStrdup(), mwTest(), mwTestBuffer(), mwUnmark(), EvtMultiChannelParser::parse(), RootInterface::printJobInfo(), parityC::readParityC(), readTree(), BesRunAction::SetAsciiFile(), BesRunAction::SetRootFile(), BesRunAction::SetTuningFile(), sim_conv2root(), WriteBeamParToDb(), WriteLumDB(), and writeTree().

ISNeedReFit

bool ISNeedReFit =0

Definition at line 21 of file DQA_TO_DB.cxx.

Referenced by main(), and WriteBeamParToDb().

ISNeedReFitX

bool ISNeedReFitX =0

Definition at line 22 of file DQA_TO_DB.cxx.

Referenced by ReWriteBeamParToDb(), and WriteBeamParToDb().

ISNeedReFitY

bool ISNeedReFitY =0

Definition at line 23 of file DQA_TO_DB.cxx.

Referenced by ReWriteBeamParToDb(), and WriteBeamParToDb().

ISNeedReFitZ

bool ISNeedReFitZ =0

Definition at line 24 of file DQA_TO_DB.cxx.

Referenced by ReWriteBeamParToDb(), and WriteBeamParToDb().

LumTau_txt

char* LumTau_txt

Definition at line 20 of file DQA_TO_DB.cxx.

Referenced by main(), and WriteLumTauDB().

offline_passwd

char* offline_passwd

Definition at line 14 of file DQA_TO_DB.cxx.

Referenced by main().

offline_user

char* offline_user

Definition at line 13 of file DQA_TO_DB.cxx.

Referenced by main().

ParVer

char* ParVer

Definition at line 19 of file DQA_TO_DB.cxx.

Referenced by RealDBUtil::ConnectionProvider::getLumCurvePar(), RealDBUtil::ConnectionProvider::getReadBunchInfo(), RealDBUtil::ConnectionProvider::getReadLumInfo(), main(), ReadFromDB(), ReWriteBeamParToDb(), WriteBeamParToDb(), WriteLumDB(), and WriteLumTauDB().

runNo

int runNo

Definition at line 12 of file DQA_TO_DB.cxx.

Referenced by DedxCalibRunByRun::AnalyseHists(), DedxCalibRunByRun::BookHists(), PackedRawDataCnvSvc::connectOutput(), CalibMySQLCnvSvc::createCalib(), Ppjrhopi::execute(), AbsCor::execute(), Rhopi::execute(), DDecay::execute(), DSemilepAlg::execute(), DQA_TOF::execute(), TwoGamma::execute(), ReadRawData::execute(), EvtDecay::execute(), KKMC::execute(), MixerAlg::execute(), EsTimeAlg::execute(), KalFitAlg::execute(), PrintMcInfo::execute(), QCMCFilter::execute(), SD0Tag::execute(), T0Dummy::execute(), ValidRecMdcTrackAlg::execute(), OfflineEventLoopMgr::executeEvent(), DedxCalibRunByRun::FillHists(), FillValidRecMdcTrackHisto(), MeasuredEcmsSvc::getAveEcms(), MeasuredEcmsSvc::getAveEcmsErr(), FieldDBUtil::ConnectionDB::getBeamEnergy(), RealDBUtil::ConnectionProvider::getcal(), MeasuredEcmsSvc::getEcms(), MeasuredEcmsSvc::getEcmsErr(), RealDBUtil::ConnectionProvider::getEmcGain(), MeasuredEcmsSvc::getInfo(), RealDBUtil::ConnectionProvider::getLumCurvePar(), RealizationSvc::getLuminosity(), MeasuredEcmsSvc::getPx(), MeasuredEcmsSvc::getPy(), MeasuredEcmsSvc::getPz(), RealDBUtil::ConnectionProvider::getReadBackgroundInfo(), RealDBUtil::ConnectionProvider::getReadBunchInfo(), calibUtil::Metadata::getReadDedxInfo(), calibUtil::Metadata::getReadDedxSimInfo(), calibUtil::Metadata::getReadEMCInfo(), calibUtil::Metadata::getReadEsTimeInfo(), calibUtil::Metadata::getReadEstTofInfo(), RealDBUtil::ConnectionProvider::getReadLumInfo(), calibUtil::Metadata::getReadMdcAlignInfo(), calibUtil::Metadata::getReadMdcDataConstInfo(), calibUtil::Metadata::getReadMDCInfo(), calibUtil::Metadata::getReadMUCInfo(), FieldDBUtil::ConnectionDB::getReadSC_MagnetInfo(), calibUtil::Metadata::getReadTOFInfo(), calibUtil::Metadata::getReadTofQElecInfo(), calibUtil::Metadata::getReadTofSimInfo(), RealDBUtil::ConnectionProvider::getReadTofThreshInfo(), RealDBUtil::ConnectionProvider::getReadTrgTableInfo(), BesClient::GetRecEvent(), MeasuredEcmsSvc::getRunFrom(), RealDBUtil::ConnectionProvider::getRunInfo(), MeasuredEcmsSvc::getRunTo(), MeasuredEcmsSvc::getSampleName(), TofQCorrSvc::getTofQCorrInfo(), RealDBUtil::ConnectionProvider::getTrgConfigInfo(), RealizationSvc::handle(), MagneticFieldSvc::init_params(), MeasuredEcmsSvc::isReadDBValid(), MeasuredEcmsSvc::isRunNoValid(), main(), K0kk::MTotal(), K0kpi::MTotal(), K0pi0::MTotal(), K0pipi::MTotal(), K0pipipi0::MTotal(), K3pi::MTotal(), K3pipi0::MTotal(), Kk::MTotal(), Kkpi0::MTotal(), Kkpipi::MTotal(), Kpi::MTotal(), Kpipi0::MTotal(), Kpipi0pi0::MTotal(), Pipi::MTotal(), Pipipi0::MTotal(), MdcUtilitySvc::p_cms(), CalibEventSelect::readbeamEfromDb(), MeasuredEcmsSvc::readDB(), RealizationSvc::readDB(), ReadFromDB(), MeasuredEcmsSvc::readInfo(), ReadME::ReadME(), ReadME::readMeasuredEcms(), MeasuredEcmsSvc::readMeasuredEcms(), MeasuredEcmsSvc::readRunParams(), CalibDataSvc::retrieveObject(), ReWriteBeamParToDb(), McContext::setRunNumber(), McIterator::setRunNumber(), CalibMySQLCnvSvc::updateCalib(), WriteBeamParToDb(), DedxCalibRunByRun::WriteHists(), and WriteLumDB().

server_ip

const char* server_ip = "bes3db1.ihep.ac.cn"

Definition at line 16 of file DQA_TO_DB.cxx.

Referenced by main().

SftVer

char* SftVer =getenv("BES_RELEASE")

Definition at line 18 of file DQA_TO_DB.cxx.

Referenced by calibUtil::Metadata::findBest(), calibUtil::Metadata::findSoonAfter(), RealDBUtil::ConnectionProvider::getLumCurvePar(), RealDBUtil::ConnectionProvider::getReadBunchInfo(), calibUtil::Metadata::getReadDedxInfo(), calibUtil::Metadata::getReadDedxSimInfo(), calibUtil::Metadata::getReadEMCInfo(), calibUtil::Metadata::getReadEsTimeInfo(), calibUtil::Metadata::getReadEstTofInfo(), RealDBUtil::ConnectionProvider::getReadLumInfo(), calibUtil::Metadata::getReadMdcAlignInfo(), calibUtil::Metadata::getReadMdcDataConstInfo(), calibUtil::Metadata::getReadMDCInfo(), calibUtil::Metadata::getReadMUCInfo(), calibUtil::Metadata::getReadTOFInfo(), calibUtil::Metadata::getReadTofQElecInfo(), calibUtil::Metadata::getReadTofSimInfo(), CalibMySQLCnvSvc::getSftParVer(), ReadFromDB(), ReWriteBeamParToDb(), WriteBeamParToDb(), WriteLumDB(), and WriteLumTauDB().

sqloffline

db_mysql sqloffline

Definition at line 11 of file DQA_TO_DB.cxx.

Referenced by main(), ReadFromDB(), ReWriteBeamParToDb(), WriteBeamParToDb(), WriteLumDB(), and WriteLumTauDB().

sqlonline

db_mysql sqlonline

Definition at line 10 of file DQA_TO_DB.cxx.

Referenced by WriteLumDB().