---

CdbBdbNTupleSimpleImplP.cc

Go to the documentation of this file.

// File and Version Information:
//      $Id: CdbBdbNTupleSimpleImplP.cc,v 1.2 2004/08/06 05:54:31 bartoldu Exp $

/// The implementation file for the CdbBdbNTupleSimpleImplP class
/**
  * @see CdbBdbNTupleSimpleImplP
  */

#include "BaBar/BaBar.hh"

#if !defined(OO_DDL_TRANSLATION)
#include "CdbBdbTable/CdbBdbNTupleSimpleImplP.hh"
#endif // OO_DDL_TRANSLATION

#include <iostream>
#include <assert.h>
using std::cout;
using std::endl;

template< class E >
CdbBdbNTupleSimpleImplP<E>::CdbBdbNTupleSimpleImplP( d_ULong                         theNumberOfColumns,
                                                     const std::string&              theName,
                                                     const std::string&              theDescription,
                                                     const std::vector<std::string>& theColumnNames ) :
    CdbBdbNTupleP<E>( theNumberOfColumns,
                      theName,
                      theDescription,
                      theColumnNames ),
    _rows(0),
    _dataRef(0)
{
    _dataRef = new( ooThis( )) CdbBdbSPagedVarrayP<E>( );
    if( BdbIsNull(_dataRef)) {
        cout << "CdbBdbNTupleSimpleImplP<E>::CdbBdbNTupleSimpleImplP() -- FATAL ERROR IN THE CONSTRUCTOR." << endl
             << "    Failed to create an instance of the paged v-array object to store elements" << endl
             << "    of the n-tuple." << endl;
        assert(0);
    }
}

template< class E >
CdbBdbNTupleSimpleImplP<E>::~CdbBdbNTupleSimpleImplP( ) 
{
    BdbDelete(_dataRef);
    _dataRef = 0;
}

template< class E >
d_ULong
CdbBdbNTupleSimpleImplP<E>::rows( ) const
{
    return _rows;
}

template< class E >
CdbStatus
CdbBdbNTupleSimpleImplP<E>::get_row( std::vector<E>& theRow,
                                     const d_ULong   theNumber ) const
{
    if( theNumber >= _rows ) return CdbStatus::NotFound;

    d_ULong nColumns = columns( );
    d_ULong first    = nColumns * theNumber;

  // Check for the consistentcy of the data structures

    if( _dataRef->size( ) < first + nColumns ) {
        cout << "CdbBdbNTupleSimpleImplP<E>::get_row() -- ERROR." << endl
             << "    An inconsistency in the internal data structures of the current" << endl
             << "    object " << ooThis( ).sprint( ) << " detected." << endl
             << "    It may happen due to a transient memory corruption or a corrupted" << endl
             << "    persistent store." << endl;
        return CdbStatus::Error;
    }

  // Copy over a row from the v-array into the specified vector

    theRow.clear( );
    for( d_ULong i = 0; i < nColumns; ++i )
        theRow.push_back( _dataRef->elementAt( first + i ));

    return CdbStatus::Success;
}

template< class E >
CdbStatus
CdbBdbNTupleSimpleImplP<E>::append_row( const std::vector<E>& theRow )
{
    ooUpdate( );
    if( columns( ) != theRow.size( )) return CdbStatus::IllegalParameters;

    d_ULong nColumns = columns( );
    d_ULong first    = nColumns * _rows;

  // Check for the consistentcy of the data structures

    d_ULong capacity = _dataRef->size( );

    if( capacity < first ) {
        cout << "CdbBdbNTupleSimpleImplP<E>::append_row() -- ERROR." << endl
             << "    An inconsistency in the internal data structures of the current" << endl
             << "    object " << ooThis( ).sprint( ) << " detected." << endl
             << "    It may happen due to a transient memory corruption or a corrupted" << endl
             << "    persistent store." << endl;
        return CdbStatus::Error;
    }

  // Check if the v-array has enough capacity to accomodate one more row. Extend
  // by a factor of x2 or the number of required elements whatever is greater.

    d_ULong nFree = capacity - first;
    if( nFree < nColumns ) {
        d_ULong nToAdd = ( capacity > ( nColumns - nFree ) ? capacity : ( nColumns - nFree ));
        if( BdbcSuccess != _dataRef->resize( capacity + nToAdd )) return CdbStatus::Error;
    }

  // Copy over elements from the input row into the v-array and make sure that we
  // properly increment the actual number of rows stored in the tuple.

    for( d_ULong i = 0; i < nColumns; ++i )
        _dataRef->setElementAt( first + i, theRow[i] );

    ++_rows;

    return CdbStatus::Success;
}

template< class E >
CdbStatus
CdbBdbNTupleSimpleImplP<E>::repack( )
{
    ooUpdate( );
    return ( BdbcSuccess == _dataRef->resize( columns( ) * _rows ) ? CdbStatus::Success : CdbStatus::Error );
}

/////////////////
// End Of File //
/////////////////

---