DBBase.cpp

Go to the documentation of this file.

/*
 * DBBase.cpp
 *
 *  This file is part of the HausmiSEP project
 *
 *  Copyright (C) 2012, 2013 Marco Alvarado (malvcr@gmail.com)
 *
 *  This program is free software: you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation, either version 3 of the License, or
 *  (at your option) any later version.
 *
 *  This program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */

#include <HSEPData/DBBase.h>

#include <stdio.h>

namespace HSEPData {

    string& BaseWhatMethod(string& pMessageRef, exception* pExceptionPtr) {

        char vTemp[10240];

        sprintf(vTemp,
                "# ERR: Exception in %s (%s) on line %d\n# ERR: %s ()\n",
                __FILE__,
                __FUNCTION__,
                __LINE__,
                pExceptionPtr->what());

        pMessageRef = string(vTemp);

        return pMessageRef;

    } // BaseWhatMethod


    bool QueryUniqueCycle::execute(DBResultSet* pResultSetPtr,bool pIsFirst,bool pIsLast) {

        DBMetadata vMetadata;
        pResultSetPtr->getMetadata(vMetadata);

        vMetadata.forEach([&](DBMetadataField* xField) {
            string vColumnName = xField->aColumnName;
            string vValue      = pResultSetPtr->getString(vColumnName);
            aResults.put(vColumnName,vValue);
        });

        pResultSetPtr->destroyMetadata(vMetadata); // to eliminate heap based elements

        return true; // TODO: check what need to be returned

    } // QueryUniqueCycle::execute

    string& QueryUniqueCycle::getValueRef(string& pKeyRef) {
        return aResults.ref(pKeyRef);
    } // QueryUniqueCycle::getValue


    void DBResultSet::destroyMetadata(DBMetadata& pMetadataRef) {

        pMetadataRef.forEach([](DBMetadataField* vField){
            DBMetadataField* xField = vField;
            delete xField;
        });
        pMetadataRef.clear();

    } // DBResultSet::destroyMetadata

    // DBStatement --------------------------------------------

    int DBStatement::cycleQuery(CycleBase& pCycleRef) {
        int vResult;
        DBResultSet* vResultSet = executeQueryPtr();
        if (vResultSet) {
            vResult = vResultSet->forEach(pCycleRef);
            delete vResultSet;
        }
        else {
            vResult = -1;
        }
        return vResult;
    } //  DBStatement::cycleQuery

    int DBStatement::cycleQuery(ExecuteFunctionType pFunction) {
        int vResult;
        DBResultSet* vResultSet = executeQueryPtr();
        if (vResultSet) {
            vResult = vResultSet->forEach(pFunction);
            delete vResultSet;
        }
        else {
            vResult = -1;
        }
        return vResult;
    } //  DBStatement::cycleQuery

    int DBStatement::cycleQuery(DBParameters& pParametersRef, ExecuteFunctionType pFunction) {
        int vResult;
        DBResultSet* vResultSet = executeQueryPtr(pParametersRef);
        if (nullptr != vResultSet) {
            vResult = vResultSet->forEach(pFunction);
            delete vResultSet;
        }
        else {
            vResult = -1;
        }
        return vResult;
    }//  DBStatement::cycleQuery

    int DBStatement::cycleQuery(DBParameters& pParametersRef, CycleBase& pCycleRef) {
        int vResult;
        DBResultSet* vResultSet = executeQueryPtr(pParametersRef);
        if (vResultSet) {
            vResult = vResultSet->forEach(pCycleRef);
            delete vResultSet;
        }
        else {
            vResult = -1;
        }
        return vResult;
    }//  DBStatement::cycleQuery


    DBException::DBException(exception& pExceptionRef, WhatMethod pMethod) {
        pMethod(aMessage, &pExceptionRef);
    }
    DBException::DBException(exception& pExceptionRef) {
        BaseWhatMethod(aMessage,&pExceptionRef);
    }
    const char* DBException::what() const throw() {
        return aMessage.c_str();
    }

} // HSEPData namespace