UniDetectorParameter.cxx

Go to the documentation of this file.

// ----------------------------------------------------------------------
//                    UniDetectorParameter cxx file
// ----------------------------------------------------------------------
 
#include "TObjString.h"
#include "TSQLServer.h"
#include "TSQLStatement.h"
 
// #define ONLY_DECLARATIONS
// #include "function_set.h"
#include "TSystem.h"
#include "UniDetectorParameter.h"
#include "UniRunPeriod.h"
#include "uni_db_structures.h"
 
#include <fstream>
 
/* GENERATED CLASS MEMBERS (SHOULD NOT BE CHANGED MANUALLY) */
// -----   Constructor with database connection   -----------------------
UniDetectorParameter::UniDetectorParameter(UniConnection* db_connect,
                                           int value_id,
                                           TString detector_name,
                                           int parameter_id,
                                           int start_period,
                                           int start_run,
                                           int end_period,
                                           int end_run,
                                           int value_key,
                                           unsigned char* parameter_value,
                                           Long_t size_parameter_value,
                                           TDatime* expiry_date)
{
    connectionDB = db_connect;
 
    i_value_id = value_id;
    str_detector_name = detector_name;
    i_parameter_id = parameter_id;
    i_start_period = start_period;
    i_start_run = start_run;
    i_end_period = end_period;
    i_end_run = end_run;
    i_value_key = value_key;
    blob_parameter_value = parameter_value;
    sz_parameter_value = size_parameter_value;
    ts_expiry_date = expiry_date;
}
 
// -----   Destructor   -------------------------------------------------
UniDetectorParameter::~UniDetectorParameter()
{
    if (connectionDB)
        delete connectionDB;
    if (blob_parameter_value)
        delete[] blob_parameter_value;
    if (ts_expiry_date)
        delete ts_expiry_date;
}
 
// -----   Creating new detector parameter in the database  ---------------------------
UniDetectorParameter* UniDetectorParameter::CreateDetectorParameter(TString detector_name,
                                                                    int parameter_id,
                                                                    int start_period,
                                                                    int start_run,
                                                                    int end_period,
                                                                    int end_run,
                                                                    int value_key,
                                                                    unsigned char* parameter_value,
                                                                    Long_t size_parameter_value,
                                                                    TDatime* expiry_date)
{
    UniConnection* connDb = UniConnection::Open();
    if (connDb == nullptr)
        return nullptr;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = TString::Format("insert into detector_parameter(detector_name, parameter_id, start_period, "
                                  "start_run, end_period, end_run, value_key, parameter_value, expiry_date) "
                                  "values ($1, $2, $3, $4, $5, $6, $7, $8, $9)");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetString(0, detector_name);
    stmt->SetInt(1, parameter_id);
    stmt->SetInt(2, start_period);
    stmt->SetInt(3, start_run);
    stmt->SetInt(4, end_period);
    stmt->SetInt(5, end_run);
    stmt->SetInt(6, value_key);
    stmt->SetBinary(7, parameter_value, size_parameter_value, 0x4000000);
    if (expiry_date == nullptr)
        stmt->SetNull(8);
    else
        stmt->SetDatime(8, *expiry_date);
 
    // inserting new detector parameter to the Database
    if (!stmt->Process()) {
        cout << "ERROR: inserting new detector parameter to the Database has been failed" << endl;
        delete stmt;
        delete connDb;
        return nullptr;
    }
 
    delete stmt;
 
    // getting last inserted ID
    int value_id;
    TSQLStatement* stmt_last =
        db_server->Statement("SELECT currval(pg_get_serial_sequence('detector_parameter','value_id'))");
 
    // process getting last id
    if (stmt_last->Process()) {
        // store result of statement in buffer
        stmt_last->StoreResult();
 
        // if there is no last id then exit with error
        if (!stmt_last->NextResultRow()) {
            cout << "ERROR: no last ID in DB!" << endl;
            delete stmt_last;
            return nullptr;
        } else {
            value_id = stmt_last->GetInt(0);
            delete stmt_last;
        }
    } else {
        cout << "ERROR: getting last ID has been failed!" << endl;
        delete stmt_last;
        return nullptr;
    }
 
    int tmp_value_id;
    tmp_value_id = value_id;
    TString tmp_detector_name;
    tmp_detector_name = detector_name;
    int tmp_parameter_id;
    tmp_parameter_id = parameter_id;
    int tmp_start_period;
    tmp_start_period = start_period;
    int tmp_start_run;
    tmp_start_run = start_run;
    int tmp_end_period;
    tmp_end_period = end_period;
    int tmp_end_run;
    tmp_end_run = end_run;
    int tmp_value_key;
    tmp_value_key = value_key;
    unsigned char* tmp_parameter_value;
    Long_t tmp_sz_parameter_value = size_parameter_value;
    tmp_parameter_value = new unsigned char[tmp_sz_parameter_value];
    memcpy(tmp_parameter_value, parameter_value, tmp_sz_parameter_value);
    TDatime* tmp_expiry_date;
    if (expiry_date == nullptr)
        tmp_expiry_date = nullptr;
    else
        tmp_expiry_date = new TDatime(*expiry_date);
 
    return new UniDetectorParameter(connDb, tmp_value_id, tmp_detector_name, tmp_parameter_id, tmp_start_period,
                                    tmp_start_run, tmp_end_period, tmp_end_run, tmp_value_key, tmp_parameter_value,
                                    tmp_sz_parameter_value, tmp_expiry_date);
}
 
// -----  Get detector parameter from the database  ---------------------------
UniDetectorParameter* UniDetectorParameter::GetDetectorParameter(int value_id)
{
    UniConnection* connDb = UniConnection::Open();
    if (connDb == nullptr)
        return nullptr;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = TString::Format("select value_id, detector_name, parameter_id, start_period, start_run, end_period, "
                                  "end_run, value_key, parameter_value, expiry_date "
                                  "from detector_parameter "
                                  "where value_id = %d",
                                  value_id);
    TSQLStatement* stmt = db_server->Statement(sql);
 
    // get detector parameter from the database
    if (!stmt->Process()) {
        cout << "ERROR: getting detector parameter 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: detector parameter was not found in the database" << endl;
 
        delete stmt;
        delete connDb;
        return nullptr;
    }
 
    int tmp_value_id;
    tmp_value_id = stmt->GetInt(0);
    TString tmp_detector_name;
    tmp_detector_name = stmt->GetString(1);
    int tmp_parameter_id;
    tmp_parameter_id = stmt->GetInt(2);
    int tmp_start_period;
    tmp_start_period = stmt->GetInt(3);
    int tmp_start_run;
    tmp_start_run = stmt->GetInt(4);
    int tmp_end_period;
    tmp_end_period = stmt->GetInt(5);
    int tmp_end_run;
    tmp_end_run = stmt->GetInt(6);
    int tmp_value_key;
    tmp_value_key = stmt->GetInt(7);
    unsigned char* tmp_parameter_value;
    tmp_parameter_value = nullptr;
    Long_t tmp_sz_parameter_value = 0;
    stmt->GetBinary(8, (void*&)tmp_parameter_value, tmp_sz_parameter_value);
    TDatime* tmp_expiry_date;
    if (stmt->IsNull(9))
        tmp_expiry_date = nullptr;
    else
        tmp_expiry_date = new TDatime(stmt->GetDatime(9));
 
    delete stmt;
 
    return new UniDetectorParameter(connDb, tmp_value_id, tmp_detector_name, tmp_parameter_id, tmp_start_period,
                                    tmp_start_run, tmp_end_period, tmp_end_run, tmp_value_key, tmp_parameter_value,
                                    tmp_sz_parameter_value, tmp_expiry_date);
}
 
// -----  Check detector parameter exists in the database  ---------------------------
int UniDetectorParameter::CheckDetectorParameterExists(int value_id)
{
    UniConnection* connDb = UniConnection::Open();
    if (connDb == nullptr)
        return -1;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = TString::Format("select 1 "
                                  "from detector_parameter "
                                  "where value_id = %d",
                                  value_id);
    TSQLStatement* stmt = db_server->Statement(sql);
 
    // get detector parameter from the database
    if (!stmt->Process()) {
        cout << "ERROR: getting detector parameter 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 detector parameter from the database  ---------------------------
int UniDetectorParameter::DeleteDetectorParameter(int value_id)
{
    UniConnection* connDb = UniConnection::Open();
    if (connDb == nullptr)
        return -1;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = TString::Format("delete from detector_parameter "
                                  "where value_id = $1");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetInt(0, value_id);
 
    // delete detector parameter from the dataBase
    if (!stmt->Process()) {
        cout << "ERROR: deleting detector parameter from the dataBase has been failed" << endl;
 
        delete stmt;
        delete connDb;
        return -2;
    }
 
    delete stmt;
    delete connDb;
    return 0;
}
 
// -----  Print all 'detector parameters'  ---------------------------------
int UniDetectorParameter::PrintAll()
{
    UniConnection* connDb = UniConnection::Open();
    if (connDb == nullptr)
        return -1;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = TString::Format("select value_id, detector_name, parameter_id, start_period, start_run, end_period, "
                                  "end_run, value_key, parameter_value, expiry_date "
                                  "from detector_parameter");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    // get all 'detector parameters' from the database
    if (!stmt->Process()) {
        cout << "ERROR: getting all 'detector parameters' 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 'detector_parameter':" << endl;
    while (stmt->NextResultRow()) {
        cout << "value_id: ";
        cout << (stmt->GetInt(0));
        cout << ", detector_name: ";
        cout << (stmt->GetString(1));
        cout << ", parameter_id: ";
        cout << (stmt->GetInt(2));
        cout << ", start_period: ";
        cout << (stmt->GetInt(3));
        cout << ", start_run: ";
        cout << (stmt->GetInt(4));
        cout << ", end_period: ";
        cout << (stmt->GetInt(5));
        cout << ", end_run: ";
        cout << (stmt->GetInt(6));
        cout << ", value_key: ";
        cout << (stmt->GetInt(7));
        cout << ", parameter_value: ";
        unsigned char* tmp_parameter_value = nullptr;
        Long_t tmp_sz_parameter_value = 0;
        stmt->GetBinary(8, (void*&)tmp_parameter_value, tmp_sz_parameter_value);
        cout << (void*)tmp_parameter_value << ", binary size: " << tmp_sz_parameter_value;
        cout << ", expiry_date: ";
        if (stmt->IsNull(9))
            cout << "nullptr";
        else
            cout << stmt->GetDatime(9).AsSQLString();
        cout << "." << endl;
    }
 
    delete stmt;
    delete connDb;
 
    return 0;
}
 
// Setters functions
int UniDetectorParameter::SetDetectorName(TString detector_name)
{
    if (!connectionDB) {
        cout << "CRITICAL ERROR: Connection object is null" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connectionDB->GetSQLServer();
 
    TString sql = TString::Format("update detector_parameter "
                                  "set detector_name = $1 "
                                  "where value_id = $2");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetString(0, detector_name);
    stmt->SetInt(1, i_value_id);
 
    // write new value to the database
    if (!stmt->Process()) {
        cout << "ERROR: updating information about detector parameter has been failed" << endl;
 
        delete stmt;
        return -2;
    }
 
    str_detector_name = detector_name;
 
    delete stmt;
    return 0;
}
 
int UniDetectorParameter::SetParameterId(int parameter_id)
{
    if (!connectionDB) {
        cout << "CRITICAL ERROR: Connection object is null" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connectionDB->GetSQLServer();
 
    TString sql = TString::Format("update detector_parameter "
                                  "set parameter_id = $1 "
                                  "where value_id = $2");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetInt(0, parameter_id);
    stmt->SetInt(1, i_value_id);
 
    // write new value to the database
    if (!stmt->Process()) {
        cout << "ERROR: updating information about detector parameter has been failed" << endl;
 
        delete stmt;
        return -2;
    }
 
    i_parameter_id = parameter_id;
 
    delete stmt;
    return 0;
}
 
int UniDetectorParameter::SetStartPeriod(int start_period)
{
    if (!connectionDB) {
        cout << "CRITICAL ERROR: Connection object is null" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connectionDB->GetSQLServer();
 
    TString sql = TString::Format("update detector_parameter "
                                  "set start_period = $1 "
                                  "where value_id = $2");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetInt(0, start_period);
    stmt->SetInt(1, i_value_id);
 
    // write new value to the database
    if (!stmt->Process()) {
        cout << "ERROR: updating information about detector parameter has been failed" << endl;
 
        delete stmt;
        return -2;
    }
 
    i_start_period = start_period;
 
    delete stmt;
    return 0;
}
 
int UniDetectorParameter::SetStartRun(int start_run)
{
    if (!connectionDB) {
        cout << "CRITICAL ERROR: Connection object is null" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connectionDB->GetSQLServer();
 
    TString sql = TString::Format("update detector_parameter "
                                  "set start_run = $1 "
                                  "where value_id = $2");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetInt(0, start_run);
    stmt->SetInt(1, i_value_id);
 
    // write new value to the database
    if (!stmt->Process()) {
        cout << "ERROR: updating information about detector parameter has been failed" << endl;
 
        delete stmt;
        return -2;
    }
 
    i_start_run = start_run;
 
    delete stmt;
    return 0;
}
 
int UniDetectorParameter::SetEndPeriod(int end_period)
{
    if (!connectionDB) {
        cout << "CRITICAL ERROR: Connection object is null" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connectionDB->GetSQLServer();
 
    TString sql = TString::Format("update detector_parameter "
                                  "set end_period = $1 "
                                  "where value_id = $2");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetInt(0, end_period);
    stmt->SetInt(1, i_value_id);
 
    // write new value to the database
    if (!stmt->Process()) {
        cout << "ERROR: updating information about detector parameter has been failed" << endl;
 
        delete stmt;
        return -2;
    }
 
    i_end_period = end_period;
 
    delete stmt;
    return 0;
}
 
int UniDetectorParameter::SetEndRun(int end_run)
{
    if (!connectionDB) {
        cout << "CRITICAL ERROR: Connection object is null" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connectionDB->GetSQLServer();
 
    TString sql = TString::Format("update detector_parameter "
                                  "set end_run = $1 "
                                  "where value_id = $2");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetInt(0, end_run);
    stmt->SetInt(1, i_value_id);
 
    // write new value to the database
    if (!stmt->Process()) {
        cout << "ERROR: updating information about detector parameter has been failed" << endl;
 
        delete stmt;
        return -2;
    }
 
    i_end_run = end_run;
 
    delete stmt;
    return 0;
}
 
int UniDetectorParameter::SetValueKey(int value_key)
{
    if (!connectionDB) {
        cout << "CRITICAL ERROR: Connection object is null" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connectionDB->GetSQLServer();
 
    TString sql = TString::Format("update detector_parameter "
                                  "set value_key = $1 "
                                  "where value_id = $2");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetInt(0, value_key);
    stmt->SetInt(1, i_value_id);
 
    // write new value to the database
    if (!stmt->Process()) {
        cout << "ERROR: updating information about detector parameter has been failed" << endl;
 
        delete stmt;
        return -2;
    }
 
    i_value_key = value_key;
 
    delete stmt;
    return 0;
}
 
int UniDetectorParameter::SetParameterValue(unsigned char* parameter_value, Long_t size_parameter_value)
{
    if (!connectionDB) {
        cout << "CRITICAL ERROR: Connection object is null" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connectionDB->GetSQLServer();
 
    TString sql = TString::Format("update detector_parameter "
                                  "set parameter_value = $1 "
                                  "where value_id = $2");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetBinary(0, parameter_value, size_parameter_value, 0x4000000);
    stmt->SetInt(1, i_value_id);
 
    // write new value to the database
    if (!stmt->Process()) {
        cout << "ERROR: updating information about detector parameter has been failed" << endl;
 
        delete stmt;
        return -2;
    }
 
    if (blob_parameter_value)
        delete[] blob_parameter_value;
    sz_parameter_value = size_parameter_value;
    blob_parameter_value = new unsigned char[sz_parameter_value];
    memcpy(blob_parameter_value, parameter_value, sz_parameter_value);
 
    delete stmt;
    return 0;
}
 
int UniDetectorParameter::SetExpiryDate(TDatime* expiry_date)
{
    if (!connectionDB) {
        cout << "CRITICAL ERROR: Connection object is null" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connectionDB->GetSQLServer();
 
    TString sql = TString::Format("update detector_parameter "
                                  "set expiry_date = $1 "
                                  "where value_id = $2");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    if (expiry_date == nullptr)
        stmt->SetNull(0);
    else
        stmt->SetDatime(0, *expiry_date);
    stmt->SetInt(1, i_value_id);
 
    // write new value to the database
    if (!stmt->Process()) {
        cout << "ERROR: updating information about detector parameter has been failed" << endl;
 
        delete stmt;
        return -2;
    }
 
    if (ts_expiry_date)
        delete ts_expiry_date;
    if (expiry_date == nullptr)
        ts_expiry_date = nullptr;
    else
        ts_expiry_date = new TDatime(*expiry_date);
 
    delete stmt;
    return 0;
}
 
// -----  Print current detector parameter  ---------------------------------------
void UniDetectorParameter::Print()
{
    cout << "Table 'detector_parameter'";
    cout << ". value_id: " << i_value_id << ". detector_name: " << str_detector_name
         << ". parameter_id: " << i_parameter_id << ". start_period: " << i_start_period
         << ". start_run: " << i_start_run << ". end_period: " << i_end_period << ". end_run: " << i_end_run
         << ". value_key: " << i_value_key << ". parameter_value: " << (void*)blob_parameter_value
         << ", binary size: " << sz_parameter_value
         << ". expiry_date: " << (ts_expiry_date == nullptr ? "nullptr" : (*ts_expiry_date).AsSQLString()) << endl;
 
    return;
}
/* END OF GENERATED CLASS PART (SHOULD NOT BE CHANGED MANUALLY) */
 
// non-user function for getting parameter value as a binary (char) array
unsigned char* UniDetectorParameter::GetUNC(enumValueType enum_parameter_type)
{
    if (enum_parameter_type > -1) {
        if (!connectionDB) {
            cout << "CRITICAL ERROR: Connection object is null" << endl;
            return nullptr;
        }
 
        TSQLServer* db_server = connectionDB->GetSQLServer();
 
        // get parameter object from 'parameter_' table
        TString sql = TString::Format("select parameter_name, parameter_type "
                                      "from parameter_ "
                                      "where parameter_id = %d",
                                      i_parameter_id);
        TSQLStatement* stmt = db_server->Statement(sql);
 
        // get table record from DB
        if (!stmt->Process()) {
            cout << "CRITICAL ERROR: getting record with parameter from 'parameter_' table has been failed" << endl;
            delete stmt;
            return nullptr;
        }
 
        stmt->StoreResult();
 
        // extract row with parameter
        if (!stmt->NextResultRow()) {
            cout << "CRITICAL ERROR: the parameter with id '" << i_parameter_id << "' was not found" << endl;
            delete stmt;
            return nullptr;
        }
 
        TString parameter_name = stmt->GetString(0);
        int parameter_type = stmt->GetInt(1);
        delete stmt;
 
        if (parameter_type != enum_parameter_type) {
            cout << "CRITICAL ERROR: the parameter with name '" << parameter_name
                 << "' is not corresponding the given type: "
                    "Database Type - "
                 << parameter_type << ", but user type - " << enum_parameter_type << endl;
            return nullptr;
        }
    }
 
    return blob_parameter_value;
}
 
// non-user function for setting parameter value as a binary (char) array
int UniDetectorParameter::SetUNC(unsigned char* p_parameter_value, Long_t size_parameter_value)
{
    if (!connectionDB) {
        cout << "Connection object is null" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connectionDB->GetSQLServer();
 
    TString sql = TString::Format("update detector_parameter "
                                  "set parameter_value = $1 "
                                  "where detector_name = $2 and parameter_id = $3 and start_period = $4 and start_run "
                                  "= $5 and end_period = $6 and end_run = $7 and value_key = $8");
 
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetBinary(0, (void*)p_parameter_value, size_parameter_value);
    stmt->SetString(1, str_detector_name);
    stmt->SetInt(2, i_parameter_id);
    stmt->SetInt(3, i_start_period);
    stmt->SetInt(4, i_start_run);
    stmt->SetInt(5, i_end_period);
    stmt->SetInt(6, i_end_run);
    stmt->SetInt(7, i_value_key);
 
    // write new value to database
    if (!stmt->Process()) {
        cout << "ERROR: updating the detector parameter has been failed" << endl;
        delete stmt;
        return -2;
    }
 
    if (blob_parameter_value)
        delete[] blob_parameter_value;
    blob_parameter_value = p_parameter_value;
    sz_parameter_value = size_parameter_value;
 
    delete stmt;
    return 0;
}
 
// non-user function for writing new parameter value (integer value key is optional, default, 0)
UniDetectorParameter* UniDetectorParameter::CreateDetectorParameter(TString detector_name,
                                                                    TString parameter_name,
                                                                    int start_period,
                                                                    int start_run,
                                                                    int end_period,
                                                                    int end_run,
                                                                    unsigned char* p_parameter_value,
                                                                    Long_t size_parameter_value,
                                                                    enumValueType enum_parameter_type,
                                                                    int value_key)
{
    if (((end_period < start_period) or ((end_period == start_period) and (end_run < start_run)))
        or ((start_period > end_period) or ((start_period == end_period) and (start_run > end_run))))
    {
        cout << "ERROR: end run should be after or the same as start run" << endl;
        return nullptr;
    }
 
    UniConnection* connDb = UniConnection::Open();
    if (connDb == nullptr)
        return nullptr;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    int parameter_id = -1;
    bool res_code = UniParameter::CheckAndGetParameterID(db_server, parameter_name, enum_parameter_type, parameter_id);
    if (!res_code) {
        delete connDb;
        return nullptr;
    }
 
    TString sql = TString::Format("insert into detector_parameter(detector_name, parameter_id, start_period, "
                                  "start_run, end_period, end_run, value_key, parameter_value) "
                                  "values ($1, $2, $3, $4, $5, $6, $7, $8)");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    // cout<<"DEBUG: detector_name = "<<detector_name<<". parameter_id = "<<parameter_id<<". start_period =
    // "<<start_period<<". start_run = "<<start_run<<". end_period = "<<end_period<<". end_run = "<<end_run<<".
    // value_key = "<<value_key<<". p_parameter_value[0] = "<<p_parameter_value[0]<<". size_parameter_value =
    // "<<size_parameter_value<<endl;
    stmt->NextIteration();
    stmt->SetString(0, detector_name);
    stmt->SetInt(1, parameter_id);
    stmt->SetInt(2, start_period);
    stmt->SetInt(3, start_run);
    stmt->SetInt(4, end_period);
    stmt->SetInt(5, end_run);
    stmt->SetInt(6, value_key);
    stmt->SetBinary(7, (void*)p_parameter_value, size_parameter_value);
 
    // inserting new record to DB
    if (!stmt->Process()) {
        cout << "ERROR: inserting new parameter value to the database has been failed" << endl;
        delete stmt;
        delete connDb;
        return nullptr;
    }
 
    delete stmt;
 
    // getting last inserted node ID
    int last_id = -1;
    // TSQLStatement* stmt_last = db_server->Statement("SELECT LAST_INSERT_ID()");  //MySQL
    TSQLStatement* stmt_last =
        db_server->Statement("SELECT currval(pg_get_serial_sequence('detector_parameter','value_id'))");
 
    if (stmt_last->Process()) {
        // store result of statement in buffer
        stmt_last->StoreResult();
 
        // if there is no last id then exit with error
        if (!stmt_last->NextResultRow()) {
            cout << "ERROR: no last ID in the Database for the parameter value has been found!" << endl;
            delete stmt_last;
            return nullptr;
        } else {
            last_id = stmt_last->GetInt(0);
            delete stmt_last;
        }
    } else {
        cout << "ERROR: getting last ID for new parameter value has been failed!" << endl;
        delete stmt_last;
        return nullptr;
    }
 
    // unsigned char* tmp_parameter_value = new unsigned char[size_parameter_value];
    // memcpy(tmp_parameter_value, p_parameter_value, size_parameter_value);
    return new UniDetectorParameter(connDb, last_id, detector_name, parameter_id, start_period, start_run, end_period,
                                    end_run, value_key, p_parameter_value, size_parameter_value, nullptr);
}
 
// write detector parameter value presented by an array (integer value key is optional, default, 0)
UniDetectorParameter* UniDetectorParameter::CreateDetectorParameter(TString detector_name,
                                                                    TString parameter_name,
                                                                    int start_period,
                                                                    int start_run,
                                                                    int end_period,
                                                                    int end_run,
                                                                    vector<UniValue*> parameter_value,
                                                                    int value_key)
{
    if (parameter_value.size() < 1) {
        cout << "ERROR: The length of the parameter array should be greater zero" << endl;
        return nullptr;
    }
    enumValueType parameter_type = parameter_value[0]->GetType();
 
    // calculate total size
    size_t size_parameter_value = 0;
    for (size_t i = 0; i < parameter_value.size(); i++) {
        if (parameter_value[i]->GetType() != parameter_type) {
            cout << "ERROR: the type of the parameters in the array must be the same" << endl;
            return nullptr;
        }
        size_parameter_value += parameter_value[i]->GetStorageSize();
    }
 
    // write parameters of the vector to the buffer
    unsigned char* p_parameter_value = new unsigned char[size_parameter_value];
    unsigned char* tmp_pointer = p_parameter_value;
    for (size_t i = 0; i < parameter_value.size(); i++) {
        parameter_value[i]->WriteValue(tmp_pointer);
        tmp_pointer += parameter_value[i]->GetStorageSize();
    }
 
    if (start_run < 1) {
        int first_run = UniRunPeriod::GetFirstRunNumber(start_period);
        if (first_run >= 0)
            start_run = first_run;
    }
    if (end_period < 1)
        end_period = start_period;
    if (end_run < 1) {
        int last_run = UniRunPeriod::GetLastRunNumber(end_period);
        if (last_run >= 0)
            end_run = last_run;
    }
 
    UniDetectorParameter* pDetectorParameter = UniDetectorParameter::CreateDetectorParameter(
        detector_name, parameter_name, start_period, start_run, end_period, end_run, p_parameter_value,
        size_parameter_value, parameter_type, value_key);
    if (pDetectorParameter == nullptr)
        delete[] p_parameter_value;
 
    return pDetectorParameter;
}
 
// write detector parameter value presented by a single value (integer value key is optional, default, 0)
UniDetectorParameter* UniDetectorParameter::CreateDetectorParameter(TString detector_name,
                                                                    TString parameter_name,
                                                                    int start_period,
                                                                    int start_run,
                                                                    int end_period,
                                                                    int end_run,
                                                                    UniValue* parameter_value,
                                                                    int value_key)
{
    if (parameter_value == nullptr) {
        cout << "ERROR: the parameter value must not be nullptr" << endl;
        return nullptr;
    }
    enumValueType parameter_type = parameter_value->GetType();
 
    // write the parameter to the buffer
    size_t size_parameter_value = parameter_value->GetStorageSize();
    unsigned char* p_parameter_value = new unsigned char[size_parameter_value];
    parameter_value->WriteValue(p_parameter_value);
 
    if (start_run < 1) {
        int first_run = UniRunPeriod::GetFirstRunNumber(start_period);
        if (first_run >= 0)
            start_run = first_run;
    }
    if (end_period < 1)
        end_period = start_period;
    if (end_run < 1) {
        int last_run = UniRunPeriod::GetLastRunNumber(end_period);
        if (last_run >= 0)
            end_run = last_run;
    }
 
    UniDetectorParameter* pDetectorParameter = UniDetectorParameter::CreateDetectorParameter(
        detector_name, parameter_name, start_period, start_run, end_period, end_run, p_parameter_value,
        size_parameter_value, parameter_type, value_key);
    if (pDetectorParameter == nullptr)
        delete[] p_parameter_value;
 
    return pDetectorParameter;
}
 
// get detector parameter value (integer value key is optional, default, 0)
UniDetectorParameter* UniDetectorParameter::GetDetectorParameter(TString detector_name,
                                                                 TString parameter_name,
                                                                 int period_number,
                                                                 int run_number,
                                                                 TDatime* usage_time,
                                                                 int value_key)
{
    UniConnection* connDb = UniConnection::Open();
    if (connDb == nullptr)
        return nullptr;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = TString::Format("select value_id, detector_name, p.parameter_id, start_period, start_run, "
                                  "end_period, end_run, parameter_value, expiry_date "
                                  "from detector_parameter dp join parameter_ p on dp.parameter_id = p.parameter_id "
                                  "where lower(detector_name) = lower('%s') and lower(parameter_name) = lower('%s') "
                                  "and (not (((%d < start_period) or ((%d = start_period) and (%d < start_run))) or "
                                  "((%d > end_period) or ((%d = end_period) and (%d > end_run))))) "
                                  "and value_key = %d",
                                  detector_name.Data(), parameter_name.Data(), period_number, period_number, run_number,
                                  period_number, period_number, run_number, value_key);
    if (usage_time != nullptr)
        sql += TString::Format(" and ((expiry_date is null) or ('%s' < expiry_date)) order by expiry_date",
                               (*usage_time).AsSQLString());
    else
        sql += " and expiry_date is null";
    TSQLStatement* stmt = db_server->Statement(sql);
 
    // get table record from DB
    if (!stmt->Process()) {
        cout << "ERROR: getting record 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: parameter value was not found in the Condition Database" << endl;
        delete stmt;
        delete connDb;
        return nullptr;
    }
 
    int tmp_value_id;
    tmp_value_id = stmt->GetInt(0);
    TString tmp_detector_name;
    tmp_detector_name = stmt->GetString(1);
    int tmp_parameter_id;
    tmp_parameter_id = stmt->GetInt(2);
    int tmp_start_period;
    tmp_start_period = stmt->GetInt(3);
    int tmp_start_run;
    tmp_start_run = stmt->GetInt(4);
    int tmp_end_period;
    tmp_end_period = stmt->GetInt(5);
    int tmp_end_run;
    tmp_end_run = stmt->GetInt(6);
    unsigned char* tmp_parameter_value = nullptr;
    Long_t tmp_sz_parameter_value = 0;
    stmt->GetBinary(7, (void*&)tmp_parameter_value, tmp_sz_parameter_value);
    TDatime* tmp_expiry_date;
    if (stmt->IsNull(8))
        tmp_expiry_date = nullptr;
    else
        tmp_expiry_date = new TDatime(stmt->GetDatime(8));
 
    delete stmt;
 
    return new UniDetectorParameter(connDb, tmp_value_id, tmp_detector_name, tmp_parameter_id, tmp_start_period,
                                    tmp_start_run, tmp_end_period, tmp_end_run, value_key, tmp_parameter_value,
                                    tmp_sz_parameter_value, tmp_expiry_date);
}
 
// delete detector parameter value (integer value key is optional, default, 0)
int UniDetectorParameter::DeleteDetectorParameter(TString detector_name,
                                                  TString parameter_name,
                                                  int start_period,
                                                  int start_run,
                                                  int end_period,
                                                  int end_run,
                                                  TDatime* usage_time,
                                                  int value_key)
{
    UniConnection* connDb = UniConnection::Open();
    if (connDb == nullptr)
        return -1;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = "delete from detector_parameter "
                  "where lower(detector_name) = lower($1) and parameter_id IN (select parameter_id from parameter_ "
                  "where lower(parameter_name) = lower($2)) and "
                  "start_period = $3 and start_run = $4 and end_period = $5 and end_run = $6 and value_key = $7";
    if (usage_time == nullptr)
        sql += " and expiry_date is null";
    else
        sql += " and expiry_date >= $8 and expiry_date < $9";
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetString(0, detector_name);
    stmt->SetString(1, parameter_name);
    stmt->SetInt(2, start_period);
    stmt->SetInt(3, start_run);
    stmt->SetInt(4, end_period);
    stmt->SetInt(5, end_run);
    stmt->SetInt(6, value_key);
    if (usage_time != nullptr) {
        stmt->SetDatime(7, *usage_time);
        TDatime dt_plus_1(usage_time->Convert() + 1);
        stmt->SetDatime(8, dt_plus_1);
    }
 
    // delete table record from DB
    if (!stmt->Process()) {
        cout << "ERROR: deleting parameter value from the Database has been failed" << endl;
 
        delete stmt;
        delete connDb;
        return -2;
    }
 
    if (stmt->GetNumAffectedRows() == 0) {
        cout << "WARNING: parameter value was not found in the Condition Database for deletion" << endl;
        delete stmt;
        delete connDb;
        return -2;
    }
 
    delete stmt;
    delete connDb;
    return 0;
}
 
// get value of detector parameter presented by an array
int UniDetectorParameter::GetValue(vector<UniValue*>& parameter_value)
{
    unsigned char* p_parameter_value = GetUNC();
    if (p_parameter_value == nullptr)
        return -1;
 
    Long_t full_size = sz_parameter_value;
    while (full_size > 0) {
        // cout<<"full_size = "<<full_size<<". GetParameterType() = "<<GetParameterType()<<endl;
        UniValue* pParameterValue = CreateParameterValue(GetParameterType());
        pParameterValue->ReadValue(p_parameter_value);
        full_size -= pParameterValue->GetStorageSize();
        p_parameter_value += pParameterValue->GetStorageSize();
        parameter_value.push_back(pParameterValue);
    }
 
    return 0;
}
 
// get value of detector parameter presented by a single value
UniValue* UniDetectorParameter::GetValue()
{
    unsigned char* p_parameter_value = GetUNC();
    if (p_parameter_value == nullptr)
        return nullptr;
 
    UniValue* parameter_value = CreateParameterValue(GetParameterType());
    parameter_value->ReadValue(p_parameter_value);
 
    return parameter_value;
}
 
// set value to detector parameter presented by an array
int UniDetectorParameter::SetValue(vector<UniValue*> parameter_value)
{
    if (parameter_value.size() < 1) {
        cout << "ERROR: The length of the parameter array should be greater zero" << endl;
        return -1;
    }
 
    // calculate full size to create a 'char' buffer
    size_t size_parameter_value = 0;
    for (size_t i = 0; i < parameter_value.size(); i++)
        size_parameter_value += parameter_value[i]->GetStorageSize();
    unsigned char* p_parameter_value = new unsigned char[size_parameter_value];
 
    // write value by value to the 'char' buffer
    unsigned char* tmp_pointer = p_parameter_value;
    for (size_t i = 0; i < parameter_value.size(); i++) {
        parameter_value[i]->WriteValue(tmp_pointer);
        tmp_pointer += parameter_value[i]->GetStorageSize();
    }
 
    int res_code = SetUNC(p_parameter_value, size_parameter_value);
    if (res_code != 0) {
        delete[] p_parameter_value;
        return res_code;
    }
 
    return 0;
}
 
// set value to detector parameter presented by a single value
int UniDetectorParameter::SetValue(UniValue* parameter_value)
{
    if (parameter_value == nullptr) {
        cout << "ERROR: the parameter value must not be nullptr" << endl;
        return -1;
    }
 
    // write value to the 'char' buffer
    size_t size_parameter_value = parameter_value->GetStorageSize();
    unsigned char* p_parameter_value = new unsigned char[size_parameter_value];
    parameter_value->WriteValue(p_parameter_value);
 
    int res_code = SetUNC(p_parameter_value, size_parameter_value);
    if (res_code != 0) {
        delete[] p_parameter_value;
        return res_code;
    }
 
    return 0;
}
 
// write a whole file with parameter value (with given detector and parameter names) to the Database from start run to
// end one
int UniDetectorParameter::WriteFile(const char* detector_name,
                                    const char* parameter_name,
                                    int start_period,
                                    int start_run,
                                    int end_period,
                                    int end_run,
                                    const char* file_path)
{
    TString strFilePath(file_path);
    gSystem->ExpandPathName(strFilePath);
 
    FILE* cur_file = fopen(strFilePath.Data(), "rb");
    if (cur_file == nullptr) {
        cout << "ERROR: opening file: " << strFilePath << " was failed" << endl;
        return -1;
    }
 
    fseek(cur_file, 0, SEEK_END);
    size_t file_size = ftell(cur_file);
    rewind(cur_file);
    if (file_size <= 0) {
        cout << "ERROR: getting file size: " << strFilePath << " was failed" << endl;
        fclose(cur_file);
        return -2;
    }
 
    unsigned char* buffer = new unsigned char[file_size];
    if (buffer == nullptr) {
        cout << "ERROR: getting memory from heap for file was failed" << endl;
        fclose(cur_file);
        return -3;
    }
 
    size_t bytes_read = fread(buffer, 1, file_size, cur_file);
    if (bytes_read != file_size) {
        cout << "ERROR: reading file: " << strFilePath << ", got " << bytes_read << " bytes of " << file_size << endl;
        delete[] buffer;
        fclose(cur_file);
        return -4;
    }
 
    fclose(cur_file);
 
    // create binary parameter with file's bytes
    BinaryValue* pValue = new BinaryValue;
    pValue->size = file_size;
    pValue->value = buffer;
    UniDetectorParameter* pParameterValue = UniDetectorParameter::CreateDetectorParameter(
        detector_name, parameter_name, start_period, start_run, end_period, end_run, pValue);
    if (pParameterValue == nullptr) {
        delete[] buffer;
        return -5;
    }
    delete pValue;
 
    delete[] buffer;
    delete pParameterValue;
 
    return 0;
}
 
// read a whole file with parameter value (with given detector and parameter names) from the Database for the selected
// run
int UniDetectorParameter::ReadFile(const char* detector_name,
                                   const char* parameter_name,
                                   int period_number,
                                   int run_number,
                                   const char* file_path)
{
    UniDetectorParameter* pDetectorParameter =
        UniDetectorParameter::GetDetectorParameter(detector_name, parameter_name, period_number, run_number);
    if (pDetectorParameter == nullptr)
        return -1;
    BinaryValue* pValue = (BinaryValue*)pDetectorParameter->GetValue();
 
    FILE* cur_file = fopen(file_path, "wb");
    if (cur_file == nullptr) {
        cout << "ERROR: creating file: " << file_path << " has been failed!" << endl;
        delete pValue;
        delete pDetectorParameter;
        return -2;
    }
 
    unsigned char* buffer = pValue->value;
    if (buffer == nullptr) {
        cout << "ERROR: getting binary parameter array" << endl;
        delete pValue;
        delete pDetectorParameter;
        fclose(cur_file);
        return -3;
    }
    size_t parameter_size = pValue->size;
 
    size_t bytes_write = fwrite(buffer, 1, parameter_size, cur_file);
    delete pDetectorParameter;
    if (bytes_write != parameter_size) {
        cout << "ERROR: writing file: " << file_path << ", put " << bytes_write << " bytes of " << parameter_size
             << endl;
        fclose(cur_file);
        delete pValue;
        return -4;
    }
 
    fclose(cur_file);
    delete[] buffer;
    delete pValue;
 
    return 0;
}
 
TObjArray* UniDetectorParameter::Search(TObjArray& search_conditions)
{
    TObjArray* arrayResult = nullptr;
    search_conditions.SetOwner(kTRUE);
 
    UniConnection* connDb = UniConnection::Open();
    if (connDb == nullptr) {
        cout << "ERROR: the connection to the Unified Condition Database was failed" << endl;
        return arrayResult;
    }
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = TString::Format("select value_id, detector_name, p.parameter_id, start_period, start_run, "
                                  "end_period, end_run, value_key, parameter_value, expiry_date "
                                  "from detector_parameter dp join parameter_ p on dp.parameter_id = p.parameter_id");
 
    TString strCondition;
    bool isFirst = true;
    TIter next(&search_conditions);
    UniSearchCondition* curCondition;
    while ((curCondition = (UniSearchCondition*)next()) != nullptr) {
        strCondition = "";
 
        switch (curCondition->GetColumn()) {
            case UniSearchCondition::columnDetectorName:
                strCondition += "lower(detector_name) ";
                break;
            case UniSearchCondition::columnParameterName:
                strCondition += "lower(parameter_name) ";
                break;
            case UniSearchCondition::columnStartPeriod:
                strCondition += "start_period ";
                break;
            case UniSearchCondition::columnStartRun:
                strCondition += "start_run ";
                break;
            case UniSearchCondition::columnEndPeriod:
                strCondition += "end_period ";
                break;
            case UniSearchCondition::columnEndRun:
                strCondition += "end_run ";
                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;
    }
 
    TSQLStatement* stmt = db_server->Statement(sql);
 
    // 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* connPar = UniConnection::Open();
        if (connPar == nullptr) {
            cout << "ERROR: the connection to the Unified Condition Database for the selected run was failed" << endl;
            return arrayResult;
        }
 
        int tmp_value_id;
        tmp_value_id = stmt->GetInt(0);
        TString tmp_detector_name;
        tmp_detector_name = stmt->GetString(1);
        int tmp_parameter_id;
        tmp_parameter_id = stmt->GetInt(2);
        int tmp_start_period;
        tmp_start_period = stmt->GetInt(3);
        int tmp_start_run;
        tmp_start_run = stmt->GetInt(4);
        int tmp_end_period;
        tmp_end_period = stmt->GetInt(5);
        int tmp_end_run;
        tmp_end_run = stmt->GetInt(6);
        int tmp_value_key;
        tmp_value_key = stmt->GetInt(7);
        unsigned char* tmp_parameter_value;
        tmp_parameter_value = nullptr;
        Long_t tmp_sz_parameter_value = 0;
        stmt->GetBinary(8, (void*&)tmp_parameter_value, tmp_sz_parameter_value);
        TDatime* tmp_expiry_date;
        if (stmt->IsNull(9))
            tmp_expiry_date = nullptr;
        else
            tmp_expiry_date = new TDatime(stmt->GetDatime(9));
 
        arrayResult->Add((TObject*)new UniDetectorParameter(
            connPar, tmp_value_id, tmp_detector_name, tmp_parameter_id, tmp_start_period, tmp_start_run, tmp_end_period,
            tmp_end_run, tmp_value_key, tmp_parameter_value, tmp_sz_parameter_value, tmp_expiry_date));
    }
 
    delete stmt;
 
    arrayResult->SetOwner(kTRUE);
    return arrayResult;
}
 
TObjArray* UniDetectorParameter::Search(UniSearchCondition& search_condition)
{
    TObjArray search_conditions;
    search_conditions.Add((TObject*)&search_condition);
 
    return Search(search_conditions);
}
 
// get parameter name of the current detector parameter
TString UniDetectorParameter::GetParameterName()
{
    UniParameter* pCurParameter = UniParameter::GetParameter(i_parameter_id);
    if (pCurParameter == nullptr) {
        cout << "ERROR: parameter with current ID was not found" << endl;
        return "";
    }
 
    TString par_name = pCurParameter->GetParameterName();
 
    delete pCurParameter;
    return par_name;
}
 
// get parameter type of the current detector parameter
enumValueType UniDetectorParameter::GetParameterType()
{
    UniParameter* pCurParameter = UniParameter::GetParameter(i_parameter_id);
    if (pCurParameter == nullptr) {
        cout << "ERROR: parameter with current ID was not found" << endl;
        return UndefinedType;
    }
 
    enumValueType par_type = (enumValueType)pCurParameter->GetParameterType();
 
    delete pCurParameter;
    return par_type;
}
 
// get start period and run of the current detector parameter
void UniDetectorParameter::GetStart(int& start_period, int& start_run)
{
    start_period = i_start_period;
    start_run = i_start_run;
 
    return;
}
 
// get end period and run of the current detector parameter
void UniDetectorParameter::GetEnd(int& end_period, int& end_run)
{
    end_period = i_end_period;
    end_run = i_end_run;
 
    return;
}
 
// set start period and run of the current detector parameter
int UniDetectorParameter::SetStart(int start_period, int start_run)
{
    if (!connectionDB) {
        cout << "ERROR: Connection object is null" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connectionDB->GetSQLServer();
 
    TString sql = TString::Format("update detector_parameter "
                                  "set start_period = $1, start_run = $2"
                                  "where value_id = $3");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetInt(0, start_period);
    stmt->SetInt(1, start_run);
    stmt->SetInt(2, i_value_id);
 
    // write new value to database
    if (!stmt->Process()) {
        cout << "ERROR: updating the record has been failed" << endl;
 
        delete stmt;
        return -2;
    }
 
    i_start_period = start_period;
    i_start_run = start_run;
 
    delete stmt;
    return 0;
}
 
// set end period and run of the current detector parameter
int UniDetectorParameter::SetEnd(int end_period, int end_run)
{
    if (!connectionDB) {
        cout << "ERROR: Connection object is null" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connectionDB->GetSQLServer();
 
    TString sql = TString::Format("update detector_parameter "
                                  "set end_period = $1, end_run = $2"
                                  "where value_id = $3");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetInt(0, end_period);
    stmt->SetInt(1, end_run);
    stmt->SetInt(2, i_value_id);
 
    // write new value to database
    if (!stmt->Process()) {
        cout << "ERROR: updating the record has been failed" << endl;
 
        delete stmt;
        return -2;
    }
 
    i_end_period = end_period;
    i_end_run = end_run;
 
    delete stmt;
    return 0;
}
 
/*
int UniDetectorParameter::ParseTxt(TString text_file, TString detector_name, TString parameter_name, int start_period,
int start_run, int end_period, int end_run, bool isSerialChannel)
{
    ifstream txtFile;
    txtFile.open(text_file, ios::in);
    if (!txtFile.is_open())
    {
        cout<<"Error: opening TXT file '"<<text_file<<"' was failed"<<endl;
        return -1;
    }
 
    // open connection to database
    UniConnection* connDb = UniConnection::Open();
    if (connDb == nullptr)
        return -3;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    string cur_line;
    while (getline(txtFile, cur_line))
    {
        //remove duplicates of whitespaces and tabs
        TString reduce_line = reduce(cur_line);
 
        if (reduce_line[0] == '#')
            continue;
 
        //stringstream ss;
        //ss.str(reduce_line);
 
        // get detector object from 'detector_' table
        TString sql = TString::Format(
                    "select detector_name "
                    "from detector_ "
                    "where lower(detector_name) = lower('%s'')", detector_name.Data());
        TSQLStatement* stmt = db_server->Statement(sql);
 
        // get table record from DB
        if (!stmt->Process())
        {
            cout<<"Error: getting record with detector from 'detector_' table has been failed"<<endl;
            delete stmt;
            return -4;
        }
        stmt->StoreResult();
 
        // check detector with the given name is exist
        if (!stmt->NextResultRow())
        {
            cout<<"Error: the detector with name '"<<detector_name<<"' was not found"<<endl;
            delete stmt;
            return -5;
        }
 
        detector_name = stmt->GetString(0);
 
        delete stmt;
 
        // get parameter object from 'parameter_' table
        sql = TString::Format(
                    "select parameter_id, parameter_name, parameter_type "
                    "from parameter_ "
                    "where lower(parameter_name) = lower('%s')", parameter_name.Data());
        stmt = db_server->Statement(sql);
 
        // get table record from DB
        if (!stmt->Process())
        {
            cout<<"Error: getting record with parameter from 'parameter_' table has been failed"<<endl;
            delete stmt;
            return -6;
        }
 
        stmt->StoreResult();
 
        // extract row with parameter
        if (!stmt->NextResultRow())
        {
            cout<<"Error: the parameter with name '"<<parameter_name<<"' was not found"<<endl;
            delete stmt;
            return -7;
        }
 
        //int parameter_id = stmt->GetInt(0);
        parameter_name = stmt->GetString(1);
        int parameter_type = stmt->GetInt(2);
 
        delete stmt;
 
        TObjArray* tokens = reduce_line.Tokenize("\t ");
        TObjString* item;
        int value_count = tokens->GetEntriesFast();
 
        UniDetectorParameter* pDetectorParameter = nullptr;
        // choose parsing method for parameter's value according it's type
        int serial_number = -1, channel_number = -1, cur_num_item = 0;
        switch (parameter_type)
        {
            case BoolType:
                {
                    int count_required = 1;
                    if (isSerialChannel) count_required++, count_required++;
 
                    if (value_count != count_required)
                    {
                        cout<<"Warning: the count of parameters is not equal 1 or 3 ([serial] [channel]
value)"<<endl<<"The current line will be skipped!"<<endl; tokens->Delete(); continue;
                    }
                    if (isSerialChannel)
                    {
                        // get serial number
                        item = (TObjString*) tokens->At(cur_num_item++);
                        serial_number = item->GetString().Atoi();
                        // get channel number
                        item = (TObjString*) tokens->At(cur_num_item++);
                        channel_number = item->GetString().Atoi();
                    }
                    item = (TObjString*) tokens->At(cur_num_item++);
                    tokens->Delete();
 
                    bool value = (bool) item->GetString().Atoi();
                    if (isSerialChannel)
                        pDetectorParameter = UniDetectorParameter::CreateDetectorParameter(detector_name,
parameter_name,start_period, start_run, end_period, end_run, serial_number, channel_number, value); else
                        pDetectorParameter = UniDetectorParameter::CreateDetectorParameter(detector_name,
parameter_name,start_period, start_run, end_period, end_run, value);
 
                    break;
                }
            case IntType:
                {
                    int count_required = 1;
                    if (isSerialChannel) count_required++, count_required++;
 
                    if (value_count != count_required)
                    {
                        cout<<"Warning: the count of parameters is not equal 1 or 3 ([serial] [channel]
value)"<<endl<<"The current line will be skipped!"<<endl; tokens->Delete(); continue;
                    }
                    if (isSerialChannel)
                    {
                        // get serial number
                        item = (TObjString*) tokens->At(cur_num_item++);
                        serial_number = item->GetString().Atoi();
                        // get channel number
                        item = (TObjString*) tokens->At(cur_num_item++);
                        channel_number = item->GetString().Atoi();
                    }
                    item = (TObjString*) tokens->At(cur_num_item++);
                    tokens->Delete();
 
                    int value = item->GetString().Atoi();
                    if (value == 0)
                    {
                        if (!item->GetString().IsDigit())
                        {
                            cout<<"Error: the parameter value is not integer: '"<<item<<"'"<<endl;
                            continue;
                        }
                    }
 
                    if (isSerialChannel)
                       pDetectorParameter = UniDetectorParameter::CreateDetectorParameter(detector_name,
parameter_name,start_period, start_run, end_period, end_run, serial_number, channel_number, value); else
                       pDetectorParameter = UniDetectorParameter::CreateDetectorParameter(detector_name,
parameter_name,start_period, start_run, end_period, end_run, value);
 
                    break;
                }
            case DoubleType:
                {
                    int count_required = 1;
                    if (isSerialChannel) count_required++, count_required++;
 
                    if (value_count != count_required)
                    {
                        cout<<"Warning: the count of parameters is not equal 1 or 3 ([serial] [channel]
value)"<<endl<<"The current line will be skipped!"<<endl; tokens->Delete(); continue;
                    }
                    if (isSerialChannel)
                    {
                        // get serial number
                        item = (TObjString*) tokens->At(cur_num_item++);
                        serial_number = item->GetString().Atoi();
                        // get channel number
                        item = (TObjString*) tokens->At(cur_num_item++);
                        channel_number = item->GetString().Atoi();
                    }
                    item = (TObjString*) tokens->At(cur_num_item++);
                    tokens->Delete();
 
                    double value = item->GetString().Atof();
                    if (isSerialChannel)
                        pDetectorParameter = UniDetectorParameter::CreateDetectorParameter(detector_name,
parameter_name,start_period, start_run, end_period, end_run, serial_number, channel_number, value); else
                        pDetectorParameter = UniDetectorParameter::CreateDetectorParameter(detector_name,
parameter_name,start_period, start_run, end_period, end_run, value);
 
                    break;
                }
            case IIArrayType:
                {
                    int count_required = 2, size_arr = value_count/2;
                    if (isSerialChannel)
                    {
                        count_required++, count_required++;
                        size_arr--;
                    }
 
                    if ((value_count < count_required) || ((value_count % 2) != 0))
                    {
                        cout<<"Warning: the count of parameters should be greater 2 or 4 ([serial] [channel] values@2)
and should be even"<<endl<<"The current line will be skipped!"<<endl; tokens->Delete(); continue;
                    }
                    if (isSerialChannel)
                    {
                        // get serial number
                        item = (TObjString*) tokens->At(cur_num_item++);
                        serial_number = item->GetString().Atoi();
                        // get channel number
                        item = (TObjString*) tokens->At(cur_num_item++);
                        channel_number = item->GetString().Atoi();
                    }
 
                    int iter = 0, num = count_required-2;
                    IIStructure* pValues = new IIStructure[size_arr];
                    for (; iter < size_arr; iter++)
                    {
                        pValues[iter].int_1 = ((TObjString*) tokens->At(num++))->GetString().Atoi();
                        pValues[iter].int_2 = ((TObjString*) tokens->At(num++))->GetString().Atoi();
                    }
                    tokens->Delete();
 
                    if (isSerialChannel)
                        pDetectorParameter = UniDetectorParameter::CreateDetectorParameter(detector_name,
parameter_name,start_period, start_run, end_period, end_run, serial_number, channel_number, pValues, size_arr); else
                        pDetectorParameter = UniDetectorParameter::CreateDetectorParameter(detector_name,
parameter_name,start_period, start_run, end_period, end_run, pValues, size_arr);
 
                    delete [] pValues;
                    break;
                }
            case IntArrayType:
                {
                    int count_required = 1, size_arr = value_count;
                    if (isSerialChannel)
                    {
                        count_required++, count_required++;
                        size_arr--, size_arr--;
                    }
 
                    if (value_count < count_required)
                    {
                        cout<<"Warning: the count of parameters should be greater 1 or 3 ([serial] [channel] value1
value2...)"<<endl<<"The current line will be skipped!"<<endl; tokens->Delete(); continue;
                    }
                    if (isSerialChannel)
                    {
                        // get serial number
                        item = (TObjString*) tokens->At(cur_num_item++);
                        serial_number = item->GetString().Atoi();
                        // get channel number
                        item = (TObjString*) tokens->At(cur_num_item++);
                        channel_number = item->GetString().Atoi();
                    }
 
                    int iter = 0;
                    int* pValues = new int[size_arr];
                    for (int num = count_required-1; num < value_count; num++,iter++)
                        pValues[iter] = ((TObjString*) tokens->At(num))->GetString().Atoi();
                    tokens->Delete();
 
                    if (isSerialChannel)
                        pDetectorParameter = UniDetectorParameter::CreateDetectorParameter(detector_name,
parameter_name,start_period, start_run, end_period, end_run, serial_number, channel_number, pValues, size_arr); else
                        pDetectorParameter = UniDetectorParameter::CreateDetectorParameter(detector_name,
parameter_name,start_period, start_run, end_period, end_run, pValues, size_arr);
 
                    delete [] pValues;
                    break;
                }
            case DoubleArrayType:
                {
                    int count_required = 1, size_arr = value_count;
                    if (isSerialChannel)
                    {
                        count_required++, count_required++;
                        size_arr--, size_arr--;
                    }
 
                    if (value_count < count_required)
                    {
                        cout<<"Warning: the count of parameters should be greater 1 or 3 ([serial] [channel] value1
value2...)"<<endl<<"The current line will be skipped!"<<endl; tokens->Delete(); continue;
                    }
                    if (isSerialChannel)
                    {
                        // get serial number
                        item = (TObjString*) tokens->At(cur_num_item++);
                        serial_number = item->GetString().Atoi();
                        // get channel number
                        item = (TObjString*) tokens->At(cur_num_item++);
                        channel_number = item->GetString().Atoi();
                    }
 
                    int iter = 0;
                    double* pValues = new double[size_arr];
                    for (int num = count_required-1; num < value_count; num++, iter++)
                        pValues[iter] = ((TObjString*) tokens->At(num))->GetString().Atof();
                    tokens->Delete();
 
                    if (isSerialChannel)
                        pDetectorParameter = UniDetectorParameter::CreateDetectorParameter(detector_name,
parameter_name,start_period, start_run, end_period, end_run, serial_number, channel_number, pValues, size_arr); else
                        pDetectorParameter = UniDetectorParameter::CreateDetectorParameter(detector_name,
parameter_name,start_period, start_run, end_period, end_run, pValues, size_arr);
 
                    delete [] pValues;
                    break;
                }
            case UIntArrayType:
                {
                    int count_required = 1, size_arr = value_count;
                    if (isSerialChannel)
                    {
                        count_required++, count_required++;
                        size_arr--, size_arr--;
                    }
 
                    if (value_count < count_required)
                    {
                        cout<<"Warning: the count of parameters should be greater 1 or 3 ([serial] [channel] value1
value2...)"<<endl<<"The current line will be skipped!"<<endl; tokens->Delete(); continue;
                    }
                    if (isSerialChannel)
                    {
                        // get serial number
                        item = (TObjString*) tokens->At(cur_num_item++);
                        serial_number = item->GetString().Atoi();
                        // get channel number
                        item = (TObjString*) tokens->At(cur_num_item++);
                        channel_number = item->GetString().Atoi();
                    }
 
                    int iter = 0;
                    unsigned int* pValues = new unsigned int[size_arr];
                    for (int num = count_required-1; num < value_count; num++, iter++)
                        pValues[iter] = (unsigned int) ((TObjString*) tokens->At(num))->GetString().Atoll();
                    tokens->Delete();
 
                    if (isSerialChannel)
                        pDetectorParameter = UniDetectorParameter::CreateDetectorParameter(detector_name,
parameter_name,start_period, start_run, end_period, end_run, serial_number, channel_number, pValues, size_arr); else
                        pDetectorParameter = UniDetectorParameter::CreateDetectorParameter(detector_name,
parameter_name,start_period, start_run, end_period, end_run, pValues, size_arr);
 
                    delete [] pValues;
                    break;
                }
            case DchMapArrayType:
                {
                    int count_required = 6, size_arr = value_count/6;
                    if (isSerialChannel)
                        count_required++, count_required++;
 
                    if ((value_count < count_required) || (((value_count-count_required+6) % 6) != 0))
                    {
                        cout<<"Warning: the count of parameters should be greater 6 or 8 ([serial] [channel] values@6)
and must be divisible by 6"<<endl<<"The current line will be skipped!"<<endl; tokens->Delete(); continue;
                    }
                    if (isSerialChannel)
                    {
                        // get serial number
                        item = (TObjString*) tokens->At(cur_num_item++);
                        serial_number = item->GetString().Atoi();
                        // get channel number
                        item = (TObjString*) tokens->At(cur_num_item++);
                        channel_number = item->GetString().Atoi();
                    }
 
                    int iter = 0, num = count_required-6;
                    DchMapStructure* pValues = new DchMapStructure[size_arr];
                    for (; iter < size_arr; iter++)
                    {
                        pValues[iter].plane = ((TObjString*) tokens->At(num++))->GetString().Atoi();
                        pValues[iter].group = ((TObjString*) tokens->At(num++))->GetString().Atoi();
                        pValues[iter].crate = (unsigned int) ((TObjString*) tokens->At(num++))->GetString().Atoll();
                        pValues[iter].slot = ((TObjString*) tokens->At(num++))->GetString().Atoi();
                        pValues[iter].channel_low = ((TObjString*) tokens->At(num++))->GetString().Atoi();
                        pValues[iter].channel_high = ((TObjString*) tokens->At(num++))->GetString().Atoi();
                    }
                    tokens->Delete();
 
                    if (isSerialChannel)
                        pDetectorParameter = UniDetectorParameter::CreateDetectorParameter(detector_name,
parameter_name,start_period, start_run, end_period, end_run, serial_number, channel_number, pValues, size_arr); else
                        pDetectorParameter = UniDetectorParameter::CreateDetectorParameter(detector_name,
parameter_name,start_period, start_run, end_period, end_run, pValues, size_arr);
 
                    delete [] pValues;
                    break;
                }
            case GemMapArrayType:
                {
                    int count_required = 6, size_arr = value_count/6;
                    if (isSerialChannel)
                        count_required++, count_required++;
 
                    if ((value_count < count_required) || (((value_count-count_required+6) % 6) != 0))
                    {
                        cout<<"Warning: the count of parameters should be greater 6 or 8 ([serial] [channel] values@6)
and must be divisible by 6"<<endl<<"The current line will be skipped!"<<endl; tokens->Delete(); continue;
                    }
                    if (isSerialChannel)
                    {
                        // get serial number
                        item = (TObjString*) tokens->At(cur_num_item++);
                        serial_number = item->GetString().Atoi();
                        // get channel number
                        item = (TObjString*) tokens->At(cur_num_item++);
                        channel_number = item->GetString().Atoi();
                    }
 
                    int iter = 0, num = count_required-6;
                    GemMapStructure* pValues = new GemMapStructure[size_arr];
                    for (; iter < size_arr; iter++)
                    {
                        pValues[iter].serial = (unsigned int) ((TObjString*) tokens->At(num++))->GetString().Atoll();
                        pValues[iter].id = ((TObjString*) tokens->At(num++))->GetString().Atoi();
                        pValues[iter].station = ((TObjString*) tokens->At(num++))->GetString().Atoi();
                        pValues[iter].channel_low = ((TObjString*) tokens->At(num++))->GetString().Atoi();
                        pValues[iter].channel_high = ((TObjString*) tokens->At(num++))->GetString().Atoi();
                        pValues[iter].hotZone = ((TObjString*) tokens->At(num++))->GetString().Atoi();
                    }
                    tokens->Delete();
 
                    if (isSerialChannel)
                        pDetectorParameter = UniDetectorParameter::CreateDetectorParameter(detector_name,
parameter_name,start_period, start_run, end_period, end_run, serial_number, channel_number, pValues, size_arr); else
                        pDetectorParameter = UniDetectorParameter::CreateDetectorParameter(detector_name,
parameter_name,start_period, start_run, end_period, end_run, pValues, size_arr);
 
                    delete [] pValues;
                    break;
                }
            case GemPedestalArrayType:
                {
                    int count_required = 4, size_arr = value_count/4;
                    if (isSerialChannel)
                        count_required++, count_required++;
 
                    if ((value_count < count_required) || (((value_count-count_required+4) % 4) != 0))
                    {
                        cout<<"Warning: the count of parameters should be greater 4 or 6 ([serial] [channel] values@6)
and must be divisible by 4"<<endl<<"The current line will be skipped!"<<endl; tokens->Delete(); continue;
                    }
                    if (isSerialChannel)
                    {
                        // get serial number
                        item = (TObjString*) tokens->At(cur_num_item++);
                        serial_number = item->GetString().Atoi();
                        // get channel number
                        item = (TObjString*) tokens->At(cur_num_item++);
                        channel_number = item->GetString().Atoi();
                    }
 
                    int iter = 0, num = count_required-4;
                    GemPedestalStructure* pValues = new GemPedestalStructure[size_arr];
                    for (; iter < size_arr; iter++)
                    {
                        pValues[iter].serial = (unsigned int) ((TObjString*) tokens->At(num++))->GetString().Atoll();
                        pValues[iter].channel = ((TObjString*) tokens->At(num++))->GetString().Atoi();
                        pValues[iter].pedestal = ((TObjString*) tokens->At(num++))->GetString().Atoi();
                        pValues[iter].noise = ((TObjString*) tokens->At(num++))->GetString().Atoi();
                    }
                    tokens->Delete();
 
                    if (isSerialChannel)
                        pDetectorParameter = UniDetectorParameter::CreateDetectorParameter(detector_name,
parameter_name,start_period, start_run, end_period, end_run, serial_number, channel_number, pValues, size_arr); else
                        pDetectorParameter = UniDetectorParameter::CreateDetectorParameter(detector_name,
parameter_name,start_period, start_run, end_period, end_run, pValues, size_arr);
 
                    delete [] pValues;
                    break;
                }
            case TriggerMapArrayType:
                {
                    int count_required = 3, size_arr = value_count/3;
                    if (isSerialChannel)
                        count_required++, count_required++;
 
                    if ((value_count < count_required) || (((value_count-count_required+3) % 3) != 0))
                    {
                        cout<<"Warning: the count of parameters should be greater 3 or 5 ([serial] [channel] values@3)
and must be divisible by 3"<<endl<<"The current line will be skipped!"<<endl; tokens->Delete(); continue;
                    }
                    if (isSerialChannel)
                    {
                        // get serial number
                        item = (TObjString*) tokens->At(cur_num_item++);
                        serial_number = item->GetString().Atoi();
                        // get channel number
                        item = (TObjString*) tokens->At(cur_num_item++);
                        channel_number = item->GetString().Atoi();
                    }
 
                    int iter = 0, num = count_required-3;
                    TriggerMapStructure* pValues = new TriggerMapStructure[size_arr];
                    for (; iter < size_arr; iter++)
                    {
                        pValues[iter].serial = (unsigned int) ((TObjString*) tokens->At(num++))->GetString().Atoll();
                        pValues[iter].slot = (unsigned int) ((TObjString*) tokens->At(num++))->GetString().Atoll();
                        pValues[iter].channel = ((TObjString*) tokens->At(num++))->GetString().Atoi();
                    }
                    tokens->Delete();
 
                    if (isSerialChannel)
                        pDetectorParameter = UniDetectorParameter::CreateDetectorParameter(detector_name,
parameter_name,start_period, start_run, end_period, end_run, serial_number, channel_number, pValues, size_arr); else
                        pDetectorParameter = UniDetectorParameter::CreateDetectorParameter(detector_name,
parameter_name,start_period, start_run, end_period, end_run, pValues, size_arr);
 
                    delete [] pValues;
                    break;
                }
            default:
                {
                    cout<<"Error: the type of parameter ("<<parameter_name<<") is not supported for parsing (txt)
now"<<endl; continue;
                }
        }// switch (parameter_type)
 
        // clean memory
        if (pDetectorParameter)
            delete pDetectorParameter;
    }
 
    txtFile.close();
    delete connDb;
 
    return 0;
}*/