ElogTrigger.cxx

Go to the documentation of this file.

// ----------------------------------------------------------------------
//                    ElogTrigger cxx file
//                      Generated 27-11-2017
// ----------------------------------------------------------------------
 
#include "ElogTrigger.h"
 
#include "TSQLServer.h"
#include "TSQLStatement.h"
 
#include <iostream>
using namespace std;
 
/* GENERATED CLASS MEMBERS (SHOULD NOT BE CHANGED MANUALLY) */
// -----   Constructor with database connection   -----------------------
ElogTrigger::ElogTrigger(ElogConnection* db_connect, int trigger_id, TString trigger_info, bool is_active)
{
    connectionDB = db_connect;
 
    i_trigger_id = trigger_id;
    str_trigger_info = trigger_info;
    b_is_active = is_active;
}
 
// -----   Destructor   -------------------------------------------------
ElogTrigger::~ElogTrigger()
{
    if (connectionDB)
        delete connectionDB;
}
 
// -----   Creating new trigger in the database  ---------------------------
ElogTrigger* ElogTrigger::CreateTrigger(TString trigger_info, bool is_active)
{
    ElogConnection* connDb = ElogConnection::Open();
    if (connDb == nullptr)
        return nullptr;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = TString::Format("insert into trigger_(trigger_info, is_active) "
                                  "values ($1, $2)");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetString(0, trigger_info);
    stmt->SetInt(1, is_active);
 
    // inserting new trigger to the Database
    if (!stmt->Process()) {
        cout << "ERROR: inserting new trigger to the Database has been failed" << endl;
        delete stmt;
        delete connDb;
        return nullptr;
    }
 
    delete stmt;
 
    // getting last inserted ID
    int trigger_id;
    TSQLStatement* stmt_last = db_server->Statement("SELECT currval(pg_get_serial_sequence('trigger_','trigger_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 {
            trigger_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_trigger_id;
    tmp_trigger_id = trigger_id;
    TString tmp_trigger_info;
    tmp_trigger_info = trigger_info;
    bool tmp_is_active;
    tmp_is_active = is_active;
 
    return new ElogTrigger(connDb, tmp_trigger_id, tmp_trigger_info, tmp_is_active);
}
 
// -----  Get trigger from the database  ---------------------------
ElogTrigger* ElogTrigger::GetTrigger(int trigger_id)
{
    ElogConnection* connDb = ElogConnection::Open();
    if (connDb == nullptr)
        return nullptr;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = TString::Format("select trigger_id, trigger_info, is_active "
                                  "from trigger_ "
                                  "where trigger_id = %d",
                                  trigger_id);
    TSQLStatement* stmt = db_server->Statement(sql);
 
    // get trigger from the database
    if (!stmt->Process()) {
        cout << "ERROR: getting trigger 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: trigger was not found in the database" << endl;
 
        delete stmt;
        delete connDb;
        return nullptr;
    }
 
    int tmp_trigger_id;
    tmp_trigger_id = stmt->GetInt(0);
    TString tmp_trigger_info;
    tmp_trigger_info = stmt->GetString(1);
    bool tmp_is_active;
    tmp_is_active = stmt->GetInt(2);
 
    delete stmt;
 
    return new ElogTrigger(connDb, tmp_trigger_id, tmp_trigger_info, tmp_is_active);
}
 
// -----  Get trigger from the database by unique key  --------------
ElogTrigger* ElogTrigger::GetTrigger(TString trigger_info)
{
    ElogConnection* connDb = ElogConnection::Open();
    if (connDb == nullptr)
        return nullptr;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = TString::Format("select trigger_id, trigger_info, is_active "
                                  "from trigger_ "
                                  "where lower(trigger_info) = lower('%s')",
                                  trigger_info.Data());
    TSQLStatement* stmt = db_server->Statement(sql);
 
    // get trigger from the database
    if (!stmt->Process()) {
        cout << "ERROR: getting trigger 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: trigger was not found in the database" << endl;
 
        delete stmt;
        delete connDb;
        return nullptr;
    }
 
    int tmp_trigger_id;
    tmp_trigger_id = stmt->GetInt(0);
    TString tmp_trigger_info;
    tmp_trigger_info = stmt->GetString(1);
    bool tmp_is_active;
    tmp_is_active = stmt->GetInt(2);
 
    delete stmt;
 
    return new ElogTrigger(connDb, tmp_trigger_id, tmp_trigger_info, tmp_is_active);
}
 
// -----  Check trigger exists in the database  ---------------------------
int ElogTrigger::CheckTriggerExists(int trigger_id)
{
    ElogConnection* connDb = ElogConnection::Open();
    if (connDb == nullptr)
        return -1;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = TString::Format("select 1 "
                                  "from trigger_ "
                                  "where trigger_id = %d",
                                  trigger_id);
    TSQLStatement* stmt = db_server->Statement(sql);
 
    // get trigger from the database
    if (!stmt->Process()) {
        cout << "ERROR: getting trigger 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;
}
 
// -----  Check trigger exists in the database by unique key  --------------
int ElogTrigger::CheckTriggerExists(TString trigger_info)
{
    ElogConnection* connDb = ElogConnection::Open();
    if (connDb == nullptr)
        return -1;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = TString::Format("select 1 "
                                  "from trigger_ "
                                  "where lower(trigger_info) = lower('%s')",
                                  trigger_info.Data());
    TSQLStatement* stmt = db_server->Statement(sql);
 
    // get trigger from the database
    if (!stmt->Process()) {
        cout << "ERROR: getting trigger 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 trigger from the database  ---------------------------
int ElogTrigger::DeleteTrigger(int trigger_id)
{
    ElogConnection* connDb = ElogConnection::Open();
    if (connDb == nullptr)
        return -1;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = TString::Format("delete from trigger_ "
                                  "where trigger_id = $1");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetInt(0, trigger_id);
 
    // delete trigger from the dataBase
    if (!stmt->Process()) {
        cout << "ERROR: deleting trigger from the dataBase has been failed" << endl;
 
        delete stmt;
        delete connDb;
        return -2;
    }
 
    delete stmt;
    delete connDb;
    return 0;
}
 
// -----  Delete trigger from the database by unique key  --------------
int ElogTrigger::DeleteTrigger(TString trigger_info)
{
    ElogConnection* connDb = ElogConnection::Open();
    if (connDb == nullptr)
        return -1;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = TString::Format("delete from trigger_ "
                                  "where lower(trigger_info) = lower($1)");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetString(0, trigger_info);
 
    // delete trigger from the dataBase
    if (!stmt->Process()) {
        cout << "ERROR: deleting trigger from the DataBase has been failed" << endl;
 
        delete stmt;
        delete connDb;
        return -2;
    }
 
    delete stmt;
    delete connDb;
    return 0;
}
 
// -----  Print all 'triggers'  ---------------------------------
int ElogTrigger::PrintAll()
{
    ElogConnection* connDb = ElogConnection::Open();
    if (connDb == nullptr)
        return -1;
 
    TSQLServer* db_server = connDb->GetSQLServer();
 
    TString sql = TString::Format("select trigger_id, trigger_info, is_active "
                                  "from trigger_");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    // get all 'triggers' from the database
    if (!stmt->Process()) {
        cout << "ERROR: getting all 'triggers' 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 'trigger_':" << endl;
    while (stmt->NextResultRow()) {
        cout << "trigger_id: ";
        cout << (stmt->GetInt(0));
        cout << ", trigger_info: ";
        cout << (stmt->GetString(1));
        cout << ", is_active: ";
        cout << (stmt->GetInt(2));
        cout << "." << endl;
    }
 
    delete stmt;
    delete connDb;
 
    return 0;
}
 
// Setters functions
int ElogTrigger::SetTriggerInfo(TString trigger_info)
{
    if (!connectionDB) {
        cout << "CRITICAL ERROR: Connection object is null" << endl;
        return -1;
    }
 
    TSQLServer* db_server = connectionDB->GetSQLServer();
 
    TString sql = TString::Format("update trigger_ "
                                  "set trigger_info = $1 "
                                  "where trigger_id = $2");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetString(0, trigger_info);
    stmt->SetInt(1, i_trigger_id);
 
    // write new value to the database
    if (!stmt->Process()) {
        cout << "ERROR: updating information about trigger has been failed" << endl;
 
        delete stmt;
        return -2;
    }
 
    str_trigger_info = trigger_info;
 
    delete stmt;
    return 0;
}
 
int ElogTrigger::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 trigger_ "
                                  "set is_active = $1 "
                                  "where trigger_id = $2");
    TSQLStatement* stmt = db_server->Statement(sql);
 
    stmt->NextIteration();
    stmt->SetInt(0, is_active);
    stmt->SetInt(1, i_trigger_id);
 
    // write new value to the database
    if (!stmt->Process()) {
        cout << "ERROR: updating information about trigger has been failed" << endl;
 
        delete stmt;
        return -2;
    }
 
    b_is_active = is_active;
 
    delete stmt;
    return 0;
}
 
// -----  Print current trigger  ---------------------------------------
void ElogTrigger::Print()
{
    cout << "Table 'trigger_'";
    cout << ". trigger_id: " << i_trigger_id << ". trigger_info: " << str_trigger_info << ". is_active: " << b_is_active
         << endl;
 
    return;
}
/* END OF GENERATED CLASS PART (SHOULD NOT BE CHANGED MANUALLY) */