---

cResultBase.cpp

Go to the documentation of this file.

/******************************************************************************/
/*                                                                            */
/* POLiTe - Persistent Object Library Test                                    */
/*                                        Ph.D. Thesis by Mgr. Michal Kopecky */
/*                                                                            */
/* Charles University Prague                                                  */
/*                                                                            */
/******************************************************************************/
/*                                                                            */
/* File name: ...                                                             */
/* Module: ......                                                             */
/*                                                                            */
/******************************************************************************/

// Standard Header(s)
#include <stdio.h>

// Common POLiTe Header(s)
#include <lDefs.h>
#include <lTrace.h>

// INCLUDE OWN HEADER
#include <cResultBase.h>

// Other POLiTe Header(s)
#include <cComplexQuery.h>
#include <cConnection.h>
#include <cCursor.h>
#include <cObjectBuffer.h>
#include <cProtoBase.h>

ResultBase::ResultBase()
{
#ifdef NO_DATABASE_PRESENT
        _row_counter = 0;
#endif
        _query = NULL;
        _isValRef = false;
        _sql_select = NULL;
        _queryPrototype = NULL;
        _queryConnection = NULL;
        _cursor = NULL;
};

ResultBase::~ResultBase()
{
        StrFree(_sql_select);
        if (_query) delete(_query);
        if (_cursor)
        {
                _cursor->_Close();
                delete(_cursor);
        };
        StrFree(_sql_select);
};

bool ResultBase::Open(){
#ifdef C_RESULTBASE_TRACE
logmsg("ResultBase::Open() invoked");
#endif
        _isValRef = false;
#ifdef NO_DATABASE_PRESENT
        _row_counter = 0;
#endif
        if (_cursor == NULL)
                return false;
        if (!ObjectCache.UpdateAll(_cursor->_DatabaseConnection))
                return(false);
        if (
                _cursor->_Open()
                && _cursor->_Prepare(_sql_select)
                && _cursor->_Execute()
                )
        {
                //BIND OUTPUT VARIABLES NOW!
                _queryPrototype->_BindPtr(_cursor);
                return true;
        }
        return false;
};

bool ResultBase::Close(){
#ifdef C_RESULTBASE_TRACE
        logmsg("ResultBase::Close() invoked");
#endif
        _isValRef = false;
        return _cursor == NULL ? false : _cursor->_Close();
};

class  ResultBase &ResultBase::operator++ () {
#ifdef C_RESULTBASE_TRACE
logmsg("ResultBase++ invoked");
#endif
        Next();
        return *this;
};

class  ResultBase &ResultBase::operator += (long int n) {
#ifdef C_RESULTBASE_TRACE
logmsg("ResultBase += long int invoked");
#endif
        while ((n-- > 0) && ((++(*this)) != DBNULL))
          ;
        return *this;
};

bool ResultBase::operator== (const ResultBase &Q) const {
#ifdef C_RESULTBASE_TRACE
logmsg("ResultBase==invoked");
#endif
        return (this == &Q);
};

bool ResultBase::operator!= (const ResultBase &Q) const {
#ifdef C_RESULTBASE_TRACE
logmsg("ResultBase!=invoked");
#endif
        return (this != &Q);
};

bool ResultBase::Prev() {
#ifdef C_RESULTBASE_TRACE
logmsg("ResultBase::Prev() invoked");
#endif
        long i;
        if ((i = Position()) > 0)
                return GoToPosition(i-1);
        return true;
};

bool ResultBase::Next() {
#ifdef C_RESULTBASE_TRACE
logmsg("ResultBase::Next() invoked");
#endif
        _isValRef = false;
        bool _retval;
        if (_cursor == NULL)
        {
                _Connection=NULL;
                _ObjectIdentification._prototype=NULL;
                StrFree(_ObjectIdentification._SelectKeyValues);
                return false;
        };
#ifdef NO_DATABASE_PRESENT
        if (++_row_counter > MAX_FETCHES_FROM_DUMMY_DATABASE)
        {
                _Connection=NULL;
                _ObjectIdentification._prototype=NULL;
                StrFree(_ObjectIdentification._SelectKeyValues);
                return false;
        };
#else
        if (!(_cursor->_FetchNext()))
        {
                // No data were found. Make this reference equal to DBNULL
                _Connection=NULL;
                _ObjectIdentification._prototype=NULL;
                StrFree(_ObjectIdentification._SelectKeyValues);
                return false;
        };
#endif
        if (_queryPrototype->IsObject())
        {
                // Object descendants create instances directly
                // pointer is set as transient pointer to that instance
                _Connection=NULL;
                _ObjectIdentification._object=_queryPrototype->New();
                _retval = _queryPrototype->_ImportAttributes(*(Object *)(_ObjectIdentification._object));
        }
        else
        {
                // Other classes set only database pointers
                _Connection=_queryConnection;
                _ObjectIdentification._prototype=_queryPrototype;
                _retval = _queryPrototype->_ImportKeyAttributes(*this);
        };
#ifdef AUTO_VIRTUAL_OBJECT_LOAD
        // set the prototype according to the class name for PersistentObject descendants
        if (_queryPrototype->IsPersistentObject())
        {
                _ObjectIdentification._prototype=_queryPrototype->_PtrPrototype();
        };
#endif //AUTO_VIRTUAL_OBJECT_LOAD
        _isValRef = _retval;
        return _retval;
};

bool ResultBase::First() {
#ifdef C_RESULTBASE_TRACE
        logmsg("ResultBase::First() invoked");
#endif
        return Open() && Next();
};

bool ResultBase::Last() {
#ifdef C_RESULTBASE_TRACE
logmsg("ResultBase::Last() invoked");
#endif
        while (Next())
                ;
        return true;
};

long ResultBase::Count() {
#ifdef C_RESULTBASE_TRACE
        logmsg("ResultBase::Count() invoked");
#endif
        long _p = Position();
        Last();
        long _retval = Position();
        GoToPosition(_p);
        return _retval;
};

bool ResultBase::IsOnFirst() {
#ifdef C_RESULTBASE_TRACE
        logmsg("ResultBase::IsOnFirst() invoked");
#endif
        return(Position() == 1);
};


bool ResultBase::IsOnLast() {
#ifdef C_RESULTBASE_TRACE
        logmsg("ResultBase::IsOnLast() invoked");
#endif
        return(Count() == Position());
};

bool ResultBase::GoToPosition (long Pos) {
#ifdef C_RESULTBASE_TRACE
        logmsg("ResultBase::GoToPosition() invoked");
#endif
        if (Pos < 1)
                return false;
        bool _retval = true;
        if (Pos < Position())
                _retval = _retval && Open();
        long i=Position();
        for( ; i < Pos; i++)
                _retval = _retval && Next();
        return(_retval);
};

long ResultBase::Position() {
#ifdef C_RESULTBASE_TRACE
logmsg("ResultBase::Position() invoked");
#endif
        return _cursor == NULL ? (long)-1 : _cursor->_Position();
};

bool ResultBase::_SetSqlCommand(char *SQLcommand) {
#ifdef C_RESULTBASE_TRACE
logmsg("ResultBase::_SetSqlCommand() invoked");
#endif
        if (SQLcommand != NULL)
                StrCpy(_sql_select,SQLcommand);
        return true;
};


bool ResultBase::operator == (
        const class RefBase &DbPtr
        ) const
{
        return (this->_Connection == DbPtr._Connection)
                &&(this->_ObjectIdentification == DbPtr._ObjectIdentification);
};

bool ResultBase::operator != (
        const class RefBase &DbPtr
        ) const
{
        return (this->_Connection != DbPtr._Connection)
                ||(this->_ObjectIdentification != DbPtr._ObjectIdentification);
};

---