Developers Manual Project homepage

O3DBIRecordSet.cpp

Go to the documentation of this file.

#include "O3DBIRecordSet.h"
#include "O3DBIException.h"
#include "O3DBIError.h"
#include <algorithm>            // Std lib algorithms

// ----------------------------------------------------------------------------
// O3DBIRecordSet construction/destruction

O3DBIRecordSet::O3DBIRecordSet()
{

}

O3DBIRecordSet::O3DBIRecordSet(const O3DBIRecordSet& records)
{
    _records = records._records;
}

O3DBIRecordSet::O3DBIRecordSet(TRecordSetConstIter& first,
                               TRecordSetConstIter& last)
{
    _records.reserve(last - first);
    std::copy(first, last, _records.begin());   
}

O3DBIRecordSet::~O3DBIRecordSet()
{

}

// ----------------------------------------------------------------------------
// O3DBIRecordSet operations

bool O3DBIRecordSet::operator==(const O3DBIRecordSet& other) const
{
    if (_records.size() != other._records.size())
        return false;
    return std::equal(_records.begin(), _records.end(),
        other._records.begin());
}

TRecordIndex O3DBIRecordSet::InsertRecord(const O3DBIRecord& record)
{
    // The first inserted record appoints the size (number of fields) of all
    // subsequent records!
    if (_records.size() > 0 &&
        _records[0].GetFieldCount() != record.GetFieldCount())
        throw new O3DBIException(O3DBI_INVALID_NUMOFFIELDS,
        O3DBIErrorTxt::pchInvalidNumOfFields, _T("O3DBIRecordSet::InsertRecord"),
        this);
    _records.push_back(record);
    return (_records.size() - 1);
}

O3DBIRecord O3DBIRecordSet::GetRecord(TRecordIndex index) const
{
    if (index >= _records.size())
        throw new O3DBIException(O3DBI_INDEX_OUTOFBOUNDS,
        O3DBIErrorTxt::pchIndexOutOfBounds, _T("O3DBIRecordSet::GetRecord"),
        this);
    return _records[index];
}

const O3DBIRecord& O3DBIRecordSet::operator[](TRecordIndex index) const
{
    if (index >= _records.size())
        throw new O3DBIException(O3DBI_INDEX_OUTOFBOUNDS,
        O3DBIErrorTxt::pchIndexOutOfBounds, _T("O3DBIRecordSet::operator[]"),
        this);
    return _records[index];
}

TO3DBIResult O3DBIRecordSet::RemoveRecord(const O3DBIRecord& record)
{
    TRecordSetIter iter = std::find(_records.begin(), _records.end(), record);
    if (iter != _records.end())
    {
        _records.erase(iter);
        return OSUCCESS;
    } else {
        return OFAILED;
    }
}

TO3DBIResult O3DBIRecordSet::RemoveRecord(TRecordIndex index)
{
    if (index >= _records.size())
        throw new O3DBIException(O3DBI_INDEX_OUTOFBOUNDS,
        O3DBIErrorTxt::pchIndexOutOfBounds, _T("O3DBIRecordSet::RemoveRecord"),
        this);
    return RemoveRecord((*this)[index]);
}

TRecordSet& O3DBIRecordSet::GetRecords()
{
    return _records;
}

TRecordSetSize O3DBIRecordSet::GetRecordCount() const
{
    return _records.size();
}

void O3DBIRecordSet::CancelModified()
{
    TRecordSetIter iter = _records.begin();
    while (iter != _records.end())
    {
        (*iter).CancelModified();
        ++iter;
    }
}

bool O3DBIRecordSet::IsModified() const
{
    TRecordSetConstIter iter = _records.begin();
    while (iter != _records.end() && ! (*iter).IsModified())
        ++iter;
    return (iter != _records.end());
}

TO3DBIString O3DBIRecordSet::ToString() const
{
    _TCHAR buffer[512];
    int p;
    p = ::_stprintf(buffer, _T("O3DBIRecordSet at: 0x%x\n"), this);
    if (_records.size() == 0)
    {
        ::_tcscpy(buffer + p, _T("\t<contains no records>\n"));
        return TO3DBIString(buffer);
    } else {
        ::_stprintf(buffer + p, _T("O3DBIRecordSet contains %d records"),
            GetRecordCount());
    }
    TO3DBIString str(buffer);
    TRecordSetConstIter iter = _records.begin();
    while (iter != _records.end())
    {
        str += (*iter).ToString();
        ++iter;
    }
    return str;
}

// ----------------------------------------------------------------------------
// O3DBIObject unit test 

#ifdef __TEST__
bool O3DBIRecordSet::TestMe()
{
    STDOUT << _T("Entering test of O3DBIRecordSet >>>") << LF;
    try
    {
        O3DBIRecordSet recordset;

        O3DBIDataField field1(_T("EMPNO"), 12);
        O3DBIDataField field2(_T("EMPNAME"), _T("Scott Tiger"));
        O3DBIDataField field3(_T("SALARY"), 2400.0);

        // Fill a record with three fields
        O3DBIRecord record;
        record.InsertField(field1);
        record.InsertField(field2);
        record.InsertField(field3);

        // Fill a record set with 100 records
        for (int i = 0; i <= 100; i++)
        {
            recordset.InsertRecord(record);
        }
        STDOUT << recordset.ToString().c_str() << LF;
    }
    catch (O3DBIException* pEx)
    {
        PRINT_EXCEPTION(pEx);
        delete pEx;
    }
    STDOUT << _T("<<< Test of O3DBIRecordSet finished!") << LF << LF;
    return true;
}
#endif

---

Generated on Sun Jan 23 11:36:34 2005 for Oracle Object Oriented Database Interface (O3DBI) by  1.3.9.1