| 374 |
} |
} |
| 375 |
|
|
| 376 |
/** |
/** |
| 377 |
* |
* This method delete the run from the "FromTable" table and store it in the GL_RUN_TRASH table |
| 378 |
* |
* If IDRUN is 0 "this->ID" run is used. |
| 379 |
* |
* |
| 380 |
**/ |
**/ |
| 381 |
Int_t GL_RUN::DeleteRun(TSQLServer *dbc,UInt_t IDRUN,TString FromTable){ |
Int_t GL_RUN::DeleteRun(TSQLServer *dbc,UInt_t IDRUN,TString FromTable){ |
| 429 |
// |
// |
| 430 |
dbc->Query(myquery.str().c_str()); |
dbc->Query(myquery.str().c_str()); |
| 431 |
// |
// |
| 432 |
|
// retrieve this ID_TRASH |
| 433 |
|
// |
| 434 |
|
myquery.str(""); |
| 435 |
|
myquery << " SELECT ID_TRASH,ID_ROOT_L0,ID_ROOT_L2 FROM GL_RUN_TRASH ORDER BY ID_TRASH DESC LIMIT 1"; |
| 436 |
|
pResult = dbc->Query(myquery.str().c_str()); |
| 437 |
|
// |
| 438 |
|
UInt_t idtrash = 0; |
| 439 |
|
UInt_t idl0 = 0; |
| 440 |
|
UInt_t idl2 = 0; |
| 441 |
|
// |
| 442 |
|
Row = pResult->Next(); |
| 443 |
|
if( Row != NULL ){ |
| 444 |
|
idtrash = (UInt_t)atoll(Row->GetField(0)); |
| 445 |
|
idl0 = (UInt_t)atoll(Row->GetField(1)); |
| 446 |
|
idl2 = (UInt_t)atoll(Row->GetField(2)); |
| 447 |
|
}; |
| 448 |
|
// |
| 449 |
TString fileL0 = ""; |
TString fileL0 = ""; |
| 450 |
TString fileL2 = ""; |
TString fileL2 = ""; |
| 451 |
myquery.str(""); |
myquery.str(""); |
| 452 |
myquery << " SELECT NAME FROM GL_ROOT WHERE ID="; |
myquery << " SELECT NAME FROM GL_ROOT WHERE ID="; |
| 453 |
myquery << (UInt_t)ID_ROOT_L0 << ";"; |
myquery << idl0 << ";"; |
| 454 |
// |
// |
| 455 |
// printf("2myquery is %s \n",myquery.str().c_str()); |
// printf("2myquery is %s \n",myquery.str().c_str()); |
| 456 |
// |
// |
| 465 |
// |
// |
| 466 |
myquery.str(""); |
myquery.str(""); |
| 467 |
myquery << " SELECT NAME FROM GL_ROOT WHERE ID="; |
myquery << " SELECT NAME FROM GL_ROOT WHERE ID="; |
| 468 |
myquery << (UInt_t)ID_ROOT_L2 << ";"; |
myquery << idl2 << ";"; |
| 469 |
// |
// |
| 470 |
// printf("3myquery is %s \n",myquery.str().c_str()); |
// printf("3myquery is %s \n",myquery.str().c_str()); |
| 471 |
// |
// |
| 480 |
// |
// |
| 481 |
myquery.str(""); |
myquery.str(""); |
| 482 |
myquery << " UPDATE GL_RUN_TRASH SET FILENAMEL0='"; |
myquery << " UPDATE GL_RUN_TRASH SET FILENAMEL0='"; |
| 483 |
myquery << fileL0.Data() << "' where ID="; |
myquery << fileL0.Data() << "' where ID_TRASH="; |
| 484 |
myquery << IDRUN << ";"; |
myquery << idtrash << ";"; |
| 485 |
// |
// |
| 486 |
// printf("4myquery is %s \n",myquery.str().c_str()); |
// printf("4myquery is %s \n",myquery.str().c_str()); |
| 487 |
// |
// |
| 489 |
// |
// |
| 490 |
myquery.str(""); |
myquery.str(""); |
| 491 |
myquery << " UPDATE GL_RUN_TRASH SET FILENAMEL2='"; |
myquery << " UPDATE GL_RUN_TRASH SET FILENAMEL2='"; |
| 492 |
myquery << fileL2.Data() << "' where ID="; |
myquery << fileL2.Data() << "' where ID_TRASH="; |
| 493 |
myquery << IDRUN << ";"; |
myquery << idtrash << ";"; |
| 494 |
// |
// |
| 495 |
// printf("4myquery is %s \n",myquery.str().c_str()); |
// printf("4myquery is %s \n",myquery.str().c_str()); |
| 496 |
// |
// |
| 498 |
// |
// |
| 499 |
myquery.str(""); |
myquery.str(""); |
| 500 |
myquery << " UPDATE GL_RUN_TRASH SET BELONGED_TO='"; |
myquery << " UPDATE GL_RUN_TRASH SET BELONGED_TO='"; |
| 501 |
myquery << FromTable.Data() << "' where ID="; |
myquery << FromTable.Data() << "' where ID_TRASH="; |
| 502 |
myquery << IDRUN << ";"; |
myquery << idtrash << ";"; |
| 503 |
// |
// |
| 504 |
// printf("4myquery is %s \n",myquery.str().c_str()); |
// printf("4myquery is %s \n",myquery.str().c_str()); |
| 505 |
// |
// |
| 522 |
|
|
| 523 |
|
|
| 524 |
/** |
/** |
| 525 |
* |
* This method restore a run from the GL_RUN_TRASH table. |
| 526 |
* |
* If ID is 0 "this->ID" is used; if "ToTable" is empty BELONG_TO field of GL_RUN_TRASH is used. |
| 527 |
* |
* |
| 528 |
**/ |
**/ |
| 529 |
Int_t GL_RUN::RestoreRun(TSQLServer *dbc,UInt_t ID,TString FromTable){ |
Int_t GL_RUN::RestoreRun(TSQLServer *dbc,UInt_t IDRUN,TString ToTable){ |
| 530 |
// insert into GL_RUN_FRAGMENTS select * FROM GL_RUN where ID=11; |
// insert into GL_RUN_FRAGMENTS select * FROM GL_RUN where ID=11; |
| 531 |
//insert into GL_RUN_TRASH VALUES (ID , ID_RUN_FRAG , ID_ROOT_L0 , ID_ROOT_L2 , RUNHEADER_TIME , RUNTRAILER_TIME , RUNHEADER_OBT , RUNTRAILER_OBT , RUNHEADER_PKT , RUNTRAILER_PKT , BOOT_NUMBER , EV_FROM , EV_TO , NEVENTS , PKT_COUNTER , PKT_READY_COUNTER , COMPILATIONTIMESTAMP , FAV_WRK_SCHEDULE , EFF_WRK_SCHEDULE , PRH_VAR_TRG_MODE_A , PRH_VAR_TRG_MODE_B , ACQ_BUILD_INFO , ACQ_VAR_INFO , RM_ACQ_AFTER_CALIB , RM_ACQ_SETTING_MODE, TRK_CALIB_USED,CAL_DSP_MASK, LAST_TIMESYNC, OBT_TIMESYNC, VALIDATION, INSERT_TIME) select * FROM GL_RUN where ID=11; |
//insert into GL_RUN_TRASH VALUES (ID , ID_RUN_FRAG , ID_ROOT_L0 , ID_ROOT_L2 , RUNHEADER_TIME , RUNTRAILER_TIME , RUNHEADER_OBT , RUNTRAILER_OBT , RUNHEADER_PKT , RUNTRAILER_PKT , BOOT_NUMBER , EV_FROM , EV_TO , NEVENTS , PKT_COUNTER , PKT_READY_COUNTER , COMPILATIONTIMESTAMP , FAV_WRK_SCHEDULE , EFF_WRK_SCHEDULE , PRH_VAR_TRG_MODE_A , PRH_VAR_TRG_MODE_B , ACQ_BUILD_INFO , ACQ_VAR_INFO , RM_ACQ_AFTER_CALIB , RM_ACQ_SETTING_MODE, TRK_CALIB_USED,CAL_DSP_MASK, LAST_TIMESYNC, OBT_TIMESYNC, VALIDATION, INSERT_TIME) select * FROM GL_RUN where ID=11; |
| 532 |
|
// MySQL variables |
| 533 |
|
TSQLResult *pResult; |
| 534 |
|
TSQLRow *Row; |
| 535 |
|
stringstream myquery; |
| 536 |
|
// |
| 537 |
|
if ( !IDRUN ) IDRUN = ID; |
| 538 |
|
if ( !IDRUN ) return 1; |
| 539 |
|
// |
| 540 |
|
if ( !strcmp(ToTable.Data(),"") ){ |
| 541 |
|
// |
| 542 |
|
myquery.str(""); |
| 543 |
|
myquery << " SELECT BELONGED_TO FROM GL_RUN_TRASH WHERE ID="; |
| 544 |
|
myquery << (UInt_t)IDRUN << ";"; |
| 545 |
|
// |
| 546 |
|
printf(" qui? myquery is %s \n",myquery.str().c_str()); |
| 547 |
|
// |
| 548 |
|
pResult = dbc->Query(myquery.str().c_str()); |
| 549 |
|
// |
| 550 |
|
Row = pResult->Next(); |
| 551 |
|
if( Row != NULL ){ |
| 552 |
|
ToTable = (TString)Row->GetField(0); |
| 553 |
|
} else { |
| 554 |
|
return 1; |
| 555 |
|
}; |
| 556 |
|
}; |
| 557 |
|
// ---------------- |
| 558 |
|
myquery.str(""); |
| 559 |
|
myquery << " INSERT INTO "; |
| 560 |
|
myquery << ToTable.Data(); |
| 561 |
|
myquery << " ("; |
| 562 |
|
myquery << "ID"; |
| 563 |
|
myquery << ",ID_RUN_FRAG"; |
| 564 |
|
myquery << ",ID_ROOT_L0"; |
| 565 |
|
myquery << ",ID_ROOT_L2"; |
| 566 |
|
myquery << ",RUNHEADER_TIME"; |
| 567 |
|
myquery << ",RUNTRAILER_TIME"; |
| 568 |
|
myquery << ",RUNHEADER_OBT"; |
| 569 |
|
myquery << ",RUNTRAILER_OBT"; |
| 570 |
|
myquery << ",RUNHEADER_PKT"; |
| 571 |
|
myquery << ",RUNTRAILER_PKT"; |
| 572 |
|
myquery << ",BOOT_NUMBER"; |
| 573 |
|
myquery << ",EV_FROM"; |
| 574 |
|
myquery << ",EV_TO"; |
| 575 |
|
myquery << ",NEVENTS"; |
| 576 |
|
myquery << ",PKT_COUNTER"; |
| 577 |
|
myquery << ",PKT_READY_COUNTER"; |
| 578 |
|
myquery << ",COMPILATIONTIMESTAMP"; |
| 579 |
|
myquery << ",FAV_WRK_SCHEDULE"; |
| 580 |
|
myquery << ",EFF_WRK_SCHEDULE"; |
| 581 |
|
myquery << ",PRH_VAR_TRG_MODE_A"; |
| 582 |
|
myquery << ",PRH_VAR_TRG_MODE_B"; |
| 583 |
|
myquery << ",ACQ_BUILD_INFO"; |
| 584 |
|
myquery << ",ACQ_VAR_INFO"; |
| 585 |
|
myquery << ",RM_ACQ_AFTER_CALIB"; |
| 586 |
|
myquery << ",RM_ACQ_SETTING_MODE"; |
| 587 |
|
myquery << ",TRK_CALIB_USED"; |
| 588 |
|
myquery << ",CAL_DSP_MASK"; |
| 589 |
|
myquery << ",LAST_TIMESYNC"; |
| 590 |
|
myquery << ",OBT_TIMESYNC"; |
| 591 |
|
myquery << ",VALIDATION"; |
| 592 |
|
myquery << ",INSERT_TIME"; |
| 593 |
|
myquery << ") SELECT "; |
| 594 |
|
myquery << "ID"; |
| 595 |
|
myquery << ",ID_RUN_FRAG"; |
| 596 |
|
myquery << ",ID_ROOT_L0"; |
| 597 |
|
myquery << ",ID_ROOT_L2"; |
| 598 |
|
myquery << ",RUNHEADER_TIME"; |
| 599 |
|
myquery << ",RUNTRAILER_TIME"; |
| 600 |
|
myquery << ",RUNHEADER_OBT"; |
| 601 |
|
myquery << ",RUNTRAILER_OBT"; |
| 602 |
|
myquery << ",RUNHEADER_PKT"; |
| 603 |
|
myquery << ",RUNTRAILER_PKT"; |
| 604 |
|
myquery << ",BOOT_NUMBER"; |
| 605 |
|
myquery << ",EV_FROM"; |
| 606 |
|
myquery << ",EV_TO"; |
| 607 |
|
myquery << ",NEVENTS"; |
| 608 |
|
myquery << ",PKT_COUNTER"; |
| 609 |
|
myquery << ",PKT_READY_COUNTER"; |
| 610 |
|
myquery << ",COMPILATIONTIMESTAMP"; |
| 611 |
|
myquery << ",FAV_WRK_SCHEDULE"; |
| 612 |
|
myquery << ",EFF_WRK_SCHEDULE"; |
| 613 |
|
myquery << ",PRH_VAR_TRG_MODE_A"; |
| 614 |
|
myquery << ",PRH_VAR_TRG_MODE_B"; |
| 615 |
|
myquery << ",ACQ_BUILD_INFO"; |
| 616 |
|
myquery << ",ACQ_VAR_INFO"; |
| 617 |
|
myquery << ",RM_ACQ_AFTER_CALIB"; |
| 618 |
|
myquery << ",RM_ACQ_SETTING_MODE"; |
| 619 |
|
myquery << ",TRK_CALIB_USED"; |
| 620 |
|
myquery << ",CAL_DSP_MASK"; |
| 621 |
|
myquery << ",LAST_TIMESYNC"; |
| 622 |
|
myquery << ",OBT_TIMESYNC"; |
| 623 |
|
myquery << ",VALIDATION"; |
| 624 |
|
myquery << ",INSERT_TIME"; |
| 625 |
|
myquery << " FROM GL_RUN_TRASH "; |
| 626 |
|
myquery << " WHERE BELONGED_TO='GL_RUN_FRAGMENTS' AND ID="; |
| 627 |
|
myquery << (UInt_t)IDRUN << ";"; |
| 628 |
|
// |
| 629 |
|
// printf("5myquery is %s \n",myquery.str().c_str()); |
| 630 |
|
// |
| 631 |
|
dbc->Query(myquery.str().c_str()); |
| 632 |
|
// |
| 633 |
|
// |
| 634 |
|
myquery.str(""); |
| 635 |
|
myquery << " DELETE FROM GL_RUN_TRASH where BELONGED_TO='GL_RUN_FRAGMENTS' AND ID="; |
| 636 |
|
myquery << IDRUN << ";"; |
| 637 |
|
// |
| 638 |
|
dbc->Query(myquery.str().c_str()); |
| 639 |
|
// |
| 640 |
return 0; |
return 0; |
| 641 |
}; |
}; |
| 642 |
|
|