UniRun.cxx

Go to the documentation of this file.

// ----------------------------------------------------------------------
//                    UniRun cxx file
//                      Generated 05-11-2015
// ----------------------------------------------------------------------
 
#include "UniRun.h"
 
#include "TSQLServer.h"
#include "TSQLStatement.h"
#include "TSystem.h"
#include "UniRawFile.h"
 
#include <iostream>
using namespace std;
 
/* GENERATED CLASS MEMBERS (SHOULD NOT BE CHANGED MANUALLY) */
// -----   Constructor with database connection   -----------------------
UniRun::UniRun(UniConnection* db_connect,
               int period_number,
               int run_number,
               int run_type,
               TDatime start_datetime,
               TDatime* end_datetime,
               TString beam_particle,
               TString target_particle,
               double* energy,
               double* field_voltage,
               int* event_count,
               int run_quality)
{
    connectionDB = db_connect;
 
    i_period_number = period_number;
    i_run_number = run_number;
    i_run_type = run_type;
    ts_start_datetime = start_datetime;
    ts_end_datetime = end_datetime;
    str_beam_particle = beam_particle;
    str_target_particle = target_particle;
    d_energy = energy;
    d_field_voltage = field_voltage;
    i_event_count = event_count;
    i_run_quality = run_quality;
}
 
// -----   Destructor   -------------------------------------------------
UniRun::~UniRun()
{
    if (connectionDB)
        delete connectionDB;
    if (ts_end_datetime)
        delete ts_end_datetime;
    if (d_energy)
        delete d_energy;
    if (d_field_voltage)
        delete d_field_voltage;
    if (i_event_count)
        delete i_event_count;
}
 
// -----   Creating new run in the database  ---------------------------
UniRun* UniRun::CreateRun(int period_number,
                          int run_number,
                          int run_type,
                          TDatime start_datetime,
                          TDatime* end_datetime,
                          TString beam_particle,
                          TString target_particle,
                          double* energy,
                          double* field_voltage,
                          int* event_count,
                          int run_quality)
{
    UniConnection* connDb = UniConnection::Open();
    if (connDb == nullptr)
        return nullptr;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = TString::Format("insert into run_(period_number, run_number, run_type, start_datetime, end_datetime, "
                                  "beam_particle, target_particle, energy, field_voltage, event_count, run_quality) "
                                  "values ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11)");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetInt(0, period_number);
    stmt->SetInt(1, run_number);
    stmt->SetInt(2, run_type);
    stmt->SetDatime(3, start_datetime);
    if (end_datetime == nullptr)
        stmt->SetNull(4);
    else
        stmt->SetDatime(4, *end_datetime);
    stmt->SetString(5, beam_particle);
    stmt->SetString(6, target_particle);
    if (energy == nullptr)
        stmt->SetNull(7);
    else
        stmt->SetDouble(7, *energy);
    if (field_voltage == nullptr)
        stmt->SetNull(8);
    else
        stmt->SetDouble(8, *field_voltage);
    if (event_count == nullptr)
        stmt->SetNull(9);
    else
        stmt->SetInt(9, *event_count);
    stmt->SetInt(10, run_quality);
 
    // inserting new run to the Database
    if (!stmt->Process()) {
        cout << "ERROR: inserting new run to the Database has been failed" << endl;
        delete stmt;
        delete connDb;
        return nullptr;
    }
 
    delete stmt;
 
    int tmp_period_number;
    tmp_period_number = period_number;
    int tmp_run_number;
    tmp_run_number = run_number;
    int tmp_run_type;
    tmp_run_type = run_type;
    TDatime tmp_start_datetime;
    tmp_start_datetime = start_datetime;
    TDatime* tmp_end_datetime;
    if (end_datetime == nullptr)
        tmp_end_datetime = nullptr;
    else
        tmp_end_datetime = new TDatime(*end_datetime);
    TString tmp_beam_particle;
    tmp_beam_particle = beam_particle;
    TString tmp_target_particle;
    tmp_target_particle = target_particle;
    double* tmp_energy;
    if (energy == nullptr)
        tmp_energy = nullptr;
    else
        tmp_energy = new double(*energy);
    double* tmp_field_voltage;
    if (field_voltage == nullptr)
        tmp_field_voltage = nullptr;
    else
        tmp_field_voltage = new double(*field_voltage);
    int* tmp_event_count;
    if (event_count == nullptr)
        tmp_event_count = nullptr;
    else
        tmp_event_count = new int(*event_count);
    int tmp_run_quality;
    tmp_run_quality = run_quality;
 
    return new UniRun(connDb, tmp_period_number, tmp_run_number, tmp_run_type, tmp_start_datetime, tmp_end_datetime,
                      tmp_beam_particle, tmp_target_particle, tmp_energy, tmp_field_voltage, tmp_event_count,
                      tmp_run_quality);
}
 
// -----  Get run from the database  ---------------------------
UniRun* UniRun::GetRun(int period_number, int run_number)
{
    UniConnection* connDb = UniConnection::Open();
    if (connDb == nullptr)
        return nullptr;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql =
        TString::Format("select period_number, run_number, run_type, start_datetime, end_datetime, beam_particle, "
                        "target_particle, energy, field_voltage, event_count, run_quality "
                        "from run_ "
                        "where period_number = %d and run_number = %d",
                        period_number, run_number);
    TSQLStatement* stmt = db_server->Statement(sql);
 
    // get run from the database
    if (!stmt->Process()) {
        cout << "ERROR: getting run from the database has been failed" << endl;
 
        delete stmt;
        delete connDb;
        return nullptr;
    }
 
    // store result of statement in buffer
    stmt->StoreResult();
 
    // extract row
    if (!stmt->NextResultRow()) {
        cout << "ERROR: run was not found in the database" << endl;
 
        delete stmt;
        delete connDb;
        return nullptr;
    }
 
    int tmp_period_number;
    tmp_period_number = stmt->GetInt(0);
    int tmp_run_number;
    tmp_run_number = stmt->GetInt(1);
    int tmp_run_type;
    tmp_run_type = stmt->GetInt(2);
    TDatime tmp_start_datetime;
    tmp_start_datetime = stmt->GetDatime(3);
    TDatime* tmp_end_datetime;
    if (stmt->IsNull(4))
        tmp_end_datetime = nullptr;
    else
        tmp_end_datetime = new TDatime(stmt->GetDatime(4));
    TString tmp_beam_particle;
    tmp_beam_particle = stmt->GetString(5);
    TString tmp_target_particle;
    tmp_target_particle = stmt->GetString(6);
    double* tmp_energy;
    if (stmt->IsNull(7))
        tmp_energy = nullptr;
    else
        tmp_energy = new double(stmt->GetDouble(7));
    double* tmp_field_voltage;
    if (stmt->IsNull(8))
        tmp_field_voltage = nullptr;
    else
        tmp_field_voltage = new double(stmt->GetDouble(8));
    int* tmp_event_count;
    if (stmt->IsNull(9))
        tmp_event_count = nullptr;
    else
        tmp_event_count = new int(stmt->GetInt(9));
    int tmp_run_quality;
    tmp_run_quality = stmt->GetInt(10);
 
    delete stmt;
 
    return new UniRun(connDb, tmp_period_number, tmp_run_number, tmp_run_type, tmp_start_datetime, tmp_end_datetime,
                      tmp_beam_particle, tmp_target_particle, tmp_energy, tmp_field_voltage, tmp_event_count,
                      tmp_run_quality);
}
 
// -----  Check run exists in the database  ---------------------------
int UniRun::CheckRunExists(int period_number, int run_number)
{
    UniConnection* connDb = UniConnection::Open();
    if (connDb == nullptr)
        return -1;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = TString::Format("select 1 "
                                  "from run_ "
                                  "where period_number = %d and run_number = %d",
                                  period_number, run_number);
    TSQLStatement* stmt = db_server->Statement(sql);
 
    // get run from the database
    if (!stmt->Process()) {
        cout << "ERROR: getting run from the database has been failed" << endl;
 
        delete stmt;
        delete connDb;
        return -2;
    }
 
    // store result of statement in buffer
    stmt->StoreResult();
 
    // extract row
    if (!stmt->NextResultRow()) {
        delete stmt;
        delete connDb;
        return 0;
    }
 
    delete stmt;
    delete connDb;
 
    return 1;
}
 
// -----  Delete run from the database  ---------------------------
int UniRun::DeleteRun(int period_number, int run_number)
{
    UniConnection* connDb = UniConnection::Open();
    if (connDb == nullptr)
        return -1;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = TString::Format("delete from run_ "
                                  "where period_number = $1 and run_number = $2");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetInt(0, period_number);
    stmt->SetInt(1, run_number);
 
    // delete run from the dataBase
    if (!stmt->Process()) {
        cout << "ERROR: deleting run from the dataBase has been failed" << endl;
 
        delete stmt;
        delete connDb;
        return -2;
    }
 
    delete stmt;
    delete connDb;
    return 0;
}
 
// -----  Print all 'runs'  ---------------------------------
int UniRun::PrintAll()
{
    UniConnection* connDb = UniConnection::Open();
    if (connDb == nullptr)
        return -1;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql =
        TString::Format("select period_number, run_number, run_type, start_datetime, end_datetime, beam_particle, "
                        "target_particle, energy, field_voltage, event_count, run_quality "
                        "from run_");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    // get all 'runs' from the database
    if (!stmt->Process()) {
        cout << "ERROR: getting all 'runs' from the dataBase has been failed" << endl;
 
        delete stmt;
        delete connDb;
        return -2;
    }
 
    // store result of statement in buffer
    stmt->StoreResult();
 
    // print rows
    cout << "Table 'run_':" << endl;
    while (stmt->NextResultRow()) {
        cout << "period_number: ";
        cout << (stmt->GetInt(0));
        cout << ", run_number: ";
        cout << (stmt->GetInt(1));
        cout << ", run_type: ";
        cout << (stmt->GetInt(2));
        cout << ", start_datetime: ";
        cout << (stmt->GetDatime(3)).AsSQLString();
        cout << ", end_datetime: ";
        if (stmt->IsNull(4))
            cout << "nullptr";
        else
            cout << stmt->GetDatime(4).AsSQLString();
        cout << ", beam_particle: ";
        cout << (stmt->GetString(5));
        cout << ", target_particle: ";
        cout << (stmt->GetString(6));
        cout << ", energy: ";
        if (stmt->IsNull(7))
            cout << "nullptr";
        else
            cout << stmt->GetDouble(7);
        cout << ", field_voltage: ";
        if (stmt->IsNull(8))
            cout << "nullptr";
        else
            cout << stmt->GetDouble(8);
        cout << ", event_count: ";
        if (stmt->IsNull(9))
            cout << "nullptr";
        else
            cout << stmt->GetInt(9);
        cout << ", run_quality: ";
        cout << (stmt->GetInt(10));
        cout << "." << endl;
    }
 
    delete stmt;
    delete connDb;
 
    return 0;
}
 
// Setters functions
int UniRun::SetPeriodNumber(int period_number)
{
    if (!connectionDB) {
        cout << "CRITICAL ERROR: Connection object is null" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connectionDB->GetSQLServer();
 
    TString sql = TString::Format("update run_ "
                                  "set period_number = $1 "
                                  "where period_number = $2 and run_number = $3");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetInt(0, period_number);
    stmt->SetInt(1, i_period_number);
    stmt->SetInt(2, i_run_number);
 
    // write new value to the database
    if (!stmt->Process()) {
        cout << "ERROR: updating information about run has been failed" << endl;
 
        delete stmt;
        return -2;
    }
 
    i_period_number = period_number;
 
    delete stmt;
    return 0;
}
 
int UniRun::SetRunNumber(int run_number)
{
    if (!connectionDB) {
        cout << "CRITICAL ERROR: Connection object is null" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connectionDB->GetSQLServer();
 
    TString sql = TString::Format("update run_ "
                                  "set run_number = $1 "
                                  "where period_number = $2 and run_number = $3");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetInt(0, run_number);
    stmt->SetInt(1, i_period_number);
    stmt->SetInt(2, i_run_number);
 
    // write new value to the database
    if (!stmt->Process()) {
        cout << "ERROR: updating information about run has been failed" << endl;
 
        delete stmt;
        return -2;
    }
 
    i_run_number = run_number;
 
    delete stmt;
    return 0;
}
 
int UniRun::SetRunType(int run_type)
{
    if (!connectionDB) {
        cout << "CRITICAL ERROR: Connection object is null" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connectionDB->GetSQLServer();
 
    TString sql = TString::Format("update run_ "
                                  "set run_type = $1 "
                                  "where period_number = $2 and run_number = $3");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetInt(0, run_type);
    stmt->SetInt(1, i_period_number);
    stmt->SetInt(2, i_run_number);
 
    // write new value to the database
    if (!stmt->Process()) {
        cout << "ERROR: updating information about run has been failed" << endl;
 
        delete stmt;
        return -2;
    }
 
    i_run_type = run_type;
 
    delete stmt;
    return 0;
}
 
int UniRun::SetStartDatetime(TDatime start_datetime)
{
    if (!connectionDB) {
        cout << "CRITICAL ERROR: Connection object is null" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connectionDB->GetSQLServer();
 
    TString sql = TString::Format("update run_ "
                                  "set start_datetime = $1 "
                                  "where period_number = $2 and run_number = $3");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetDatime(0, start_datetime);
    stmt->SetInt(1, i_period_number);
    stmt->SetInt(2, i_run_number);
 
    // write new value to the database
    if (!stmt->Process()) {
        cout << "ERROR: updating information about run has been failed" << endl;
 
        delete stmt;
        return -2;
    }
 
    ts_start_datetime = start_datetime;
 
    delete stmt;
    return 0;
}
 
int UniRun::SetEndDatetime(TDatime* end_datetime)
{
    if (!connectionDB) {
        cout << "CRITICAL ERROR: Connection object is null" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connectionDB->GetSQLServer();
 
    TString sql = TString::Format("update run_ "
                                  "set end_datetime = $1 "
                                  "where period_number = $2 and run_number = $3");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    if (end_datetime == nullptr)
        stmt->SetNull(0);
    else
        stmt->SetDatime(0, *end_datetime);
    stmt->SetInt(1, i_period_number);
    stmt->SetInt(2, i_run_number);
 
    // write new value to the database
    if (!stmt->Process()) {
        cout << "ERROR: updating information about run has been failed" << endl;
 
        delete stmt;
        return -2;
    }
 
    if (ts_end_datetime)
        delete ts_end_datetime;
    if (end_datetime == nullptr)
        ts_end_datetime = nullptr;
    else
        ts_end_datetime = new TDatime(*end_datetime);
 
    delete stmt;
    return 0;
}
 
int UniRun::SetBeamParticle(TString beam_particle)
{
    if (!connectionDB) {
        cout << "CRITICAL ERROR: Connection object is null" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connectionDB->GetSQLServer();
 
    TString sql = TString::Format("update run_ "
                                  "set beam_particle = $1 "
                                  "where period_number = $2 and run_number = $3");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetString(0, beam_particle);
    stmt->SetInt(1, i_period_number);
    stmt->SetInt(2, i_run_number);
 
    // write new value to the database
    if (!stmt->Process()) {
        cout << "ERROR: updating information about run has been failed" << endl;
 
        delete stmt;
        return -2;
    }
 
    str_beam_particle = beam_particle;
 
    delete stmt;
    return 0;
}
 
int UniRun::SetTargetParticle(TString target_particle)
{
    if (!connectionDB) {
        cout << "CRITICAL ERROR: Connection object is null" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connectionDB->GetSQLServer();
 
    TString sql = TString::Format("update run_ "
                                  "set target_particle = $1 "
                                  "where period_number = $2 and run_number = $3");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetString(0, target_particle);
    stmt->SetInt(1, i_period_number);
    stmt->SetInt(2, i_run_number);
 
    // write new value to the database
    if (!stmt->Process()) {
        cout << "ERROR: updating information about run has been failed" << endl;
 
        delete stmt;
        return -2;
    }
 
    str_target_particle = target_particle;
 
    delete stmt;
    return 0;
}
 
int UniRun::SetEnergy(double* energy)
{
    if (!connectionDB) {
        cout << "CRITICAL ERROR: Connection object is null" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connectionDB->GetSQLServer();
 
    TString sql = TString::Format("update run_ "
                                  "set energy = $1 "
                                  "where period_number = $2 and run_number = $3");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    if (energy == nullptr)
        stmt->SetNull(0);
    else
        stmt->SetDouble(0, *energy);
    stmt->SetInt(1, i_period_number);
    stmt->SetInt(2, i_run_number);
 
    // write new value to the database
    if (!stmt->Process()) {
        cout << "ERROR: updating information about run has been failed" << endl;
 
        delete stmt;
        return -2;
    }
 
    if (d_energy)
        delete d_energy;
    if (energy == nullptr)
        d_energy = nullptr;
    else
        d_energy = new double(*energy);
 
    delete stmt;
    return 0;
}
 
int UniRun::SetFieldVoltage(double* field_voltage)
{
    if (!connectionDB) {
        cout << "CRITICAL ERROR: Connection object is null" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connectionDB->GetSQLServer();
 
    TString sql = TString::Format("update run_ "
                                  "set field_voltage = $1 "
                                  "where period_number = $2 and run_number = $3");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    if (field_voltage == nullptr)
        stmt->SetNull(0);
    else
        stmt->SetDouble(0, *field_voltage);
    stmt->SetInt(1, i_period_number);
    stmt->SetInt(2, i_run_number);
 
    // write new value to the database
    if (!stmt->Process()) {
        cout << "ERROR: updating information about run has been failed" << endl;
 
        delete stmt;
        return -2;
    }
 
    if (d_field_voltage)
        delete d_field_voltage;
    if (field_voltage == nullptr)
        d_field_voltage = nullptr;
    else
        d_field_voltage = new double(*field_voltage);
 
    delete stmt;
    return 0;
}
 
int UniRun::SetEventCount(int* event_count)
{
    if (!connectionDB) {
        cout << "CRITICAL ERROR: Connection object is null" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connectionDB->GetSQLServer();
 
    TString sql = TString::Format("update run_ "
                                  "set event_count = $1 "
                                  "where period_number = $2 and run_number = $3");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    if (event_count == nullptr)
        stmt->SetNull(0);
    else
        stmt->SetInt(0, *event_count);
    stmt->SetInt(1, i_period_number);
    stmt->SetInt(2, i_run_number);
 
    // write new value to the database
    if (!stmt->Process()) {
        cout << "ERROR: updating information about run has been failed" << endl;
 
        delete stmt;
        return -2;
    }
 
    if (i_event_count)
        delete i_event_count;
    if (event_count == nullptr)
        i_event_count = nullptr;
    else
        i_event_count = new int(*event_count);
 
    delete stmt;
    return 0;
}
 
int UniRun::SetRunQuality(int run_quality)
{
    if (!connectionDB) {
        cout << "CRITICAL ERROR: Connection object is null" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connectionDB->GetSQLServer();
 
    TString sql = TString::Format("update run_ "
                                  "set run_quality = $1 "
                                  "where period_number = $2 and run_number = $3");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetInt(0, run_quality);
    stmt->SetInt(1, i_period_number);
    stmt->SetInt(2, i_run_number);
 
    // write new value to the database
    if (!stmt->Process()) {
        cout << "ERROR: updating information about run has been failed" << endl;
 
        delete stmt;
        return -2;
    }
 
    i_run_quality = run_quality;
 
    delete stmt;
    return 0;
}
 
// -----  Print current run  ---------------------------------------
void UniRun::Print()
{
    cout << "Table 'run_'";
    cout << ". period_number: " << i_period_number << ". run_number: " << i_run_number << ". run_type: " << i_run_type
         << ". start_datetime: " << ts_start_datetime.AsSQLString()
         << ". end_datetime: " << (ts_end_datetime == nullptr ? "nullptr" : (*ts_end_datetime).AsSQLString())
         << ". beam_particle: " << str_beam_particle << ". target_particle: " << str_target_particle
         << ". energy: " << (d_energy == nullptr ? "nullptr" : TString::Format("%f", *d_energy))
         << ". field_voltage: " << (d_field_voltage == nullptr ? "nullptr" : TString::Format("%f", *d_field_voltage))
         << ". event_count: " << (i_event_count == nullptr ? "nullptr" : TString::Format("%d", *i_event_count))
         << ". run_quality: " << i_run_quality << endl;
 
    return;
}
/* END OF GENERATED CLASS PART (SHOULD NOT BE CHANGED MANUALLY) */
 
// get array of raw files (UniRawFile*) corresponding to the run (return nullptr if an error occured)
TObjArray* UniRun::GetRawFiles()
{
    return UniRawFile::GetRawFiles(i_period_number, i_run_number);
}
 
// get numbers of runs existing in the Database for a selected range
int UniRun::GetRunNumbers(UniqueRunNumber*& run_numbers, int start_period, int start_run, int end_period, int end_run)
{
    UniConnection* connDb = UniConnection::Open();
    if (connDb == nullptr) {
        cout << "ERROR: connection to the database was failed" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    if (end_period == -1)
        end_period = start_period;
    TString sql = TString::Format(
        "select period_number, run_number "
        "from run_ "
        "where (not (((%d < period_number) or ((%d = period_number) and (%d <> -1) and (%d < run_number))) "
        "or ((%d > period_number) or ((%d = period_number) and (%d > run_number))))) "
        "order by period_number, run_number",
        end_period, end_period, end_run, end_run, start_period, start_period, start_run);
    TSQLStatement* stmt = db_server->Statement(sql);
 
    // get table record from DB
    if (!stmt->Process()) {
        cout << "ERROR: getting run numbers from the database has been failed" << endl;
        delete stmt;
        delete connDb;
        return -2;
    }
 
    // store result of statement in buffer
    stmt->StoreResult();
 
    vector<int> vecPeriods;
    vector<int> vecRuns;
    while (stmt->NextResultRow()) {
        vecPeriods.push_back(stmt->GetInt(0));
        vecRuns.push_back(stmt->GetInt(1));
    }
 
    delete stmt;
    delete connDb;
 
    int run_count = vecPeriods.size();
    run_numbers = new UniqueRunNumber[run_count];
    for (int i = 0; i < run_count; i++) {
        run_numbers[i].period_number = vecPeriods[i];
        run_numbers[i].run_number = vecRuns[i];
    }
 
    return run_count;
}
 
// get numbers of existing runs in the Database
int UniRun::GetRunNumbers(UniqueRunNumber*& run_numbers)
{
    UniConnection* connDb = UniConnection::Open();
    if (connDb == nullptr) {
        cout << "ERROR: connection to the database was failed" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = TString::Format("select period_number, run_number "
                                  "from run_ "
                                  "order by period_number, run_number");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    // get table record from DB
    if (!stmt->Process()) {
        cout << "ERROR: getting run numbers from the database has been failed" << endl;
        delete stmt;
        delete connDb;
        return -2;
    }
 
    // store result of statement in buffer
    stmt->StoreResult();
 
    vector<int> vecPeriods;
    vector<int> vecRuns;
    while (stmt->NextResultRow()) {
        vecPeriods.push_back(stmt->GetInt(0));
        vecRuns.push_back(stmt->GetInt(1));
    }
 
    delete stmt;
    delete connDb;
 
    int run_count = vecPeriods.size();
    run_numbers = new UniqueRunNumber[run_count];
    for (int i = 0; i < run_count; i++) {
        run_numbers[i].period_number = vecPeriods[i];
        run_numbers[i].run_number = vecRuns[i];
    }
 
    return run_count;
}
 
// get field voltage value
// if period_number > 0 and run_number > 0: from the closest previous run, below (period:run)
// in another case: for the latest run in the database
// ATTENTION: changes the input period and run numbers to the correspoding ones of the previous run with the field
// voltage
double UniRun::FindPreviousFieldVoltage(int& period_number, int& run_number)
{
    UniConnection* connDb = UniConnection::Open();
    if (connDb == nullptr)
        return 0;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql("select period_number, run_number, field_voltage "
                "from run_ ");
    if ((period_number > 0) and (run_number > 0))
        sql += TString::Format(
            "where period_number < %d OR (period_number = %d and run_number < %d) and field_voltage is not NULL ",
            period_number, period_number, run_number);
    sql += "order by period_number desc, run_number desc "
           "limit 1";
    TSQLStatement* stmt = db_server->Statement(sql);
 
    // get field_voltage from the database
    if (!stmt->Process()) {
        cout << "ERROR: getting previous field_voltage from the database has been failed" << endl;
 
        delete stmt;
        delete connDb;
        return 0;
    }
 
    // store result of statement in buffer
    stmt->StoreResult();
 
    // extract row
    if (!stmt->NextResultRow()) {
        delete stmt;
        delete connDb;
        return 0;
    }
 
    period_number = stmt->GetInt(0);
    run_number = stmt->GetInt(1);
    double field_voltage = stmt->GetDouble(2);
 
    delete stmt;
    delete connDb;
 
    return field_voltage;
}
 
TObjArray* UniRun::Search(TObjArray& search_conditions)
{
    TObjArray* arrayResult = nullptr;
    search_conditions.SetOwner(kTRUE);
 
    UniConnection* connDb = UniConnection::Open();
    if (connDb == nullptr) {
        cout << "ERROR: connection to the Unified Condition Database was failed" << endl;
        return arrayResult;
    }
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = TString::Format("select period_number, run_number, run_type, start_datetime, end_datetime, "
                                  "beam_particle, target_particle, energy, field_voltage, event_count, run_quality "
                                  "from run_");
 
    TString strCondition;
    bool isFirst = true;
    TIter next(&search_conditions);
    UniSearchCondition* curCondition;
    while ((curCondition = (UniSearchCondition*)next()) != nullptr) {
        strCondition = "";
 
        switch (curCondition->GetColumn()) {
            case UniSearchCondition::columnRunNumber:
                strCondition += "run_number ";
                break;
            case UniSearchCondition::columnPeriodNumber:
                strCondition += "period_number ";
                break;
            // case UniSearchCondition::columnFilePath:        strCondition += "lower(file_path) "; break;
            case UniSearchCondition::columnBeamParticle:
                strCondition += "lower(beam_particle) ";
                break;
            case UniSearchCondition::columnTargetParticle:
                strCondition += "lower(target_particle) ";
                break;
            case UniSearchCondition::columnEnergy:
                strCondition += "energy ";
                break;
            case UniSearchCondition::columnStartDatetime:
                strCondition += "start_datetime ";
                break;
            case UniSearchCondition::columnEndDateTime:
                strCondition += "end_datetime ";
                break;
            case UniSearchCondition::columnEventCount:
                strCondition += "event_count ";
                break;
            case UniSearchCondition::columnFieldVoltage:
                strCondition += "field_voltage ";
                break;
            // case UniSearchCondition::columnFileSize:        strCondition += "file_size "; break;
            default:
                cout << "ERROR: the column in the search condition was not defined, the condition is skipped" << endl;
                continue;
        }
 
        switch (curCondition->GetCondition()) {
            case UniSearchCondition::conditionLess:
                strCondition += "< ";
                break;
            case UniSearchCondition::conditionLessOrEqual:
                strCondition += "<= ";
                break;
            case UniSearchCondition::conditionEqual:
                strCondition += "= ";
                break;
            case UniSearchCondition::conditionNotEqual:
                strCondition += "<> ";
                break;
            case UniSearchCondition::conditionGreater:
                strCondition += "> ";
                break;
            case UniSearchCondition::conditionGreaterOrEqual:
                strCondition += ">= ";
                break;
            case UniSearchCondition::conditionLike:
                strCondition += "like ";
                break;
            case UniSearchCondition::conditionNull:
                strCondition += "is null ";
                break;
            case UniSearchCondition::conditionNotNull:
                strCondition += "is not null ";
                break;
            default:
                cout << "ERROR: the comparison operator in the search condition was not defined, the condition is "
                        "skipped"
                     << endl;
                continue;
        }
 
        switch (curCondition->GetValueType()) {
            case 0:
                if ((curCondition->GetCondition() != UniSearchCondition::conditionNull)
                    && (curCondition->GetCondition() != UniSearchCondition::conditionNotNull))
                    continue;
                break;
            case 1:
                strCondition += Form("%d", curCondition->GetIntValue());
                break;
            case 2:
                strCondition += Form("%u", curCondition->GetUIntValue());
                break;
            case 3:
                strCondition += Form("%f", curCondition->GetDoubleValue());
                break;
            case 4:
                strCondition += Form("lower('%s')", curCondition->GetStringValue().Data());
                break;
            case 5:
                strCondition += Form("'%s'", curCondition->GetDatimeValue().AsSQLString());
                break;
            default:
                cout << "ERROR: the value type in the search condition was not found, the condition is skipped" << endl;
                continue;
        }
 
        if (isFirst) {
            sql += " where ";
            isFirst = false;
        } else
            sql += " and ";
 
        sql += strCondition;
    }
    sql += " order by period_number,run_number";
 
    TSQLStatement* stmt = db_server->Statement(sql);
    // cout<<"SQL code: "<<sql<<endl;
 
    // get table record from DB
    if (!stmt->Process()) {
        cout << "ERROR: getting runs from the Unified Condition Database has been failed" << endl;
        delete stmt;
        delete connDb;
 
        return arrayResult;
    }
 
    // store result of statement in buffer
    stmt->StoreResult();
 
    // extract rows one after another
    arrayResult = new TObjArray();
    arrayResult->SetOwner(kTRUE);
    while (stmt->NextResultRow()) {
        UniConnection* connRun = UniConnection::Open();
        if (connRun == nullptr) {
            cout << "ERROR: the connection to the Unified Condition Database for the selected run was failed" << endl;
            return arrayResult;
        }
 
        int tmp_period_number;
        tmp_period_number = stmt->GetInt(0);
        int tmp_run_number;
        tmp_run_number = stmt->GetInt(1);
        int tmp_run_type;
        tmp_run_type = stmt->GetInt(2);
        TDatime tmp_start_datetime;
        tmp_start_datetime = stmt->GetDatime(3);
        TDatime* tmp_end_datetime;
        if (stmt->IsNull(4))
            tmp_end_datetime = nullptr;
        else
            tmp_end_datetime = new TDatime(stmt->GetDatime(4));
        TString tmp_beam_particle;
        tmp_beam_particle = stmt->GetString(5);
        TString tmp_target_particle;
        tmp_target_particle = stmt->GetString(6);
        double* tmp_energy;
        if (stmt->IsNull(7))
            tmp_energy = nullptr;
        else
            tmp_energy = new double(stmt->GetDouble(7));
        double* tmp_field_voltage;
        if (stmt->IsNull(8))
            tmp_field_voltage = nullptr;
        else
            tmp_field_voltage = new double(stmt->GetDouble(8));
        int* tmp_event_count;
        if (stmt->IsNull(9))
            tmp_event_count = nullptr;
        else
            tmp_event_count = new int(stmt->GetInt(9));
        int tmp_run_quality;
        tmp_run_quality = stmt->GetInt(10);
 
        arrayResult->Add((TObject*)new UniRun(
            connRun, tmp_period_number, tmp_run_number, tmp_run_type, tmp_start_datetime, tmp_end_datetime,
            tmp_beam_particle, tmp_target_particle, tmp_energy, tmp_field_voltage, tmp_event_count, tmp_run_quality));
    }
 
    delete stmt;
 
    return arrayResult;
}
 
TObjArray* UniRun::Search(UniSearchCondition& search_condition)
{
    TObjArray search_conditions;
    search_conditions.Add((TObject*)&search_condition);
 
    return Search(search_conditions);
}
 
// get run from the database with the given period and run numbers
// if usePrevRunIfMissing is true then find and get the previous (existing) run in case the given run is absent
// ATTENTION: changes the input period and run numbers to ones of the found run (if usePrevRunIfMissing is true)
UniRun* UniRun::GetRun(int& period_number, int& run_number, bool usePrevRunIfMissing)
{
    if (!usePrevRunIfMissing)
        return UniRun::GetRun(period_number, run_number);
 
    UniRun* pRun = UniRun::GetRun(period_number, run_number);
    if (pRun == nullptr) {
        cout << "INFO: Trying to get the previous run number before " << period_number << ":" << run_number << " run"
             << endl;
        int res_prev_code = UniRun::FindPreviousRun(period_number, run_number);
        if (res_prev_code != 0)
            return nullptr;
        cout << "INFO: The previous run number was defined: " << period_number << ":" << run_number << endl;
        pRun = UniRun::GetRun(period_number, run_number);
    }
 
    return pRun;
}
 
// get number of the closest run below the given one
// or return the latest run in the database if period_number < 1 or run_number < 1
int UniRun::FindPreviousRun(int& period_number, int& run_number)
{
    UniConnection* connDb = UniConnection::Open();
    if (connDb == nullptr) {
        cout << "ERROR: connection to the Database was failed" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = "select period_number, run_number "
                  "from run_ ";
    if ((period_number > 0) and (run_number > 0))
        sql += TString::Format("where (period_number < %d) OR ((period_number = %d) AND (run_number < %d)) ",
                               period_number, period_number, run_number);
    sql += "order by period_number desc, run_number desc "
           "limit 1";
    TSQLStatement* stmt = db_server->Statement(sql);
 
    // get table record from DB
    if (!stmt->Process()) {
        cout << "ERROR: getting previous run number from DB has been failed" << endl;
        delete stmt;
        delete connDb;
        return -2;
    }
 
    // store result of statement in buffer
    stmt->StoreResult();
 
    // extract row
    if (!stmt->NextResultRow()) {
        cout << "ERROR: previous run was not found in the database" << endl;
 
        delete stmt;
        delete connDb;
        return -3;
    }
 
    period_number = stmt->GetInt(0);
    run_number = stmt->GetInt(1);
 
    delete stmt;
    delete connDb;
 
    return 0;
}