403 |
myquery << (UInt_t)BOOT_NUMBER << "','"; |
myquery << (UInt_t)BOOT_NUMBER << "','"; |
404 |
myquery << (UInt_t)VALIDATION << "');"; |
myquery << (UInt_t)VALIDATION << "');"; |
405 |
// |
// |
406 |
//printf("myquery is %s \n",myquery.str().c_str()); |
// printf("myquery is %s \n",myquery.str().c_str()); |
407 |
// |
// |
408 |
dbc->Query(myquery.str().c_str()); |
dbc->Query(myquery.str().c_str()); |
409 |
// |
// |
573 |
if (t==27) CAL_DSP_MASK = (UInt_t)atoll(Row->GetField(t)); |
if (t==27) CAL_DSP_MASK = (UInt_t)atoll(Row->GetField(t)); |
574 |
if (t==28) BOOT_NUMBER = (UInt_t)atoll(Row->GetField(t)); |
if (t==28) BOOT_NUMBER = (UInt_t)atoll(Row->GetField(t)); |
575 |
if (t==29) VALIDATION = (UInt_t)atoll(Row->GetField(t)); |
if (t==29) VALIDATION = (UInt_t)atoll(Row->GetField(t)); |
576 |
|
|
577 |
|
|
578 |
}; |
}; |
579 |
}; |
}; |
580 |
delete pResult; |
delete pResult; |
591 |
* |
* |
592 |
*/ |
*/ |
593 |
Int_t GL_RUN::Query_GL_RUN_FRAGMENTS(TString where, TSQLServer *dbc){ |
Int_t GL_RUN::Query_GL_RUN_FRAGMENTS(TString where, TSQLServer *dbc){ |
|
// Bool_t debug = 1; |
|
594 |
// MySQL variables |
// MySQL variables |
595 |
TSQLResult *pResult; |
TSQLResult *pResult; |
596 |
TSQLRow *Row; |
TSQLRow *Row; |
598 |
int r; |
int r; |
599 |
stringstream myquery; |
stringstream myquery; |
600 |
// ---------------- |
// ---------------- |
|
// NB! unsigned long long integers: when set to a number use ULL to store the correct number |
|
601 |
myquery.str(""); |
myquery.str(""); |
602 |
myquery << " select "; |
myquery << " select "; |
|
// myquery << " * "; |
|
603 |
myquery << "ID"; |
myquery << "ID"; |
604 |
|
myquery << ",ID_RUN_FRAG"; |
605 |
myquery << ",ID_ROOT_L0"; |
myquery << ",ID_ROOT_L0"; |
606 |
|
myquery << ",ID_ROOT_L2"; |
607 |
myquery << ",RUNHEADER_TIME"; |
myquery << ",RUNHEADER_TIME"; |
608 |
myquery << ",RUNTRAILER_TIME"; |
myquery << ",RUNTRAILER_TIME"; |
609 |
myquery << ",RUNHEADER_OBT"; |
myquery << ",RUNHEADER_OBT"; |
629 |
myquery << ",TRK_CALIB_USED"; |
myquery << ",TRK_CALIB_USED"; |
630 |
myquery << ",CAL_DSP_MASK"; |
myquery << ",CAL_DSP_MASK"; |
631 |
myquery << ",BOOT_NUMBER"; |
myquery << ",BOOT_NUMBER"; |
632 |
|
myquery << ",VALIDATION"; |
633 |
myquery << " from GL_RUN_FRAGMENTS where " << where.Data() << ";"; |
myquery << " from GL_RUN_FRAGMENTS where " << where.Data() << ";"; |
634 |
// |
// |
635 |
|
// printf(" query is %s \n",myquery.str().c_str()); |
636 |
|
// |
637 |
pResult = dbc->Query(myquery.str().c_str()); |
pResult = dbc->Query(myquery.str().c_str()); |
638 |
if(!pResult->GetRowCount())return(-50); |
if(!pResult->GetRowCount())return(-50); |
639 |
for( r=0; r < 1000; r++){ |
for( r=0; r < 1000; r++){ |
640 |
Row = pResult->Next(); |
Row = pResult->Next(); |
641 |
if( Row == NULL ) break; |
if( Row == NULL ) break; |
642 |
for( t = 0; t < pResult->GetFieldCount(); t++){ |
for( t = 0; t < pResult->GetFieldCount(); t++){ |
643 |
if (t== 0) ID = (UInt_t)atoll(Row->GetField(t)); |
if (t== 0) ID = (UInt_t)atoll(Row->GetField(t)); |
644 |
if (t== 1) ID_ROOT_L0 = (UInt_t)atoll(Row->GetField(t)); |
if (t== 1) ID_RUN_FRAG = (UInt_t)atoll(Row->GetField(t)); |
645 |
if (t== 2) RUNHEADER_TIME = (UInt_t)atoll(Row->GetField(t)); |
if (t== 2) ID_ROOT_L0 = (UInt_t)atoll(Row->GetField(t)); |
646 |
if (t== 3) RUNTRAILER_TIME = (UInt_t)atoll(Row->GetField(t)); |
if (t== 3) ID_ROOT_L2 = (UInt_t)atoll(Row->GetField(t)); |
647 |
if (t== 4) RUNHEADER_OBT = (UInt_t)atoll(Row->GetField(t)); |
if (t== 4) RUNHEADER_TIME = (UInt_t)atoll(Row->GetField(t)); |
648 |
if (t== 5) RUNTRAILER_OBT = (UInt_t)atoll(Row->GetField(t)); |
if (t== 5) RUNTRAILER_TIME = (UInt_t)atoll(Row->GetField(t)); |
649 |
if (t== 6) RUNHEADER_PKT = (UInt_t)atoll(Row->GetField(t)); |
if (t== 6) RUNHEADER_OBT = (UInt_t)atoll(Row->GetField(t)); |
650 |
if (t== 7) RUNTRAILER_PKT = (UInt_t)atoll(Row->GetField(t)); |
if (t== 7) RUNTRAILER_OBT = (UInt_t)atoll(Row->GetField(t)); |
651 |
if (t== 8) EV_FROM = (UInt_t)atoll(Row->GetField(t)); |
if (t== 8) RUNHEADER_PKT = (UInt_t)atoll(Row->GetField(t)); |
652 |
if (t== 9) EV_TO = (UInt_t)atoll(Row->GetField(t)); |
if (t== 9) RUNTRAILER_PKT = (UInt_t)atoll(Row->GetField(t)); |
653 |
if (t==10) NEVENTS = (UInt_t)atoll(Row->GetField(t)); |
if (t==10) EV_FROM = (UInt_t)atoll(Row->GetField(t)); |
654 |
if (t==11) LAST_TIMESYNC = (UInt_t)atoll(Row->GetField(t)); |
if (t==11) EV_TO = (UInt_t)atoll(Row->GetField(t)); |
655 |
if (t==12) OBT_TIMESYNC = (UInt_t)atoll(Row->GetField(t)); |
if (t==12) NEVENTS = (UInt_t)atoll(Row->GetField(t)); |
656 |
if (t==13) COMPILATIONTIMESTAMP = (UInt_t)atoll(Row->GetField(t)); |
if (t==13) LAST_TIMESYNC = (UInt_t)atoll(Row->GetField(t)); |
657 |
if (t==14) FAV_WRK_SCHEDULE = (UInt_t)atoll(Row->GetField(t)); |
if (t==14) OBT_TIMESYNC = (UInt_t)atoll(Row->GetField(t)); |
658 |
if (t==15) EFF_WRK_SCHEDULE = (UInt_t)atoll(Row->GetField(t)); |
if (t==15) COMPILATIONTIMESTAMP = (UInt_t)atoll(Row->GetField(t)); |
659 |
if (t==16) PRH_VAR_TRG_MODE_A = (UInt_t)atoll(Row->GetField(t)); |
if (t==16) FAV_WRK_SCHEDULE = (UInt_t)atoll(Row->GetField(t)); |
660 |
if (t==17) PRH_VAR_TRG_MODE_B = (UInt_t)atoll(Row->GetField(t)); |
if (t==17) EFF_WRK_SCHEDULE = (UInt_t)atoll(Row->GetField(t)); |
661 |
if (t==18) ACQ_BUILD_INFO = (UInt_t)atoll(Row->GetField(t)); |
if (t==18) PRH_VAR_TRG_MODE_A= (UInt_t)atoll(Row->GetField(t)); |
662 |
if (t==19) ACQ_VAR_INFO = (UInt_t)atoll(Row->GetField(t)); |
if (t==19) PRH_VAR_TRG_MODE_B= (UInt_t)atoll(Row->GetField(t)); |
663 |
if (t==20) RM_ACQ_AFTER_CALIB = (UInt_t)atoll(Row->GetField(t)); |
if (t==20) ACQ_BUILD_INFO = (UInt_t)atoll(Row->GetField(t)); |
664 |
if (t==21) RM_ACQ_SETTING_MODE = (UInt_t)atoll(Row->GetField(t)); |
if (t==21) ACQ_VAR_INFO = (UInt_t)atoll(Row->GetField(t)); |
665 |
if (t==22) PKT_COUNTER = (UInt_t)atoll(Row->GetField(t)); |
if (t==22) RM_ACQ_AFTER_CALIB= (UInt_t)atoll(Row->GetField(t)); |
666 |
if (t==23) PKT_READY_COUNTER = (UInt_t)atoll(Row->GetField(t)); |
if (t==23) RM_ACQ_SETTING_MODE = (UInt_t)atoll(Row->GetField(t)); |
667 |
if (t==24) TRK_CALIB_USED = (UInt_t)atoll(Row->GetField(t)); |
if (t==24) PKT_COUNTER = (UInt_t)atoll(Row->GetField(t)); |
668 |
if (t==25) CAL_DSP_MASK = (UInt_t)atoll(Row->GetField(t)); |
if (t==25) PKT_READY_COUNTER = (UInt_t)atoll(Row->GetField(t)); |
669 |
if (t==26) BOOT_NUMBER = (UInt_t)atoll(Row->GetField(t)); |
if (t==26) TRK_CALIB_USED = (UInt_t)atoll(Row->GetField(t)); |
670 |
}; |
if (t==27) CAL_DSP_MASK = (UInt_t)atoll(Row->GetField(t)); |
671 |
|
if (t==28) BOOT_NUMBER = (UInt_t)atoll(Row->GetField(t)); |
672 |
|
if (t==29) VALIDATION = (UInt_t)atoll(Row->GetField(t)); |
673 |
|
}; |
674 |
}; |
}; |
675 |
delete pResult; |
// delete pResult; |
676 |
|
return(0); |
|
return 0; |
|
|
|
|
677 |
};// **************************************************** |
};// **************************************************** |
678 |
|
|
679 |
/** |
/** |
680 |
* Function to query the GL_ROOT table of the DB. |
* Function to query the GL_ROOT table of the DB. |
681 |
* |
* |
740 |
Row = pResult->Next(); |
Row = pResult->Next(); |
741 |
if( Row == NULL ) break; |
if( Row == NULL ) break; |
742 |
for( t = 0; t < pResult->GetFieldCount(); t++){ |
for( t = 0; t < pResult->GetFieldCount(); t++){ |
743 |
|
stringstream row; |
744 |
|
row.str(""); |
745 |
|
row << "0" << Row->GetField(t); // add leading 0 since we have two fields that could be "null" and we want to avoid crashes due to atoll |
746 |
if (t==0) ID = (UInt_t)atoll(Row->GetField(t)); |
if (t==0) ID = (UInt_t)atoll(Row->GetField(t)); |
747 |
if (t==1) ID_ROOT_L0 = (UInt_t)atoll(Row->GetField(t)); |
if (t==1) ID_ROOT_L0 = (UInt_t)atoll(Row->GetField(t)); |
748 |
if (t==2) EV_ROOT_CALIBTRK1 = (UInt_t)atoll(Row->GetField(t)); |
if (t==2) EV_ROOT_CALIBTRK1 = (UInt_t)atoll(row.str().c_str()); |
749 |
if (t==3) EV_ROOT_CALIBTRK2 = (UInt_t)atoll(Row->GetField(t)); |
if (t==3) EV_ROOT_CALIBTRK2 = (UInt_t)atoll(row.str().c_str()); |
750 |
if (t==4) FROM_TIME = (UInt_t)atoll(Row->GetField(t)); |
if (t==4) FROM_TIME = (UInt_t)atoll(Row->GetField(t)); |
751 |
if (t==5) TO_TIME = (UInt_t)atoll(Row->GetField(t)); |
if (t==5) TO_TIME = (UInt_t)atoll(Row->GetField(t)); |
752 |
// |
// |
1001 |
toffset = (UInt_t)atoll(Row->GetField(1)) - (UInt_t)(this->DBobt((UInt_t)atoll(Row->GetField(0)))/1000) + t0; |
toffset = (UInt_t)atoll(Row->GetField(1)) - (UInt_t)(this->DBobt((UInt_t)atoll(Row->GetField(0)))/1000) + t0; |
1002 |
}; |
}; |
1003 |
}; |
}; |
1004 |
|
// |
1005 |
|
file->Close(); |
1006 |
delete pResult; |
delete pResult; |
1007 |
}; |
}; |
1008 |
|
|