---

CdbCommandBase.cc

Go to the documentation of this file.

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

/// Implementation file for the CdbCommandBase class
/**
  * @see CdbCommandBase
  */

#include "BaBar/BaBar.hh"

#include "CdbTools/CdbCommandBase.hh"
#include "CdbTools/CdbCommandTrans.hh"

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

CdbCommandBase::CdbCommandBase( CdbCommandTrans* theTransaction ) :
    _isValid(false),
    _myTransaction(theTransaction)
{
}

CdbCommandBase::~CdbCommandBase( )
{
    delete _myTransaction;
}

bool
CdbCommandBase::setValid( bool theNewState )
{
    bool oldState = _isValid;
    _isValid = theNewState;
    return oldState;
}

bool
CdbCommandBase::isValid( ) const
{
    return _isValid;
}

CdbStatus
CdbCommandBase::execute( )
{
    const char* errorString = "CdbCommandBase::execute() -- ERROR";

    CdbStatus result = CdbStatus::Error;
    do {

      // Verify if the object context is valid.

        if( !isValid( )) {
            cout << errorString << endl
                 << "    The object is not prepared for execution." << endl
                 << "    Perhaps the translation for the current command failed." << endl;
            break;
        }

      // Start a transaction.

        if( CdbStatus::Success != _myTransaction->start( ) ) {
            cout << errorString << endl
                 << "    Failed to start the transaction." << endl;
            break;
        }

      // Execute operation.

        if( CdbStatus::Success != operation( )) {
            if( CdbStatus::Success != _myTransaction->abort( )) {
                cout << errorString << endl
                     << "    Failed to abort the current transaction." << endl;
            }
            break;
        }

      // Commit a transaction.

        if( CdbStatus::Success != _myTransaction->commit( )) {
            cout << errorString << endl
                 << "    Failed to commit the transaction." << endl;
            break;
        }

      // Done

        result = CdbStatus::Success;

    } while( false );

    return result;
}

CdbStatus
CdbCommandBase::checkpoint( bool commitAndHold )
{
    const char* errorString = "CdbCommandBase::checkpoint() -- ERROR.";

    CdbStatus result = CdbStatus::Error;
    do {

      // Choose a specified method of checkpointing

        if( commitAndHold ) {

          // Commit the current transaction and hold existing locks.

            if( CdbStatus::Success != _myTransaction->commitAndHold( )) {
                cout << errorString << endl
                     << "    Failed to commit the current transaction and hold existing locks." << endl;
                break;
            }

        } else {

          // Commit the current transaction.

            if( CdbStatus::Success != _myTransaction->commit( )) {
                cout << errorString << endl
                     << "    Failed to commit the current transaction." << endl;
                break;
            }

          // Start a new transaction.

            if( CdbStatus::Success != _myTransaction->start( )) {
                cout << errorString << endl
                     << "    Failed to start a new transaction." << endl;
                break;
            }
        }

      // Done

        result = CdbStatus::Success;

    } while( false );

    return result;
}

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

---