ElogBeam.cxx

Go to the documentation of this file.

// ----------------------------------------------------------------------
//                    ElogBeam cxx file
//                      Generated 27-11-2017
// ----------------------------------------------------------------------
 
#include "ElogBeam.h"
 
#include "TSQLServer.h"
#include "TSQLStatement.h"
 
#include <iostream>
using namespace std;
 
/* GENERATED CLASS MEMBERS (SHOULD NOT BE CHANGED MANUALLY) */
// -----   Constructor with database connection   -----------------------
ElogBeam::ElogBeam(ElogConnection* db_connect, TString beam, bool is_active)
{
    connectionDB = db_connect;
 
    str_beam = beam;
    b_is_active = is_active;
}
 
// -----   Destructor   -------------------------------------------------
ElogBeam::~ElogBeam()
{
    if (connectionDB)
        delete connectionDB;
}
 
// -----   Creating new beam in the database  ---------------------------
ElogBeam* ElogBeam::CreateBeam(TString beam, bool is_active)
{
    ElogConnection* connDb = ElogConnection::Open();
    if (connDb == nullptr)
        return nullptr;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = TString::Format("insert into beam_(beam, is_active) "
                                  "values ($1, $2)");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetString(0, beam);
    stmt->SetInt(1, is_active);
 
    // inserting new beam to the Database
    if (!stmt->Process()) {
        cout << "ERROR: inserting new beam to the Database has been failed" << endl;
        delete stmt;
        delete connDb;
        return nullptr;
    }
 
    delete stmt;
 
    TString tmp_beam;
    tmp_beam = beam;
    bool tmp_is_active;
    tmp_is_active = is_active;
 
    return new ElogBeam(connDb, tmp_beam, tmp_is_active);
}
 
// -----  Get beam from the database  ---------------------------
ElogBeam* ElogBeam::GetBeam(TString beam)
{
    ElogConnection* connDb = ElogConnection::Open();
    if (connDb == nullptr)
        return nullptr;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = TString::Format("select beam, is_active "
                                  "from beam_ "
                                  "where lower(beam) = lower('%s')",
                                  beam.Data());
    TSQLStatement* stmt = db_server->Statement(sql);
 
    // get beam from the database
    if (!stmt->Process()) {
        cout << "ERROR: getting beam 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: beam was not found in the database" << endl;
 
        delete stmt;
        delete connDb;
        return nullptr;
    }
 
    TString tmp_beam;
    tmp_beam = stmt->GetString(0);
    bool tmp_is_active;
    tmp_is_active = stmt->GetInt(1);
 
    delete stmt;
 
    return new ElogBeam(connDb, tmp_beam, tmp_is_active);
}
 
// -----  Check beam exists in the database  ---------------------------
int ElogBeam::CheckBeamExists(TString beam)
{
    ElogConnection* connDb = ElogConnection::Open();
    if (connDb == nullptr)
        return -1;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = TString::Format("select 1 "
                                  "from beam_ "
                                  "where lower(beam) = lower('%s')",
                                  beam.Data());
    TSQLStatement* stmt = db_server->Statement(sql);
 
    // get beam from the database
    if (!stmt->Process()) {
        cout << "ERROR: getting beam 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 beam from the database  ---------------------------
int ElogBeam::DeleteBeam(TString beam)
{
    ElogConnection* connDb = ElogConnection::Open();
    if (connDb == nullptr)
        return -1;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = TString::Format("delete from beam_ "
                                  "where lower(beam) = lower($1)");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetString(0, beam);
 
    // delete beam from the dataBase
    if (!stmt->Process()) {
        cout << "ERROR: deleting beam from the dataBase has been failed" << endl;
 
        delete stmt;
        delete connDb;
        return -2;
    }
 
    delete stmt;
    delete connDb;
    return 0;
}
 
// -----  Print all 'beams'  ---------------------------------
int ElogBeam::PrintAll()
{
    ElogConnection* connDb = ElogConnection::Open();
    if (connDb == nullptr)
        return -1;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = TString::Format("select beam, is_active "
                                  "from beam_");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    // get all 'beams' from the database
    if (!stmt->Process()) {
        cout << "ERROR: getting all 'beams' 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 'beam_':" << endl;
    while (stmt->NextResultRow()) {
        cout << "beam: ";
        cout << (stmt->GetString(0));
        cout << ", is_active: ";
        cout << (stmt->GetInt(1));
        cout << "." << endl;
    }
 
    delete stmt;
    delete connDb;
 
    return 0;
}
 
// Setters functions
int ElogBeam::SetBeam(TString beam)
{
    if (!connectionDB) {
        cout << "CRITICAL ERROR: Connection object is null" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connectionDB->GetSQLServer();
 
    TString sql = TString::Format("update beam_ "
                                  "set beam = $1 "
                                  "where beam = $2");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetString(0, beam);
    stmt->SetString(1, str_beam);
 
    // write new value to the database
    if (!stmt->Process()) {
        cout << "ERROR: updating information about beam has been failed" << endl;
 
        delete stmt;
        return -2;
    }
 
    str_beam = beam;
 
    delete stmt;
    return 0;
}
 
int ElogBeam::SetIsActive(bool is_active)
{
    if (!connectionDB) {
        cout << "CRITICAL ERROR: Connection object is null" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connectionDB->GetSQLServer();
 
    TString sql = TString::Format("update beam_ "
                                  "set is_active = $1 "
                                  "where beam = $2");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetInt(0, is_active);
    stmt->SetString(1, str_beam);
 
    // write new value to the database
    if (!stmt->Process()) {
        cout << "ERROR: updating information about beam has been failed" << endl;
 
        delete stmt;
        return -2;
    }
 
    b_is_active = is_active;
 
    delete stmt;
    return 0;
}
 
// -----  Print current beam  ---------------------------------------
void ElogBeam::Print()
{
    cout << "Table 'beam_'";
    cout << ". beam: " << str_beam << ". is_active: " << b_is_active << endl;
 
    return;
}
/* END OF GENERATED CLASS PART (SHOULD NOT BE CHANGED MANUALLY) */